http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java index 89eb819..1405203 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataByExprResult.java @@ -444,16 +444,16 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF case 1: // METADATA if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map524 = iprot.readMapBegin(); - struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map524.size); - long _key525; - MetadataPpdResult _val526; - for (int _i527 = 0; _i527 < _map524.size; ++_i527) + org.apache.thrift.protocol.TMap _map540 = iprot.readMapBegin(); + struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map540.size); + long _key541; + MetadataPpdResult _val542; + for (int _i543 = 0; _i543 < _map540.size; ++_i543) { - _key525 = iprot.readI64(); - _val526 = new MetadataPpdResult(); - _val526.read(iprot); - struct.metadata.put(_key525, _val526); + _key541 = iprot.readI64(); + _val542 = new MetadataPpdResult(); + _val542.read(iprot); + struct.metadata.put(_key541, _val542); } iprot.readMapEnd(); } @@ -487,10 +487,10 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF oprot.writeFieldBegin(METADATA_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, struct.metadata.size())); - for (Map.Entry<Long, MetadataPpdResult> _iter528 : struct.metadata.entrySet()) + for (Map.Entry<Long, MetadataPpdResult> _iter544 : struct.metadata.entrySet()) { - oprot.writeI64(_iter528.getKey()); - _iter528.getValue().write(oprot); + oprot.writeI64(_iter544.getKey()); + _iter544.getValue().write(oprot); } oprot.writeMapEnd(); } @@ -518,10 +518,10 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.metadata.size()); - for (Map.Entry<Long, MetadataPpdResult> _iter529 : struct.metadata.entrySet()) + for (Map.Entry<Long, MetadataPpdResult> _iter545 : struct.metadata.entrySet()) { - oprot.writeI64(_iter529.getKey()); - _iter529.getValue().write(oprot); + oprot.writeI64(_iter545.getKey()); + _iter545.getValue().write(oprot); } } oprot.writeBool(struct.isSupported); @@ -531,16 +531,16 @@ public class GetFileMetadataByExprResult implements org.apache.thrift.TBase<GetF public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataByExprResult struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TMap _map530 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map530.size); - long _key531; - MetadataPpdResult _val532; - for (int _i533 = 0; _i533 < _map530.size; ++_i533) + org.apache.thrift.protocol.TMap _map546 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.metadata = new HashMap<Long,MetadataPpdResult>(2*_map546.size); + long _key547; + MetadataPpdResult _val548; + for (int _i549 = 0; _i549 < _map546.size; ++_i549) { - _key531 = iprot.readI64(); - _val532 = new MetadataPpdResult(); - _val532.read(iprot); - struct.metadata.put(_key531, _val532); + _key547 = iprot.readI64(); + _val548 = new MetadataPpdResult(); + _val548.read(iprot); + struct.metadata.put(_key547, _val548); } } struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java index 2408ad1..ae867d0 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataRequest.java @@ -351,13 +351,13 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe case 1: // FILE_IDS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list552 = iprot.readListBegin(); - struct.fileIds = new ArrayList<Long>(_list552.size); - long _elem553; - for (int _i554 = 0; _i554 < _list552.size; ++_i554) + org.apache.thrift.protocol.TList _list568 = iprot.readListBegin(); + struct.fileIds = new ArrayList<Long>(_list568.size); + long _elem569; + for (int _i570 = 0; _i570 < _list568.size; ++_i570) { - _elem553 = iprot.readI64(); - struct.fileIds.add(_elem553); + _elem569 = iprot.readI64(); + struct.fileIds.add(_elem569); } iprot.readListEnd(); } @@ -383,9 +383,9 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe oprot.writeFieldBegin(FILE_IDS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.fileIds.size())); - for (long _iter555 : struct.fileIds) + for (long _iter571 : struct.fileIds) { - oprot.writeI64(_iter555); + oprot.writeI64(_iter571); } oprot.writeListEnd(); } @@ -410,9 +410,9 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.fileIds.size()); - for (long _iter556 : struct.fileIds) + for (long _iter572 : struct.fileIds) { - oprot.writeI64(_iter556); + oprot.writeI64(_iter572); } } } @@ -421,13 +421,13 @@ public class GetFileMetadataRequest implements org.apache.thrift.TBase<GetFileMe public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list557 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.fileIds = new ArrayList<Long>(_list557.size); - long _elem558; - for (int _i559 = 0; _i559 < _list557.size; ++_i559) + org.apache.thrift.protocol.TList _list573 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.fileIds = new ArrayList<Long>(_list573.size); + long _elem574; + for (int _i575 = 0; _i575 < _list573.size; ++_i575) { - _elem558 = iprot.readI64(); - struct.fileIds.add(_elem558); + _elem574 = iprot.readI64(); + struct.fileIds.add(_elem574); } } struct.setFileIdsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java index 8946635..21c9eea 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetFileMetadataResult.java @@ -433,15 +433,15 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet case 1: // METADATA if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map542 = iprot.readMapBegin(); - struct.metadata = new HashMap<Long,ByteBuffer>(2*_map542.size); - long _key543; - ByteBuffer _val544; - for (int _i545 = 0; _i545 < _map542.size; ++_i545) + org.apache.thrift.protocol.TMap _map558 = iprot.readMapBegin(); + struct.metadata = new HashMap<Long,ByteBuffer>(2*_map558.size); + long _key559; + ByteBuffer _val560; + for (int _i561 = 0; _i561 < _map558.size; ++_i561) { - _key543 = iprot.readI64(); - _val544 = iprot.readBinary(); - struct.metadata.put(_key543, _val544); + _key559 = iprot.readI64(); + _val560 = iprot.readBinary(); + struct.metadata.put(_key559, _val560); } iprot.readMapEnd(); } @@ -475,10 +475,10 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet oprot.writeFieldBegin(METADATA_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, struct.metadata.size())); - for (Map.Entry<Long, ByteBuffer> _iter546 : struct.metadata.entrySet()) + for (Map.Entry<Long, ByteBuffer> _iter562 : struct.metadata.entrySet()) { - oprot.writeI64(_iter546.getKey()); - oprot.writeBinary(_iter546.getValue()); + oprot.writeI64(_iter562.getKey()); + oprot.writeBinary(_iter562.getValue()); } oprot.writeMapEnd(); } @@ -506,10 +506,10 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.metadata.size()); - for (Map.Entry<Long, ByteBuffer> _iter547 : struct.metadata.entrySet()) + for (Map.Entry<Long, ByteBuffer> _iter563 : struct.metadata.entrySet()) { - oprot.writeI64(_iter547.getKey()); - oprot.writeBinary(_iter547.getValue()); + oprot.writeI64(_iter563.getKey()); + oprot.writeBinary(_iter563.getValue()); } } oprot.writeBool(struct.isSupported); @@ -519,15 +519,15 @@ public class GetFileMetadataResult implements org.apache.thrift.TBase<GetFileMet public void read(org.apache.thrift.protocol.TProtocol prot, GetFileMetadataResult struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TMap _map548 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.metadata = new HashMap<Long,ByteBuffer>(2*_map548.size); - long _key549; - ByteBuffer _val550; - for (int _i551 = 0; _i551 < _map548.size; ++_i551) + org.apache.thrift.protocol.TMap _map564 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.I64, org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.metadata = new HashMap<Long,ByteBuffer>(2*_map564.size); + long _key565; + ByteBuffer _val566; + for (int _i567 = 0; _i567 < _map564.size; ++_i567) { - _key549 = iprot.readI64(); - _val550 = iprot.readBinary(); - struct.metadata.put(_key549, _val550); + _key565 = iprot.readI64(); + _val566 = iprot.readBinary(); + struct.metadata.put(_key565, _val566); } } struct.setMetadataIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java index 629c042..b2f98d6 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsInfoResponse.java @@ -447,14 +447,14 @@ public class GetOpenTxnsInfoResponse implements org.apache.thrift.TBase<GetOpenT case 2: // OPEN_TXNS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list428 = iprot.readListBegin(); - struct.open_txns = new ArrayList<TxnInfo>(_list428.size); - TxnInfo _elem429; - for (int _i430 = 0; _i430 < _list428.size; ++_i430) + org.apache.thrift.protocol.TList _list444 = iprot.readListBegin(); + struct.open_txns = new ArrayList<TxnInfo>(_list444.size); + TxnInfo _elem445; + for (int _i446 = 0; _i446 < _list444.size; ++_i446) { - _elem429 = new TxnInfo(); - _elem429.read(iprot); - struct.open_txns.add(_elem429); + _elem445 = new TxnInfo(); + _elem445.read(iprot); + struct.open_txns.add(_elem445); } iprot.readListEnd(); } @@ -483,9 +483,9 @@ public class GetOpenTxnsInfoResponse implements org.apache.thrift.TBase<GetOpenT oprot.writeFieldBegin(OPEN_TXNS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.open_txns.size())); - for (TxnInfo _iter431 : struct.open_txns) + for (TxnInfo _iter447 : struct.open_txns) { - _iter431.write(oprot); + _iter447.write(oprot); } oprot.writeListEnd(); } @@ -511,9 +511,9 @@ public class GetOpenTxnsInfoResponse implements org.apache.thrift.TBase<GetOpenT oprot.writeI64(struct.txn_high_water_mark); { oprot.writeI32(struct.open_txns.size()); - for (TxnInfo _iter432 : struct.open_txns) + for (TxnInfo _iter448 : struct.open_txns) { - _iter432.write(oprot); + _iter448.write(oprot); } } } @@ -524,14 +524,14 @@ public class GetOpenTxnsInfoResponse implements org.apache.thrift.TBase<GetOpenT struct.txn_high_water_mark = iprot.readI64(); struct.setTxn_high_water_markIsSet(true); { - org.apache.thrift.protocol.TList _list433 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.open_txns = new ArrayList<TxnInfo>(_list433.size); - TxnInfo _elem434; - for (int _i435 = 0; _i435 < _list433.size; ++_i435) + org.apache.thrift.protocol.TList _list449 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.open_txns = new ArrayList<TxnInfo>(_list449.size); + TxnInfo _elem450; + for (int _i451 = 0; _i451 < _list449.size; ++_i451) { - _elem434 = new TxnInfo(); - _elem434.read(iprot); - struct.open_txns.add(_elem434); + _elem450 = new TxnInfo(); + _elem450.read(iprot); + struct.open_txns.add(_elem450); } } struct.setOpen_txnsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java index 9f57a4a..ba99b89 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetOpenTxnsResponse.java @@ -444,13 +444,13 @@ public class GetOpenTxnsResponse implements org.apache.thrift.TBase<GetOpenTxnsR case 2: // OPEN_TXNS if (schemeField.type == org.apache.thrift.protocol.TType.SET) { { - org.apache.thrift.protocol.TSet _set436 = iprot.readSetBegin(); - struct.open_txns = new HashSet<Long>(2*_set436.size); - long _elem437; - for (int _i438 = 0; _i438 < _set436.size; ++_i438) + org.apache.thrift.protocol.TSet _set452 = iprot.readSetBegin(); + struct.open_txns = new HashSet<Long>(2*_set452.size); + long _elem453; + for (int _i454 = 0; _i454 < _set452.size; ++_i454) { - _elem437 = iprot.readI64(); - struct.open_txns.add(_elem437); + _elem453 = iprot.readI64(); + struct.open_txns.add(_elem453); } iprot.readSetEnd(); } @@ -479,9 +479,9 @@ public class GetOpenTxnsResponse implements org.apache.thrift.TBase<GetOpenTxnsR oprot.writeFieldBegin(OPEN_TXNS_FIELD_DESC); { oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.open_txns.size())); - for (long _iter439 : struct.open_txns) + for (long _iter455 : struct.open_txns) { - oprot.writeI64(_iter439); + oprot.writeI64(_iter455); } oprot.writeSetEnd(); } @@ -507,9 +507,9 @@ public class GetOpenTxnsResponse implements org.apache.thrift.TBase<GetOpenTxnsR oprot.writeI64(struct.txn_high_water_mark); { oprot.writeI32(struct.open_txns.size()); - for (long _iter440 : struct.open_txns) + for (long _iter456 : struct.open_txns) { - oprot.writeI64(_iter440); + oprot.writeI64(_iter456); } } } @@ -520,13 +520,13 @@ public class GetOpenTxnsResponse implements org.apache.thrift.TBase<GetOpenTxnsR struct.txn_high_water_mark = iprot.readI64(); struct.setTxn_high_water_markIsSet(true); { - org.apache.thrift.protocol.TSet _set441 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.open_txns = new HashSet<Long>(2*_set441.size); - long _elem442; - for (int _i443 = 0; _i443 < _set441.size; ++_i443) + org.apache.thrift.protocol.TSet _set457 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.open_txns = new HashSet<Long>(2*_set457.size); + long _elem458; + for (int _i459 = 0; _i459 < _set457.size; ++_i459) { - _elem442 = iprot.readI64(); - struct.open_txns.add(_elem442); + _elem458 = iprot.readI64(); + struct.open_txns.add(_elem458); } } struct.setOpen_txnsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java index b00fb9c..5b399ae 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java @@ -453,13 +453,13 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb case 1: // ABORTED if (schemeField.type == org.apache.thrift.protocol.TType.SET) { { - org.apache.thrift.protocol.TSet _set468 = iprot.readSetBegin(); - struct.aborted = new HashSet<Long>(2*_set468.size); - long _elem469; - for (int _i470 = 0; _i470 < _set468.size; ++_i470) + org.apache.thrift.protocol.TSet _set484 = iprot.readSetBegin(); + struct.aborted = new HashSet<Long>(2*_set484.size); + long _elem485; + for (int _i486 = 0; _i486 < _set484.size; ++_i486) { - _elem469 = iprot.readI64(); - struct.aborted.add(_elem469); + _elem485 = iprot.readI64(); + struct.aborted.add(_elem485); } iprot.readSetEnd(); } @@ -471,13 +471,13 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb case 2: // NOSUCH if (schemeField.type == org.apache.thrift.protocol.TType.SET) { { - org.apache.thrift.protocol.TSet _set471 = iprot.readSetBegin(); - struct.nosuch = new HashSet<Long>(2*_set471.size); - long _elem472; - for (int _i473 = 0; _i473 < _set471.size; ++_i473) + org.apache.thrift.protocol.TSet _set487 = iprot.readSetBegin(); + struct.nosuch = new HashSet<Long>(2*_set487.size); + long _elem488; + for (int _i489 = 0; _i489 < _set487.size; ++_i489) { - _elem472 = iprot.readI64(); - struct.nosuch.add(_elem472); + _elem488 = iprot.readI64(); + struct.nosuch.add(_elem488); } iprot.readSetEnd(); } @@ -503,9 +503,9 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb oprot.writeFieldBegin(ABORTED_FIELD_DESC); { oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.aborted.size())); - for (long _iter474 : struct.aborted) + for (long _iter490 : struct.aborted) { - oprot.writeI64(_iter474); + oprot.writeI64(_iter490); } oprot.writeSetEnd(); } @@ -515,9 +515,9 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb oprot.writeFieldBegin(NOSUCH_FIELD_DESC); { oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.nosuch.size())); - for (long _iter475 : struct.nosuch) + for (long _iter491 : struct.nosuch) { - oprot.writeI64(_iter475); + oprot.writeI64(_iter491); } oprot.writeSetEnd(); } @@ -542,16 +542,16 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.aborted.size()); - for (long _iter476 : struct.aborted) + for (long _iter492 : struct.aborted) { - oprot.writeI64(_iter476); + oprot.writeI64(_iter492); } } { oprot.writeI32(struct.nosuch.size()); - for (long _iter477 : struct.nosuch) + for (long _iter493 : struct.nosuch) { - oprot.writeI64(_iter477); + oprot.writeI64(_iter493); } } } @@ -560,24 +560,24 @@ public class HeartbeatTxnRangeResponse implements org.apache.thrift.TBase<Heartb public void read(org.apache.thrift.protocol.TProtocol prot, HeartbeatTxnRangeResponse struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TSet _set478 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.aborted = new HashSet<Long>(2*_set478.size); - long _elem479; - for (int _i480 = 0; _i480 < _set478.size; ++_i480) + org.apache.thrift.protocol.TSet _set494 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.aborted = new HashSet<Long>(2*_set494.size); + long _elem495; + for (int _i496 = 0; _i496 < _set494.size; ++_i496) { - _elem479 = iprot.readI64(); - struct.aborted.add(_elem479); + _elem495 = iprot.readI64(); + struct.aborted.add(_elem495); } } struct.setAbortedIsSet(true); { - org.apache.thrift.protocol.TSet _set481 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.nosuch = new HashSet<Long>(2*_set481.size); - long _elem482; - for (int _i483 = 0; _i483 < _set481.size; ++_i483) + org.apache.thrift.protocol.TSet _set497 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.nosuch = new HashSet<Long>(2*_set497.size); + long _elem498; + for (int _i499 = 0; _i499 < _set497.size; ++_i499) { - _elem482 = iprot.readI64(); - struct.nosuch.add(_elem482); + _elem498 = iprot.readI64(); + struct.nosuch.add(_elem498); } } struct.setNosuchIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java index 488d3a0..7511336 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java @@ -351,13 +351,13 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve case 1: // FILES_ADDED if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list508 = iprot.readListBegin(); - struct.filesAdded = new ArrayList<String>(_list508.size); - String _elem509; - for (int _i510 = 0; _i510 < _list508.size; ++_i510) + org.apache.thrift.protocol.TList _list524 = iprot.readListBegin(); + struct.filesAdded = new ArrayList<String>(_list524.size); + String _elem525; + for (int _i526 = 0; _i526 < _list524.size; ++_i526) { - _elem509 = iprot.readString(); - struct.filesAdded.add(_elem509); + _elem525 = iprot.readString(); + struct.filesAdded.add(_elem525); } iprot.readListEnd(); } @@ -383,9 +383,9 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve oprot.writeFieldBegin(FILES_ADDED_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.filesAdded.size())); - for (String _iter511 : struct.filesAdded) + for (String _iter527 : struct.filesAdded) { - oprot.writeString(_iter511); + oprot.writeString(_iter527); } oprot.writeListEnd(); } @@ -410,9 +410,9 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.filesAdded.size()); - for (String _iter512 : struct.filesAdded) + for (String _iter528 : struct.filesAdded) { - oprot.writeString(_iter512); + oprot.writeString(_iter528); } } } @@ -421,13 +421,13 @@ public class InsertEventRequestData implements org.apache.thrift.TBase<InsertEve public void read(org.apache.thrift.protocol.TProtocol prot, InsertEventRequestData struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list513 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.filesAdded = new ArrayList<String>(_list513.size); - String _elem514; - for (int _i515 = 0; _i515 < _list513.size; ++_i515) + org.apache.thrift.protocol.TList _list529 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.filesAdded = new ArrayList<String>(_list529.size); + String _elem530; + for (int _i531 = 0; _i531 < _list529.size; ++_i531) { - _elem514 = iprot.readString(); - struct.filesAdded.add(_elem514); + _elem530 = iprot.readString(); + struct.filesAdded.add(_elem530); } } struct.setFilesAddedIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java index f39f582..bd10329 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java @@ -689,14 +689,14 @@ public class LockRequest implements org.apache.thrift.TBase<LockRequest, LockReq case 1: // COMPONENT if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list452 = iprot.readListBegin(); - struct.component = new ArrayList<LockComponent>(_list452.size); - LockComponent _elem453; - for (int _i454 = 0; _i454 < _list452.size; ++_i454) + org.apache.thrift.protocol.TList _list468 = iprot.readListBegin(); + struct.component = new ArrayList<LockComponent>(_list468.size); + LockComponent _elem469; + for (int _i470 = 0; _i470 < _list468.size; ++_i470) { - _elem453 = new LockComponent(); - _elem453.read(iprot); - struct.component.add(_elem453); + _elem469 = new LockComponent(); + _elem469.read(iprot); + struct.component.add(_elem469); } iprot.readListEnd(); } @@ -754,9 +754,9 @@ public class LockRequest implements org.apache.thrift.TBase<LockRequest, LockReq oprot.writeFieldBegin(COMPONENT_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.component.size())); - for (LockComponent _iter455 : struct.component) + for (LockComponent _iter471 : struct.component) { - _iter455.write(oprot); + _iter471.write(oprot); } oprot.writeListEnd(); } @@ -803,9 +803,9 @@ public class LockRequest implements org.apache.thrift.TBase<LockRequest, LockReq TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.component.size()); - for (LockComponent _iter456 : struct.component) + for (LockComponent _iter472 : struct.component) { - _iter456.write(oprot); + _iter472.write(oprot); } } oprot.writeString(struct.user); @@ -830,14 +830,14 @@ public class LockRequest implements org.apache.thrift.TBase<LockRequest, LockReq public void read(org.apache.thrift.protocol.TProtocol prot, LockRequest struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list457 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.component = new ArrayList<LockComponent>(_list457.size); - LockComponent _elem458; - for (int _i459 = 0; _i459 < _list457.size; ++_i459) + org.apache.thrift.protocol.TList _list473 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.component = new ArrayList<LockComponent>(_list473.size); + LockComponent _elem474; + for (int _i475 = 0; _i475 < _list473.size; ++_i475) { - _elem458 = new LockComponent(); - _elem458.read(iprot); - struct.component.add(_elem458); + _elem474 = new LockComponent(); + _elem474.read(iprot); + struct.component.add(_elem474); } } struct.setComponentIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java index fcbbd18..8010cf5 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java @@ -354,14 +354,14 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi case 1: // EVENTS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list500 = iprot.readListBegin(); - struct.events = new ArrayList<NotificationEvent>(_list500.size); - NotificationEvent _elem501; - for (int _i502 = 0; _i502 < _list500.size; ++_i502) + org.apache.thrift.protocol.TList _list516 = iprot.readListBegin(); + struct.events = new ArrayList<NotificationEvent>(_list516.size); + NotificationEvent _elem517; + for (int _i518 = 0; _i518 < _list516.size; ++_i518) { - _elem501 = new NotificationEvent(); - _elem501.read(iprot); - struct.events.add(_elem501); + _elem517 = new NotificationEvent(); + _elem517.read(iprot); + struct.events.add(_elem517); } iprot.readListEnd(); } @@ -387,9 +387,9 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi oprot.writeFieldBegin(EVENTS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.events.size())); - for (NotificationEvent _iter503 : struct.events) + for (NotificationEvent _iter519 : struct.events) { - _iter503.write(oprot); + _iter519.write(oprot); } oprot.writeListEnd(); } @@ -414,9 +414,9 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.events.size()); - for (NotificationEvent _iter504 : struct.events) + for (NotificationEvent _iter520 : struct.events) { - _iter504.write(oprot); + _iter520.write(oprot); } } } @@ -425,14 +425,14 @@ public class NotificationEventResponse implements org.apache.thrift.TBase<Notifi public void read(org.apache.thrift.protocol.TProtocol prot, NotificationEventResponse struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list505 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.events = new ArrayList<NotificationEvent>(_list505.size); - NotificationEvent _elem506; - for (int _i507 = 0; _i507 < _list505.size; ++_i507) + org.apache.thrift.protocol.TList _list521 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.events = new ArrayList<NotificationEvent>(_list521.size); + NotificationEvent _elem522; + for (int _i523 = 0; _i523 < _list521.size; ++_i523) { - _elem506 = new NotificationEvent(); - _elem506.read(iprot); - struct.events.add(_elem506); + _elem522 = new NotificationEvent(); + _elem522.read(iprot); + struct.events.add(_elem522); } } struct.setEventsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java index e11a2b3..f745954 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java @@ -351,13 +351,13 @@ public class OpenTxnsResponse implements org.apache.thrift.TBase<OpenTxnsRespons case 1: // TXN_IDS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list444 = iprot.readListBegin(); - struct.txn_ids = new ArrayList<Long>(_list444.size); - long _elem445; - for (int _i446 = 0; _i446 < _list444.size; ++_i446) + org.apache.thrift.protocol.TList _list460 = iprot.readListBegin(); + struct.txn_ids = new ArrayList<Long>(_list460.size); + long _elem461; + for (int _i462 = 0; _i462 < _list460.size; ++_i462) { - _elem445 = iprot.readI64(); - struct.txn_ids.add(_elem445); + _elem461 = iprot.readI64(); + struct.txn_ids.add(_elem461); } iprot.readListEnd(); } @@ -383,9 +383,9 @@ public class OpenTxnsResponse implements org.apache.thrift.TBase<OpenTxnsRespons oprot.writeFieldBegin(TXN_IDS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.txn_ids.size())); - for (long _iter447 : struct.txn_ids) + for (long _iter463 : struct.txn_ids) { - oprot.writeI64(_iter447); + oprot.writeI64(_iter463); } oprot.writeListEnd(); } @@ -410,9 +410,9 @@ public class OpenTxnsResponse implements org.apache.thrift.TBase<OpenTxnsRespons TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.txn_ids.size()); - for (long _iter448 : struct.txn_ids) + for (long _iter464 : struct.txn_ids) { - oprot.writeI64(_iter448); + oprot.writeI64(_iter464); } } } @@ -421,13 +421,13 @@ public class OpenTxnsResponse implements org.apache.thrift.TBase<OpenTxnsRespons public void read(org.apache.thrift.protocol.TProtocol prot, OpenTxnsResponse struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list449 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); - struct.txn_ids = new ArrayList<Long>(_list449.size); - long _elem450; - for (int _i451 = 0; _i451 < _list449.size; ++_i451) + org.apache.thrift.protocol.TList _list465 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32()); + struct.txn_ids = new ArrayList<Long>(_list465.size); + long _elem466; + for (int _i467 = 0; _i467 < _list465.size; ++_i467) { - _elem450 = iprot.readI64(); - struct.txn_ids.add(_elem450); + _elem466 = iprot.readI64(); + struct.txn_ids.add(_elem466); } } struct.setTxn_idsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java index 12ae66d..2d3c156 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsByExprResult.java @@ -439,14 +439,14 @@ public class PartitionsByExprResult implements org.apache.thrift.TBase<Partition case 1: // PARTITIONS if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list322 = iprot.readListBegin(); - struct.partitions = new ArrayList<Partition>(_list322.size); - Partition _elem323; - for (int _i324 = 0; _i324 < _list322.size; ++_i324) + org.apache.thrift.protocol.TList _list338 = iprot.readListBegin(); + struct.partitions = new ArrayList<Partition>(_list338.size); + Partition _elem339; + for (int _i340 = 0; _i340 < _list338.size; ++_i340) { - _elem323 = new Partition(); - _elem323.read(iprot); - struct.partitions.add(_elem323); + _elem339 = new Partition(); + _elem339.read(iprot); + struct.partitions.add(_elem339); } iprot.readListEnd(); } @@ -480,9 +480,9 @@ public class PartitionsByExprResult implements org.apache.thrift.TBase<Partition oprot.writeFieldBegin(PARTITIONS_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.partitions.size())); - for (Partition _iter325 : struct.partitions) + for (Partition _iter341 : struct.partitions) { - _iter325.write(oprot); + _iter341.write(oprot); } oprot.writeListEnd(); } @@ -510,9 +510,9 @@ public class PartitionsByExprResult implements org.apache.thrift.TBase<Partition TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.partitions.size()); - for (Partition _iter326 : struct.partitions) + for (Partition _iter342 : struct.partitions) { - _iter326.write(oprot); + _iter342.write(oprot); } } oprot.writeBool(struct.hasUnknownPartitions); @@ -522,14 +522,14 @@ public class PartitionsByExprResult implements org.apache.thrift.TBase<Partition public void read(org.apache.thrift.protocol.TProtocol prot, PartitionsByExprResult struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TList _list327 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - struct.partitions = new ArrayList<Partition>(_list327.size); - Partition _elem328; - for (int _i329 = 0; _i329 < _list327.size; ++_i329) + org.apache.thrift.protocol.TList _list343 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + struct.partitions = new ArrayList<Partition>(_list343.size); + Partition _elem344; + for (int _i345 = 0; _i345 < _list343.size; ++_i345) { - _elem328 = new Partition(); - _elem328.read(iprot); - struct.partitions.add(_elem328); + _elem344 = new Partition(); + _elem344.read(iprot); + struct.partitions.add(_elem344); } } struct.setPartitionsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java index 8416369..0ac7481 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsRequest.java @@ -639,13 +639,13 @@ public class PartitionsStatsRequest implements org.apache.thrift.TBase<Partition case 3: // COL_NAMES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list364 = iprot.readListBegin(); - struct.colNames = new ArrayList<String>(_list364.size); - String _elem365; - for (int _i366 = 0; _i366 < _list364.size; ++_i366) + org.apache.thrift.protocol.TList _list380 = iprot.readListBegin(); + struct.colNames = new ArrayList<String>(_list380.size); + String _elem381; + for (int _i382 = 0; _i382 < _list380.size; ++_i382) { - _elem365 = iprot.readString(); - struct.colNames.add(_elem365); + _elem381 = iprot.readString(); + struct.colNames.add(_elem381); } iprot.readListEnd(); } @@ -657,13 +657,13 @@ public class PartitionsStatsRequest implements org.apache.thrift.TBase<Partition case 4: // PART_NAMES if (schemeField.type == org.apache.thrift.protocol.TType.LIST) { { - org.apache.thrift.protocol.TList _list367 = iprot.readListBegin(); - struct.partNames = new ArrayList<String>(_list367.size); - String _elem368; - for (int _i369 = 0; _i369 < _list367.size; ++_i369) + org.apache.thrift.protocol.TList _list383 = iprot.readListBegin(); + struct.partNames = new ArrayList<String>(_list383.size); + String _elem384; + for (int _i385 = 0; _i385 < _list383.size; ++_i385) { - _elem368 = iprot.readString(); - struct.partNames.add(_elem368); + _elem384 = iprot.readString(); + struct.partNames.add(_elem384); } iprot.readListEnd(); } @@ -699,9 +699,9 @@ public class PartitionsStatsRequest implements org.apache.thrift.TBase<Partition oprot.writeFieldBegin(COL_NAMES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.colNames.size())); - for (String _iter370 : struct.colNames) + for (String _iter386 : struct.colNames) { - oprot.writeString(_iter370); + oprot.writeString(_iter386); } oprot.writeListEnd(); } @@ -711,9 +711,9 @@ public class PartitionsStatsRequest implements org.apache.thrift.TBase<Partition oprot.writeFieldBegin(PART_NAMES_FIELD_DESC); { oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.partNames.size())); - for (String _iter371 : struct.partNames) + for (String _iter387 : struct.partNames) { - oprot.writeString(_iter371); + oprot.writeString(_iter387); } oprot.writeListEnd(); } @@ -740,16 +740,16 @@ public class PartitionsStatsRequest implements org.apache.thrift.TBase<Partition oprot.writeString(struct.tblName); { oprot.writeI32(struct.colNames.size()); - for (String _iter372 : struct.colNames) + for (String _iter388 : struct.colNames) { - oprot.writeString(_iter372); + oprot.writeString(_iter388); } } { oprot.writeI32(struct.partNames.size()); - for (String _iter373 : struct.partNames) + for (String _iter389 : struct.partNames) { - oprot.writeString(_iter373); + oprot.writeString(_iter389); } } } @@ -762,24 +762,24 @@ public class PartitionsStatsRequest implements org.apache.thrift.TBase<Partition struct.tblName = iprot.readString(); struct.setTblNameIsSet(true); { - org.apache.thrift.protocol.TList _list374 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.colNames = new ArrayList<String>(_list374.size); - String _elem375; - for (int _i376 = 0; _i376 < _list374.size; ++_i376) + org.apache.thrift.protocol.TList _list390 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.colNames = new ArrayList<String>(_list390.size); + String _elem391; + for (int _i392 = 0; _i392 < _list390.size; ++_i392) { - _elem375 = iprot.readString(); - struct.colNames.add(_elem375); + _elem391 = iprot.readString(); + struct.colNames.add(_elem391); } } struct.setColNamesIsSet(true); { - org.apache.thrift.protocol.TList _list377 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); - struct.partNames = new ArrayList<String>(_list377.size); - String _elem378; - for (int _i379 = 0; _i379 < _list377.size; ++_i379) + org.apache.thrift.protocol.TList _list393 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32()); + struct.partNames = new ArrayList<String>(_list393.size); + String _elem394; + for (int _i395 = 0; _i395 < _list393.size; ++_i395) { - _elem378 = iprot.readString(); - struct.partNames.add(_elem378); + _elem394 = iprot.readString(); + struct.partNames.add(_elem394); } } struct.setPartNamesIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java index 2e903f1..51e05ae 100644 --- a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PartitionsStatsResult.java @@ -363,26 +363,26 @@ public class PartitionsStatsResult implements org.apache.thrift.TBase<Partitions case 1: // PART_STATS if (schemeField.type == org.apache.thrift.protocol.TType.MAP) { { - org.apache.thrift.protocol.TMap _map338 = iprot.readMapBegin(); - struct.partStats = new HashMap<String,List<ColumnStatisticsObj>>(2*_map338.size); - String _key339; - List<ColumnStatisticsObj> _val340; - for (int _i341 = 0; _i341 < _map338.size; ++_i341) + org.apache.thrift.protocol.TMap _map354 = iprot.readMapBegin(); + struct.partStats = new HashMap<String,List<ColumnStatisticsObj>>(2*_map354.size); + String _key355; + List<ColumnStatisticsObj> _val356; + for (int _i357 = 0; _i357 < _map354.size; ++_i357) { - _key339 = iprot.readString(); + _key355 = iprot.readString(); { - org.apache.thrift.protocol.TList _list342 = iprot.readListBegin(); - _val340 = new ArrayList<ColumnStatisticsObj>(_list342.size); - ColumnStatisticsObj _elem343; - for (int _i344 = 0; _i344 < _list342.size; ++_i344) + org.apache.thrift.protocol.TList _list358 = iprot.readListBegin(); + _val356 = new ArrayList<ColumnStatisticsObj>(_list358.size); + ColumnStatisticsObj _elem359; + for (int _i360 = 0; _i360 < _list358.size; ++_i360) { - _elem343 = new ColumnStatisticsObj(); - _elem343.read(iprot); - _val340.add(_elem343); + _elem359 = new ColumnStatisticsObj(); + _elem359.read(iprot); + _val356.add(_elem359); } iprot.readListEnd(); } - struct.partStats.put(_key339, _val340); + struct.partStats.put(_key355, _val356); } iprot.readMapEnd(); } @@ -408,14 +408,14 @@ public class PartitionsStatsResult implements org.apache.thrift.TBase<Partitions oprot.writeFieldBegin(PART_STATS_FIELD_DESC); { oprot.writeMapBegin(new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.LIST, struct.partStats.size())); - for (Map.Entry<String, List<ColumnStatisticsObj>> _iter345 : struct.partStats.entrySet()) + for (Map.Entry<String, List<ColumnStatisticsObj>> _iter361 : struct.partStats.entrySet()) { - oprot.writeString(_iter345.getKey()); + oprot.writeString(_iter361.getKey()); { - oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, _iter345.getValue().size())); - for (ColumnStatisticsObj _iter346 : _iter345.getValue()) + oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, _iter361.getValue().size())); + for (ColumnStatisticsObj _iter362 : _iter361.getValue()) { - _iter346.write(oprot); + _iter362.write(oprot); } oprot.writeListEnd(); } @@ -443,14 +443,14 @@ public class PartitionsStatsResult implements org.apache.thrift.TBase<Partitions TTupleProtocol oprot = (TTupleProtocol) prot; { oprot.writeI32(struct.partStats.size()); - for (Map.Entry<String, List<ColumnStatisticsObj>> _iter347 : struct.partStats.entrySet()) + for (Map.Entry<String, List<ColumnStatisticsObj>> _iter363 : struct.partStats.entrySet()) { - oprot.writeString(_iter347.getKey()); + oprot.writeString(_iter363.getKey()); { - oprot.writeI32(_iter347.getValue().size()); - for (ColumnStatisticsObj _iter348 : _iter347.getValue()) + oprot.writeI32(_iter363.getValue().size()); + for (ColumnStatisticsObj _iter364 : _iter363.getValue()) { - _iter348.write(oprot); + _iter364.write(oprot); } } } @@ -461,25 +461,25 @@ public class PartitionsStatsResult implements org.apache.thrift.TBase<Partitions public void read(org.apache.thrift.protocol.TProtocol prot, PartitionsStatsResult struct) throws org.apache.thrift.TException { TTupleProtocol iprot = (TTupleProtocol) prot; { - org.apache.thrift.protocol.TMap _map349 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.LIST, iprot.readI32()); - struct.partStats = new HashMap<String,List<ColumnStatisticsObj>>(2*_map349.size); - String _key350; - List<ColumnStatisticsObj> _val351; - for (int _i352 = 0; _i352 < _map349.size; ++_i352) + org.apache.thrift.protocol.TMap _map365 = new org.apache.thrift.protocol.TMap(org.apache.thrift.protocol.TType.STRING, org.apache.thrift.protocol.TType.LIST, iprot.readI32()); + struct.partStats = new HashMap<String,List<ColumnStatisticsObj>>(2*_map365.size); + String _key366; + List<ColumnStatisticsObj> _val367; + for (int _i368 = 0; _i368 < _map365.size; ++_i368) { - _key350 = iprot.readString(); + _key366 = iprot.readString(); { - org.apache.thrift.protocol.TList _list353 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); - _val351 = new ArrayList<ColumnStatisticsObj>(_list353.size); - ColumnStatisticsObj _elem354; - for (int _i355 = 0; _i355 < _list353.size; ++_i355) + org.apache.thrift.protocol.TList _list369 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32()); + _val367 = new ArrayList<ColumnStatisticsObj>(_list369.size); + ColumnStatisticsObj _elem370; + for (int _i371 = 0; _i371 < _list369.size; ++_i371) { - _elem354 = new ColumnStatisticsObj(); - _elem354.read(iprot); - _val351.add(_elem354); + _elem370 = new ColumnStatisticsObj(); + _elem370.read(iprot); + _val367.add(_elem370); } } - struct.partStats.put(_key350, _val351); + struct.partStats.put(_key366, _val367); } } struct.setPartStatsIsSet(true); http://git-wip-us.apache.org/repos/asf/hive/blob/55375ec1/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrimaryKeysRequest.java ---------------------------------------------------------------------- diff --git a/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrimaryKeysRequest.java b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrimaryKeysRequest.java new file mode 100644 index 0000000..8763ec8 --- /dev/null +++ b/metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PrimaryKeysRequest.java @@ -0,0 +1,490 @@ +/** + * Autogenerated by Thrift Compiler (0.9.3) + * + * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING + * @generated + */ +package org.apache.hadoop.hive.metastore.api; + +import org.apache.thrift.scheme.IScheme; +import org.apache.thrift.scheme.SchemeFactory; +import org.apache.thrift.scheme.StandardScheme; + +import org.apache.thrift.scheme.TupleScheme; +import org.apache.thrift.protocol.TTupleProtocol; +import org.apache.thrift.protocol.TProtocolException; +import org.apache.thrift.EncodingUtils; +import org.apache.thrift.TException; +import org.apache.thrift.async.AsyncMethodCallback; +import org.apache.thrift.server.AbstractNonblockingServer.*; +import java.util.List; +import java.util.ArrayList; +import java.util.Map; +import java.util.HashMap; +import java.util.EnumMap; +import java.util.Set; +import java.util.HashSet; +import java.util.EnumSet; +import java.util.Collections; +import java.util.BitSet; +import java.nio.ByteBuffer; +import java.util.Arrays; +import javax.annotation.Generated; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"}) +@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)") +public class PrimaryKeysRequest implements org.apache.thrift.TBase<PrimaryKeysRequest, PrimaryKeysRequest._Fields>, java.io.Serializable, Cloneable, Comparable<PrimaryKeysRequest> { + private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("PrimaryKeysRequest"); + + private static final org.apache.thrift.protocol.TField DB_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("db_name", org.apache.thrift.protocol.TType.STRING, (short)1); + private static final org.apache.thrift.protocol.TField TBL_NAME_FIELD_DESC = new org.apache.thrift.protocol.TField("tbl_name", org.apache.thrift.protocol.TType.STRING, (short)2); + + private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>(); + static { + schemes.put(StandardScheme.class, new PrimaryKeysRequestStandardSchemeFactory()); + schemes.put(TupleScheme.class, new PrimaryKeysRequestTupleSchemeFactory()); + } + + private String db_name; // required + private String tbl_name; // required + + /** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */ + public enum _Fields implements org.apache.thrift.TFieldIdEnum { + DB_NAME((short)1, "db_name"), + TBL_NAME((short)2, "tbl_name"); + + private static final Map<String, _Fields> byName = new HashMap<String, _Fields>(); + + static { + for (_Fields field : EnumSet.allOf(_Fields.class)) { + byName.put(field.getFieldName(), field); + } + } + + /** + * Find the _Fields constant that matches fieldId, or null if its not found. + */ + public static _Fields findByThriftId(int fieldId) { + switch(fieldId) { + case 1: // DB_NAME + return DB_NAME; + case 2: // TBL_NAME + return TBL_NAME; + default: + return null; + } + } + + /** + * Find the _Fields constant that matches fieldId, throwing an exception + * if it is not found. + */ + public static _Fields findByThriftIdOrThrow(int fieldId) { + _Fields fields = findByThriftId(fieldId); + if (fields == null) throw new IllegalArgumentException("Field " + fieldId + " doesn't exist!"); + return fields; + } + + /** + * Find the _Fields constant that matches name, or null if its not found. + */ + public static _Fields findByName(String name) { + return byName.get(name); + } + + private final short _thriftId; + private final String _fieldName; + + _Fields(short thriftId, String fieldName) { + _thriftId = thriftId; + _fieldName = fieldName; + } + + public short getThriftFieldId() { + return _thriftId; + } + + public String getFieldName() { + return _fieldName; + } + } + + // isset id assignments + public static final Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> metaDataMap; + static { + Map<_Fields, org.apache.thrift.meta_data.FieldMetaData> tmpMap = new EnumMap<_Fields, org.apache.thrift.meta_data.FieldMetaData>(_Fields.class); + tmpMap.put(_Fields.DB_NAME, new org.apache.thrift.meta_data.FieldMetaData("db_name", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + tmpMap.put(_Fields.TBL_NAME, new org.apache.thrift.meta_data.FieldMetaData("tbl_name", org.apache.thrift.TFieldRequirementType.REQUIRED, + new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING))); + metaDataMap = Collections.unmodifiableMap(tmpMap); + org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(PrimaryKeysRequest.class, metaDataMap); + } + + public PrimaryKeysRequest() { + } + + public PrimaryKeysRequest( + String db_name, + String tbl_name) + { + this(); + this.db_name = db_name; + this.tbl_name = tbl_name; + } + + /** + * Performs a deep copy on <i>other</i>. + */ + public PrimaryKeysRequest(PrimaryKeysRequest other) { + if (other.isSetDb_name()) { + this.db_name = other.db_name; + } + if (other.isSetTbl_name()) { + this.tbl_name = other.tbl_name; + } + } + + public PrimaryKeysRequest deepCopy() { + return new PrimaryKeysRequest(this); + } + + @Override + public void clear() { + this.db_name = null; + this.tbl_name = null; + } + + public String getDb_name() { + return this.db_name; + } + + public void setDb_name(String db_name) { + this.db_name = db_name; + } + + public void unsetDb_name() { + this.db_name = null; + } + + /** Returns true if field db_name is set (has been assigned a value) and false otherwise */ + public boolean isSetDb_name() { + return this.db_name != null; + } + + public void setDb_nameIsSet(boolean value) { + if (!value) { + this.db_name = null; + } + } + + public String getTbl_name() { + return this.tbl_name; + } + + public void setTbl_name(String tbl_name) { + this.tbl_name = tbl_name; + } + + public void unsetTbl_name() { + this.tbl_name = null; + } + + /** Returns true if field tbl_name is set (has been assigned a value) and false otherwise */ + public boolean isSetTbl_name() { + return this.tbl_name != null; + } + + public void setTbl_nameIsSet(boolean value) { + if (!value) { + this.tbl_name = null; + } + } + + public void setFieldValue(_Fields field, Object value) { + switch (field) { + case DB_NAME: + if (value == null) { + unsetDb_name(); + } else { + setDb_name((String)value); + } + break; + + case TBL_NAME: + if (value == null) { + unsetTbl_name(); + } else { + setTbl_name((String)value); + } + break; + + } + } + + public Object getFieldValue(_Fields field) { + switch (field) { + case DB_NAME: + return getDb_name(); + + case TBL_NAME: + return getTbl_name(); + + } + throw new IllegalStateException(); + } + + /** Returns true if field corresponding to fieldID is set (has been assigned a value) and false otherwise */ + public boolean isSet(_Fields field) { + if (field == null) { + throw new IllegalArgumentException(); + } + + switch (field) { + case DB_NAME: + return isSetDb_name(); + case TBL_NAME: + return isSetTbl_name(); + } + throw new IllegalStateException(); + } + + @Override + public boolean equals(Object that) { + if (that == null) + return false; + if (that instanceof PrimaryKeysRequest) + return this.equals((PrimaryKeysRequest)that); + return false; + } + + public boolean equals(PrimaryKeysRequest that) { + if (that == null) + return false; + + boolean this_present_db_name = true && this.isSetDb_name(); + boolean that_present_db_name = true && that.isSetDb_name(); + if (this_present_db_name || that_present_db_name) { + if (!(this_present_db_name && that_present_db_name)) + return false; + if (!this.db_name.equals(that.db_name)) + return false; + } + + boolean this_present_tbl_name = true && this.isSetTbl_name(); + boolean that_present_tbl_name = true && that.isSetTbl_name(); + if (this_present_tbl_name || that_present_tbl_name) { + if (!(this_present_tbl_name && that_present_tbl_name)) + return false; + if (!this.tbl_name.equals(that.tbl_name)) + return false; + } + + return true; + } + + @Override + public int hashCode() { + List<Object> list = new ArrayList<Object>(); + + boolean present_db_name = true && (isSetDb_name()); + list.add(present_db_name); + if (present_db_name) + list.add(db_name); + + boolean present_tbl_name = true && (isSetTbl_name()); + list.add(present_tbl_name); + if (present_tbl_name) + list.add(tbl_name); + + return list.hashCode(); + } + + @Override + public int compareTo(PrimaryKeysRequest other) { + if (!getClass().equals(other.getClass())) { + return getClass().getName().compareTo(other.getClass().getName()); + } + + int lastComparison = 0; + + lastComparison = Boolean.valueOf(isSetDb_name()).compareTo(other.isSetDb_name()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetDb_name()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.db_name, other.db_name); + if (lastComparison != 0) { + return lastComparison; + } + } + lastComparison = Boolean.valueOf(isSetTbl_name()).compareTo(other.isSetTbl_name()); + if (lastComparison != 0) { + return lastComparison; + } + if (isSetTbl_name()) { + lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.tbl_name, other.tbl_name); + if (lastComparison != 0) { + return lastComparison; + } + } + return 0; + } + + public _Fields fieldForId(int fieldId) { + return _Fields.findByThriftId(fieldId); + } + + public void read(org.apache.thrift.protocol.TProtocol iprot) throws org.apache.thrift.TException { + schemes.get(iprot.getScheme()).getScheme().read(iprot, this); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot) throws org.apache.thrift.TException { + schemes.get(oprot.getScheme()).getScheme().write(oprot, this); + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("PrimaryKeysRequest("); + boolean first = true; + + sb.append("db_name:"); + if (this.db_name == null) { + sb.append("null"); + } else { + sb.append(this.db_name); + } + first = false; + if (!first) sb.append(", "); + sb.append("tbl_name:"); + if (this.tbl_name == null) { + sb.append("null"); + } else { + sb.append(this.tbl_name); + } + first = false; + sb.append(")"); + return sb.toString(); + } + + public void validate() throws org.apache.thrift.TException { + // check for required fields + if (!isSetDb_name()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'db_name' is unset! Struct:" + toString()); + } + + if (!isSetTbl_name()) { + throw new org.apache.thrift.protocol.TProtocolException("Required field 'tbl_name' is unset! Struct:" + toString()); + } + + // check for sub-struct validity + } + + private void writeObject(java.io.ObjectOutputStream out) throws java.io.IOException { + try { + write(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(out))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private void readObject(java.io.ObjectInputStream in) throws java.io.IOException, ClassNotFoundException { + try { + read(new org.apache.thrift.protocol.TCompactProtocol(new org.apache.thrift.transport.TIOStreamTransport(in))); + } catch (org.apache.thrift.TException te) { + throw new java.io.IOException(te); + } + } + + private static class PrimaryKeysRequestStandardSchemeFactory implements SchemeFactory { + public PrimaryKeysRequestStandardScheme getScheme() { + return new PrimaryKeysRequestStandardScheme(); + } + } + + private static class PrimaryKeysRequestStandardScheme extends StandardScheme<PrimaryKeysRequest> { + + public void read(org.apache.thrift.protocol.TProtocol iprot, PrimaryKeysRequest struct) throws org.apache.thrift.TException { + org.apache.thrift.protocol.TField schemeField; + iprot.readStructBegin(); + while (true) + { + schemeField = iprot.readFieldBegin(); + if (schemeField.type == org.apache.thrift.protocol.TType.STOP) { + break; + } + switch (schemeField.id) { + case 1: // DB_NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.db_name = iprot.readString(); + struct.setDb_nameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + case 2: // TBL_NAME + if (schemeField.type == org.apache.thrift.protocol.TType.STRING) { + struct.tbl_name = iprot.readString(); + struct.setTbl_nameIsSet(true); + } else { + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + break; + default: + org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type); + } + iprot.readFieldEnd(); + } + iprot.readStructEnd(); + struct.validate(); + } + + public void write(org.apache.thrift.protocol.TProtocol oprot, PrimaryKeysRequest struct) throws org.apache.thrift.TException { + struct.validate(); + + oprot.writeStructBegin(STRUCT_DESC); + if (struct.db_name != null) { + oprot.writeFieldBegin(DB_NAME_FIELD_DESC); + oprot.writeString(struct.db_name); + oprot.writeFieldEnd(); + } + if (struct.tbl_name != null) { + oprot.writeFieldBegin(TBL_NAME_FIELD_DESC); + oprot.writeString(struct.tbl_name); + oprot.writeFieldEnd(); + } + oprot.writeFieldStop(); + oprot.writeStructEnd(); + } + + } + + private static class PrimaryKeysRequestTupleSchemeFactory implements SchemeFactory { + public PrimaryKeysRequestTupleScheme getScheme() { + return new PrimaryKeysRequestTupleScheme(); + } + } + + private static class PrimaryKeysRequestTupleScheme extends TupleScheme<PrimaryKeysRequest> { + + @Override + public void write(org.apache.thrift.protocol.TProtocol prot, PrimaryKeysRequest struct) throws org.apache.thrift.TException { + TTupleProtocol oprot = (TTupleProtocol) prot; + oprot.writeString(struct.db_name); + oprot.writeString(struct.tbl_name); + } + + @Override + public void read(org.apache.thrift.protocol.TProtocol prot, PrimaryKeysRequest struct) throws org.apache.thrift.TException { + TTupleProtocol iprot = (TTupleProtocol) prot; + struct.db_name = iprot.readString(); + struct.setDb_nameIsSet(true); + struct.tbl_name = iprot.readString(); + struct.setTbl_nameIsSet(true); + } + } + +} +