Package com.facebook.presto.hive.shaded.org.apache.thrift.protocol

Examples of com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TTupleProtocol

399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
  private static class AddPartitionsResultTupleScheme extends TupleScheme<AddPartitionsResult> {

    @Override
    public void write(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, AddPartitionsResult struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol oprot = (TTupleProtocol) prot;
      BitSet optionals = new BitSet();
      if (struct.isSetPartitions()) {
        optionals.set(0);
      }
      oprot.writeBitSet(optionals, 1);
      if (struct.isSetPartitions()) {
        {
          oprot.writeI32(struct.partitions.size());
          for (Partition _iter334 : struct.partitions)
          {
            _iter334.write(oprot);
          }
        }
View Full Code Here
418
419
420
421
422
423
424
425
426
427
428
429
430
431
432
      }
    }

    @Override
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, AddPartitionsResult struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol iprot = (TTupleProtocol) prot;
      BitSet incoming = iprot.readBitSet(1);
      if (incoming.get(0)) {
        {
          com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList _list335 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
          struct.partitions = new ArrayList<Partition>(_list335.size);
          for (int _i336 = 0; _i336 < _list335.size; ++_i336)
          {
            Partition _elem337; // required
            _elem337 = new Partition();
View Full Code Here
405
406
407
408
409
410
411
412
413
414
415
416
417
  private static class ShowCompactResponseTupleScheme extends TupleScheme<ShowCompactResponse> {

    @Override
    public void write(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, ShowCompactResponse struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol oprot = (TTupleProtocol) prot;
      {
        oprot.writeI32(struct.compacts.size());
        for (ShowCompactResponseElement _iter438 : struct.compacts)
        {
          _iter438.write(oprot);
        }
      }
View Full Code Here
417
418
419
420
421
422
423
424
425
426
427
428
429
      }
    }

    @Override
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, ShowCompactResponse struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol iprot = (TTupleProtocol) prot;
      {
        com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList _list439 = new com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TList(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
        struct.compacts = new ArrayList<ShowCompactResponseElement>(_list439.size);
        for (int _i440 = 0; _i440 < _list439.size; ++_i440)
        {
          ShowCompactResponseElement _elem441; // required
          _elem441 = new ShowCompactResponseElement();
View Full Code Here
365
366
367
368
369
370
371
372
  private static class CommitTxnRequestTupleScheme extends TupleScheme<CommitTxnRequest> {

    @Override
    public void write(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, CommitTxnRequest struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol oprot = (TTupleProtocol) prot;
      oprot.writeI64(struct.txnid);
    }
View Full Code Here
371
372
373
374
375
376
377
378
379
      oprot.writeI64(struct.txnid);
    }

    @Override
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, CommitTxnRequest struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol iprot = (TTupleProtocol) prot;
      struct.txnid = iprot.readI64();
      struct.setTxnidIsSet(true);
    }
View Full Code Here
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
  private static class InvalidObjectExceptionTupleScheme extends TupleScheme<InvalidObjectException> {

    @Override
    public void write(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, InvalidObjectException struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol oprot = (TTupleProtocol) prot;
      BitSet optionals = new BitSet();
      if (struct.isSetMessage()) {
        optionals.set(0);
      }
      oprot.writeBitSet(optionals, 1);
      if (struct.isSetMessage()) {
        oprot.writeString(struct.message);
      }
    }
View Full Code Here
376
377
378
379
380
381
382
383
384
385
386
387
      }
    }

    @Override
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, InvalidObjectException struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol iprot = (TTupleProtocol) prot;
      BitSet incoming = iprot.readBitSet(1);
      if (incoming.get(0)) {
        struct.message = iprot.readString();
        struct.setMessageIsSet(true);
      }
    }
View Full Code Here
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
  private static class TxnOpenExceptionTupleScheme extends TupleScheme<TxnOpenException> {

    @Override
    public void write(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, TxnOpenException struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol oprot = (TTupleProtocol) prot;
      BitSet optionals = new BitSet();
      if (struct.isSetMessage()) {
        optionals.set(0);
      }
      oprot.writeBitSet(optionals, 1);
      if (struct.isSetMessage()) {
        oprot.writeString(struct.message);
      }
    }
View Full Code Here
376
377
378
379
380
381
382
383
384
385
386
387
      }
    }

    @Override
    public void read(com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TProtocol prot, TxnOpenException struct) throws com.facebook.presto.hive.shaded.org.apache.thrift.TException {
      TTupleProtocol iprot = (TTupleProtocol) prot;
      BitSet incoming = iprot.readBitSet(1);
      if (incoming.get(0)) {
        struct.message = iprot.readString();
        struct.setMessageIsSet(true);
      }
    }
View Full Code Here
TOP

Related Classes of com.facebook.presto.hive.shaded.org.apache.thrift.protocol.TTupleProtocol

  • org.apache.hadoop.hive.metastore.api.AbortTxnRequest$AbortTxnRequestTupleScheme
  • org.apache.hadoop.hive.metastore.api.AddPartitionsRequest$AddPartitionsRequestTupleScheme
  • org.apache.hadoop.hive.metastore.api.AddPartitionsResult$AddPartitionsResultTupleScheme
  • org.apache.hadoop.hive.metastore.api.AlreadyExistsException$AlreadyExistsExceptionTupleScheme
  • org.apache.hadoop.hive.metastore.api.BinaryColumnStatsData$BinaryColumnStatsDataTupleScheme
  • org.apache.hadoop.hive.metastore.api.BooleanColumnStatsData$BooleanColumnStatsDataTupleScheme
  • org.apache.hadoop.hive.metastore.api.CheckLockRequest$CheckLockRequestTupleScheme
  • org.apache.hadoop.hive.metastore.api.ColumnStatistics$ColumnStatisticsTupleScheme
  • org.apache.hadoop.hive.metastore.api.ColumnStatisticsDesc$ColumnStatisticsDescTupleScheme
  • org.apache.hadoop.hive.metastore.api.ColumnStatisticsObj$ColumnStatisticsObjTupleScheme
    • Copyright © 2018 www.massapicom. All rights reserved.
    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.