Package org.apache.flink.table.sources.tsextractors

Class TimestampExtractorUtils

java.lang.Object

org.apache.flink.table.sources.tsextractors.TimestampExtractorUtils

@Internal
public final class TimestampExtractorUtils
extends Object

Utility methods for dealing with TimestampExtractor.

Method Summary

Modifier and Type	Method	Description
static ResolvedFieldReference[]	getAccessedFields(TimestampExtractor timestampExtractor, DataType physicalInputType, Function<String,String> nameRemapping)	Retrieves all field accesses needed for the given TimestampExtractor.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getAccessedFields

public static ResolvedFieldReference[] getAccessedFields(TimestampExtractor timestampExtractor,
                                                         DataType physicalInputType,
                                                         Function<String,String> nameRemapping)

Retrieves all field accesses needed for the given TimestampExtractor.

Parameters:

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 fields

Returns:

Array of physical field references.