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.
|
TupleTypeInfo<Tuple2<Boolean,Row>> |
getOutputType() |
TypeInformation<Row> |
getRecordType()
Returns the requested record type.
|
TableSchema |
getTableSchema()
Returns the schema of the consumed table.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getConsumedDataType, getFieldNames, getFieldTypes
public CollectStreamTableSink(InetAddress targetAddress, int targetPort, TypeSerializer<Tuple2<Boolean,Row>> serializer, TableSchema tableSchema)
public TableSchema getTableSchema()
TableSink
getTableSchema
in interface TableSink<Tuple2<Boolean,Row>>
TableSchema
of the consumed table.public CollectStreamTableSink configure(String[] fieldNames, TypeInformation<?>[] fieldTypes)
TableSink
TableSink
configured with the field names and types of the
table to emit.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.