Package | Description |
---|---|
org.apache.paimon.flink.sink | |
org.apache.paimon.flink.sink.cdc | |
org.apache.paimon.flink.sink.index |
Modifier and Type | Class and Description |
---|---|
class |
CompactorSink
FlinkSink for dedicated compact jobs. |
class |
DynamicBucketCompactSink
This class is only used for generate compact sink topology for dynamic bucket table.
|
class |
DynamicBucketSink<T>
Sink for dynamic bucket table.
|
class |
FixedBucketSink
FlinkSink for writing records into fixed bucket Paimon table. |
class |
FlinkWriteSink<T>
A
FlinkSink to write records. |
class |
RewriteFileIndexSink
File index sink for
RewriteFileIndexProcedure . |
class |
RowDynamicBucketSink
Sink for dynamic bucket table.
|
class |
RowUnawareBucketSink
An
UnawareBucketSink which handles InternalRow . |
class |
UnawareBucketCompactionSink
Compaction Sink for unaware-bucket table.
|
class |
UnawareBucketSink<T>
Sink for unaware-bucket table.
|
Modifier and Type | Class and Description |
---|---|
class |
CdcDynamicBucketSink
|
class |
CdcDynamicBucketSinkBase<T>
CDC sink for dynamic bucket table.
|
class |
CdcFixedBucketSink
|
class |
CdcUnawareBucketSink
CDC Sink for unaware bucket table.
|
Modifier and Type | Class and Description |
---|---|
class |
GlobalDynamicBucketSink
Sink for global dynamic bucket table.
|
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.