public class BatchSelectTableSink extends SelectTableSinkBase implements StreamTableSink<Row>
SelectTableSink
for batch select job.Constructor and Description |
---|
BatchSelectTableSink(TableSchema tableSchema) |
Modifier and Type | Method and Description |
---|---|
DataStreamSink<?> |
consumeDataStream(DataStream<Row> dataStream)
Consumes the DataStream and return the sink transformation
DataStreamSink . |
getConsumedDataType, getResultIterator, getTableSchema, setJobClient
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
configure, getConsumedDataType, getFieldNames, getFieldTypes, getOutputType, getTableSchema
configure
public BatchSelectTableSink(TableSchema tableSchema)
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>
consumeDataStream
in class SelectTableSinkBase
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.