@@ -0,0 +1,1938 @@
+package org.sensorhub.impl.persistence.es;%0A%0Aimport java.io.InputStream;%0Aimport java.io.OutputStream;%0A%0Aimport org.objenesis.strategy.StdInstantiatorStrategy;%0Aimport org.sensorhub.impl.persistence.es.KryoDataType.KryoInstance;%0Aimport org.vast.data.AbstractDataBlock;%0Aimport org.vast.data.DataBlockByte;%0Aimport org.vast.data.DataBlockDouble;%0Aimport org.vast.data.DataBlockFloat;%0Aimport org.vast.data.DataBlockInt;%0Aimport org.vast.data.DataBlockLong;%0Aimport org.vast.data.DataBlockParallel;%0Aimport org.vast.data.DataBlockShort;%0Aimport org.vast.data.DataBlockString;%0Aimport org.vast.data.DataBlockTuple;%0A%0Aimport com.esotericsoftware.kryo.Kryo;%0Aimport com.esotericsoftware.kryo.Kryo.DefaultInstantiatorStrategy;%0Aimport com.esotericsoftware.kryo.io.Input;%0Aimport com.esotericsoftware.kryo.io.Output;%0Aimport com.esotericsoftware.kryo.serializers.FieldSerializer;%0A%0Aimport net.opengis.OgcPropertyList;%0A%0Apublic class KryoSerializer %7B%0A%09private static final ThreadLocal%3CKryo%3E kryoLocal = new ThreadLocal%3CKryo%3E() %7B%0A%09%09protected Kryo initialValue() %7B%0A%09%09%09Kryo kryo = new Kryo();%0A%09%09%09kryo.setInstantiatorStrategy(new DefaultInstantiatorStrategy(new StdInstantiatorStrategy()));%0A%09%09%09kryo.addDefaultSerializer(OgcPropertyList.class, FieldSerializer.class);%0A%0A%09%09%09kryo.register(AbstractDataBlock%5B%5D.class);%0A%09%09%09kryo.register(DataBlockTuple.class);%0A%09%09%09kryo.register(DataBlockParallel.class);%0A%09%09%09kryo.register(DataBlockByte.class);%0A%09%09%09kryo.register(DataBlockShort.class);%0A%09%09%09kryo.register(DataBlockInt.class);%0A%09%09%09kryo.register(DataBlockLong.class);%0A%09%09%09kryo.register(DataBlockFloat.class);%0A%09%09%09kryo.register(DataBlockDouble.class);%0A%09%09%09kryo.register(DataBlockString.class);%0A%09%09%09kryo.register(DataStreamInfo.class);%0A%09%09%09return kryo;%0A%09%09%7D;%0A%09%7D;%0A%0A%09public static void serialize(Object object, Output output) %7B%0A%09%09kryoLocal.get().writeClassAndObject(output, object);%0A%09%7D%0A%0A%09public static %3CT%3E T deserialize(Input input) %7B%0A%09%09return (T) kryoLocal.get().readClassAndObject(input);%0A%09%7D%0A%7D%0A

Add kryo serializer