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, configBuilder, failureHandler, input, isWriteAheadLogEnabled, keyspace, 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, enableIgnoreNullFields, enableWriteAheadLog, enableWriteAheadLog, setClusterBuilder, setDefaultKeyspace, setFailureHandler, setHost, setHost, setMapperOptions, setMaxConcurrentRequests, setMaxConcurrentRequests, 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