org.apache.flink.streaming.connectors.cassandra

Class CassandraSink.CassandraTupleSinkBuilder<IN extends Tuple>

java.lang.Object

org.apache.flink.streaming.connectors.cassandra.CassandraSink.CassandraSinkBuilder<IN>

org.apache.flink.streaming.connectors.cassandra.CassandraSink.CassandraTupleSinkBuilder<IN>

Type Parameters:

IN -

Enclosing class:

CassandraSink<IN>

public static class CassandraSink.CassandraTupleSinkBuilder<IN extends Tuple>
extends CassandraSink.CassandraSinkBuilder<IN>

Builder for a CassandraTupleSink.

Field Summary

Fields inherited from class org.apache.flink.streaming.connectors.cassandra.CassandraSink.CassandraSinkBuilder

builder, committer, input, isWriteAheadLogEnabled, mapperOptions, query, serializer, typeInfo

Constructor Summary

Constructors

Constructor and Description
CassandraTupleSinkBuilder(DataStream<IN> input, TypeInformation<IN> typeInfo, TypeSerializer<IN> serializer)

Method Summary

Modifier and Type	Method and Description
CassandraSink<IN>	createSink()
protected CassandraSink<IN>	createWriteAheadSink()
protected void	sanityCheck()

Methods inherited from class org.apache.flink.streaming.connectors.cassandra.CassandraSink.CassandraSinkBuilder

build, enableWriteAheadLog, enableWriteAheadLog, setClusterBuilder, setHost, setHost, setMapperOptions, setQuery

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CassandraTupleSinkBuilder

public CassandraTupleSinkBuilder(DataStream<IN> input,
                                 TypeInformation<IN> typeInfo,
                                 TypeSerializer<IN> serializer)

Method Detail

sanityCheck

protected void sanityCheck()

Overrides:

sanityCheck in class CassandraSink.CassandraSinkBuilder<IN extends Tuple>

createSink

public CassandraSink<IN> createSink()
                             throws Exception

Specified by:

createSink in class CassandraSink.CassandraSinkBuilder<IN extends Tuple>

Throws:

Exception

createWriteAheadSink

protected CassandraSink<IN> createWriteAheadSink()
                                          throws Exception

Specified by:

createWriteAheadSink in class CassandraSink.CassandraSinkBuilder<IN extends Tuple>

Throws:

Exception