Skip to content

Commit

Permalink
Renamed utcMillis to epochMillis in Int64TimestampMillisColumnReader
Browse files Browse the repository at this point in the history
  • Loading branch information
sbernauer authored and findepi committed Nov 22, 2021
1 parent 0f78fa9 commit 92f2452
Showing 1 changed file with 3 additions and 3 deletions.
Expand Up @@ -39,12 +39,12 @@ public Int64TimestampMillisColumnReader(RichColumnDescriptor descriptor)
protected void readValue(BlockBuilder blockBuilder, Type type)
{
if (definitionLevel == columnDescriptor.getMaxDefinitionLevel()) {
long utcMillis = valuesReader.readLong();
long epochMillis = valuesReader.readLong();
if (type instanceof TimestampWithTimeZoneType) {
type.writeLong(blockBuilder, packDateTimeWithZone(utcMillis, UTC_KEY));
type.writeLong(blockBuilder, packDateTimeWithZone(epochMillis, UTC_KEY));
}
else if (type instanceof TimestampType) {
long epochMicros = utcMillis * MICROSECONDS_PER_MILLISECOND;
long epochMicros = epochMillis * MICROSECONDS_PER_MILLISECOND;
if (((TimestampType) type).isShort()) {
type.writeLong(blockBuilder, epochMicros);
}
Expand Down

0 comments on commit 92f2452

Please sign in to comment.