T- Type of records that this
TableSinkexpects and supports.
DynamicTableSink. The new interface consumes internal data structures and only works with the Blink planner. See FLIP-95 for more information.
@Deprecated @PublicEvolving public interface RetractStreamTableSink<T> extends StreamTableSink<Tuple2<Boolean,T>>
TableSinkto emit a streaming
Tablewith insert, update, and delete changes.
The table will be converted into a stream of accumulate and retraction messages which are
Tuple2. The first field is a
Boolean flag to indicate the message
type. The second field holds the record of the requested type
A message with true
Boolean flag is an accumulate (or add) message.
A message with false flag is a retract message.
|Modifier and Type||Method and Description|
Returns the requested record type.
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.