public class CollectStreamTableSink extends Object implements org.apache.flink.table.sinks.RetractStreamTableSink<Row>
Constructor and Description |
---|
CollectStreamTableSink(InetAddress targetAddress,
int targetPort,
TypeSerializer<Tuple2<Boolean,Row>> serializer) |
Modifier and Type | Method and Description |
---|---|
TableSink<Tuple2<Boolean,Row>> |
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<Tuple2<Boolean,Row>> stream) |
String[] |
getFieldNames()
Returns the names of the table fields.
|
TypeInformation<?>[] |
getFieldTypes()
Returns the types of the table fields.
|
TupleTypeInfo<Tuple2<Boolean,Row>> |
getOutputType()
Returns the type expected by this
TableSink . |
TypeInformation<Row> |
getRecordType() |
public CollectStreamTableSink(InetAddress targetAddress, int targetPort, TypeSerializer<Tuple2<Boolean,Row>> serializer)
public String[] getFieldNames()
TableSink
getFieldNames
in interface TableSink<Tuple2<Boolean,Row>>
public TypeInformation<?>[] getFieldTypes()
TableSink
getFieldTypes
in interface TableSink<Tuple2<Boolean,Row>>
public TableSink<Tuple2<Boolean,Row>> configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
TableSink
TableSink
configured with the field names and types of the
table to emit.public TypeInformation<Row> getRecordType()
getRecordType
in interface org.apache.flink.table.sinks.RetractStreamTableSink<Row>
public void emitDataStream(DataStream<Tuple2<Boolean,Row>> stream)
public TupleTypeInfo<Tuple2<Boolean,Row>> getOutputType()
TableSink
TableSink
.
This type should depend on the types returned by TableSink.getFieldNames()
.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.