public final class SocketDynamicTableSource extends Object implements ScanTableSource
SocketDynamicTableSourceis used during planning.
In our example, we don't implement any of the available ability interfaces such as
SupportsProjectionPushDown. Therefore, the main logic can be
ScanTableSource.getScanRuntimeProvider(ScanContext) where we instantiate the required
SourceFunction and its
DeserializationSchema for runtime. Both instances are
parameterized to return internal data structures (i.e.
|Constructor and Description|
|Modifier and Type||Method and Description|
Returns a string that summarizes this source for printing to a console or log.
Creates a copy of this instance during planning.
Returns the set of changes that the planner can expect during runtime.
Returns a provider of runtime implementation for reading the data.
public ChangelogMode getChangelogMode()
public ScanTableSource.ScanRuntimeProvider getScanRuntimeProvider(ScanTableSource.ScanContext runtimeProviderContext)
There might exist different interfaces for runtime implementation which is why
ScanTableSource.ScanRuntimeProvider serves as the base interface. Concrete
interfaces might be located in other Flink modules.
Independent of the provider interface, the table runtime expects that a source
implementation emits internal data structures (see
RowData for more information).
ScanTableSource.ScanContext offers utilities by the planner for creating runtime
implementation with minimal dependencies to internal data structures.
public DynamicTableSource copy()
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.