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 found in
where we instantiate the required
SourceFunction and its
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
serves as the base interface. Concrete
ScanTableSource.ScanRuntimeProvider 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–2020 The Apache Software Foundation. All rights reserved.