Examples of TSerializer

com.facebook.presto.hive.shaded.org.apache.thrift.TSerializer
com.facebook.thrift.TSerializer
Generic utility for easily serializing objects into a byte array or Java String.
org.apache.blur.thirdparty.thrift_0_9_0.TSerializer
Generic utility for easily serializing objects into a byte array or Java String.
org.apache.thrift.TSerializer
Generic utility for easily serializing objects into a byte array or Java String.
org.apache.thrift7.TSerializer
Generic utility for easily serializing objects into a byte array or Java String.

Examples of com.facebook.presto.hive.shaded.org.apache.thrift.TSerializer

      JSONObject jsonContainer = new JSONObject();
      jsonContainer.put("version", METADATA_FORMAT_VERSION);
      if (METADATA_FORMAT_FORWARD_COMPATIBLE_VERSION != null) {
        jsonContainer.put("fcversion", METADATA_FORMAT_FORWARD_COMPATIBLE_VERSION);
      }
      TSerializer serializer = new TSerializer(new TJSONProtocol.Factory());
      try {
        String tableDesc = serializer.toString(tableHandle.getTTable(), "UTF-8");
        jsonContainer.put("table", tableDesc);
        JSONArray jsonPartitions = new JSONArray();
        if (partitions != null) {
          for (org.apache.hadoop.hive.ql.metadata.Partition partition : partitions) {
            String partDesc = serializer.toString(partition.getTPartition(), "UTF-8");
            jsonPartitions.put(partDesc);
          }
        }
        jsonContainer.put("partitions", jsonPartitions);
      } catch (TException e) {

View Full Code Here

Examples of com.facebook.thrift.TSerializer

    separator = DefaultSeparator;
    outTransport = new TIOStreamTransport(bos);
    inTransport = new TIOStreamTransport(bis);
    outProtocol = outFactory.getProtocol(outTransport);
    inProtocol = inFactory.getProtocol(inTransport);
    json_serializer = new TSerializer(new TSimpleJSONProtocol.Factory());
  }

View Full Code Here

Examples of org.apache.blur.thirdparty.thrift_0_9_0.TSerializer

    }
  }


  private byte[] serializeTableDescriptor(TableDescriptor td) {
    try {
      TSerializer serializer = new TSerializer(new TJSONProtocol.Factory());
      return serializer.serialize(td);
    } catch (TException e) {
      throw new RuntimeException(e);
    }
  }

View Full Code Here

Examples of org.apache.thrift.TSerializer

        ByteBuffer sc = sliceCommand.super_column;
        dos.writeInt(sc == null ? 0 : sc.remaining());
        if (sc != null)
            ByteBufferUtil.write(sc, dos);


        TSerializer ser = new TSerializer(new TBinaryProtocol.Factory());
        FBUtilities.serialize(ser, sliceCommand.predicate, dos);
        AbstractBounds.serializer().serialize(sliceCommand.range, dos);
        dos.writeInt(sliceCommand.max_keys);
    }

View Full Code Here

Examples of org.apache.thrift.TSerializer


      System.out.println("Min time: " + timeMin/1000 + "us");
      System.out.println("Max time: " + timeMax/1000 + "us");
      System.out.println("Avg time: " + timeAvg/1000 + "us");


      String json = (new TSerializer(new TSimpleJSONProtocol.Factory())).toString(insane);


      System.out.println("\nFor good meausre here is some JSON:\n" + json);


    } catch (Exception x) {
      x.printStackTrace();

View Full Code Here

Examples of org.apache.thrift.TSerializer

    // System.out.println(clientInTrans.inspect());
    assertEquals(2, testClient.recv_Janky());
  }


  public void testTDeserializer() throws TException {
    TSerializer ser = new TSerializer(getFactory());
    byte[] bytes = ser.serialize(Fixtures.compactProtoTestStruct);


    TDeserializer deser = new TDeserializer(getFactory());
    CompactProtoTestStruct cpts = new CompactProtoTestStruct();
    deser.deserialize(cpts, bytes);

View Full Code Here

Examples of org.apache.thrift.TSerializer

  private static final int NUM_TRIALS = 5;
  private static final int NUM_REPS = 10000;


  protected void benchmark() throws Exception {
    for (int trial = 0; trial < NUM_TRIALS; trial++) {
      TSerializer ser = new TSerializer(getFactory());
      byte[] serialized = null;
      long serStart = System.currentTimeMillis();
      for (int rep = 0; rep < NUM_REPS; rep++) {
        serialized = ser.serialize(Fixtures.holyMoley);
      }
      long serEnd = System.currentTimeMillis();
      long serElapsed = serEnd - serStart;
      System.out.println("Ser:\t" + serElapsed + "ms\t" 
          + ((double)serElapsed / NUM_REPS) + "ms per serialization");

View Full Code Here

Examples of org.apache.thrift.TSerializer

    // System.out.println(clientInTrans.inspect());
    assertEquals(2, testClient.recv_Janky());
  }


  public void testTDeserializer() throws TException {
    TSerializer ser = new TSerializer(getFactory());
    byte[] bytes = ser.serialize(Fixtures.compactProtoTestStruct);


    TDeserializer deser = new TDeserializer(getFactory());
    CompactProtoTestStruct cpts = new CompactProtoTestStruct();
    deser.deserialize(cpts, bytes);

View Full Code Here

Examples of org.apache.thrift.TSerializer

  private static final int NUM_TRIALS = 5;
  private static final int NUM_REPS = 10000;


  protected void benchmark() throws Exception {
    for (int trial = 0; trial < NUM_TRIALS; trial++) {
      TSerializer ser = new TSerializer(getFactory());
      byte[] serialized = null;
      long serStart = System.currentTimeMillis();
      for (int rep = 0; rep < NUM_REPS; rep++) {
        serialized = ser.serialize(Fixtures.holyMoley);
      }
      long serEnd = System.currentTimeMillis();
      long serElapsed = serEnd - serStart;
      System.out.println("Ser:\t" + serElapsed + "ms\t" 
          + ((double)serElapsed / NUM_REPS) + "ms per serialization");

View Full Code Here

Examples of org.apache.thrift.TSerializer

    private static ThreadLocal<TSerializer> threadSer = new ThreadLocal<TSerializer>();
    private static ThreadLocal<TDeserializer> threadDes = new ThreadLocal<TDeserializer>();
    
    public static byte[] thriftSerialize(TBase t) {
        try {
            TSerializer ser = threadSer.get();
            if (ser == null) {
                ser = new TSerializer();
                threadSer.set(ser);
            } 
            return ser.serialize(t);
        } catch (TException e) {
            throw new RuntimeException(e);
        }
    }

View Full Code Here

0 1 2 3 4 5

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.