public class CollectStreamTableSink extends Object implements RetractStreamTableSink<Row>
Constructor and Description |
---|
CollectStreamTableSink(InetAddress targetAddress,
int targetPort,
TypeSerializer<Tuple2<Boolean,Row>> serializer,
TableSchema tableSchema) |
Modifier and Type | Method and Description |
---|---|
CollectStreamTableSink |
configure(String[] fieldNames,
TypeInformation<?>[] fieldTypes)
Returns a copy of this
TableSink configured with the field names and types of the
table to emit. |
DataStreamSink<?> |
consumeDataStream(DataStream<Tuple2<Boolean,Row>> stream)
Consumes the DataStream and return the sink transformation
DataStreamSink . |
void |
emitDataStream(DataStream<Tuple2<Boolean,Row>> stream)
Emits the DataStream.
|
String[] |
getFieldNames() |
TypeInformation<?>[] |
getFieldTypes() |
TupleTypeInfo<Tuple2<Boolean,Row>> |
getOutputType() |
TypeInformation<Row> |
getRecordType()
Returns the requested record type.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConsumedDataType, getTableSchema
public CollectStreamTableSink(InetAddress targetAddress, int targetPort, TypeSerializer<Tuple2<Boolean,Row>> serializer, TableSchema tableSchema)
public CollectStreamTableSink configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
TableSink
TableSink
configured with the field names and types of the
table to emit.public String[] getFieldNames()
getFieldNames
in interface TableSink<Tuple2<Boolean,Row>>
public TypeInformation<?>[] getFieldTypes()
getFieldTypes
in interface TableSink<Tuple2<Boolean,Row>>
public TypeInformation<Row> getRecordType()
RetractStreamTableSink
getRecordType
in interface RetractStreamTableSink<Row>
public void emitDataStream(DataStream<Tuple2<Boolean,Row>> stream)
StreamTableSink
emitDataStream
in interface StreamTableSink<Tuple2<Boolean,Row>>
public DataStreamSink<?> consumeDataStream(DataStream<Tuple2<Boolean,Row>> stream)
StreamTableSink
DataStreamSink
.
The returned DataStreamSink
will be used to set resources for the sink operator.consumeDataStream
in interface StreamTableSink<Tuple2<Boolean,Row>>
public TupleTypeInfo<Tuple2<Boolean,Row>> getOutputType()
getOutputType
in interface RetractStreamTableSink<Row>
getOutputType
in interface TableSink<Tuple2<Boolean,Row>>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.