IN
- input typepublic class CassandraSink<IN> extends Object
Modifier and Type | Class and Description |
---|---|
static class |
CassandraSink.CassandraPojoSinkBuilder<IN> |
static class |
CassandraSink.CassandraSinkBuilder<IN> |
static class |
CassandraSink.CassandraTupleSinkBuilder<IN extends Tuple> |
Modifier and Type | Method and Description |
---|---|
static <IN,T extends Tuple> |
addSink(DataStream<IN> input)
Writes a DataStream into a Cassandra database.
|
CassandraSink<IN> |
disableChaining()
Turns off chaining for this operator so thread co-location will not be
used as an optimization.
|
CassandraSink<IN> |
name(String name)
Sets the name of this sink.
|
CassandraSink<IN> |
setParallelism(int parallelism)
Sets the parallelism for this sink.
|
CassandraSink<IN> |
slotSharingGroup(String slotSharingGroup)
Sets the slot sharing group of this operation.
|
CassandraSink<IN> |
uid(String uid)
Sets an ID for this operator.
|
public CassandraSink<IN> name(String name)
public CassandraSink<IN> uid(String uid)
The specified ID is used to assign the same operator ID across job submissions (for example when starting a job from a savepoint).
Important: this ID needs to be unique per transformation and job. Otherwise, job submission will fail.
uid
- The unique user-specified ID of this transformation.public CassandraSink<IN> setParallelism(int parallelism)
parallelism
- The parallelism for this sink.public CassandraSink<IN> disableChaining()
StreamExecutionEnvironment.disableOperatorChaining()
however it is not advised for performance considerations.public CassandraSink<IN> slotSharingGroup(String slotSharingGroup)
Operations inherit the slot sharing group of input operations if all input operations are in the same slot sharing group and no slot sharing group was explicitly specified.
Initially an operation is in the default slot sharing group. An operation can be put into
the default group explicitly by setting the slot sharing group to "default"
.
slotSharingGroup
- The slot sharing group name.public static <IN,T extends Tuple> CassandraSink.CassandraSinkBuilder<IN> addSink(DataStream<IN> input)
IN
- input typeinput
- input DataStreamCopyright © 2014–2017 The Apache Software Foundation. All rights reserved.