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.TransactionHolder
Adds metadata (currently only the start time of the transaction) to the transaction object.
|
WriteFormat
Abstract class for formatting the output of the writeAsText and writeAsCsv
functions.
|
WriteSinkFunction
Simple implementation of the SinkFunction writing tuples as simple text to
the file specified by path.
|
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.
|
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.
|
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.
|
Class and Description |
---|
RichSinkFunction
A
RichFunction version of SinkFunction . |
SinkFunction
Interface for implementing user defined sink functionality.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.