Package org.apache.flink.api.connector.sink2

Class Sink.InitContextWrapper

java.lang.Object

org.apache.flink.api.connector.sink2.Sink.InitContextWrapper

All Implemented Interfaces:

InitContext, Sink.InitContext

Enclosing interface:

Sink<InputT>

@Deprecated
public static class Sink.InitContextWrapper
extends Object
implements Sink.InitContext

Deprecated.

Internal, do not use it.

Class for wrapping a new WriterInitContext to an old Sink.InitContext until deprecation.

Field Summary

Fields inherited from interface org.apache.flink.api.connector.sink2.InitContext

INITIAL_CHECKPOINT_ID

Constructor Summary

Constructors

Constructor	Description
InitContextWrapper(WriterInitContext wrapped)	Deprecated.

Method Summary

Modifier and Type	Method	Description
SerializationSchema.InitializationContext	asSerializationSchemaInitializationContext()	Deprecated. Provides a view on this context as a SerializationSchema.InitializationContext.
<IN> TypeSerializer<IN>	createInputSerializer()	Deprecated. Creates a serializer for the type of sink's input.
int	getAttemptNumber()	Deprecated. Gets the attempt number of this parallel subtask.
JobID	getJobId()	Deprecated. The ID of the current job.
JobInfo	getJobInfo()	Deprecated. Get the meta information of current job.
MailboxExecutor	getMailboxExecutor()	Deprecated. Returns the mailbox executor that allows to execute Runnables inside the task thread in between record processing.
int	getNumberOfParallelSubtasks()	Deprecated. Get the number of parallel committer tasks.
ProcessingTimeService	getProcessingTimeService()	Deprecated. Returns a 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. Get the id of task where the committer is running.
TaskInfo	getTaskInfo()	Deprecated. Get the meta information of current task.
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.
boolean	isObjectReuseEnabled()	Deprecated. Returns whether object reuse has been enabled or disabled.
<MetaT> Optional<java.util.function.Consumer<MetaT>>	metadataConsumer()	Deprecated. Returns a metadata consumer, the SinkWriter can publish metadata events of type Sink.InitContext to the consumer.
org.apache.flink.metrics.groups.SinkWriterMetricGroup	metricGroup()	Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

InitContextWrapper

public InitContextWrapper(WriterInitContext wrapped)

Deprecated.

Method Detail

getSubtaskId

public int getSubtaskId()

Deprecated.

Description copied from interface: InitContext

Get the id of task where the committer is running.

Specified by:

getSubtaskId in interface InitContext

See Also:

FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs

getNumberOfParallelSubtasks

public int getNumberOfParallelSubtasks()

Deprecated.

Description copied from interface: InitContext

Get the number of parallel committer tasks.

Specified by:

getNumberOfParallelSubtasks in interface InitContext

See Also:

FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs

getAttemptNumber

public int getAttemptNumber()

Deprecated.

Description copied from interface: InitContext

Gets the attempt number of this parallel subtask. First attempt is numbered 0.

Specified by:

getAttemptNumber in interface InitContext

Returns:

Attempt number of the subtask.

See Also:

FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs

getRestoredCheckpointId

public OptionalLong getRestoredCheckpointId()

Deprecated.

Description copied from interface: InitContext

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

Specified by:

getRestoredCheckpointId in interface InitContext

getJobId

public JobID getJobId()

Deprecated.

Description copied from interface: InitContext

The ID of the current job. Note that Job ID can change in particular upon manual restart. The returned ID should NOT be used for any job management tasks.

Specified by:

getJobId in interface InitContext

See Also:

FLIP-382: Unify the Provision of Diverse Metadata for Context-like APIs

getJobInfo

public JobInfo getJobInfo()

Deprecated.

Description copied from interface: InitContext

Get the meta information of current job.

Specified by:

getJobInfo in interface InitContext

Returns:

the job meta information.

getTaskInfo

public TaskInfo getTaskInfo()

Deprecated.

Description copied from interface: InitContext

Get the meta information of current task.

Specified by:

getTaskInfo in interface InitContext

Returns:

the task meta information.

getUserCodeClassLoader

public UserCodeClassLoader getUserCodeClassLoader()

Deprecated.

Description copied from interface: Sink.InitContext

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

Specified by:

getUserCodeClassLoader in interface Sink.InitContext

See Also:

UserCodeClassLoader

getMailboxExecutor

public MailboxExecutor getMailboxExecutor()

Deprecated.

Description copied from interface: Sink.InitContext

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.

Specified by:

getMailboxExecutor in interface Sink.InitContext

getProcessingTimeService

public ProcessingTimeService getProcessingTimeService()

Deprecated.

Description copied from interface: Sink.InitContext

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

Specified by:

getProcessingTimeService in interface Sink.InitContext

metricGroup

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

Deprecated.

Specified by:

metricGroup in interface Sink.InitContext

Returns:

The metric group this writer belongs to.

asSerializationSchemaInitializationContext

public SerializationSchema.InitializationContext asSerializationSchemaInitializationContext()

Deprecated.

Description copied from interface: Sink.InitContext

Provides a view on this context as a SerializationSchema.InitializationContext.

Specified by:

asSerializationSchemaInitializationContext in interface Sink.InitContext

isObjectReuseEnabled

public boolean isObjectReuseEnabled()

Deprecated.

Description copied from interface: Sink.InitContext

Returns whether object reuse has been enabled or disabled.

Specified by:

isObjectReuseEnabled in interface Sink.InitContext

createInputSerializer

public <IN> TypeSerializer<IN> createInputSerializer()

Deprecated.

Description copied from interface: Sink.InitContext

Creates a serializer for the type of sink's input.

Specified by:

createInputSerializer in interface Sink.InitContext

metadataConsumer

@Experimental
public <MetaT> Optional<java.util.function.Consumer<MetaT>> metadataConsumer()

Deprecated.

Description copied from interface: Sink.InitContext

Returns a metadata consumer, the SinkWriter can publish metadata events of type Sink.InitContext to the consumer.

It is recommended to use a separate thread pool to publish the metadata because enqueuing a lot of these messages in the mailbox may lead to a performance decrease. thread, and the Consumer.accept(T) method is executed very fast.

Specified by:

metadataConsumer in interface Sink.InitContext