Package | Description |
---|---|
org.apache.flink.streaming.connectors.cassandra |
Modifier and Type | Method and Description |
---|---|
abstract CassandraSink<IN> |
CassandraSink.CassandraSinkBuilder.build()
Finalizes the configuration of this sink.
|
CassandraSink<IN> |
CassandraSink.CassandraTupleSinkBuilder.build() |
CassandraSink<IN> |
CassandraSink.CassandraPojoSinkBuilder.build() |
CassandraSink<IN> |
CassandraSink.disableChaining()
Turns off chaining for this operator so thread co-location will not be
used as an optimization.
|
CassandraSink<IN> |
CassandraSink.name(String name)
Sets the name of this sink.
|
CassandraSink<IN> |
CassandraSink.setParallelism(int parallelism)
Sets the parallelism for this sink.
|
CassandraSink<IN> |
CassandraSink.setUidHash(String uidHash)
Sets an user provided hash for this operator.
|
CassandraSink<IN> |
CassandraSink.slotSharingGroup(String slotSharingGroup)
Sets the slot sharing group of this operation.
|
CassandraSink<IN> |
CassandraSink.uid(String uid)
Sets an ID for this operator.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.