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

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

Class	Description
DeadLetterQueue	Destination for elements that terminally failed to be written by a sink, used through FailureHandler.sendToDeadLetterQueue(DeadLetterQueue).
DefaultFailureHandlerContext	The FailureHandlerContext the sinks build from their WriterInitContext.
FailedElement	An element that terminally failed to be written by one of this project's sinks — the read-only contract every connector's concrete failure type implements, and the view a cross-connector DeadLetterQueue sees.
FailureHandler<F extends FailedElement>	Pluggable policy for elements that terminally fail to be written by a sink.
FailureHandlerContext	What a FailureHandler or DeadLetterQueue learns about its surroundings when it is opened: enough to stamp per-subtask output and to register its own metrics, and nothing more.