Package org.apache.flink.table.factories

Interface StreamTableSinkFactory<T>

  • Type Parameters:
    T - type of records that the factory consumes
    All Superinterfaces:
    org.apache.flink.table.factories.TableFactory, org.apache.flink.table.factories.TableSinkFactory<T>
    All Known Implementing Classes:
    CsvAppendTableSinkFactory, CsvBatchTableSinkFactory
    @Deprecated
@PublicEvolving
public interface StreamTableSinkFactory<T>
extends org.apache.flink.table.factories.TableSinkFactory<T>
    Deprecated.
    This interface has been replaced by DynamicTableSinkFactory. The new interface creates instances of DynamicTableSink. See FLIP-95 for more information.
    A factory to create configured table sink instances in a streaming environment based on string-based properties. See also TableSinkFactory for more information.

    • Nested Class Summary

      • Nested classes/interfaces inherited from interface org.apache.flink.table.factories.TableSinkFactory

        org.apache.flink.table.factories.TableSinkFactory.Context

    • Method Summary

      All Methods Instance Methods Default Methods Deprecated Methods 
      Modifier and Type Method Description
      default StreamTableSink<T> createStreamTableSink​(Map<String,​String> properties)
      Deprecated.
      TableSinkFactory.Context contains more information, and already contains table schema too.
      default org.apache.flink.table.sinks.TableSink<T> createTableSink​(Map<String,​String> properties)
      Deprecated.
      Only create stream table sink.

      • Methods inherited from interface org.apache.flink.table.factories.TableFactory

        requiredContext, supportedProperties

      • Methods inherited from interface org.apache.flink.table.factories.TableSinkFactory

        createTableSink, createTableSink

    • Method Detail

      • createStreamTableSink

        @Deprecated
default StreamTableSink<T> createStreamTableSink​(Map<String,​String> properties)
        Deprecated.
        TableSinkFactory.Context contains more information, and already contains table schema too. Please use TableSinkFactory.createTableSink(Context) instead.
        Creates and configures a StreamTableSink using the given properties.
        Parameters:
        properties - normalized properties describing a table sink.
        Returns:
        the configured table sink.

      • createTableSink

        default org.apache.flink.table.sinks.TableSink<T> createTableSink​(Map<String,​String> properties)
        Deprecated.
        Only create stream table sink.
        Specified by:
        createTableSink in interface org.apache.flink.table.factories.TableSinkFactory<T>