Package | Description |
---|---|
org.apache.flink.streaming.connectors.cassandra |
Modifier and Type | Class and Description |
---|---|
static class |
CassandraSink.CassandraPojoSinkBuilder<IN> |
static class |
CassandraSink.CassandraTupleSinkBuilder<IN extends Tuple> |
Modifier and Type | Method and Description |
---|---|
static <IN,T extends Tuple> |
CassandraSink.addSink(DataStream<IN> input)
Writes a DataStream into a Cassandra database.
|
CassandraSink.CassandraSinkBuilder<IN> |
CassandraSink.CassandraSinkBuilder.enableWriteAheadLog()
Enables the write-ahead log, which allows exactly-once processing for non-deterministic algorithms that use
idempotent updates.
|
CassandraSink.CassandraSinkBuilder<IN> |
CassandraSink.CassandraSinkBuilder.enableWriteAheadLog(CheckpointCommitter committer)
Enables the write-ahead log, which allows exactly-once processing for non-deterministic algorithms that use
idempotent updates.
|
CassandraSink.CassandraSinkBuilder<IN> |
CassandraSink.CassandraSinkBuilder.setClusterBuilder(ClusterBuilder builder)
Sets the ClusterBuilder for this sink.
|
CassandraSink.CassandraSinkBuilder<IN> |
CassandraSink.CassandraSinkBuilder.setHost(String host)
Sets the cassandra host to connect to.
|
CassandraSink.CassandraSinkBuilder<IN> |
CassandraSink.CassandraSinkBuilder.setHost(String host,
int port)
Sets the cassandra host/port to connect to.
|
CassandraSink.CassandraSinkBuilder<IN> |
CassandraSink.CassandraSinkBuilder.setQuery(String query)
Sets the query that is to be executed for every record.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.