T- Type of records that this
TableSinkexpects and supports.
@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–2020 The Apache Software Foundation. All rights reserved.