org.apache.flink.batch.connectors.cassandra

Class CassandraRowOutputFormat

java.lang.Object

org.apache.flink.api.common.io.RichOutputFormat<OUT>

org.apache.flink.batch.connectors.cassandra.CassandraOutputFormatBase<Row>

org.apache.flink.batch.connectors.cassandra.CassandraRowOutputFormat

All Implemented Interfaces:

Serializable, OutputFormat<Row>

public class CassandraRowOutputFormat
extends CassandraOutputFormatBase<Row>

OutputFormat to write Flink Rows into a Cassandra cluster.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CassandraRowOutputFormat(String insertQuery, ClusterBuilder builder)

Method Summary

Modifier and Type	Method and Description
protected Object[]	extractFields(Row record)

Methods inherited from class org.apache.flink.batch.connectors.cassandra.CassandraOutputFormatBase

close, configure, onWriteFailure, onWriteSuccess, open, writeRecord

Methods inherited from class org.apache.flink.api.common.io.RichOutputFormat

getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

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

Constructor Detail

CassandraRowOutputFormat

public CassandraRowOutputFormat(String insertQuery,
                                ClusterBuilder builder)

Method Detail

extractFields

protected Object[] extractFields(Row record)

Specified by:

extractFields in class CassandraOutputFormatBase<Row>