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.