Package | Description |
---|---|
org.apache.paimon.flink.sink | |
org.apache.paimon.flink.sink.cdc | |
org.apache.paimon.flink.sink.index |
Modifier and Type | Method and Description |
---|---|
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<InternalRow,Committable> |
RowUnawareBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<ManifestEntry,Committable> |
RewriteFileIndexSink.createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
protected abstract org.apache.flink.streaming.api.operators.OneInputStreamOperator<T,Committable> |
FlinkSink.createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<InternalRow,Committable> |
FixedBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<UnawareAppendCompactionTask,Committable> |
UnawareBucketCompactionSink.createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.table.data.RowData,Committable> |
CompactorSink.createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>,Committable> |
RowDynamicBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
Constructor and Description |
---|
DynamicBucketRowWriteOperator(FileStoreTable table,
StoreSinkWrite.Provider storeSinkWriteProvider,
String initialCommitUser) |
RowDataStoreWriteOperator(FileStoreTable table,
LogSinkFunction logSinkFunction,
StoreSinkWrite.Provider storeSinkWriteProvider,
String initialCommitUser) |
StoreCompactOperator(FileStoreTable table,
StoreSinkWrite.Provider storeSinkWriteProvider,
String initialCommitUser,
boolean fullCompaction) |
TableWriteOperator(FileStoreTable table,
StoreSinkWrite.Provider storeSinkWriteProvider,
String initialCommitUser) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<CdcRecord,Committable> |
CdcUnawareBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<CdcRecord,Integer>,Committable> |
CdcDynamicBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<CdcRecord,Committable> |
CdcFixedBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
Constructor and Description |
---|
CdcDynamicBucketWriteOperator(FileStoreTable table,
StoreSinkWrite.Provider storeSinkWriteProvider,
String initialCommitUser) |
CdcRecordStoreWriteOperator(FileStoreTable table,
StoreSinkWrite.Provider storeSinkWriteProvider,
String initialCommitUser) |
CdcUnawareBucketWriteOperator(FileStoreTable table,
StoreSinkWrite.Provider storeSinkWriteProvider,
String initialCommitUser) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.flink.streaming.api.operators.OneInputStreamOperator<org.apache.flink.api.java.tuple.Tuple2<InternalRow,Integer>,Committable> |
GlobalDynamicBucketSink.createWriteOperator(StoreSinkWrite.Provider writeProvider,
String commitUser) |
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.