@FunctionalInterface @Internal public interface PartitionFieldExtractor<T extends FileSourceSplit> extends Serializable
Modifier and Type | Method and Description |
---|---|
Object |
extract(T split,
String fieldName,
LogicalType fieldType) |
static PartitionFieldExtractor<FileSourceSplit> |
forFileSystem(String defaultPartValue) |
Object extract(T split, String fieldName, LogicalType fieldType)
static PartitionFieldExtractor<FileSourceSplit> forFileSystem(String defaultPartValue)
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.