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