List of writeClassAndObject() Examples

Examples of writeClassAndObject()

com.esotericsoftware.kryo.Kryo.writeClassAndObject()
Writes the class and object or null using the registered serializer. @param object May be null.
com.esotericsoftware.kryo.ObjectBuffer.writeClassAndObject()
@see Kryo#writeClassAndObject(ByteBuffer,Object)
com.thinkaurelius.titan.graphdb.database.serialize.DataOutput.writeClassAndObject()

Examples of com.esotericsoftware.kryo.Kryo.writeClassAndObject()

            message.put(SerTokens.TOKEN_REQUEST, responseMessage.getRequestId() != null ? responseMessage.getRequestId() : null);


            final Kryo kryo = kryoThreadLocal.get();
            try (final OutputStream baos = new ByteArrayOutputStream()) {
                final Output output = new Output(baos);
                kryo.writeClassAndObject(output, message);


                final long size = output.total();
                if (size > Integer.MAX_VALUE)
                    throw new SerializationException(String.format("Message size of %s exceeds allocatable space", size));

View Full Code Here

Examples of com.esotericsoftware.kryo.Kryo.writeClassAndObject()

                request.put(SerTokens.TOKEN_REQUEST, requestMessage.getRequestId());
                request.put(SerTokens.TOKEN_PROCESSOR, requestMessage.getProcessor());
                request.put(SerTokens.TOKEN_OP, requestMessage.getOp());
                request.put(SerTokens.TOKEN_ARGS, requestMessage.getArgs());


                kryo.writeClassAndObject(output, request);


                final long size = output.total();
                if (size > Integer.MAX_VALUE)
                    throw new SerializationException(String.format("Message size of %s exceeds allocatable space", size));

View Full Code Here

Examples of com.esotericsoftware.kryo.Kryo.writeClassAndObject()

  @Test
  public void test_measurepoint_save(){
    Kryo kryo = SerializeUtil.createKryo();
    Output output = new Output(66666);
    
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    int oldPos = output.position();
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    assertEquals(oldPos+19,output.position());//only key is written not string again
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    kryo.writeClassAndObject(output, new MeasurePointData("2222"));

View Full Code Here

Examples of com.esotericsoftware.kryo.Kryo.writeClassAndObject()

    Kryo kryo = SerializeUtil.createKryo();
    Output output = new Output(66666);
    
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    int oldPos = output.position();
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    assertEquals(oldPos+19,output.position());//only key is written not string again
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    kryo.writeClassAndObject(output, new MeasurePointData("2222"));
    kryo.writeClassAndObject(output, new MeasurePointData("2222"));
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));

View Full Code Here

Examples of com.esotericsoftware.kryo.Kryo.writeClassAndObject()

    
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    int oldPos = output.position();
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    assertEquals(oldPos+19,output.position());//only key is written not string again
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    kryo.writeClassAndObject(output, new MeasurePointData("2222"));
    kryo.writeClassAndObject(output, new MeasurePointData("2222"));
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    
    Input input = new Input(output.getBuffer());

View Full Code Here

Examples of com.esotericsoftware.kryo.Kryo.writeClassAndObject()

    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    int oldPos = output.position();
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    assertEquals(oldPos+19,output.position());//only key is written not string again
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    kryo.writeClassAndObject(output, new MeasurePointData("2222"));
    kryo.writeClassAndObject(output, new MeasurePointData("2222"));
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    
    Input input = new Input(output.getBuffer());
    assertEquals("1111", ((MeasurePointData)kryo.readClassAndObject(input)).getMeasurePointId());

View Full Code Here

Examples of com.esotericsoftware.kryo.Kryo.writeClassAndObject()

    int oldPos = output.position();
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    assertEquals(oldPos+19,output.position());//only key is written not string again
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    kryo.writeClassAndObject(output, new MeasurePointData("2222"));
    kryo.writeClassAndObject(output, new MeasurePointData("2222"));
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    
    Input input = new Input(output.getBuffer());
    assertEquals("1111", ((MeasurePointData)kryo.readClassAndObject(input)).getMeasurePointId());
    assertEquals("1111", ((MeasurePointData)kryo.readClassAndObject(input)).getMeasurePointId());

View Full Code Here

Examples of com.esotericsoftware.kryo.Kryo.writeClassAndObject()

    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    assertEquals(oldPos+19,output.position());//only key is written not string again
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    kryo.writeClassAndObject(output, new MeasurePointData("2222"));
    kryo.writeClassAndObject(output, new MeasurePointData("2222"));
    kryo.writeClassAndObject(output, new MeasurePointData("1111"));
    
    Input input = new Input(output.getBuffer());
    assertEquals("1111", ((MeasurePointData)kryo.readClassAndObject(input)).getMeasurePointId());
    assertEquals("1111", ((MeasurePointData)kryo.readClassAndObject(input)).getMeasurePointId());
    assertEquals("1111", ((MeasurePointData)kryo.readClassAndObject(input)).getMeasurePointId());

View Full Code Here

Examples of com.esotericsoftware.kryo.Kryo.writeClassAndObject()

    }
    Kryo kryo = SerializeUtil.createKryo();
    b.position(MonitoringDataStorage.FIRST_RECORD_POSITION);
    Output output = new Output(new ByteBufferOutputStream(b));
    for (MonitoringData data : values) {
      kryo.writeClassAndObject(output, data);
    }
    output.close();
    int limit = b.position();
    
    b.putLong(MonitoringDataStorage.EARLIEST_POSITION, earliest);

View Full Code Here

Examples of com.esotericsoftware.kryo.Kryo.writeClassAndObject()

    kryo.register(AdapterWfLaunchInfo.class);
    {
      Output output = new Output(1024);
      final AdapterWfLaunchInfo object = new AdapterWfLaunchInfo();
      object.setAdapterName("abc");
      kryo.writeClassAndObject(output, object);
      kryo.writeClassAndObject(output, new LogEvent());
      assertTrue(output.getBuffer().length>0);
      
      Input input = new Input(output.getBuffer());
      assertEquals(AdapterWfLaunchInfo.class, kryo.readClassAndObject(input).getClass());

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.