public interface AppendStreamTableSink<T> extends TableSink<T>
TableSink
to emit streaming Table
with only insert changes.
If the Table
is also modified by update or delete changes, a
TableException
will be thrown.
Modifier and Type | Method and Description |
---|---|
void |
emitDataStream(DataStream<T> dataStream)
Emits the DataStream.
|
configure, getFieldNames, getFieldTypes, getOutputType
void emitDataStream(DataStream<T> dataStream)
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.