public class StreamSelectTableSink extends Object implements AppendStreamTableSink<Row>, SelectTableSink
SelectTableSink
for streaming select job.
NOTES: Currently, only insert changes is supported. Once FLINK-16998 is finished, all kinds of changes will be supported.
Constructor and Description |
---|
StreamSelectTableSink(TableSchema tableSchema) |
Modifier and Type | Method and Description |
---|---|
DataStreamSink<?> |
consumeDataStream(DataStream<Row> dataStream)
Consumes the DataStream and return the sink transformation
DataStreamSink . |
DataType |
getConsumedDataType()
Returns the data type consumed by this
TableSink . |
CloseableIterator<Row> |
getResultIterator()
Returns the select result as row iterator.
|
TableSchema |
getTableSchema()
Returns the schema of the consumed table.
|
void |
setJobClient(JobClient jobClient)
Set the job client associated with the select job to retrieve the result.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
configure, getFieldNames, getFieldTypes, getOutputType
configure
public StreamSelectTableSink(TableSchema tableSchema)
public DataType getConsumedDataType()
TableSink
TableSink
.getConsumedDataType
in interface TableSink<Row>
TableSink
.public TableSchema getTableSchema()
TableSink
getTableSchema
in interface TableSink<Row>
TableSchema
of the consumed table.public DataStreamSink<?> consumeDataStream(DataStream<Row> dataStream)
StreamTableSink
DataStreamSink
. The
returned DataStreamSink
will be used to set resources for the sink operator.consumeDataStream
in interface StreamTableSink<Row>
public void setJobClient(JobClient jobClient)
SelectTableSink
setJobClient
in interface SelectTableSink
public CloseableIterator<Row> getResultIterator()
SelectTableSink
getResultIterator
in interface SelectTableSink
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.