This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit 6aaf5ed897d6b14241957b1fdc98009e5bec05d7 Author: Stefan Richter <[email protected]> AuthorDate: Mon Jul 30 19:06:48 2018 +0200 [hotfix] Minor cleanups in LongSerializer --- .../flink/api/common/typeutils/base/LongSerializer.java | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/LongSerializer.java b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/LongSerializer.java index cbdc3db..2ed2cec 100644 --- a/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/LongSerializer.java +++ b/flink-core/src/main/java/org/apache/flink/api/common/typeutils/base/LongSerializer.java @@ -18,12 +18,12 @@ package org.apache.flink.api.common.typeutils.base; -import java.io.IOException; - import org.apache.flink.annotation.Internal; import org.apache.flink.core.memory.DataInputView; import org.apache.flink.core.memory.DataOutputView; +import java.io.IOException; + @Internal public final class LongSerializer extends TypeSerializerSingleton<Long> { @@ -31,7 +31,7 @@ public final class LongSerializer extends TypeSerializerSingleton<Long> { public static final LongSerializer INSTANCE = new LongSerializer(); - private static final Long ZERO = Long.valueOf(0); + private static final Long ZERO = 0L; @Override public boolean isImmutableType() { @@ -55,17 +55,17 @@ public final class LongSerializer extends TypeSerializerSingleton<Long> { @Override public int getLength() { - return 8; + return Long.BYTES; } @Override public void serialize(Long record, DataOutputView target) throws IOException { - target.writeLong(record.longValue()); + target.writeLong(record); } @Override public Long deserialize(DataInputView source) throws IOException { - return Long.valueOf(source.readLong()); + return source.readLong(); } @Override
