IN
- Type of the elements emitted by this sink, it must extend Tuple
public class CassandraTupleSink<IN extends Tuple> extends AbstractCassandraTupleSink<IN>
Tuple
s into a Cassandra cluster.SinkFunction.Context<T>
Constructor and Description |
---|
CassandraTupleSink(String insertQuery,
ClusterBuilder builder) |
CassandraTupleSink(String insertQuery,
ClusterBuilder builder,
CassandraFailureHandler failureHandler) |
Modifier and Type | Method and Description |
---|---|
protected Object[] |
extract(IN record) |
open, send
close, createSession, initializeState, invoke, snapshotState
getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
invoke
public CassandraTupleSink(String insertQuery, ClusterBuilder builder)
public CassandraTupleSink(String insertQuery, ClusterBuilder builder, CassandraFailureHandler failureHandler)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.