| 类和说明 |
|---|
| SinkFunction
已过时。
This interface will be removed in future versions. Use the new
Sink interface instead. |
| 类和说明 |
|---|
| RichSinkFunction
已过时。
This interface will be removed in future versions. Use the new
Sink interface instead. |
| SinkFunction
已过时。
This interface will be removed in future versions. Use the new
Sink interface instead. |
| SinkFunction.Context
已过时。
Context that
SinkFunctions can use for getting additional data about an
input record. |
| TwoPhaseCommitSinkFunction
已过时。
This interface will be removed in future versions. Use the new
Sink interface instead. |
| 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
已过时。
Please use the
StreamingFileSink
for writing to files from a streaming program. |
| WriteSinkFunction
已过时。
Please use the
StreamingFileSink
for writing to files from a streaming program. |
| 类和说明 |
|---|
| RichSinkFunction
已过时。
This interface will be removed in future versions. Use the new
Sink interface instead. |
| SinkFunction
已过时。
This interface will be removed in future versions. Use the new
Sink interface instead. |
| SinkFunction.Context
已过时。
Context that
SinkFunctions can use for getting additional data about an
input record. |
| 类和说明 |
|---|
| SinkFunction
已过时。
This interface will be removed in future versions. Use the new
Sink interface instead. |
| 类和说明 |
|---|
| RichSinkFunction
已过时。
This interface will be removed in future versions. Use the new
Sink interface instead. |
| SinkFunction
已过时。
This interface will be removed in future versions. Use the new
Sink interface instead. |
| SinkFunction.Context
已过时。
Context that
SinkFunctions can use for getting additional data about an
input record. |
| 类和说明 |
|---|
| RichSinkFunction
已过时。
This interface will be removed in future versions. Use the new
Sink interface instead. |
| SinkFunction
已过时。
This interface will be removed in future versions. Use the new
Sink interface instead. |
| SinkFunction.Context
已过时。
Context that
SinkFunctions can use for getting additional data about an
input record. |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.