| Package | Description |
|---|---|
| org.apache.paimon.flink.copy |
| Modifier and Type | Field and Description |
|---|---|
static org.apache.flink.util.OutputTag<CopyFileInfo> |
CopyMetaFilesFunction.DATA_MANIFEST_FILES_TAG |
static org.apache.flink.util.OutputTag<CopyFileInfo> |
CopyMetaFilesFunction.INDEX_FILES_TAG |
| Modifier and Type | Method and Description |
|---|---|
static List<CopyFileInfo> |
CopyFilesUtil.toCopyFileInfos(List<Path> fileList,
Path sourceTableRoot,
String sourceIdentifier,
String targetIdentifier) |
| Modifier and Type | Method and Description |
|---|---|
int |
SnapshotHintChannelComputer.channel(CopyFileInfo record) |
| Modifier and Type | Method and Description |
|---|---|
void |
CopyManifestFileOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<CopyFileInfo> streamRecord) |
void |
SnapshotHintOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<CopyFileInfo> streamRecord) |
void |
CopyDataFileOperator.processElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<CopyFileInfo> streamRecord) |
Copyright © 2023–2025 The Apache Software Foundation. All rights reserved.