Examples of FieldSerializer

com.datasalt.pangool.io.Schema.Field.FieldSerializer
com.esotericsoftware.kryo.serialize.FieldSerializer
Serializes objects using direct field assignment. This is a very fast mechanism for serializing objects, often as good as {@link CustomSerialization}. FieldSerializer is many times smaller and faster than Java serialization. The fields should be public for optimal performance, which allows bytecode generation to be used instead of reflection.
FieldSerializer does not write header data, only the object data is stored. If the type of a field is not final (note primitives are final) then an extra byte is written for that field. @see Serializer @see Kryo#register(Class,Serializer) @author Nathan Sweet
com.esotericsoftware.kryo.serializers.FieldSerializer
Serializes objects using direct field assignment. No header or schema data is stored, only the data for each field. This reduces output size but means if any field is added or removed, previously serialized bytes are invalidated. If fields are public, bytecode generation will be used instead of reflection. @see Serializer @see Kryo#register(Class,Serializer) @author Nathan Sweet @author Roman Levenstein

Examples of com.datasalt.pangool.io.Schema.Field.FieldSerializer

  public static FieldSerializer[] getSerializers(Schema schema){
    FieldSerializer[] result = new FieldSerializer[schema.getFields().size()];
    for (int i= 0 ; i < result.length; i++){
      Field field = schema.getField(i);
      if (field.getSerializerClass() != null){
        FieldSerializer ser = ReflectionUtils.newInstance(field.getSerializerClass(),null);
        ser.setProps(field.getProps());
        result[i] = ser;
      }
    }
    return result;
  }

View Full Code Here

Examples of com.datasalt.pangool.io.Schema.Field.FieldSerializer

    for(int i = 0; i < c.getElements().size(); i++) {
      Field field = schema.getField(i);
      SortElement e = c.getElements().get(i);
      Object o1 = w1.get(index1[i]);
      Object o2 = w2.get(index2[i]);
      FieldSerializer serializer = (serializers == null) ? null : serializers[i];
      int comparison = compareObjects(o1, o2, e.getCustomComparator(), field.getType(),serializer);
      if(comparison != 0) {
        return(e.getOrder() == Order.ASC ? comparison : -comparison);
      }
    }

View Full Code Here

Examples of com.datasalt.pangool.io.Schema.Field.FieldSerializer

      case DOUBLE:
      case BYTES:
        record.put(i, obj); //optimistic
        break;
      case OBJECT:
        FieldSerializer customSer = customSerializers[i];
        DataOutputBuffer buffer = buffers[i];
        buffer.reset();
        if (customSer != null){
          customSer.open(buffer);
          customSer.serialize(obj);
          customSer.close(); //TODO is this safe ?
        } else {
          hadoopSer.ser(obj, buffer);
        }
        //TODO this byteBuffer instances should be cached and reused
        ByteBuffer byteBuffer = ByteBuffer.wrap(buffer.getData(), 0,buffer.getLength());

View Full Code Here

Examples of com.esotericsoftware.kryo.serialize.FieldSerializer

    waitForThreads();
  }


  static public void register (Kryo kryo) {
    kryo.register(short[].class);
    kryo.register(SomeData.class, new DeltaCompressor(kryo, new FieldSerializer(kryo, SomeData.class), 2048, 4));
    kryo.register(SomeOtherData.class);
  }

View Full Code Here

Examples of com.esotericsoftware.kryo.serialize.FieldSerializer

    waitForThreads();
  }


  static public void register (Kryo kryo) {
    kryo.register(short[].class);
    kryo.register(SomeData.class, new DeflateCompressor(new FieldSerializer(kryo, SomeData.class)));
    kryo.register(ArrayList.class, new CollectionSerializer(kryo));
  }

View Full Code Here

Examples of com.esotericsoftware.kryo.serialize.FieldSerializer

   * @see Kryo#register(Class, Serializer) */
  static public void registerClasses (Kryo kryo) {
    kryo.register(Object[].class);
    kryo.register(InvokeMethod.class);


    FieldSerializer serializer = (FieldSerializer)kryo.register(InvokeMethodResult.class).getSerializer();
    serializer.getField("objectID").setClass(int.class, new IntSerializer(true));


    kryo.register(InvocationHandler.class, new Serializer() {
      public void writeObjectData (ByteBuffer buffer, Object object) {
        RemoteInvocationHandler handler = (RemoteInvocationHandler)Proxy.getInvocationHandler(object);
        IntSerializer.put(buffer, handler.objectID, true);

View Full Code Here

Examples of com.esotericsoftware.kryo.serialize.FieldSerializer

/**
 * This test does all possible Kryo serializer optimizations.
 */
public class KryoOptimizedSerializer extends KryoSerializer {
  public KryoOptimizedSerializer () {
    FieldSerializer imageSerializer = (FieldSerializer)kryo.getSerializer(Image.class);
    imageSerializer.setFieldsCanBeNull(false);


    FieldSerializer mediaContentSerializer = (FieldSerializer)kryo.getSerializer(MediaContent.class);
    mediaContentSerializer.setFieldsCanBeNull(false);


    CachedField imagesField = mediaContentSerializer.getField("_images");
    CollectionSerializer imagesSerializer = new CollectionSerializer(kryo);
    imagesSerializer.setElementClass(Image.class);
    imagesSerializer.setElementsCanBeNull(false);
    imagesSerializer.setLength(2);
    imagesField.setClass(ArrayList.class, imagesSerializer);


    CachedField mediaField = mediaContentSerializer.getField("_media");
    FieldSerializer mediaSerializer = new FieldSerializer(kryo, Media.class);
    mediaSerializer.setFieldsCanBeNull(false);
    mediaField.setClass(Media.class, mediaSerializer);


    CachedField personsField = mediaSerializer.getField("_persons");
    CollectionSerializer personsSerializer = new CollectionSerializer(kryo);
    personsSerializer.setElementClass(String.class);
    personsSerializer.setElementsCanBeNull(false);
    personsSerializer.setLength(2);
    personsField.setClass(ArrayList.class, personsSerializer);


    mediaSerializer.getField("_copyright").setCanBeNull(true);
  }

View Full Code Here

Examples of com.esotericsoftware.kryo.serialize.FieldSerializer

    }


    @Override
    public Serializer newSerializer( final Class<?> type ) {
        if ( SERIALIZED_CLASS_NAME.equals( type.getName() ) ) {
            return new FieldSerializer( _kryo, type );
        }
        return null;
    }

View Full Code Here

Examples of com.esotericsoftware.kryo.serialize.FieldSerializer

    @Override
    public Serializer newSerializer( final Class<?> type ) {
        if( HIBERNATE_ABSTRACT_COLLECTION_CLASS == null ) {
            return null;
        } else if ( HIBERNATE_ABSTRACT_COLLECTION_CLASS.isAssignableFrom( type ) ) {
            return new FieldSerializer( _kryo, type );
        }
        return null;
    }

View Full Code Here

Examples of com.esotericsoftware.kryo.serialize.FieldSerializer

  /**
   * Called by {@link #newSerializer(Class)} when a serializer could not otherwise be determined. The default implementation
   * returns a new {@link FieldSerializer}.
   */
  protected Serializer newDefaultSerializer (Class type) {
    return new FieldSerializer(this, type);
  }

View Full Code Here

0 1 2

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.