Class and Description |
---|
SinkWriter.Context
Context that
SinkWriter.write(InputT, org.apache.flink.api.connector.sink2.SinkWriter.Context) can use for getting additional data about an input record. |
Class and Description |
---|
Committer
The
Committer is responsible for committing the data staged by the TwoPhaseCommittingSink.PrecommittingSinkWriter in the second step of a two-phase commit
protocol. |
Committer.CommitRequest
A request to commit a specific committable.
|
Sink
Base interface for developing a sink.
|
Sink.InitContext
The interface exposes some runtime info for creating a
SinkWriter . |
SinkWriter
The
SinkWriter is responsible for writing data. |
SinkWriter.Context
Context that
SinkWriter.write(InputT, org.apache.flink.api.connector.sink2.SinkWriter.Context) can use for getting additional data about an input record. |
StatefulSink.StatefulSinkWriter
A
SinkWriter whose state needs to be checkpointed. |
TwoPhaseCommittingSink.PrecommittingSinkWriter
A
SinkWriter that performs the first part of a two-phase commit protocol. |
Class and Description |
---|
StatefulSink
A
Sink with a stateful SinkWriter . |
Class and Description |
---|
Sink.InitContext
The interface exposes some runtime info for creating a
SinkWriter . |
SinkWriter.Context
Context that
SinkWriter.write(InputT, org.apache.flink.api.connector.sink2.SinkWriter.Context) can use for getting additional data about an input record. |
StatefulSink.StatefulSinkWriter
A
SinkWriter whose state needs to be checkpointed. |
Class and Description |
---|
Sink.InitContext
The interface exposes some runtime info for creating a
SinkWriter . |
SinkWriter
The
SinkWriter is responsible for writing data. |
SinkWriter.Context
Context that
SinkWriter.write(InputT, org.apache.flink.api.connector.sink2.SinkWriter.Context) can use for getting additional data about an input record. |
Class and Description |
---|
Committer
The
Committer is responsible for committing the data staged by the TwoPhaseCommittingSink.PrecommittingSinkWriter in the second step of a two-phase commit
protocol. |
Sink.InitContext
The interface exposes some runtime info for creating a
SinkWriter . |
StatefulSink
A
Sink with a stateful SinkWriter . |
StatefulSink.WithCompatibleState
A mix-in for
StatefulSink that allows users to migrate from a sink with a compatible
state to this sink. |
TwoPhaseCommittingSink
A
Sink for exactly-once semantics using a two-phase commit protocol. |
Class and Description |
---|
Committer.CommitRequest
A request to commit a specific committable.
|
Class and Description |
---|
SinkWriter.Context
Context that
SinkWriter.write(InputT, org.apache.flink.api.connector.sink2.SinkWriter.Context) can use for getting additional data about an input record. |
StatefulSink.StatefulSinkWriter
A
SinkWriter whose state needs to be checkpointed. |
TwoPhaseCommittingSink.PrecommittingSinkWriter
A
SinkWriter that performs the first part of a two-phase commit protocol. |
Class and Description |
---|
Sink.InitContext
The interface exposes some runtime info for creating a
SinkWriter . |
SinkWriter.Context
Context that
SinkWriter.write(InputT, org.apache.flink.api.connector.sink2.SinkWriter.Context) can use for getting additional data about an input record. |
StatefulSink
A
Sink with a stateful SinkWriter . |
StatefulSink.StatefulSinkWriter
A
SinkWriter whose state needs to be checkpointed. |
Class and Description |
---|
Committer
The
Committer is responsible for committing the data staged by the TwoPhaseCommittingSink.PrecommittingSinkWriter in the second step of a two-phase commit
protocol. |
Sink.InitContext
The interface exposes some runtime info for creating a
SinkWriter . |
StatefulSink
A
Sink with a stateful SinkWriter . |
TwoPhaseCommittingSink
A
Sink for exactly-once semantics using a two-phase commit protocol. |
Class and Description |
---|
Sink.InitContext
The interface exposes some runtime info for creating a
SinkWriter . |
SinkWriter.Context
Context that
SinkWriter.write(InputT, org.apache.flink.api.connector.sink2.SinkWriter.Context) can use for getting additional data about an input record. |
StatefulSink
A
Sink with a stateful SinkWriter . |
StatefulSink.StatefulSinkWriter
A
SinkWriter whose state needs to be checkpointed. |
Class and Description |
---|
Committer
The
Committer is responsible for committing the data staged by the TwoPhaseCommittingSink.PrecommittingSinkWriter in the second step of a two-phase commit
protocol. |
Sink.InitContext
The interface exposes some runtime info for creating a
SinkWriter . |
TwoPhaseCommittingSink
A
Sink for exactly-once semantics using a two-phase commit protocol. |
TwoPhaseCommittingSink.PrecommittingSinkWriter
A
SinkWriter that performs the first part of a two-phase commit protocol. |
Class and Description |
---|
Committer.CommitRequest
A request to commit a specific committable.
|
Class and Description |
---|
Sink.InitContext
The interface exposes some runtime info for creating a
SinkWriter . |
SinkWriter.Context
Context that
SinkWriter.write(InputT, org.apache.flink.api.connector.sink2.SinkWriter.Context) can use for getting additional data about an input record. |
TwoPhaseCommittingSink.PrecommittingSinkWriter
A
SinkWriter that performs the first part of a two-phase commit protocol. |
Class and Description |
---|
Sink.InitContext
The interface exposes some runtime info for creating a
SinkWriter . |
Class and Description |
---|
Sink
Base interface for developing a sink.
|
Class and Description |
---|
Sink.InitContext
The interface exposes some runtime info for creating a
SinkWriter . |
SinkWriter
The
SinkWriter is responsible for writing data. |
Class and Description |
---|
Committer
The
Committer is responsible for committing the data staged by the TwoPhaseCommittingSink.PrecommittingSinkWriter in the second step of a two-phase commit
protocol. |
Sink
Base interface for developing a sink.
|
TwoPhaseCommittingSink
A
Sink for exactly-once semantics using a two-phase commit protocol. |
Class and Description |
---|
Sink
Base interface for developing a sink.
|
Class and Description |
---|
Sink.InitContext
The interface exposes some runtime info for creating a
SinkWriter . |
SinkWriter
The
SinkWriter is responsible for writing data. |
Class and Description |
---|
Committer.CommitRequest
A request to commit a specific committable.
|
Sink
Base interface for developing a sink.
|
Sink.InitContext
The interface exposes some runtime info for creating a
SinkWriter . |
Class and Description |
---|
Sink
Base interface for developing a sink.
|
TwoPhaseCommittingSink
A
Sink for exactly-once semantics using a two-phase commit protocol. |
Class and Description |
---|
Committer
The
Committer is responsible for committing the data staged by the TwoPhaseCommittingSink.PrecommittingSinkWriter in the second step of a two-phase commit
protocol. |
Committer.CommitRequest
A request to commit a specific committable.
|
Class and Description |
---|
SinkWriter.Context
Context that
SinkWriter.write(InputT, org.apache.flink.api.connector.sink2.SinkWriter.Context) can use for getting additional data about an input record. |
Class and Description |
---|
Sink
Base interface for developing a sink.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.