Package io.github.flink.gcp.connector.base.failure

Class DefaultFailureHandlerContext

java.lang.Object

io.github.flink.gcp.connector.base.failure.DefaultFailureHandlerContext

All Implemented Interfaces:

FailureHandlerContext

@Internal
public final class DefaultFailureHandlerContext
extends Object
implements FailureHandlerContext

The FailureHandlerContext the sinks build from their WriterInitContext.

Constructor Summary

Constructors

Constructor	Description
DefaultFailureHandlerContext(int subtaskIndex, org.apache.flink.metrics.MetricGroup metricGroup)	Creates a context.

Method Summary

Modifier and Type	Method	Description
org.apache.flink.metrics.MetricGroup	getMetricGroup()	Returns the sink writer's metric group, for handler-registered counters and gauges.
int	getSubtaskIndex()	Returns the index of the sink writer subtask driving the handler.
static DefaultFailureHandlerContext	of(org.apache.flink.api.connector.sink2.WriterInitContext context)	Creates the context a sink passes to FailureHandler.open(io.github.flink.gcp.connector.base.failure.FailureHandlerContext) when creating its writer.

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultFailureHandlerContext

public DefaultFailureHandlerContext(int subtaskIndex,
 org.apache.flink.metrics.MetricGroup metricGroup)

Creates a context.

Parameters:

subtaskIndex - the sink writer's subtask index

metricGroup - the sink writer's metric group

Method Details

of

public static DefaultFailureHandlerContext of(org.apache.flink.api.connector.sink2.WriterInitContext context)

Creates the context a sink passes to FailureHandler.open(io.github.flink.gcp.connector.base.failure.FailureHandlerContext) when creating its writer.

Parameters:

context - the writer init context

Returns:

the failure-handler context

getSubtaskIndex

public int getSubtaskIndex()

Description copied from interface: FailureHandlerContext

Returns the index of the sink writer subtask driving the handler.

Specified by:

getSubtaskIndex in interface FailureHandlerContext

getMetricGroup

public org.apache.flink.metrics.MetricGroup getMetricGroup()

Description copied from interface: FailureHandlerContext

Returns the sink writer's metric group, for handler-registered counters and gauges.

Specified by:

getMetricGroup in interface FailureHandlerContext