T
- Type of DataStream
that this TableSink
expects and supports.@PublicEvolving public interface AppendStreamTableSink<T> extends StreamTableSink<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.
consumeDataStream, emitDataStream
configure, getConsumedDataType, getFieldNames, getFieldTypes, getOutputType, getTableSchema
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.