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

Packages that use io.github.flink.gcp.connector.base.failure

Package	Description
io.github.flink.gcp.connector.base.failure
io.github.flink.gcp.connector.bigquery.sink
io.github.flink.gcp.connector.bigquery.sink.failure
io.github.flink.gcp.connector.bigtable.sink
io.github.flink.gcp.connector.cloudtasks.sink
io.github.flink.gcp.connector.pubsub.deadletter
io.github.flink.gcp.connector.pubsub.sink
io.github.flink.gcp.connector.spanner.sink

Classes in io.github.flink.gcp.connector.base.failure used by 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	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.

Classes in io.github.flink.gcp.connector.base.failure used by io.github.flink.gcp.connector.bigquery.sink

Class	Description
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	Pluggable policy for elements that terminally fail to be written by a sink.

Classes in io.github.flink.gcp.connector.base.failure used by io.github.flink.gcp.connector.bigquery.sink.failure

Class	Description
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.

Classes in io.github.flink.gcp.connector.base.failure used by io.github.flink.gcp.connector.bigtable.sink

Class	Description
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	Pluggable policy for elements that terminally fail to be written by a sink.

Classes in io.github.flink.gcp.connector.base.failure used by io.github.flink.gcp.connector.cloudtasks.sink

Class	Description
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	Pluggable policy for elements that terminally fail to be written by a sink.

Classes in io.github.flink.gcp.connector.base.failure used by io.github.flink.gcp.connector.pubsub.deadletter

Class	Description
DeadLetterQueue	Destination for elements that terminally failed to be written by a sink, used through FailureHandler.sendToDeadLetterQueue(DeadLetterQueue).
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.
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.

Classes in io.github.flink.gcp.connector.base.failure used by io.github.flink.gcp.connector.pubsub.sink

Class	Description
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	Pluggable policy for elements that terminally fail to be written by a sink.

Classes in io.github.flink.gcp.connector.base.failure used by io.github.flink.gcp.connector.spanner.sink

Class	Description
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	Pluggable policy for elements that terminally fail to be written by a sink.