public class BatchSelectTableSink extends SelectTableSinkBase<RowData> implements StreamTableSink<RowData>
StreamTableSink
for batch select job to collect the result to local.converter
Constructor and Description |
---|
BatchSelectTableSink(TableSchema tableSchema) |
Modifier and Type | Method and Description |
---|---|
protected Row |
convertToRow(RowData element) |
TypeInformation<RowData> |
getOutputType() |
configure, consumeDataStream, createTypeInfo, getSelectResultProvider, getTableSchema
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
consumeDataStream
configure, getConsumedDataType, getFieldNames, getFieldTypes, getTableSchema
public BatchSelectTableSink(TableSchema tableSchema)
public TypeInformation<RowData> getOutputType()
getOutputType
in interface TableSink<RowData>
protected Row convertToRow(RowData element)
convertToRow
in class SelectTableSinkBase<RowData>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.