public class SelectTableSinkBase extends Object implements SelectTableSink
SelectTableSink
.Constructor and Description |
---|
SelectTableSinkBase(TableSchema tableSchema) |
Modifier and Type | Method and Description |
---|---|
protected DataStreamSink<?> |
consumeDataStream(DataStream<Row> dataStream) |
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
public SelectTableSinkBase(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.protected DataStreamSink<?> consumeDataStream(DataStream<Row> dataStream)
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.