public class StreamSelectTableSink extends Object implements RetractStreamTableSink<Row>
RetractStreamTableSink
for streaming select job to collect the result to local.Constructor and Description |
---|
StreamSelectTableSink(TableSchema tableSchema) |
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. |
DataStreamSink<?> |
consumeDataStream(DataStream<Tuple2<Boolean,Row>> dataStream)
Consumes the DataStream and return the sink transformation
DataStreamSink . |
TypeInformation<Row> |
getRecordType()
Returns the requested record type.
|
SelectResultProvider |
getSelectResultProvider() |
TableSchema |
getTableSchema()
Returns the schema of the consumed table.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getOutputType
getConsumedDataType, getFieldNames, getFieldTypes
public StreamSelectTableSink(TableSchema tableSchema)
public TypeInformation<Row> getRecordType()
RetractStreamTableSink
getRecordType
in interface RetractStreamTableSink<Row>
public TableSchema getTableSchema()
TableSink
getTableSchema
in interface TableSink<Tuple2<Boolean,Row>>
TableSchema
of the consumed table.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 DataStreamSink<?> consumeDataStream(DataStream<Tuple2<Boolean,Row>> dataStream)
StreamTableSink
DataStreamSink
. The
returned DataStreamSink
will be used to set resources for the sink operator.consumeDataStream
in interface StreamTableSink<Tuple2<Boolean,Row>>
public SelectResultProvider getSelectResultProvider()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.