org.apache.flink.formats.parquet.utils

Class ParquetTimestampUtils

java.lang.Object

org.apache.flink.formats.parquet.utils.ParquetTimestampUtils

public final class ParquetTimestampUtils
extends Object

Utility class for decoding INT96 encoded parquet timestamp to timestamp millis in GMT. This class is equivalent of @see org.apache.hadoop.hive.ql.io.parquet.timestamp.NanoTime, which produces less intermediate objects during decoding.

Method Summary

Modifier and Type	Method and Description
static long	getTimestampMillis(org.apache.parquet.io.api.Binary timestampBinary) Returns GMT timestamp from binary encoded parquet timestamp (12 bytes - julian date + time of day nanos).

Methods inherited from class java.lang.Object

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

Method Detail

getTimestampMillis

public static long getTimestampMillis(org.apache.parquet.io.api.Binary timestampBinary)

Returns GMT timestamp from binary encoded parquet timestamp (12 bytes - julian date + time of day nanos).

Parameters:

timestampBinary - INT96 parquet timestamp

Returns:

timestamp in millis, GMT timezone