Package org.apache.flink.table.factories

Interface StreamTableSourceFactory<T>

  • Type Parameters:
    T - type of records that the factory produces
    All Superinterfaces:
    org.apache.flink.table.factories.TableFactory, org.apache.flink.table.factories.TableSourceFactory<T>
    All Known Implementing Classes:
    CsvAppendTableSourceFactory, CsvBatchTableSourceFactory
    @Deprecated
@PublicEvolving
public interface StreamTableSourceFactory<T>
extends org.apache.flink.table.factories.TableSourceFactory<T>
    Deprecated.
    This interface has been replaced by DynamicTableSourceFactory. The new interface creates instances of DynamicTableSource. See FLIP-95 for more information.
    A factory to create configured table source instances in a streaming environment based on string-based properties. See also TableSourceFactory for more information.

    • Nested Class Summary

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

        org.apache.flink.table.factories.TableSourceFactory.Context

    • Method Summary

      All Methods Instance Methods Default Methods Deprecated Methods 
      Modifier and Type Method Description
      default StreamTableSource<T> createStreamTableSource​(Map<String,​String> properties)
      Deprecated.
      TableSourceFactory.Context contains more information, and already contains table schema too.
      default org.apache.flink.table.sources.TableSource<T> createTableSource​(Map<String,​String> properties)
      Deprecated.
      Only create a stream table source.

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

        requiredContext, supportedProperties

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

        createTableSource, createTableSource

    • Method Detail

      • createStreamTableSource

        @Deprecated
default StreamTableSource<T> createStreamTableSource​(Map<String,​String> properties)
        Deprecated.
        TableSourceFactory.Context contains more information, and already contains table schema too. Please use TableSourceFactory.createTableSource(Context) instead.
        Creates and configures a StreamTableSource using the given properties.
        Parameters:
        properties - normalized properties describing a stream table source.
        Returns:
        the configured stream table source.

      • createTableSource

        default org.apache.flink.table.sources.TableSource<T> createTableSource​(Map<String,​String> properties)
        Deprecated.
        Only create a stream table source.
        Specified by:
        createTableSource in interface org.apache.flink.table.factories.TableSourceFactory<T>