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