@Internal public final class CollectDynamicSink extends Object implements DynamicTableSink
DynamicTableSink.Context, DynamicTableSink.DataStructureConverter, DynamicTableSink.SinkRuntimeProvider
|Modifier and Type||Method and Description|
Returns a string that summarizes this sink for printing to a console or log.
Creates a copy of this instance during planning.
Returns the set of changes that the sink accepts during runtime.
Returns a provider of runtime implementation for writing the data.
public ResultProvider getSelectResultProvider()
public ChangelogMode getChangelogMode(ChangelogMode requestedMode)
The planner can make suggestions but the sink has the final decision what it requires. If
the planner does not support this mode, it will throw an error. For example, the sink can
return that it only supports
requestedMode- expected set of changes by the current plan
public DynamicTableSink.SinkRuntimeProvider getSinkRuntimeProvider(DynamicTableSink.Context context)
There might exist different interfaces for runtime implementation which is why
DynamicTableSink.SinkRuntimeProvider 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 sink
implementation accepts internal data structures (see
RowData for more information).
DynamicTableSink.Context offers utilities by the planner for creating runtime
implementation with minimal dependencies to internal data structures.
SinkProvider is the recommended core interface.
OutputFormatProvider are available for
public DynamicTableSink copy()
public String asSummaryString()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.