org.apache.flink.streaming.connectors.cassandra

Class CassandraSink.CassandraPojoSinkBuilder<IN>

java.lang.Object

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

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

Type Parameters:

IN -

Enclosing class:

CassandraSink<IN>

public static class CassandraSink.CassandraPojoSinkBuilder<IN>
extends CassandraSink.CassandraSinkBuilder<IN>

Builder for a CassandraPojoSink.

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
CassandraPojoSinkBuilder(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

CassandraPojoSinkBuilder

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

Method Detail

sanityCheck

protected void sanityCheck()

Overrides:

sanityCheck in class CassandraSink.CassandraSinkBuilder<IN>

createSink

public CassandraSink<IN> createSink()
                             throws Exception

Specified by:

createSink in class CassandraSink.CassandraSinkBuilder<IN>

Throws:

Exception

createWriteAheadSink

protected CassandraSink<IN> createWriteAheadSink()
                                          throws Exception

Specified by:

createWriteAheadSink in class CassandraSink.CassandraSinkBuilder<IN>

Throws:

Exception