Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
SinkFunction.Context
Context that
SinkFunctions can use for getting additional data about an
input record. |
Class and Description |
---|
SinkFunction
Interface for implementing user defined sink functionality.
|
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
SinkFunction.Context
Context that
SinkFunctions can use for getting additional data about an
input record. |
Class and Description |
---|
SinkFunction
Interface for implementing user defined sink functionality.
|
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
SinkFunction.Context
Context that
SinkFunctions can use for getting additional data about an
input record. |
TwoPhaseCommitSinkFunction
This is a recommended base class for all of the
SinkFunction that intend to implement
exactly-once semantic. |
TwoPhaseCommitSinkFunction.State
State POJO class coupling pendingTransaction, context and pendingCommitTransactions.
|
TwoPhaseCommitSinkFunction.StateSerializer
Custom
TypeSerializer for the sink state. |
TwoPhaseCommitSinkFunction.StateSerializerSnapshot
Snapshot for the
TwoPhaseCommitSinkFunction.StateSerializer . |
TwoPhaseCommitSinkFunction.TransactionHolder
Adds metadata (currently only the start time of the transaction) to the transaction object.
|
WriteFormat
Deprecated.
Please use the
StreamingFileSink
for writing to files from a streaming program. |
WriteSinkFunction
Deprecated.
Please use the
StreamingFileSink
for writing to files from a streaming program. |
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
SinkFunction.Context
Context that
SinkFunctions can use for getting additional data about an
input record. |
Class and Description |
---|
SinkFunction
Interface for implementing user defined sink functionality.
|
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
SinkFunction.Context
Context that
SinkFunctions can use for getting additional data about an
input record. |
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
SinkFunction.Context
Context that
SinkFunctions can use for getting additional data about an
input record. |
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
Class and Description |
---|
SinkFunction
Interface for implementing user defined sink functionality.
|
Class and Description |
---|
SinkFunction
Interface for implementing user defined sink functionality.
|
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
SinkFunction.Context
Context that
SinkFunctions can use for getting additional data about an
input record. |
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
SinkFunction.Context
Context that
SinkFunctions can use for getting additional data about an
input record. |
TwoPhaseCommitSinkFunction
This is a recommended base class for all of the
SinkFunction that intend to implement
exactly-once semantic. |
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
SinkFunction.Context
Context that
SinkFunctions can use for getting additional data about an
input record. |
TwoPhaseCommitSinkFunction
This is a recommended base class for all of the
SinkFunction that intend to implement
exactly-once semantic. |
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
SinkFunction.Context
Context that
SinkFunctions can use for getting additional data about an
input record. |
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
SinkFunction.Context
Context that
SinkFunctions can use for getting additional data about an
input record. |
Class and Description |
---|
SinkFunction
Interface for implementing user defined sink functionality.
|
Class and Description |
---|
SinkFunction
Interface for implementing user defined sink functionality.
|
Class and Description |
---|
SinkFunction
Interface for implementing user defined sink functionality.
|
SinkFunction.Context
Context that
SinkFunctions can use for getting additional data about an
input record. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.