public class CassandraRowSink extends AbstractCassandraTupleSink<Row>
SinkFunction.Context<T>
Constructor and Description |
---|
CassandraRowSink(int rowArity,
String insertQuery,
ClusterBuilder builder) |
CassandraRowSink(int rowArity,
String insertQuery,
ClusterBuilder builder,
CassandraFailureHandler failureHandler) |
Modifier and Type | Method and Description |
---|---|
protected Object[] |
extract(Row record) |
open, send
close, createSession, initializeState, invoke, snapshotState
getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
invoke
public CassandraRowSink(int rowArity, String insertQuery, ClusterBuilder builder)
public CassandraRowSink(int rowArity, String insertQuery, ClusterBuilder builder, CassandraFailureHandler failureHandler)
protected Object[] extract(Row record)
extract
in class AbstractCassandraTupleSink<Row>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.