public class StreamSelectTableSink extends SelectTableSinkBase<Tuple2<Boolean,RowData>> implements RetractStreamTableSink<RowData>
RetractStreamTableSink
for streaming select job to collect the result to local.
RowData
contains RowKind
attribute which can represents all kind of changes.
The boolean flag is useless here, only because RetractStreamTableSink
requires
Tuple2<Boolean, T> type.
converter
Constructor and Description |
---|
StreamSelectTableSink(TableSchema tableSchema) |
Modifier and Type | Method and Description |
---|---|
protected Row |
convertToRow(Tuple2<Boolean,RowData> tuple2) |
TypeInformation<RowData> |
getRecordType()
Returns the requested record type.
|
configure, consumeDataStream, createTypeInfo, getSelectResultProvider, getTableSchema
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getOutputType
consumeDataStream
configure, getConsumedDataType, getFieldNames, getFieldTypes, getTableSchema
public StreamSelectTableSink(TableSchema tableSchema)
public TypeInformation<RowData> getRecordType()
RetractStreamTableSink
getRecordType
in interface RetractStreamTableSink<RowData>
protected Row convertToRow(Tuple2<Boolean,RowData> tuple2)
convertToRow
in class SelectTableSinkBase<Tuple2<Boolean,RowData>>
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.