You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by sa...@apache.org on 2018/04/02 04:32:57 UTC
[08/12] hive git commit: HIVE-18781: Create/Replicate Open,
Commit (without writes) and Abort Txn events (Mahesh Kumar Behera,
reviewed by Sankar Hariappan)
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
index 68256c7..58c608a 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsRequest.java
@@ -436,13 +436,13 @@ import org.slf4j.LoggerFactory;
case 1: // FULL_TABLE_NAMES
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list586 = iprot.readListBegin();
- struct.fullTableNames = new ArrayList<String>(_list586.size);
- String _elem587;
- for (int _i588 = 0; _i588 < _list586.size; ++_i588)
+ org.apache.thrift.protocol.TList _list594 = iprot.readListBegin();
+ struct.fullTableNames = new ArrayList<String>(_list594.size);
+ String _elem595;
+ for (int _i596 = 0; _i596 < _list594.size; ++_i596)
{
- _elem587 = iprot.readString();
- struct.fullTableNames.add(_elem587);
+ _elem595 = iprot.readString();
+ struct.fullTableNames.add(_elem595);
}
iprot.readListEnd();
}
@@ -476,9 +476,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FULL_TABLE_NAMES_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.fullTableNames.size()));
- for (String _iter589 : struct.fullTableNames)
+ for (String _iter597 : struct.fullTableNames)
{
- oprot.writeString(_iter589);
+ oprot.writeString(_iter597);
}
oprot.writeListEnd();
}
@@ -508,9 +508,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fullTableNames.size());
- for (String _iter590 : struct.fullTableNames)
+ for (String _iter598 : struct.fullTableNames)
{
- oprot.writeString(_iter590);
+ oprot.writeString(_iter598);
}
}
oprot.writeString(struct.validTxnList);
@@ -520,13 +520,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, GetValidWriteIdsRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list591 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.fullTableNames = new ArrayList<String>(_list591.size);
- String _elem592;
- for (int _i593 = 0; _i593 < _list591.size; ++_i593)
+ org.apache.thrift.protocol.TList _list599 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.fullTableNames = new ArrayList<String>(_list599.size);
+ String _elem600;
+ for (int _i601 = 0; _i601 < _list599.size; ++_i601)
{
- _elem592 = iprot.readString();
- struct.fullTableNames.add(_elem592);
+ _elem600 = iprot.readString();
+ struct.fullTableNames.add(_elem600);
}
}
struct.setFullTableNamesIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
index 5512fb4..86bc346 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/GetValidWriteIdsResponse.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // TBL_VALID_WRITE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list602 = iprot.readListBegin();
- struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list602.size);
- TableValidWriteIds _elem603;
- for (int _i604 = 0; _i604 < _list602.size; ++_i604)
+ org.apache.thrift.protocol.TList _list610 = iprot.readListBegin();
+ struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list610.size);
+ TableValidWriteIds _elem611;
+ for (int _i612 = 0; _i612 < _list610.size; ++_i612)
{
- _elem603 = new TableValidWriteIds();
- _elem603.read(iprot);
- struct.tblValidWriteIds.add(_elem603);
+ _elem611 = new TableValidWriteIds();
+ _elem611.read(iprot);
+ struct.tblValidWriteIds.add(_elem611);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TBL_VALID_WRITE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.tblValidWriteIds.size()));
- for (TableValidWriteIds _iter605 : struct.tblValidWriteIds)
+ for (TableValidWriteIds _iter613 : struct.tblValidWriteIds)
{
- _iter605.write(oprot);
+ _iter613.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.tblValidWriteIds.size());
- for (TableValidWriteIds _iter606 : struct.tblValidWriteIds)
+ for (TableValidWriteIds _iter614 : struct.tblValidWriteIds)
{
- _iter606.write(oprot);
+ _iter614.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, GetValidWriteIdsResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list607 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list607.size);
- TableValidWriteIds _elem608;
- for (int _i609 = 0; _i609 < _list607.size; ++_i609)
+ org.apache.thrift.protocol.TList _list615 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.tblValidWriteIds = new ArrayList<TableValidWriteIds>(_list615.size);
+ TableValidWriteIds _elem616;
+ for (int _i617 = 0; _i617 < _list615.size; ++_i617)
{
- _elem608 = new TableValidWriteIds();
- _elem608.read(iprot);
- struct.tblValidWriteIds.add(_elem608);
+ _elem616 = new TableValidWriteIds();
+ _elem616.read(iprot);
+ struct.tblValidWriteIds.add(_elem616);
}
}
struct.setTblValidWriteIdsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
index c5bc23e..b270439 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/HeartbeatTxnRangeResponse.java
@@ -453,13 +453,13 @@ import org.slf4j.LoggerFactory;
case 1: // ABORTED
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set642 = iprot.readSetBegin();
- struct.aborted = new HashSet<Long>(2*_set642.size);
- long _elem643;
- for (int _i644 = 0; _i644 < _set642.size; ++_i644)
+ org.apache.thrift.protocol.TSet _set650 = iprot.readSetBegin();
+ struct.aborted = new HashSet<Long>(2*_set650.size);
+ long _elem651;
+ for (int _i652 = 0; _i652 < _set650.size; ++_i652)
{
- _elem643 = iprot.readI64();
- struct.aborted.add(_elem643);
+ _elem651 = iprot.readI64();
+ struct.aborted.add(_elem651);
}
iprot.readSetEnd();
}
@@ -471,13 +471,13 @@ import org.slf4j.LoggerFactory;
case 2: // NOSUCH
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set645 = iprot.readSetBegin();
- struct.nosuch = new HashSet<Long>(2*_set645.size);
- long _elem646;
- for (int _i647 = 0; _i647 < _set645.size; ++_i647)
+ org.apache.thrift.protocol.TSet _set653 = iprot.readSetBegin();
+ struct.nosuch = new HashSet<Long>(2*_set653.size);
+ long _elem654;
+ for (int _i655 = 0; _i655 < _set653.size; ++_i655)
{
- _elem646 = iprot.readI64();
- struct.nosuch.add(_elem646);
+ _elem654 = iprot.readI64();
+ struct.nosuch.add(_elem654);
}
iprot.readSetEnd();
}
@@ -503,9 +503,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(ABORTED_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.aborted.size()));
- for (long _iter648 : struct.aborted)
+ for (long _iter656 : struct.aborted)
{
- oprot.writeI64(_iter648);
+ oprot.writeI64(_iter656);
}
oprot.writeSetEnd();
}
@@ -515,9 +515,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(NOSUCH_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, struct.nosuch.size()));
- for (long _iter649 : struct.nosuch)
+ for (long _iter657 : struct.nosuch)
{
- oprot.writeI64(_iter649);
+ oprot.writeI64(_iter657);
}
oprot.writeSetEnd();
}
@@ -542,16 +542,16 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.aborted.size());
- for (long _iter650 : struct.aborted)
+ for (long _iter658 : struct.aborted)
{
- oprot.writeI64(_iter650);
+ oprot.writeI64(_iter658);
}
}
{
oprot.writeI32(struct.nosuch.size());
- for (long _iter651 : struct.nosuch)
+ for (long _iter659 : struct.nosuch)
{
- oprot.writeI64(_iter651);
+ oprot.writeI64(_iter659);
}
}
}
@@ -560,24 +560,24 @@ import org.slf4j.LoggerFactory;
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 _set652 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.aborted = new HashSet<Long>(2*_set652.size);
- long _elem653;
- for (int _i654 = 0; _i654 < _set652.size; ++_i654)
+ org.apache.thrift.protocol.TSet _set660 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.aborted = new HashSet<Long>(2*_set660.size);
+ long _elem661;
+ for (int _i662 = 0; _i662 < _set660.size; ++_i662)
{
- _elem653 = iprot.readI64();
- struct.aborted.add(_elem653);
+ _elem661 = iprot.readI64();
+ struct.aborted.add(_elem661);
}
}
struct.setAbortedIsSet(true);
{
- org.apache.thrift.protocol.TSet _set655 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.nosuch = new HashSet<Long>(2*_set655.size);
- long _elem656;
- for (int _i657 = 0; _i657 < _set655.size; ++_i657)
+ org.apache.thrift.protocol.TSet _set663 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.nosuch = new HashSet<Long>(2*_set663.size);
+ long _elem664;
+ for (int _i665 = 0; _i665 < _set663.size; ++_i665)
{
- _elem656 = iprot.readI64();
- struct.nosuch.add(_elem656);
+ _elem664 = iprot.readI64();
+ struct.nosuch.add(_elem664);
}
}
struct.setNosuchIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
index 8a33611..79570a5 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/InsertEventRequestData.java
@@ -538,13 +538,13 @@ import org.slf4j.LoggerFactory;
case 2: // FILES_ADDED
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list700 = iprot.readListBegin();
- struct.filesAdded = new ArrayList<String>(_list700.size);
- String _elem701;
- for (int _i702 = 0; _i702 < _list700.size; ++_i702)
+ org.apache.thrift.protocol.TList _list708 = iprot.readListBegin();
+ struct.filesAdded = new ArrayList<String>(_list708.size);
+ String _elem709;
+ for (int _i710 = 0; _i710 < _list708.size; ++_i710)
{
- _elem701 = iprot.readString();
- struct.filesAdded.add(_elem701);
+ _elem709 = iprot.readString();
+ struct.filesAdded.add(_elem709);
}
iprot.readListEnd();
}
@@ -556,13 +556,13 @@ import org.slf4j.LoggerFactory;
case 3: // FILES_ADDED_CHECKSUM
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list703 = iprot.readListBegin();
- struct.filesAddedChecksum = new ArrayList<String>(_list703.size);
- String _elem704;
- for (int _i705 = 0; _i705 < _list703.size; ++_i705)
+ org.apache.thrift.protocol.TList _list711 = iprot.readListBegin();
+ struct.filesAddedChecksum = new ArrayList<String>(_list711.size);
+ String _elem712;
+ for (int _i713 = 0; _i713 < _list711.size; ++_i713)
{
- _elem704 = iprot.readString();
- struct.filesAddedChecksum.add(_elem704);
+ _elem712 = iprot.readString();
+ struct.filesAddedChecksum.add(_elem712);
}
iprot.readListEnd();
}
@@ -593,9 +593,9 @@ import org.slf4j.LoggerFactory;
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 _iter706 : struct.filesAdded)
+ for (String _iter714 : struct.filesAdded)
{
- oprot.writeString(_iter706);
+ oprot.writeString(_iter714);
}
oprot.writeListEnd();
}
@@ -606,9 +606,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(FILES_ADDED_CHECKSUM_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.filesAddedChecksum.size()));
- for (String _iter707 : struct.filesAddedChecksum)
+ for (String _iter715 : struct.filesAddedChecksum)
{
- oprot.writeString(_iter707);
+ oprot.writeString(_iter715);
}
oprot.writeListEnd();
}
@@ -634,9 +634,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.filesAdded.size());
- for (String _iter708 : struct.filesAdded)
+ for (String _iter716 : struct.filesAdded)
{
- oprot.writeString(_iter708);
+ oprot.writeString(_iter716);
}
}
BitSet optionals = new BitSet();
@@ -653,9 +653,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetFilesAddedChecksum()) {
{
oprot.writeI32(struct.filesAddedChecksum.size());
- for (String _iter709 : struct.filesAddedChecksum)
+ for (String _iter717 : struct.filesAddedChecksum)
{
- oprot.writeString(_iter709);
+ oprot.writeString(_iter717);
}
}
}
@@ -665,13 +665,13 @@ import org.slf4j.LoggerFactory;
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 _list710 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.filesAdded = new ArrayList<String>(_list710.size);
- String _elem711;
- for (int _i712 = 0; _i712 < _list710.size; ++_i712)
+ org.apache.thrift.protocol.TList _list718 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filesAdded = new ArrayList<String>(_list718.size);
+ String _elem719;
+ for (int _i720 = 0; _i720 < _list718.size; ++_i720)
{
- _elem711 = iprot.readString();
- struct.filesAdded.add(_elem711);
+ _elem719 = iprot.readString();
+ struct.filesAdded.add(_elem719);
}
}
struct.setFilesAddedIsSet(true);
@@ -682,13 +682,13 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(1)) {
{
- org.apache.thrift.protocol.TList _list713 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.filesAddedChecksum = new ArrayList<String>(_list713.size);
- String _elem714;
- for (int _i715 = 0; _i715 < _list713.size; ++_i715)
+ org.apache.thrift.protocol.TList _list721 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.filesAddedChecksum = new ArrayList<String>(_list721.size);
+ String _elem722;
+ for (int _i723 = 0; _i723 < _list721.size; ++_i723)
{
- _elem714 = iprot.readString();
- struct.filesAddedChecksum.add(_elem714);
+ _elem722 = iprot.readString();
+ struct.filesAddedChecksum.add(_elem722);
}
}
struct.setFilesAddedChecksumIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
index 6f03ea9..62f0dd6 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/LockRequest.java
@@ -689,14 +689,14 @@ import org.slf4j.LoggerFactory;
case 1: // COMPONENT
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list626 = iprot.readListBegin();
- struct.component = new ArrayList<LockComponent>(_list626.size);
- LockComponent _elem627;
- for (int _i628 = 0; _i628 < _list626.size; ++_i628)
+ org.apache.thrift.protocol.TList _list634 = iprot.readListBegin();
+ struct.component = new ArrayList<LockComponent>(_list634.size);
+ LockComponent _elem635;
+ for (int _i636 = 0; _i636 < _list634.size; ++_i636)
{
- _elem627 = new LockComponent();
- _elem627.read(iprot);
- struct.component.add(_elem627);
+ _elem635 = new LockComponent();
+ _elem635.read(iprot);
+ struct.component.add(_elem635);
}
iprot.readListEnd();
}
@@ -754,9 +754,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(COMPONENT_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.component.size()));
- for (LockComponent _iter629 : struct.component)
+ for (LockComponent _iter637 : struct.component)
{
- _iter629.write(oprot);
+ _iter637.write(oprot);
}
oprot.writeListEnd();
}
@@ -803,9 +803,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.component.size());
- for (LockComponent _iter630 : struct.component)
+ for (LockComponent _iter638 : struct.component)
{
- _iter630.write(oprot);
+ _iter638.write(oprot);
}
}
oprot.writeString(struct.user);
@@ -830,14 +830,14 @@ import org.slf4j.LoggerFactory;
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 _list631 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.component = new ArrayList<LockComponent>(_list631.size);
- LockComponent _elem632;
- for (int _i633 = 0; _i633 < _list631.size; ++_i633)
+ org.apache.thrift.protocol.TList _list639 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.component = new ArrayList<LockComponent>(_list639.size);
+ LockComponent _elem640;
+ for (int _i641 = 0; _i641 < _list639.size; ++_i641)
{
- _elem632 = new LockComponent();
- _elem632.read(iprot);
- struct.component.add(_elem632);
+ _elem640 = new LockComponent();
+ _elem640.read(iprot);
+ struct.component.add(_elem640);
}
}
struct.setComponentIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Materialization.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Materialization.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Materialization.java
index faee4be..6960728 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Materialization.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/Materialization.java
@@ -518,13 +518,13 @@ import org.slf4j.LoggerFactory;
case 1: // TABLES_USED
if (schemeField.type == org.apache.thrift.protocol.TType.SET) {
{
- org.apache.thrift.protocol.TSet _set816 = iprot.readSetBegin();
- struct.tablesUsed = new HashSet<String>(2*_set816.size);
- String _elem817;
- for (int _i818 = 0; _i818 < _set816.size; ++_i818)
+ org.apache.thrift.protocol.TSet _set824 = iprot.readSetBegin();
+ struct.tablesUsed = new HashSet<String>(2*_set824.size);
+ String _elem825;
+ for (int _i826 = 0; _i826 < _set824.size; ++_i826)
{
- _elem817 = iprot.readString();
- struct.tablesUsed.add(_elem817);
+ _elem825 = iprot.readString();
+ struct.tablesUsed.add(_elem825);
}
iprot.readSetEnd();
}
@@ -566,9 +566,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(TABLES_USED_FIELD_DESC);
{
oprot.writeSetBegin(new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, struct.tablesUsed.size()));
- for (String _iter819 : struct.tablesUsed)
+ for (String _iter827 : struct.tablesUsed)
{
- oprot.writeString(_iter819);
+ oprot.writeString(_iter827);
}
oprot.writeSetEnd();
}
@@ -603,9 +603,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.tablesUsed.size());
- for (String _iter820 : struct.tablesUsed)
+ for (String _iter828 : struct.tablesUsed)
{
- oprot.writeString(_iter820);
+ oprot.writeString(_iter828);
}
}
oprot.writeI64(struct.invalidationTime);
@@ -623,13 +623,13 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, Materialization struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TSet _set821 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.tablesUsed = new HashSet<String>(2*_set821.size);
- String _elem822;
- for (int _i823 = 0; _i823 < _set821.size; ++_i823)
+ org.apache.thrift.protocol.TSet _set829 = new org.apache.thrift.protocol.TSet(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.tablesUsed = new HashSet<String>(2*_set829.size);
+ String _elem830;
+ for (int _i831 = 0; _i831 < _set829.size; ++_i831)
{
- _elem822 = iprot.readString();
- struct.tablesUsed.add(_elem822);
+ _elem830 = iprot.readString();
+ struct.tablesUsed.add(_elem830);
}
}
struct.setTablesUsedIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
index 5045bda..3c35a0e 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/NotificationEventResponse.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // EVENTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list692 = iprot.readListBegin();
- struct.events = new ArrayList<NotificationEvent>(_list692.size);
- NotificationEvent _elem693;
- for (int _i694 = 0; _i694 < _list692.size; ++_i694)
+ org.apache.thrift.protocol.TList _list700 = iprot.readListBegin();
+ struct.events = new ArrayList<NotificationEvent>(_list700.size);
+ NotificationEvent _elem701;
+ for (int _i702 = 0; _i702 < _list700.size; ++_i702)
{
- _elem693 = new NotificationEvent();
- _elem693.read(iprot);
- struct.events.add(_elem693);
+ _elem701 = new NotificationEvent();
+ _elem701.read(iprot);
+ struct.events.add(_elem701);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(EVENTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.events.size()));
- for (NotificationEvent _iter695 : struct.events)
+ for (NotificationEvent _iter703 : struct.events)
{
- _iter695.write(oprot);
+ _iter703.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.events.size());
- for (NotificationEvent _iter696 : struct.events)
+ for (NotificationEvent _iter704 : struct.events)
{
- _iter696.write(oprot);
+ _iter704.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
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 _list697 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.events = new ArrayList<NotificationEvent>(_list697.size);
- NotificationEvent _elem698;
- for (int _i699 = 0; _i699 < _list697.size; ++_i699)
+ org.apache.thrift.protocol.TList _list705 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.events = new ArrayList<NotificationEvent>(_list705.size);
+ NotificationEvent _elem706;
+ for (int _i707 = 0; _i707 < _list705.size; ++_i707)
{
- _elem698 = new NotificationEvent();
- _elem698.read(iprot);
- struct.events.add(_elem698);
+ _elem706 = new NotificationEvent();
+ _elem706.read(iprot);
+ struct.events.add(_elem706);
}
}
struct.setEventsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java
index 4dd235a..2dae2e9 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnRequest.java
@@ -42,6 +42,8 @@ import org.slf4j.LoggerFactory;
private static final org.apache.thrift.protocol.TField USER_FIELD_DESC = new org.apache.thrift.protocol.TField("user", org.apache.thrift.protocol.TType.STRING, (short)2);
private static final org.apache.thrift.protocol.TField HOSTNAME_FIELD_DESC = new org.apache.thrift.protocol.TField("hostname", org.apache.thrift.protocol.TType.STRING, (short)3);
private static final org.apache.thrift.protocol.TField AGENT_INFO_FIELD_DESC = new org.apache.thrift.protocol.TField("agentInfo", org.apache.thrift.protocol.TType.STRING, (short)4);
+ private static final org.apache.thrift.protocol.TField REPL_POLICY_FIELD_DESC = new org.apache.thrift.protocol.TField("replPolicy", org.apache.thrift.protocol.TType.STRING, (short)5);
+ private static final org.apache.thrift.protocol.TField REPL_SRC_TXN_IDS_FIELD_DESC = new org.apache.thrift.protocol.TField("replSrcTxnIds", org.apache.thrift.protocol.TType.LIST, (short)6);
private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
static {
@@ -53,13 +55,17 @@ import org.slf4j.LoggerFactory;
private String user; // required
private String hostname; // required
private String agentInfo; // optional
+ private String replPolicy; // optional
+ private List<Long> replSrcTxnIds; // optional
/** The set of fields this struct contains, along with convenience methods for finding and manipulating them. */
public enum _Fields implements org.apache.thrift.TFieldIdEnum {
NUM_TXNS((short)1, "num_txns"),
USER((short)2, "user"),
HOSTNAME((short)3, "hostname"),
- AGENT_INFO((short)4, "agentInfo");
+ AGENT_INFO((short)4, "agentInfo"),
+ REPL_POLICY((short)5, "replPolicy"),
+ REPL_SRC_TXN_IDS((short)6, "replSrcTxnIds");
private static final Map<String, _Fields> byName = new HashMap<String, _Fields>();
@@ -82,6 +88,10 @@ import org.slf4j.LoggerFactory;
return HOSTNAME;
case 4: // AGENT_INFO
return AGENT_INFO;
+ case 5: // REPL_POLICY
+ return REPL_POLICY;
+ case 6: // REPL_SRC_TXN_IDS
+ return REPL_SRC_TXN_IDS;
default:
return null;
}
@@ -124,7 +134,7 @@ import org.slf4j.LoggerFactory;
// isset id assignments
private static final int __NUM_TXNS_ISSET_ID = 0;
private byte __isset_bitfield = 0;
- private static final _Fields optionals[] = {_Fields.AGENT_INFO};
+ private static final _Fields optionals[] = {_Fields.AGENT_INFO,_Fields.REPL_POLICY,_Fields.REPL_SRC_TXN_IDS};
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);
@@ -136,6 +146,11 @@ import org.slf4j.LoggerFactory;
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
tmpMap.put(_Fields.AGENT_INFO, new org.apache.thrift.meta_data.FieldMetaData("agentInfo", org.apache.thrift.TFieldRequirementType.OPTIONAL,
new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.REPL_POLICY, new org.apache.thrift.meta_data.FieldMetaData("replPolicy", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
+ tmpMap.put(_Fields.REPL_SRC_TXN_IDS, new org.apache.thrift.meta_data.FieldMetaData("replSrcTxnIds", org.apache.thrift.TFieldRequirementType.OPTIONAL,
+ new org.apache.thrift.meta_data.ListMetaData(org.apache.thrift.protocol.TType.LIST,
+ new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64))));
metaDataMap = Collections.unmodifiableMap(tmpMap);
org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(OpenTxnRequest.class, metaDataMap);
}
@@ -172,6 +187,13 @@ import org.slf4j.LoggerFactory;
if (other.isSetAgentInfo()) {
this.agentInfo = other.agentInfo;
}
+ if (other.isSetReplPolicy()) {
+ this.replPolicy = other.replPolicy;
+ }
+ if (other.isSetReplSrcTxnIds()) {
+ List<Long> __this__replSrcTxnIds = new ArrayList<Long>(other.replSrcTxnIds);
+ this.replSrcTxnIds = __this__replSrcTxnIds;
+ }
}
public OpenTxnRequest deepCopy() {
@@ -186,6 +208,8 @@ import org.slf4j.LoggerFactory;
this.hostname = null;
this.agentInfo = "Unknown";
+ this.replPolicy = null;
+ this.replSrcTxnIds = null;
}
public int getNum_txns() {
@@ -279,6 +303,67 @@ import org.slf4j.LoggerFactory;
}
}
+ public String getReplPolicy() {
+ return this.replPolicy;
+ }
+
+ public void setReplPolicy(String replPolicy) {
+ this.replPolicy = replPolicy;
+ }
+
+ public void unsetReplPolicy() {
+ this.replPolicy = null;
+ }
+
+ /** Returns true if field replPolicy is set (has been assigned a value) and false otherwise */
+ public boolean isSetReplPolicy() {
+ return this.replPolicy != null;
+ }
+
+ public void setReplPolicyIsSet(boolean value) {
+ if (!value) {
+ this.replPolicy = null;
+ }
+ }
+
+ public int getReplSrcTxnIdsSize() {
+ return (this.replSrcTxnIds == null) ? 0 : this.replSrcTxnIds.size();
+ }
+
+ public java.util.Iterator<Long> getReplSrcTxnIdsIterator() {
+ return (this.replSrcTxnIds == null) ? null : this.replSrcTxnIds.iterator();
+ }
+
+ public void addToReplSrcTxnIds(long elem) {
+ if (this.replSrcTxnIds == null) {
+ this.replSrcTxnIds = new ArrayList<Long>();
+ }
+ this.replSrcTxnIds.add(elem);
+ }
+
+ public List<Long> getReplSrcTxnIds() {
+ return this.replSrcTxnIds;
+ }
+
+ public void setReplSrcTxnIds(List<Long> replSrcTxnIds) {
+ this.replSrcTxnIds = replSrcTxnIds;
+ }
+
+ public void unsetReplSrcTxnIds() {
+ this.replSrcTxnIds = null;
+ }
+
+ /** Returns true if field replSrcTxnIds is set (has been assigned a value) and false otherwise */
+ public boolean isSetReplSrcTxnIds() {
+ return this.replSrcTxnIds != null;
+ }
+
+ public void setReplSrcTxnIdsIsSet(boolean value) {
+ if (!value) {
+ this.replSrcTxnIds = null;
+ }
+ }
+
public void setFieldValue(_Fields field, Object value) {
switch (field) {
case NUM_TXNS:
@@ -313,6 +398,22 @@ import org.slf4j.LoggerFactory;
}
break;
+ case REPL_POLICY:
+ if (value == null) {
+ unsetReplPolicy();
+ } else {
+ setReplPolicy((String)value);
+ }
+ break;
+
+ case REPL_SRC_TXN_IDS:
+ if (value == null) {
+ unsetReplSrcTxnIds();
+ } else {
+ setReplSrcTxnIds((List<Long>)value);
+ }
+ break;
+
}
}
@@ -330,6 +431,12 @@ import org.slf4j.LoggerFactory;
case AGENT_INFO:
return getAgentInfo();
+ case REPL_POLICY:
+ return getReplPolicy();
+
+ case REPL_SRC_TXN_IDS:
+ return getReplSrcTxnIds();
+
}
throw new IllegalStateException();
}
@@ -349,6 +456,10 @@ import org.slf4j.LoggerFactory;
return isSetHostname();
case AGENT_INFO:
return isSetAgentInfo();
+ case REPL_POLICY:
+ return isSetReplPolicy();
+ case REPL_SRC_TXN_IDS:
+ return isSetReplSrcTxnIds();
}
throw new IllegalStateException();
}
@@ -402,6 +513,24 @@ import org.slf4j.LoggerFactory;
return false;
}
+ boolean this_present_replPolicy = true && this.isSetReplPolicy();
+ boolean that_present_replPolicy = true && that.isSetReplPolicy();
+ if (this_present_replPolicy || that_present_replPolicy) {
+ if (!(this_present_replPolicy && that_present_replPolicy))
+ return false;
+ if (!this.replPolicy.equals(that.replPolicy))
+ return false;
+ }
+
+ boolean this_present_replSrcTxnIds = true && this.isSetReplSrcTxnIds();
+ boolean that_present_replSrcTxnIds = true && that.isSetReplSrcTxnIds();
+ if (this_present_replSrcTxnIds || that_present_replSrcTxnIds) {
+ if (!(this_present_replSrcTxnIds && that_present_replSrcTxnIds))
+ return false;
+ if (!this.replSrcTxnIds.equals(that.replSrcTxnIds))
+ return false;
+ }
+
return true;
}
@@ -429,6 +558,16 @@ import org.slf4j.LoggerFactory;
if (present_agentInfo)
list.add(agentInfo);
+ boolean present_replPolicy = true && (isSetReplPolicy());
+ list.add(present_replPolicy);
+ if (present_replPolicy)
+ list.add(replPolicy);
+
+ boolean present_replSrcTxnIds = true && (isSetReplSrcTxnIds());
+ list.add(present_replSrcTxnIds);
+ if (present_replSrcTxnIds)
+ list.add(replSrcTxnIds);
+
return list.hashCode();
}
@@ -480,6 +619,26 @@ import org.slf4j.LoggerFactory;
return lastComparison;
}
}
+ lastComparison = Boolean.valueOf(isSetReplPolicy()).compareTo(other.isSetReplPolicy());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetReplPolicy()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.replPolicy, other.replPolicy);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
+ lastComparison = Boolean.valueOf(isSetReplSrcTxnIds()).compareTo(other.isSetReplSrcTxnIds());
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ if (isSetReplSrcTxnIds()) {
+ lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.replSrcTxnIds, other.replSrcTxnIds);
+ if (lastComparison != 0) {
+ return lastComparison;
+ }
+ }
return 0;
}
@@ -529,6 +688,26 @@ import org.slf4j.LoggerFactory;
}
first = false;
}
+ if (isSetReplPolicy()) {
+ if (!first) sb.append(", ");
+ sb.append("replPolicy:");
+ if (this.replPolicy == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.replPolicy);
+ }
+ first = false;
+ }
+ if (isSetReplSrcTxnIds()) {
+ if (!first) sb.append(", ");
+ sb.append("replSrcTxnIds:");
+ if (this.replSrcTxnIds == null) {
+ sb.append("null");
+ } else {
+ sb.append(this.replSrcTxnIds);
+ }
+ first = false;
+ }
sb.append(")");
return sb.toString();
}
@@ -618,6 +797,32 @@ import org.slf4j.LoggerFactory;
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
break;
+ case 5: // REPL_POLICY
+ if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
+ struct.replPolicy = iprot.readString();
+ struct.setReplPolicyIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
+ case 6: // REPL_SRC_TXN_IDS
+ if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
+ {
+ org.apache.thrift.protocol.TList _list570 = iprot.readListBegin();
+ struct.replSrcTxnIds = new ArrayList<Long>(_list570.size);
+ long _elem571;
+ for (int _i572 = 0; _i572 < _list570.size; ++_i572)
+ {
+ _elem571 = iprot.readI64();
+ struct.replSrcTxnIds.add(_elem571);
+ }
+ iprot.readListEnd();
+ }
+ struct.setReplSrcTxnIdsIsSet(true);
+ } else {
+ org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
+ }
+ break;
default:
org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
}
@@ -651,6 +856,27 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldEnd();
}
}
+ if (struct.replPolicy != null) {
+ if (struct.isSetReplPolicy()) {
+ oprot.writeFieldBegin(REPL_POLICY_FIELD_DESC);
+ oprot.writeString(struct.replPolicy);
+ oprot.writeFieldEnd();
+ }
+ }
+ if (struct.replSrcTxnIds != null) {
+ if (struct.isSetReplSrcTxnIds()) {
+ oprot.writeFieldBegin(REPL_SRC_TXN_IDS_FIELD_DESC);
+ {
+ oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.replSrcTxnIds.size()));
+ for (long _iter573 : struct.replSrcTxnIds)
+ {
+ oprot.writeI64(_iter573);
+ }
+ oprot.writeListEnd();
+ }
+ oprot.writeFieldEnd();
+ }
+ }
oprot.writeFieldStop();
oprot.writeStructEnd();
}
@@ -675,10 +901,28 @@ import org.slf4j.LoggerFactory;
if (struct.isSetAgentInfo()) {
optionals.set(0);
}
- oprot.writeBitSet(optionals, 1);
+ if (struct.isSetReplPolicy()) {
+ optionals.set(1);
+ }
+ if (struct.isSetReplSrcTxnIds()) {
+ optionals.set(2);
+ }
+ oprot.writeBitSet(optionals, 3);
if (struct.isSetAgentInfo()) {
oprot.writeString(struct.agentInfo);
}
+ if (struct.isSetReplPolicy()) {
+ oprot.writeString(struct.replPolicy);
+ }
+ if (struct.isSetReplSrcTxnIds()) {
+ {
+ oprot.writeI32(struct.replSrcTxnIds.size());
+ for (long _iter574 : struct.replSrcTxnIds)
+ {
+ oprot.writeI64(_iter574);
+ }
+ }
+ }
}
@Override
@@ -690,11 +934,28 @@ import org.slf4j.LoggerFactory;
struct.setUserIsSet(true);
struct.hostname = iprot.readString();
struct.setHostnameIsSet(true);
- BitSet incoming = iprot.readBitSet(1);
+ BitSet incoming = iprot.readBitSet(3);
if (incoming.get(0)) {
struct.agentInfo = iprot.readString();
struct.setAgentInfoIsSet(true);
}
+ if (incoming.get(1)) {
+ struct.replPolicy = iprot.readString();
+ struct.setReplPolicyIsSet(true);
+ }
+ if (incoming.get(2)) {
+ {
+ org.apache.thrift.protocol.TList _list575 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.replSrcTxnIds = new ArrayList<Long>(_list575.size);
+ long _elem576;
+ for (int _i577 = 0; _i577 < _list575.size; ++_i577)
+ {
+ _elem576 = iprot.readI64();
+ struct.replSrcTxnIds.add(_elem576);
+ }
+ }
+ struct.setReplSrcTxnIdsIsSet(true);
+ }
}
}
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java
index 7adac3a..9e38d6c 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/OpenTxnsResponse.java
@@ -351,13 +351,13 @@ import org.slf4j.LoggerFactory;
case 1: // TXN_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list570 = iprot.readListBegin();
- struct.txn_ids = new ArrayList<Long>(_list570.size);
- long _elem571;
- for (int _i572 = 0; _i572 < _list570.size; ++_i572)
+ org.apache.thrift.protocol.TList _list578 = iprot.readListBegin();
+ struct.txn_ids = new ArrayList<Long>(_list578.size);
+ long _elem579;
+ for (int _i580 = 0; _i580 < _list578.size; ++_i580)
{
- _elem571 = iprot.readI64();
- struct.txn_ids.add(_elem571);
+ _elem579 = iprot.readI64();
+ struct.txn_ids.add(_elem579);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory;
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 _iter573 : struct.txn_ids)
+ for (long _iter581 : struct.txn_ids)
{
- oprot.writeI64(_iter573);
+ oprot.writeI64(_iter581);
}
oprot.writeListEnd();
}
@@ -410,9 +410,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.txn_ids.size());
- for (long _iter574 : struct.txn_ids)
+ for (long _iter582 : struct.txn_ids)
{
- oprot.writeI64(_iter574);
+ oprot.writeI64(_iter582);
}
}
}
@@ -421,13 +421,13 @@ import org.slf4j.LoggerFactory;
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 _list575 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.txn_ids = new ArrayList<Long>(_list575.size);
- long _elem576;
- for (int _i577 = 0; _i577 < _list575.size; ++_i577)
+ org.apache.thrift.protocol.TList _list583 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.txn_ids = new ArrayList<Long>(_list583.size);
+ long _elem584;
+ for (int _i585 = 0; _i585 < _list583.size; ++_i585)
{
- _elem576 = iprot.readI64();
- struct.txn_ids.add(_elem576);
+ _elem584 = iprot.readI64();
+ struct.txn_ids.add(_elem584);
}
}
struct.setTxn_idsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
index e8cba59..474555f 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/PutFileMetadataRequest.java
@@ -547,13 +547,13 @@ import org.slf4j.LoggerFactory;
case 1: // FILE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list760 = iprot.readListBegin();
- struct.fileIds = new ArrayList<Long>(_list760.size);
- long _elem761;
- for (int _i762 = 0; _i762 < _list760.size; ++_i762)
+ org.apache.thrift.protocol.TList _list768 = iprot.readListBegin();
+ struct.fileIds = new ArrayList<Long>(_list768.size);
+ long _elem769;
+ for (int _i770 = 0; _i770 < _list768.size; ++_i770)
{
- _elem761 = iprot.readI64();
- struct.fileIds.add(_elem761);
+ _elem769 = iprot.readI64();
+ struct.fileIds.add(_elem769);
}
iprot.readListEnd();
}
@@ -565,13 +565,13 @@ import org.slf4j.LoggerFactory;
case 2: // METADATA
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list763 = iprot.readListBegin();
- struct.metadata = new ArrayList<ByteBuffer>(_list763.size);
- ByteBuffer _elem764;
- for (int _i765 = 0; _i765 < _list763.size; ++_i765)
+ org.apache.thrift.protocol.TList _list771 = iprot.readListBegin();
+ struct.metadata = new ArrayList<ByteBuffer>(_list771.size);
+ ByteBuffer _elem772;
+ for (int _i773 = 0; _i773 < _list771.size; ++_i773)
{
- _elem764 = iprot.readBinary();
- struct.metadata.add(_elem764);
+ _elem772 = iprot.readBinary();
+ struct.metadata.add(_elem772);
}
iprot.readListEnd();
}
@@ -605,9 +605,9 @@ import org.slf4j.LoggerFactory;
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 _iter766 : struct.fileIds)
+ for (long _iter774 : struct.fileIds)
{
- oprot.writeI64(_iter766);
+ oprot.writeI64(_iter774);
}
oprot.writeListEnd();
}
@@ -617,9 +617,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(METADATA_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, struct.metadata.size()));
- for (ByteBuffer _iter767 : struct.metadata)
+ for (ByteBuffer _iter775 : struct.metadata)
{
- oprot.writeBinary(_iter767);
+ oprot.writeBinary(_iter775);
}
oprot.writeListEnd();
}
@@ -651,16 +651,16 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.fileIds.size());
- for (long _iter768 : struct.fileIds)
+ for (long _iter776 : struct.fileIds)
{
- oprot.writeI64(_iter768);
+ oprot.writeI64(_iter776);
}
}
{
oprot.writeI32(struct.metadata.size());
- for (ByteBuffer _iter769 : struct.metadata)
+ for (ByteBuffer _iter777 : struct.metadata)
{
- oprot.writeBinary(_iter769);
+ oprot.writeBinary(_iter777);
}
}
BitSet optionals = new BitSet();
@@ -677,24 +677,24 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, PutFileMetadataRequest struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list770 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.fileIds = new ArrayList<Long>(_list770.size);
- long _elem771;
- for (int _i772 = 0; _i772 < _list770.size; ++_i772)
+ org.apache.thrift.protocol.TList _list778 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.fileIds = new ArrayList<Long>(_list778.size);
+ long _elem779;
+ for (int _i780 = 0; _i780 < _list778.size; ++_i780)
{
- _elem771 = iprot.readI64();
- struct.fileIds.add(_elem771);
+ _elem779 = iprot.readI64();
+ struct.fileIds.add(_elem779);
}
}
struct.setFileIdsIsSet(true);
{
- org.apache.thrift.protocol.TList _list773 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
- struct.metadata = new ArrayList<ByteBuffer>(_list773.size);
- ByteBuffer _elem774;
- for (int _i775 = 0; _i775 < _list773.size; ++_i775)
+ org.apache.thrift.protocol.TList _list781 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRING, iprot.readI32());
+ struct.metadata = new ArrayList<ByteBuffer>(_list781.size);
+ ByteBuffer _elem782;
+ for (int _i783 = 0; _i783 < _list781.size; ++_i783)
{
- _elem774 = iprot.readBinary();
- struct.metadata.add(_elem774);
+ _elem782 = iprot.readBinary();
+ struct.metadata.add(_elem782);
}
}
struct.setMetadataIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
index da919d7..12a8d1b 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/SchemaVersion.java
@@ -1119,14 +1119,14 @@ import org.slf4j.LoggerFactory;
case 4: // COLS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list888 = iprot.readListBegin();
- struct.cols = new ArrayList<FieldSchema>(_list888.size);
- FieldSchema _elem889;
- for (int _i890 = 0; _i890 < _list888.size; ++_i890)
+ org.apache.thrift.protocol.TList _list896 = iprot.readListBegin();
+ struct.cols = new ArrayList<FieldSchema>(_list896.size);
+ FieldSchema _elem897;
+ for (int _i898 = 0; _i898 < _list896.size; ++_i898)
{
- _elem889 = new FieldSchema();
- _elem889.read(iprot);
- struct.cols.add(_elem889);
+ _elem897 = new FieldSchema();
+ _elem897.read(iprot);
+ struct.cols.add(_elem897);
}
iprot.readListEnd();
}
@@ -1212,9 +1212,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(COLS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.cols.size()));
- for (FieldSchema _iter891 : struct.cols)
+ for (FieldSchema _iter899 : struct.cols)
{
- _iter891.write(oprot);
+ _iter899.write(oprot);
}
oprot.writeListEnd();
}
@@ -1323,9 +1323,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetCols()) {
{
oprot.writeI32(struct.cols.size());
- for (FieldSchema _iter892 : struct.cols)
+ for (FieldSchema _iter900 : struct.cols)
{
- _iter892.write(oprot);
+ _iter900.write(oprot);
}
}
}
@@ -1368,14 +1368,14 @@ import org.slf4j.LoggerFactory;
}
if (incoming.get(3)) {
{
- org.apache.thrift.protocol.TList _list893 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.cols = new ArrayList<FieldSchema>(_list893.size);
- FieldSchema _elem894;
- for (int _i895 = 0; _i895 < _list893.size; ++_i895)
+ org.apache.thrift.protocol.TList _list901 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.cols = new ArrayList<FieldSchema>(_list901.size);
+ FieldSchema _elem902;
+ for (int _i903 = 0; _i903 < _list901.size; ++_i903)
{
- _elem894 = new FieldSchema();
- _elem894.read(iprot);
- struct.cols.add(_elem894);
+ _elem902 = new FieldSchema();
+ _elem902.read(iprot);
+ struct.cols.add(_elem902);
}
}
struct.setColsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
index 35d6d24..6c418f5 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowCompactResponse.java
@@ -354,14 +354,14 @@ import org.slf4j.LoggerFactory;
case 1: // COMPACTS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list668 = iprot.readListBegin();
- struct.compacts = new ArrayList<ShowCompactResponseElement>(_list668.size);
- ShowCompactResponseElement _elem669;
- for (int _i670 = 0; _i670 < _list668.size; ++_i670)
+ org.apache.thrift.protocol.TList _list676 = iprot.readListBegin();
+ struct.compacts = new ArrayList<ShowCompactResponseElement>(_list676.size);
+ ShowCompactResponseElement _elem677;
+ for (int _i678 = 0; _i678 < _list676.size; ++_i678)
{
- _elem669 = new ShowCompactResponseElement();
- _elem669.read(iprot);
- struct.compacts.add(_elem669);
+ _elem677 = new ShowCompactResponseElement();
+ _elem677.read(iprot);
+ struct.compacts.add(_elem677);
}
iprot.readListEnd();
}
@@ -387,9 +387,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(COMPACTS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.compacts.size()));
- for (ShowCompactResponseElement _iter671 : struct.compacts)
+ for (ShowCompactResponseElement _iter679 : struct.compacts)
{
- _iter671.write(oprot);
+ _iter679.write(oprot);
}
oprot.writeListEnd();
}
@@ -414,9 +414,9 @@ import org.slf4j.LoggerFactory;
TTupleProtocol oprot = (TTupleProtocol) prot;
{
oprot.writeI32(struct.compacts.size());
- for (ShowCompactResponseElement _iter672 : struct.compacts)
+ for (ShowCompactResponseElement _iter680 : struct.compacts)
{
- _iter672.write(oprot);
+ _iter680.write(oprot);
}
}
}
@@ -425,14 +425,14 @@ import org.slf4j.LoggerFactory;
public void read(org.apache.thrift.protocol.TProtocol prot, ShowCompactResponse struct) throws org.apache.thrift.TException {
TTupleProtocol iprot = (TTupleProtocol) prot;
{
- org.apache.thrift.protocol.TList _list673 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.compacts = new ArrayList<ShowCompactResponseElement>(_list673.size);
- ShowCompactResponseElement _elem674;
- for (int _i675 = 0; _i675 < _list673.size; ++_i675)
+ org.apache.thrift.protocol.TList _list681 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.compacts = new ArrayList<ShowCompactResponseElement>(_list681.size);
+ ShowCompactResponseElement _elem682;
+ for (int _i683 = 0; _i683 < _list681.size; ++_i683)
{
- _elem674 = new ShowCompactResponseElement();
- _elem674.read(iprot);
- struct.compacts.add(_elem674);
+ _elem682 = new ShowCompactResponseElement();
+ _elem682.read(iprot);
+ struct.compacts.add(_elem682);
}
}
struct.setCompactsIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
index c8fd20e..857dc7a 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/ShowLocksResponse.java
@@ -350,14 +350,14 @@ import org.slf4j.LoggerFactory;
case 1: // LOCKS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list634 = iprot.readListBegin();
- struct.locks = new ArrayList<ShowLocksResponseElement>(_list634.size);
- ShowLocksResponseElement _elem635;
- for (int _i636 = 0; _i636 < _list634.size; ++_i636)
+ org.apache.thrift.protocol.TList _list642 = iprot.readListBegin();
+ struct.locks = new ArrayList<ShowLocksResponseElement>(_list642.size);
+ ShowLocksResponseElement _elem643;
+ for (int _i644 = 0; _i644 < _list642.size; ++_i644)
{
- _elem635 = new ShowLocksResponseElement();
- _elem635.read(iprot);
- struct.locks.add(_elem635);
+ _elem643 = new ShowLocksResponseElement();
+ _elem643.read(iprot);
+ struct.locks.add(_elem643);
}
iprot.readListEnd();
}
@@ -383,9 +383,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(LOCKS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, struct.locks.size()));
- for (ShowLocksResponseElement _iter637 : struct.locks)
+ for (ShowLocksResponseElement _iter645 : struct.locks)
{
- _iter637.write(oprot);
+ _iter645.write(oprot);
}
oprot.writeListEnd();
}
@@ -416,9 +416,9 @@ import org.slf4j.LoggerFactory;
if (struct.isSetLocks()) {
{
oprot.writeI32(struct.locks.size());
- for (ShowLocksResponseElement _iter638 : struct.locks)
+ for (ShowLocksResponseElement _iter646 : struct.locks)
{
- _iter638.write(oprot);
+ _iter646.write(oprot);
}
}
}
@@ -430,14 +430,14 @@ import org.slf4j.LoggerFactory;
BitSet incoming = iprot.readBitSet(1);
if (incoming.get(0)) {
{
- org.apache.thrift.protocol.TList _list639 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
- struct.locks = new ArrayList<ShowLocksResponseElement>(_list639.size);
- ShowLocksResponseElement _elem640;
- for (int _i641 = 0; _i641 < _list639.size; ++_i641)
+ org.apache.thrift.protocol.TList _list647 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.STRUCT, iprot.readI32());
+ struct.locks = new ArrayList<ShowLocksResponseElement>(_list647.size);
+ ShowLocksResponseElement _elem648;
+ for (int _i649 = 0; _i649 < _list647.size; ++_i649)
{
- _elem640 = new ShowLocksResponseElement();
- _elem640.read(iprot);
- struct.locks.add(_elem640);
+ _elem648 = new ShowLocksResponseElement();
+ _elem648.read(iprot);
+ struct.locks.add(_elem648);
}
}
struct.setLocksIsSet(true);
http://git-wip-us.apache.org/repos/asf/hive/blob/59483bca/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
----------------------------------------------------------------------
diff --git a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
index e0defbd..40822c6 100644
--- a/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
+++ b/standalone-metastore/src/gen/thrift/gen-javabean/org/apache/hadoop/hive/metastore/api/TableValidWriteIds.java
@@ -708,13 +708,13 @@ import org.slf4j.LoggerFactory;
case 3: // INVALID_WRITE_IDS
if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
{
- org.apache.thrift.protocol.TList _list594 = iprot.readListBegin();
- struct.invalidWriteIds = new ArrayList<Long>(_list594.size);
- long _elem595;
- for (int _i596 = 0; _i596 < _list594.size; ++_i596)
+ org.apache.thrift.protocol.TList _list602 = iprot.readListBegin();
+ struct.invalidWriteIds = new ArrayList<Long>(_list602.size);
+ long _elem603;
+ for (int _i604 = 0; _i604 < _list602.size; ++_i604)
{
- _elem595 = iprot.readI64();
- struct.invalidWriteIds.add(_elem595);
+ _elem603 = iprot.readI64();
+ struct.invalidWriteIds.add(_elem603);
}
iprot.readListEnd();
}
@@ -764,9 +764,9 @@ import org.slf4j.LoggerFactory;
oprot.writeFieldBegin(INVALID_WRITE_IDS_FIELD_DESC);
{
oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.invalidWriteIds.size()));
- for (long _iter597 : struct.invalidWriteIds)
+ for (long _iter605 : struct.invalidWriteIds)
{
- oprot.writeI64(_iter597);
+ oprot.writeI64(_iter605);
}
oprot.writeListEnd();
}
@@ -803,9 +803,9 @@ import org.slf4j.LoggerFactory;
oprot.writeI64(struct.writeIdHighWaterMark);
{
oprot.writeI32(struct.invalidWriteIds.size());
- for (long _iter598 : struct.invalidWriteIds)
+ for (long _iter606 : struct.invalidWriteIds)
{
- oprot.writeI64(_iter598);
+ oprot.writeI64(_iter606);
}
}
oprot.writeBinary(struct.abortedBits);
@@ -827,13 +827,13 @@ import org.slf4j.LoggerFactory;
struct.writeIdHighWaterMark = iprot.readI64();
struct.setWriteIdHighWaterMarkIsSet(true);
{
- org.apache.thrift.protocol.TList _list599 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.invalidWriteIds = new ArrayList<Long>(_list599.size);
- long _elem600;
- for (int _i601 = 0; _i601 < _list599.size; ++_i601)
+ org.apache.thrift.protocol.TList _list607 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
+ struct.invalidWriteIds = new ArrayList<Long>(_list607.size);
+ long _elem608;
+ for (int _i609 = 0; _i609 < _list607.size; ++_i609)
{
- _elem600 = iprot.readI64();
- struct.invalidWriteIds.add(_elem600);
+ _elem608 = iprot.readI64();
+ struct.invalidWriteIds.add(_elem608);
}
}
struct.setInvalidWriteIdsIsSet(true);