@Internal public final class TimestampExtractorUtils extends Object
TimestampExtractor
.Modifier and Type | Method and Description |
---|---|
static ResolvedFieldReference[] |
getAccessedFields(TimestampExtractor timestampExtractor,
DataType physicalInputType,
Function<String,String> nameRemapping)
Retrieves all field accesses needed for the given
TimestampExtractor . |
public static ResolvedFieldReference[] getAccessedFields(TimestampExtractor timestampExtractor, DataType physicalInputType, Function<String,String> nameRemapping)
TimestampExtractor
.timestampExtractor
- Extractor for which to construct array of field accesses.physicalInputType
- Physical input type that the timestamp extractor accesses.nameRemapping
- Additional remapping of a logical to a physical field name.
TimestampExtractor works with logical names, but accesses physical fieldsCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.