IN
- public static class CassandraSink.CassandraTupleSinkBuilder<IN extends Tuple> extends CassandraSink.CassandraSinkBuilder<IN>
CassandraTupleSink
.builder, committer, configBuilder, failureHandler, input, isWriteAheadLogEnabled, keyspace, mapperOptions, query, serializer, typeInfo
Constructor and Description |
---|
CassandraTupleSinkBuilder(DataStream<IN> input,
TypeInformation<IN> typeInfo,
TypeSerializer<IN> serializer) |
Modifier and Type | Method and Description |
---|---|
CassandraSink<IN> |
createSink() |
protected CassandraSink<IN> |
createWriteAheadSink() |
protected void |
sanityCheck() |
build, enableIgnoreNullFields, enableWriteAheadLog, enableWriteAheadLog, setClusterBuilder, setDefaultKeyspace, setFailureHandler, setHost, setHost, setMapperOptions, setMaxConcurrentRequests, setMaxConcurrentRequests, setQuery
public CassandraTupleSinkBuilder(DataStream<IN> input, TypeInformation<IN> typeInfo, TypeSerializer<IN> serializer)
protected void sanityCheck()
sanityCheck
in class CassandraSink.CassandraSinkBuilder<IN extends Tuple>
public CassandraSink<IN> createSink() throws Exception
createSink
in class CassandraSink.CassandraSinkBuilder<IN extends Tuple>
Exception
protected CassandraSink<IN> createWriteAheadSink() throws Exception
createWriteAheadSink
in class CassandraSink.CassandraSinkBuilder<IN extends Tuple>
Exception
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.