Package org.apache.flink.connector.file.table

Class DefaultPartTimeExtractor

java.lang.Object

org.apache.flink.connector.file.table.DefaultPartTimeExtractor

All Implemented Interfaces:

Serializable, PartitionTimeExtractor

@Internal
public class DefaultPartTimeExtractor
extends Object
implements PartitionTimeExtractor

Default PartitionTimeExtractor. See FileSystemConnectorOptions.PARTITION_TIME_EXTRACTOR_TIMESTAMP_PATTERN.

See Also:

Serialized Form

Field Summary

Fields inherited from interface org.apache.flink.connector.file.table.PartitionTimeExtractor

CUSTOM, DEFAULT

Constructor Summary

Constructors

Constructor	Description
DefaultPartTimeExtractor(String extractorPattern, String formatterPattern)

Method Summary

Modifier and Type	Method	Description
LocalDateTime	extract(List<String> partitionKeys, List<String> partitionValues)	Extract time from partition keys and values.
static LocalDateTime	toLocalDateTime(String timestampString, String formatterPattern)
static LocalDateTime	toLocalDateTimeDefault(String timestampString)
static long	toMills(LocalDateTime dateTime)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultPartTimeExtractor

public DefaultPartTimeExtractor(@Nullable
                                String extractorPattern,
                                @Nullable
                                String formatterPattern)

Method Detail

extract

public LocalDateTime extract(List<String> partitionKeys,
                             List<String> partitionValues)

Description copied from interface: PartitionTimeExtractor

Extract time from partition keys and values.

Specified by:

extract in interface PartitionTimeExtractor

toLocalDateTime

public static LocalDateTime toLocalDateTime(String timestampString,
                                            @Nullable
                                            String formatterPattern)

toLocalDateTimeDefault

public static LocalDateTime toLocalDateTimeDefault(String timestampString)

toMills

public static long toMills(LocalDateTime dateTime)