Package org.apache.flink.api.connector.sink

Interface Sink.InitContext

Enclosing interface:

Sink<InputT,CommT,WriterStateT,GlobalCommT>

@Deprecated
@PublicEvolving
public static interface Sink.InitContext

Deprecated.

Please migrate to Sink and use Sink.InitContext.

The interface exposes some runtime info for creating a SinkWriter.

Method Summary

Modifier and Type	Method	Description
MailboxExecutor	getMailboxExecutor()	Deprecated. Returns the mailbox executor that allows to execute Runnables inside the task thread in between record processing.
int	getNumberOfParallelSubtasks()	Deprecated.
Sink.ProcessingTimeService	getProcessingTimeService()	Deprecated. Returns a Sink.ProcessingTimeService that can be used to get the current time and register timers.
OptionalLong	getRestoredCheckpointId()	Deprecated. Returns id of the restored checkpoint, if state was restored from the snapshot of a previous execution.
int	getSubtaskId()	Deprecated.
UserCodeClassLoader	getUserCodeClassLoader()	Deprecated. Gets the UserCodeClassLoader to load classes that are not in system's classpath, but are part of the jar file of a user job.
org.apache.flink.metrics.groups.SinkWriterMetricGroup	metricGroup()	Deprecated.

Method Detail

getUserCodeClassLoader

UserCodeClassLoader getUserCodeClassLoader()

Deprecated.

Gets the UserCodeClassLoader to load classes that are not in system's classpath, but are part of the jar file of a user job.

See Also:

UserCodeClassLoader

getMailboxExecutor

MailboxExecutor getMailboxExecutor()

Deprecated.

Returns the mailbox executor that allows to execute Runnables inside the task thread in between record processing.

Note that this method should not be used per-record for performance reasons in the same way as records should not be sent to the external system individually. Rather, implementers are expected to batch records and only enqueue a single Runnable per batch to handle the result.

getProcessingTimeService

Sink.ProcessingTimeService getProcessingTimeService()

Deprecated.

Returns a Sink.ProcessingTimeService that can be used to get the current time and register timers.

getSubtaskId

int getSubtaskId()

Deprecated.

Returns:

The id of task where the writer is.

getNumberOfParallelSubtasks

int getNumberOfParallelSubtasks()

Deprecated.

Returns:

The number of parallel Sink tasks.

metricGroup

org.apache.flink.metrics.groups.SinkWriterMetricGroup metricGroup()

Deprecated.

Returns:

The metric group this writer belongs to.

getRestoredCheckpointId

OptionalLong getRestoredCheckpointId()

Deprecated.

Returns id of the restored checkpoint, if state was restored from the snapshot of a previous execution.