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) |
void |
emitDataStream(DataStream<Row> dataStream) |
String[] |
getFieldNames() |
TypeInformation<?>[] |
getFieldTypes() |
TypeInformation<Row> |
getOutputType() |
public CassandraAppendTableSink(ClusterBuilder builder, String cql)
public CassandraAppendTableSink(ClusterBuilder builder, String cql, Properties properties)
public TypeInformation<Row> getOutputType()
getOutputType
in interface org.apache.flink.table.sinks.TableSink<Row>
public String[] getFieldNames()
getFieldNames
in interface org.apache.flink.table.sinks.TableSink<Row>
public TypeInformation<?>[] getFieldTypes()
getFieldTypes
in interface org.apache.flink.table.sinks.TableSink<Row>
public CassandraAppendTableSink configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
configure
in interface org.apache.flink.table.sinks.TableSink<Row>
public void emitDataStream(DataStream<Row> dataStream)
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.