You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sr...@apache.org on 2018/08/02 15:43:47 UTC
[flink] 02/02: [hotfix] Minor cleanups in LongSerializer
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 <s....@data-artisans.com>
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