-
Notifications
You must be signed in to change notification settings - Fork 259
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
[Java] put together all primitive serializers (#934)
put together all primitive serializers
- Loading branch information
1 parent
73778d0
commit 6ced04f
Showing
6 changed files
with
365 additions
and
297 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
303 changes: 303 additions & 0 deletions
303
java/fury-core/src/main/java/io/fury/serializer/PrimitiveSerializers.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,303 @@ | ||
| /* | ||
| * Copyright 2023 The Fury Authors | ||
| * | ||
| * Licensed under the Apache License, Version 2.0 (the "License"); | ||
| * you may not use this file except in compliance with the License. | ||
| * You may obtain a copy of the License at | ||
| * | ||
| * http://www.apache.org/licenses/LICENSE-2.0 | ||
| * | ||
| * Unless required by applicable law or agreed to in writing, software | ||
| * distributed under the License is distributed on an "AS IS" BASIS, | ||
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| * See the License for the specific language governing permissions and | ||
| * limitations under the License. | ||
| */ | ||
|
|
||
| package io.fury.serializer; | ||
|
|
||
| import com.google.common.base.Preconditions; | ||
| import io.fury.Fury; | ||
| import io.fury.memory.MemoryBuffer; | ||
| import io.fury.type.Type; | ||
|
|
||
| /** | ||
| * Serializers for java primitive types. | ||
| * | ||
| * @author chaokunyang | ||
| */ | ||
| @SuppressWarnings({"rawtypes", "unchecked"}) | ||
| public class PrimitiveSerializers { | ||
| public static final class BooleanSerializer | ||
| extends Serializers.CrossLanguageCompatibleSerializer<Boolean> { | ||
| public BooleanSerializer(Fury fury, Class<?> cls) { | ||
| super( | ||
| fury, | ||
| (Class) cls, | ||
| Type.BOOL.getId(), | ||
| !(cls.isPrimitive() || fury.isBasicTypesRefIgnored())); | ||
| } | ||
|
|
||
| @Override | ||
| public void write(MemoryBuffer buffer, Boolean value) { | ||
| buffer.writeBoolean(value); | ||
| } | ||
|
|
||
| @Override | ||
| public Boolean read(MemoryBuffer buffer) { | ||
| return buffer.readBoolean(); | ||
| } | ||
| } | ||
|
|
||
| public static final class ByteSerializer | ||
| extends Serializers.CrossLanguageCompatibleSerializer<Byte> { | ||
| public ByteSerializer(Fury fury, Class<?> cls) { | ||
| super( | ||
| fury, | ||
| (Class) cls, | ||
| Type.INT8.getId(), | ||
| !(cls.isPrimitive() || fury.isBasicTypesRefIgnored())); | ||
| } | ||
|
|
||
| @Override | ||
| public void write(MemoryBuffer buffer, Byte value) { | ||
| buffer.writeByte(value); | ||
| } | ||
|
|
||
| @Override | ||
| public Byte read(MemoryBuffer buffer) { | ||
| return buffer.readByte(); | ||
| } | ||
| } | ||
|
|
||
| public static final class Uint8Serializer extends Serializer<Integer> { | ||
| public Uint8Serializer(Fury fury) { | ||
| super(fury, Integer.class); | ||
| } | ||
|
|
||
| @Override | ||
| public short getXtypeId() { | ||
| return Type.UINT8.getId(); | ||
| } | ||
|
|
||
| @Override | ||
| public void xwrite(MemoryBuffer buffer, Integer value) { | ||
| Preconditions.checkArgument(value >= 0 && value <= 255); | ||
| buffer.writeByte(value.byteValue()); | ||
| } | ||
|
|
||
| @Override | ||
| public Integer xread(MemoryBuffer buffer) { | ||
| int b = buffer.readByte(); | ||
| return b >>> 24; | ||
| } | ||
| } | ||
|
|
||
| public static final class Uint16Serializer extends Serializer<Integer> { | ||
| public Uint16Serializer(Fury fury) { | ||
| super(fury, Integer.class); | ||
| } | ||
|
|
||
| @Override | ||
| public short getXtypeId() { | ||
| return Type.UINT16.getId(); | ||
| } | ||
|
|
||
| @Override | ||
| public void xwrite(MemoryBuffer buffer, Integer value) { | ||
| Preconditions.checkArgument(value >= 0 && value <= 65535); | ||
| buffer.writeByte(value.byteValue()); | ||
| } | ||
|
|
||
| @Override | ||
| public Integer xread(MemoryBuffer buffer) { | ||
| int b = buffer.readByte(); | ||
| return b >>> 16; | ||
| } | ||
| } | ||
|
|
||
| public static final class CharSerializer extends Serializer<Character> { | ||
| public CharSerializer(Fury fury, Class<?> cls) { | ||
| super(fury, (Class) cls, !(cls.isPrimitive() || fury.isBasicTypesRefIgnored())); | ||
| } | ||
|
|
||
| @Override | ||
| public void write(MemoryBuffer buffer, Character value) { | ||
| buffer.writeChar(value); | ||
| } | ||
|
|
||
| @Override | ||
| public Character read(MemoryBuffer buffer) { | ||
| return buffer.readChar(); | ||
| } | ||
| } | ||
|
|
||
| public static final class ShortSerializer | ||
| extends Serializers.CrossLanguageCompatibleSerializer<Short> { | ||
| public ShortSerializer(Fury fury, Class<?> cls) { | ||
| super( | ||
| fury, | ||
| (Class) cls, | ||
| Type.INT16.getId(), | ||
| !(cls.isPrimitive() || fury.isBasicTypesRefIgnored())); | ||
| } | ||
|
|
||
| @Override | ||
| public void write(MemoryBuffer buffer, Short value) { | ||
| buffer.writeShort(value); | ||
| } | ||
|
|
||
| @Override | ||
| public Short read(MemoryBuffer buffer) { | ||
| return buffer.readShort(); | ||
| } | ||
| } | ||
|
|
||
| public static final class IntSerializer | ||
| extends Serializers.CrossLanguageCompatibleSerializer<Integer> { | ||
| private final boolean compressNumber; | ||
|
|
||
| public IntSerializer(Fury fury, Class<?> cls) { | ||
| super( | ||
| fury, | ||
| (Class) cls, | ||
| Type.INT32.getId(), | ||
| !(cls.isPrimitive() || fury.isBasicTypesRefIgnored())); | ||
| compressNumber = fury.compressInt(); | ||
| } | ||
|
|
||
| @Override | ||
| public void write(MemoryBuffer buffer, Integer value) { | ||
| if (compressNumber) { | ||
| buffer.writeVarInt(value); | ||
| } else { | ||
| buffer.writeInt(value); | ||
| } | ||
| } | ||
|
|
||
| @Override | ||
| public Integer read(MemoryBuffer buffer) { | ||
| if (compressNumber) { | ||
| return buffer.readVarInt(); | ||
| } else { | ||
| return buffer.readInt(); | ||
| } | ||
| } | ||
|
|
||
| @Override | ||
| public void xwrite(MemoryBuffer buffer, Integer value) { | ||
| // TODO support varint in cross-language serialization | ||
| buffer.writeInt(value); | ||
| } | ||
|
|
||
| @Override | ||
| public Integer xread(MemoryBuffer buffer) { | ||
| return buffer.readInt(); | ||
| } | ||
| } | ||
|
|
||
| public static final class LongSerializer | ||
| extends Serializers.CrossLanguageCompatibleSerializer<Long> { | ||
| private final boolean compressNumber; | ||
|
|
||
| public LongSerializer(Fury fury, Class<?> cls) { | ||
| super( | ||
| fury, | ||
| (Class) cls, | ||
| Type.INT64.getId(), | ||
| !(cls.isPrimitive() || fury.isBasicTypesRefIgnored())); | ||
| compressNumber = fury.compressLong(); | ||
| } | ||
|
|
||
| @Override | ||
| public void write(MemoryBuffer buffer, Long value) { | ||
| if (compressNumber) { | ||
| buffer.writeVarLong(value); | ||
| } else { | ||
| buffer.writeLong(value); | ||
| } | ||
| } | ||
|
|
||
| @Override | ||
| public Long read(MemoryBuffer buffer) { | ||
| if (compressNumber) { | ||
| return buffer.readVarLong(); | ||
| } else { | ||
| return buffer.readLong(); | ||
| } | ||
| } | ||
|
|
||
| @Override | ||
| public void xwrite(MemoryBuffer buffer, Long value) { | ||
| // TODO support var long in cross-language serialization | ||
| buffer.writeLong(value); | ||
| } | ||
|
|
||
| @Override | ||
| public Long xread(MemoryBuffer buffer) { | ||
| return buffer.readLong(); | ||
| } | ||
| } | ||
|
|
||
| public static final class FloatSerializer | ||
| extends Serializers.CrossLanguageCompatibleSerializer<Float> { | ||
| public FloatSerializer(Fury fury, Class<?> cls) { | ||
| super( | ||
| fury, | ||
| (Class) cls, | ||
| Type.FLOAT.getId(), | ||
| !(cls.isPrimitive() || fury.isBasicTypesRefIgnored())); | ||
| } | ||
|
|
||
| @Override | ||
| public void write(MemoryBuffer buffer, Float value) { | ||
| buffer.writeFloat(value); | ||
| } | ||
|
|
||
| @Override | ||
| public Float read(MemoryBuffer buffer) { | ||
| return buffer.readFloat(); | ||
| } | ||
| } | ||
|
|
||
| public static final class DoubleSerializer | ||
| extends Serializers.CrossLanguageCompatibleSerializer<Double> { | ||
| public DoubleSerializer(Fury fury, Class<?> cls) { | ||
| super( | ||
| fury, | ||
| (Class) cls, | ||
| Type.DOUBLE.getId(), | ||
| !(cls.isPrimitive() || fury.isBasicTypesRefIgnored())); | ||
| } | ||
|
|
||
| @Override | ||
| public void write(MemoryBuffer buffer, Double value) { | ||
| buffer.writeDouble(value); | ||
| } | ||
|
|
||
| @Override | ||
| public Double read(MemoryBuffer buffer) { | ||
| return buffer.readDouble(); | ||
| } | ||
| } | ||
|
|
||
| public static void registerDefaultSerializers(Fury fury) { | ||
| // primitive types will be boxed. | ||
| fury.registerSerializer(boolean.class, new BooleanSerializer(fury, boolean.class)); | ||
| fury.registerSerializer(byte.class, new ByteSerializer(fury, byte.class)); | ||
| fury.registerSerializer(short.class, new ShortSerializer(fury, short.class)); | ||
| fury.registerSerializer(char.class, new CharSerializer(fury, char.class)); | ||
| fury.registerSerializer(int.class, new IntSerializer(fury, int.class)); | ||
| fury.registerSerializer(long.class, new LongSerializer(fury, long.class)); | ||
| fury.registerSerializer(float.class, new FloatSerializer(fury, float.class)); | ||
| fury.registerSerializer(double.class, new DoubleSerializer(fury, double.class)); | ||
| fury.registerSerializer(Boolean.class, new BooleanSerializer(fury, Boolean.class)); | ||
| fury.registerSerializer(Byte.class, new ByteSerializer(fury, Byte.class)); | ||
| fury.registerSerializer(Short.class, new ShortSerializer(fury, Short.class)); | ||
| fury.registerSerializer(Character.class, new CharSerializer(fury, Character.class)); | ||
| fury.registerSerializer(Integer.class, new IntSerializer(fury, Integer.class)); | ||
| fury.registerSerializer(Long.class, new LongSerializer(fury, Long.class)); | ||
| fury.registerSerializer(Float.class, new FloatSerializer(fury, Float.class)); | ||
| fury.registerSerializer(Double.class, new DoubleSerializer(fury, Double.class)); | ||
| } | ||
| } |
Oops, something went wrong.