public static class CassandraSink.CassandraPojoSinkBuilder<IN> extends CassandraSink.CassandraSinkBuilder<IN>
builder, committer, input, isWriteAheadLogEnabled, query, serializer, typeInfo
Constructor and Description |
---|
CassandraPojoSinkBuilder(DataStream<IN> input,
TypeInformation<IN> typeInfo,
TypeSerializer<IN> serializer) |
Modifier and Type | Method and Description |
---|---|
CassandraSink<IN> |
build()
Finalizes the configuration of this sink.
|
protected void |
sanityCheck() |
enableWriteAheadLog, enableWriteAheadLog, setClusterBuilder, setHost, setHost, setQuery
public CassandraPojoSinkBuilder(DataStream<IN> input, TypeInformation<IN> typeInfo, TypeSerializer<IN> serializer)
protected void sanityCheck()
sanityCheck
in class CassandraSink.CassandraSinkBuilder<IN>
public CassandraSink<IN> build() throws Exception
CassandraSink.CassandraSinkBuilder
build
in class CassandraSink.CassandraSinkBuilder<IN>
Exception
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.