public interface RetractStreamTableSink<T> extends TableSink<Tuple2<Boolean,T>>
TableSink
to emit a streaming Table
with insert, update, and delete
changes.
The table will be converted into a stream of accumulate and retraction messages which are
encoded as JTuple2
.
The first field is a JBool
flag to indicate the message type.
The second field holds the record of the requested type T
.
A message with true JBool
flag is an accumulate (or add) message.
A message with false flag is a retract message.
Modifier and Type | Method and Description |
---|---|
void |
emitDataStream(DataStream<Tuple2<Boolean,T>> dataStream)
Emits the DataStream.
|
TupleTypeInfo<Tuple2<Boolean,T>> |
getOutputType()
Return the type expected by this
TableSink . |
TypeInformation<T> |
getRecordType()
Returns the requested record type
|
configure, getFieldNames, getFieldTypes
TypeInformation<T> getRecordType()
void emitDataStream(DataStream<Tuple2<Boolean,T>> dataStream)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.