Package io.github.flink.gcp.connector.bigquery.sink

Class DestinationResolutionDispatcher

java.lang.Object

io.github.flink.gcp.connector.bigquery.sink.DestinationResolutionDispatcher

@Internal
public final class DestinationResolutionDispatcher
extends Object

Dispatches destination-resolution results to the writer that owns the record.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	DestinationResolutionDispatcher.Visitor<T>	Handles every destination-resolution result supported by the connector.

Method Summary

Modifier and Type	Method	Description
static <T> void	dispatch(DestinationResolution resolution, T element, org.apache.flink.api.connector.sink2.SinkWriter.Context context, DestinationResolutionDispatcher.Visitor<T> visitor)	Dispatches a result without allocating a per-record callback.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

dispatch

public static <T> void dispatch(DestinationResolution resolution,
 T element,
 org.apache.flink.api.connector.sink2.SinkWriter.Context context,
 DestinationResolutionDispatcher.Visitor<T> visitor)
                         throws IOException

Dispatches a result without allocating a per-record callback.

Throws:

IOException