OUT
- Type of Tuple
to write to Cassandra.public class CassandraTupleOutputFormat<OUT extends Tuple> extends CassandraOutputFormatBase<OUT>
Tuple
s into a Cassandra cluster.Constructor and Description |
---|
CassandraTupleOutputFormat(String insertQuery,
ClusterBuilder builder) |
Modifier and Type | Method and Description |
---|---|
protected Object[] |
extractFields(OUT record) |
close, configure, onWriteFailure, onWriteSuccess, open, writeRecord
getRuntimeContext, setRuntimeContext
public CassandraTupleOutputFormat(String insertQuery, ClusterBuilder builder)
protected Object[] extractFields(OUT record)
extractFields
in class CassandraOutputFormatBase<OUT extends Tuple>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.