org.apache.flink.core.fs.FileInputSplit to org.apache.flink.streaming.api.functions.source.TimestampedFileInputSplit
No. of Instances - 11
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: T_SUPER_R
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
- new StreamRecord<>(split) to new StreamRecord<>(new TimestampedFileInputSplit(modTimes.get(split.getPath().getName()),split.getSplitNumber(),split.getPath(),split.getStart(),split.getLength(),split.getHostnames()))
- new StreamRecord<>(split) to new StreamRecord<>(new TimestampedFileInputSplit(modTimes.get(split.getPath().getName()),split.getSplitNumber(),split.getPath(),split.getStart(),split.getLength(),split.getHostnames()))