T
- type of records that the factory consumes@PublicEvolving public interface StreamTableSinkFactory<T> extends TableSinkFactory<T>
TableSinkFactory
for more information.Modifier and Type | Method and Description |
---|---|
StreamTableSink<T> |
createStreamTableSink(Map<String,String> properties)
Creates and configures a
StreamTableSink using the given properties. |
default TableSink<T> |
createTableSink(Map<String,String> properties)
Only create stream table sink.
|
createTableSink
requiredContext, supportedProperties
StreamTableSink<T> createStreamTableSink(Map<String,String> properties)
StreamTableSink
using the given properties.properties
- normalized properties describing a table sink.default TableSink<T> createTableSink(Map<String,String> properties)
createTableSink
in interface TableSinkFactory<T>
properties
- normalized properties describing a table sink.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.