public class CassandraAppendTableSink extends Object implements org.apache.flink.table.sinks.AppendStreamTableSink<Row>
AppendStreamTableSink
to write an append stream Table to a Cassandra table.Constructor and Description |
---|
CassandraAppendTableSink(ClusterBuilder builder,
String cql) |
CassandraAppendTableSink(ClusterBuilder builder,
String cql,
Properties properties) |
Modifier and Type | Method and Description |
---|---|
CassandraAppendTableSink |
configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Returns a copy of this
TableSink configured with the field names and types of the
table to emit. |
void |
emitDataStream(DataStream<Row> dataStream) |
String[] |
getFieldNames()
Returns the names of the table fields.
|
TypeInformation<?>[] |
getFieldTypes()
Returns the types of the table fields.
|
TypeInformation<Row> |
getOutputType()
Returns the type expected by this
TableSink . |
public CassandraAppendTableSink(ClusterBuilder builder, String cql)
public CassandraAppendTableSink(ClusterBuilder builder, String cql, Properties properties)
public TypeInformation<Row> getOutputType()
TableSink
TableSink
.
This type should depend on the types returned by TableSink.getFieldNames()
.
getOutputType
in interface TableSink<Row>
TableSink
.public String[] getFieldNames()
TableSink
getFieldNames
in interface TableSink<Row>
public TypeInformation<?>[] getFieldTypes()
TableSink
getFieldTypes
in interface TableSink<Row>
public CassandraAppendTableSink configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
TableSink
TableSink
configured with the field names and types of the
table to emit.public void emitDataStream(DataStream<Row> dataStream)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.