You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tephra.apache.org by po...@apache.org on 2016/05/06 23:02:53 UTC
[47/51] [partial] incubator-tephra git commit: Rename package to
org.apache.tephra
http://git-wip-us.apache.org/repos/asf/incubator-tephra/blob/9c693743/tephra-core/src/main/java/co/cask/tephra/distributed/TransactionServiceThriftHandler.java
----------------------------------------------------------------------
diff --git a/tephra-core/src/main/java/co/cask/tephra/distributed/TransactionServiceThriftHandler.java b/tephra-core/src/main/java/co/cask/tephra/distributed/TransactionServiceThriftHandler.java
deleted file mode 100644
index ab298cc..0000000
--- a/tephra-core/src/main/java/co/cask/tephra/distributed/TransactionServiceThriftHandler.java
+++ /dev/null
@@ -1,184 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package co.cask.tephra.distributed;
-
-import co.cask.tephra.InvalidTruncateTimeException;
-import co.cask.tephra.TransactionManager;
-import co.cask.tephra.TransactionNotInProgressException;
-import co.cask.tephra.TxConstants;
-import co.cask.tephra.distributed.thrift.TBoolean;
-import co.cask.tephra.distributed.thrift.TInvalidTruncateTimeException;
-import co.cask.tephra.distributed.thrift.TTransaction;
-import co.cask.tephra.distributed.thrift.TTransactionCouldNotTakeSnapshotException;
-import co.cask.tephra.distributed.thrift.TTransactionNotInProgressException;
-import co.cask.tephra.distributed.thrift.TTransactionServer;
-import co.cask.tephra.rpc.RPCServiceHandler;
-import com.google.common.collect.Sets;
-import org.apache.thrift.TException;
-
-import java.io.ByteArrayOutputStream;
-import java.io.IOException;
-import java.nio.ByteBuffer;
-import java.util.Set;
-
-/**
- * The implementation of a thrift service for tx service.
- * All operations arrive over the wire as Thrift objects.
- * <p/>
- * Why all this conversion (wrap/unwrap), and not define all Operations
- * themselves as Thrift objects?
- * <ul><li>
- * All the non-thrift executors would have to use the Thrift objects
- * </li><li>
- * Thrift's object model is too restrictive: it has only limited inheritance
- * and no overloading
- * </li><li>
- * Thrift objects are bare-bone, all they have are getters, setters, and
- * basic object methods.
- * </li></ul>
- */
-public class TransactionServiceThriftHandler implements TTransactionServer.Iface, RPCServiceHandler {
-
- private final TransactionManager txManager;
-
- public TransactionServiceThriftHandler(TransactionManager txManager) {
- this.txManager = txManager;
- }
-
- @Override
- public TTransaction startLong() throws TException {
- return TransactionConverterUtils.wrap(txManager.startLong());
- }
-
- @Override
- public TTransaction startShort() throws TException {
- return TransactionConverterUtils.wrap(txManager.startShort());
- }
-
- @Override
- public TTransaction startShortTimeout(int timeout) throws TException {
- return TransactionConverterUtils.wrap(txManager.startShort(timeout));
- }
-
-
- @Override
- public TBoolean canCommitTx(TTransaction tx, Set<ByteBuffer> changes) throws TException {
-
- Set<byte[]> changeIds = Sets.newHashSet();
- for (ByteBuffer bb : changes) {
- byte[] changeId = new byte[bb.remaining()];
- bb.get(changeId);
- changeIds.add(changeId);
- }
- try {
- return new TBoolean(txManager.canCommit(TransactionConverterUtils.unwrap(tx), changeIds));
- } catch (TransactionNotInProgressException e) {
- throw new TTransactionNotInProgressException(e.getMessage());
- }
- }
-
- @Override
- public TBoolean commitTx(TTransaction tx) throws TException {
- try {
- return new TBoolean(txManager.commit(TransactionConverterUtils.unwrap(tx)));
- } catch (TransactionNotInProgressException e) {
- throw new TTransactionNotInProgressException(e.getMessage());
- }
- }
-
- @Override
- public void abortTx(TTransaction tx) throws TException {
- txManager.abort(TransactionConverterUtils.unwrap(tx));
- }
-
- @Override
- public boolean invalidateTx(long tx) throws TException {
- return txManager.invalidate(tx);
- }
-
- @Override
- public ByteBuffer getSnapshot() throws TException {
- try {
- ByteArrayOutputStream out = new ByteArrayOutputStream();
- try {
- boolean snapshotTaken = txManager.takeSnapshot(out);
- if (!snapshotTaken) {
- throw new TTransactionCouldNotTakeSnapshotException("Transaction manager could not get a snapshot.");
- }
- } finally {
- out.close();
- }
- // todo find a way to encode directly to the stream, without having the snapshot in memory twice
- return ByteBuffer.wrap(out.toByteArray());
- } catch (IOException e) {
- throw new TTransactionCouldNotTakeSnapshotException(e.getMessage());
- }
- }
-
- @Override
- public void resetState() throws TException {
- txManager.resetState();
- }
-
- @Override
- public String status() throws TException {
- return txManager.isRunning() ? TxConstants.STATUS_OK : TxConstants.STATUS_NOTOK;
- }
-
- @Override
- public TBoolean truncateInvalidTx(Set<Long> txns) throws TException {
- return new TBoolean(txManager.truncateInvalidTx(txns));
- }
-
- @Override
- public TBoolean truncateInvalidTxBefore(long time) throws TException {
- try {
- return new TBoolean(txManager.truncateInvalidTxBefore(time));
- } catch (InvalidTruncateTimeException e) {
- throw new TInvalidTruncateTimeException(e.getMessage());
- }
- }
-
- @Override
- public int invalidTxSize() throws TException {
- return txManager.getInvalidSize();
- }
-
- @Override
- public TTransaction checkpoint(TTransaction originalTx) throws TException {
- try {
- return TransactionConverterUtils.wrap(
- txManager.checkpoint(TransactionConverterUtils.unwrap(originalTx)));
- } catch (TransactionNotInProgressException e) {
- throw new TTransactionNotInProgressException(e.getMessage());
- }
- }
-
- /* RPCServiceHandler implementation */
-
- @Override
- public void init() throws Exception {
- txManager.startAndWait();
- }
-
- @Override
- public void destroy() throws Exception {
- txManager.stopAndWait();
- }
-}
http://git-wip-us.apache.org/repos/asf/incubator-tephra/blob/9c693743/tephra-core/src/main/java/co/cask/tephra/distributed/package-info.java
----------------------------------------------------------------------
diff --git a/tephra-core/src/main/java/co/cask/tephra/distributed/package-info.java b/tephra-core/src/main/java/co/cask/tephra/distributed/package-info.java
deleted file mode 100644
index 2cc7677..0000000
--- a/tephra-core/src/main/java/co/cask/tephra/distributed/package-info.java
+++ /dev/null
@@ -1,23 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * This package contains standalone server of the transaction system v2. It is now simple netty piece, but will change
- * we integrate new RPC
- */
-package co.cask.tephra.distributed;
http://git-wip-us.apache.org/repos/asf/incubator-tephra/blob/9c693743/tephra-core/src/main/java/co/cask/tephra/distributed/thrift/TBoolean.java
----------------------------------------------------------------------
diff --git a/tephra-core/src/main/java/co/cask/tephra/distributed/thrift/TBoolean.java b/tephra-core/src/main/java/co/cask/tephra/distributed/thrift/TBoolean.java
deleted file mode 100644
index 48ee2f9..0000000
--- a/tephra-core/src/main/java/co/cask/tephra/distributed/thrift/TBoolean.java
+++ /dev/null
@@ -1,402 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * Autogenerated by Thrift Compiler (0.9.0)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-package co.cask.tephra.distributed.thrift;
-
-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 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 org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-public class TBoolean implements org.apache.thrift.TBase<TBoolean, TBoolean._Fields>, java.io.Serializable, Cloneable {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TBoolean");
-
- private static final org.apache.thrift.protocol.TField VALUE_FIELD_DESC = new org.apache.thrift.protocol.TField("value", org.apache.thrift.protocol.TType.BOOL, (short)1);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new TBooleanStandardSchemeFactory());
- schemes.put(TupleScheme.class, new TBooleanTupleSchemeFactory());
- }
-
- public boolean value; // 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 {
- VALUE((short)1, "value");
-
- 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: // VALUE
- return VALUE;
- 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
- private static final int __VALUE_ISSET_ID = 0;
- private byte __isset_bitfield = 0;
- 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.VALUE, new org.apache.thrift.meta_data.FieldMetaData("value", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.BOOL)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TBoolean.class, metaDataMap);
- }
-
- public TBoolean() {
- }
-
- public TBoolean(
- boolean value)
- {
- this();
- this.value = value;
- setValueIsSet(true);
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public TBoolean(TBoolean other) {
- __isset_bitfield = other.__isset_bitfield;
- this.value = other.value;
- }
-
- public TBoolean deepCopy() {
- return new TBoolean(this);
- }
-
- @Override
- public void clear() {
- setValueIsSet(false);
- this.value = false;
- }
-
- public boolean isValue() {
- return this.value;
- }
-
- public TBoolean setValue(boolean value) {
- this.value = value;
- setValueIsSet(true);
- return this;
- }
-
- public void unsetValue() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __VALUE_ISSET_ID);
- }
-
- /** Returns true if field value is set (has been assigned a value) and false otherwise */
- public boolean isSetValue() {
- return EncodingUtils.testBit(__isset_bitfield, __VALUE_ISSET_ID);
- }
-
- public void setValueIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __VALUE_ISSET_ID, value);
- }
-
- public void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case VALUE:
- if (value == null) {
- unsetValue();
- } else {
- setValue((Boolean)value);
- }
- break;
-
- }
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case VALUE:
- return Boolean.valueOf(isValue());
-
- }
- 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 VALUE:
- return isSetValue();
- }
- throw new IllegalStateException();
- }
-
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof TBoolean)
- return this.equals((TBoolean)that);
- return false;
- }
-
- public boolean equals(TBoolean that) {
- if (that == null)
- return false;
-
- boolean this_present_value = true;
- boolean that_present_value = true;
- if (this_present_value || that_present_value) {
- if (!(this_present_value && that_present_value))
- return false;
- if (this.value != that.value)
- return false;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- return 0;
- }
-
- public int compareTo(TBoolean other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
- TBoolean typedOther = (TBoolean)other;
-
- lastComparison = Boolean.valueOf(isSetValue()).compareTo(typedOther.isSetValue());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetValue()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.value, typedOther.value);
- 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("TBoolean(");
- boolean first = true;
-
- sb.append("value:");
- sb.append(this.value);
- first = false;
- sb.append(")");
- return sb.toString();
- }
-
- public void validate() throws org.apache.thrift.TException {
- // check for required fields
- // 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 {
- // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bitfield = 0;
- 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 TBooleanStandardSchemeFactory implements SchemeFactory {
- public TBooleanStandardScheme getScheme() {
- return new TBooleanStandardScheme();
- }
- }
-
- private static class TBooleanStandardScheme extends StandardScheme<TBoolean> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, TBoolean 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: // VALUE
- if (schemeField.type == org.apache.thrift.protocol.TType.BOOL) {
- struct.value = iprot.readBool();
- struct.setValueIsSet(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();
-
- // check for required fields of primitive type, which can't be checked in the validate method
- struct.validate();
- }
-
- public void write(org.apache.thrift.protocol.TProtocol oprot, TBoolean struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- oprot.writeFieldBegin(VALUE_FIELD_DESC);
- oprot.writeBool(struct.value);
- oprot.writeFieldEnd();
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class TBooleanTupleSchemeFactory implements SchemeFactory {
- public TBooleanTupleScheme getScheme() {
- return new TBooleanTupleScheme();
- }
- }
-
- private static class TBooleanTupleScheme extends TupleScheme<TBoolean> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, TBoolean struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- BitSet optionals = new BitSet();
- if (struct.isSetValue()) {
- optionals.set(0);
- }
- oprot.writeBitSet(optionals, 1);
- if (struct.isSetValue()) {
- oprot.writeBool(struct.value);
- }
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, TBoolean struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(1);
- if (incoming.get(0)) {
- struct.value = iprot.readBool();
- struct.setValueIsSet(true);
- }
- }
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/incubator-tephra/blob/9c693743/tephra-core/src/main/java/co/cask/tephra/distributed/thrift/TInvalidTruncateTimeException.java
----------------------------------------------------------------------
diff --git a/tephra-core/src/main/java/co/cask/tephra/distributed/thrift/TInvalidTruncateTimeException.java b/tephra-core/src/main/java/co/cask/tephra/distributed/thrift/TInvalidTruncateTimeException.java
deleted file mode 100644
index 9a321e6..0000000
--- a/tephra-core/src/main/java/co/cask/tephra/distributed/thrift/TInvalidTruncateTimeException.java
+++ /dev/null
@@ -1,394 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * Autogenerated by Thrift Compiler (0.9.0)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-package co.cask.tephra.distributed.thrift;
-
-import org.apache.thrift.TException;
-import org.apache.thrift.protocol.TTupleProtocol;
-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 java.util.BitSet;
-import java.util.Collections;
-import java.util.EnumMap;
-import java.util.EnumSet;
-import java.util.HashMap;
-import java.util.Map;
-
-public class TInvalidTruncateTimeException extends TException implements org.apache.thrift.TBase<TInvalidTruncateTimeException, TInvalidTruncateTimeException._Fields>, java.io.Serializable, Cloneable {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TInvalidTruncateTimeException");
-
- private static final org.apache.thrift.protocol.TField MESSAGE_FIELD_DESC = new org.apache.thrift.protocol.TField("message", org.apache.thrift.protocol.TType.STRING, (short)1);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new TInvalidTruncateTimeExceptionStandardSchemeFactory());
- schemes.put(TupleScheme.class, new TInvalidTruncateTimeExceptionTupleSchemeFactory());
- }
-
- public String message; // 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 {
- MESSAGE((short)1, "message");
-
- 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: // MESSAGE
- return MESSAGE;
- 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.MESSAGE, new org.apache.thrift.meta_data.FieldMetaData("message", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TInvalidTruncateTimeException.class, metaDataMap);
- }
-
- public TInvalidTruncateTimeException() {
- }
-
- public TInvalidTruncateTimeException(
- String message)
- {
- this();
- this.message = message;
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public TInvalidTruncateTimeException(TInvalidTruncateTimeException other) {
- if (other.isSetMessage()) {
- this.message = other.message;
- }
- }
-
- public TInvalidTruncateTimeException deepCopy() {
- return new TInvalidTruncateTimeException(this);
- }
-
- @Override
- public void clear() {
- this.message = null;
- }
-
- public String getMessage() {
- return this.message;
- }
-
- public TInvalidTruncateTimeException setMessage(String message) {
- this.message = message;
- return this;
- }
-
- public void unsetMessage() {
- this.message = null;
- }
-
- /** Returns true if field message is set (has been assigned a value) and false otherwise */
- public boolean isSetMessage() {
- return this.message != null;
- }
-
- public void setMessageIsSet(boolean value) {
- if (!value) {
- this.message = null;
- }
- }
-
- public void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case MESSAGE:
- if (value == null) {
- unsetMessage();
- } else {
- setMessage((String)value);
- }
- break;
-
- }
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case MESSAGE:
- return getMessage();
-
- }
- 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 MESSAGE:
- return isSetMessage();
- }
- throw new IllegalStateException();
- }
-
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof TInvalidTruncateTimeException)
- return this.equals((TInvalidTruncateTimeException)that);
- return false;
- }
-
- public boolean equals(TInvalidTruncateTimeException that) {
- if (that == null)
- return false;
-
- boolean this_present_message = true && this.isSetMessage();
- boolean that_present_message = true && that.isSetMessage();
- if (this_present_message || that_present_message) {
- if (!(this_present_message && that_present_message))
- return false;
- if (!this.message.equals(that.message))
- return false;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- return 0;
- }
-
- public int compareTo(TInvalidTruncateTimeException other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
- TInvalidTruncateTimeException typedOther = (TInvalidTruncateTimeException)other;
-
- lastComparison = Boolean.valueOf(isSetMessage()).compareTo(typedOther.isSetMessage());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetMessage()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.message, typedOther.message);
- 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("TInvalidTruncateTimeException(");
- boolean first = true;
-
- sb.append("message:");
- if (this.message == null) {
- sb.append("null");
- } else {
- sb.append(this.message);
- }
- first = false;
- sb.append(")");
- return sb.toString();
- }
-
- public void validate() throws org.apache.thrift.TException {
- // check for required fields
- // 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 TInvalidTruncateTimeExceptionStandardSchemeFactory implements SchemeFactory {
- public TInvalidTruncateTimeExceptionStandardScheme getScheme() {
- return new TInvalidTruncateTimeExceptionStandardScheme();
- }
- }
-
- private static class TInvalidTruncateTimeExceptionStandardScheme extends StandardScheme<TInvalidTruncateTimeException> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, TInvalidTruncateTimeException 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: // MESSAGE
- if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
- struct.message = iprot.readString();
- struct.setMessageIsSet(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();
-
- // check for required fields of primitive type, which can't be checked in the validate method
- struct.validate();
- }
-
- public void write(org.apache.thrift.protocol.TProtocol oprot, TInvalidTruncateTimeException struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- if (struct.message != null) {
- oprot.writeFieldBegin(MESSAGE_FIELD_DESC);
- oprot.writeString(struct.message);
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class TInvalidTruncateTimeExceptionTupleSchemeFactory implements SchemeFactory {
- public TInvalidTruncateTimeExceptionTupleScheme getScheme() {
- return new TInvalidTruncateTimeExceptionTupleScheme();
- }
- }
-
- private static class TInvalidTruncateTimeExceptionTupleScheme extends TupleScheme<TInvalidTruncateTimeException> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, TInvalidTruncateTimeException struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- BitSet optionals = new BitSet();
- if (struct.isSetMessage()) {
- optionals.set(0);
- }
- oprot.writeBitSet(optionals, 1);
- if (struct.isSetMessage()) {
- oprot.writeString(struct.message);
- }
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, TInvalidTruncateTimeException struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(1);
- if (incoming.get(0)) {
- struct.message = iprot.readString();
- struct.setMessageIsSet(true);
- }
- }
- }
-
-}
-
http://git-wip-us.apache.org/repos/asf/incubator-tephra/blob/9c693743/tephra-core/src/main/java/co/cask/tephra/distributed/thrift/TTransaction.java
----------------------------------------------------------------------
diff --git a/tephra-core/src/main/java/co/cask/tephra/distributed/thrift/TTransaction.java b/tephra-core/src/main/java/co/cask/tephra/distributed/thrift/TTransaction.java
deleted file mode 100644
index 39c5af6..0000000
--- a/tephra-core/src/main/java/co/cask/tephra/distributed/thrift/TTransaction.java
+++ /dev/null
@@ -1,1364 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one
- * or more contributor license agreements. See the NOTICE file
- * distributed with this work for additional information
- * regarding copyright ownership. The ASF licenses this file
- * to you under the Apache License, Version 2.0 (the
- * "License"); you may not use this file except in compliance
- * with the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-/**
- * Autogenerated by Thrift Compiler (0.9.0)
- *
- * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
- * @generated
- */
-package co.cask.tephra.distributed.thrift;
-
-import org.apache.thrift.EncodingUtils;
-import org.apache.thrift.protocol.TTupleProtocol;
-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 java.util.ArrayList;
-import java.util.BitSet;
-import java.util.Collections;
-import java.util.EnumMap;
-import java.util.EnumSet;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
-
-public class TTransaction implements org.apache.thrift.TBase<TTransaction, TTransaction._Fields>, java.io.Serializable, Cloneable {
- private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("TTransaction");
-
- private static final org.apache.thrift.protocol.TField TRANSACTION_ID_FIELD_DESC = new org.apache.thrift.protocol.TField("transactionId", org.apache.thrift.protocol.TType.I64, (short)1);
- private static final org.apache.thrift.protocol.TField READ_POINTER_FIELD_DESC = new org.apache.thrift.protocol.TField("readPointer", org.apache.thrift.protocol.TType.I64, (short)2);
- private static final org.apache.thrift.protocol.TField INVALIDS_FIELD_DESC = new org.apache.thrift.protocol.TField("invalids", org.apache.thrift.protocol.TType.LIST, (short)3);
- private static final org.apache.thrift.protocol.TField IN_PROGRESS_FIELD_DESC = new org.apache.thrift.protocol.TField("inProgress", org.apache.thrift.protocol.TType.LIST, (short)4);
- private static final org.apache.thrift.protocol.TField FIRST_SHORT_FIELD_DESC = new org.apache.thrift.protocol.TField("firstShort", org.apache.thrift.protocol.TType.I64, (short)5);
- private static final org.apache.thrift.protocol.TField TYPE_FIELD_DESC = new org.apache.thrift.protocol.TField("type", org.apache.thrift.protocol.TType.I32, (short)6);
- private static final org.apache.thrift.protocol.TField WRITE_POINTER_FIELD_DESC = new org.apache.thrift.protocol.TField("writePointer", org.apache.thrift.protocol.TType.I64, (short)7);
- private static final org.apache.thrift.protocol.TField CHECKPOINT_WRITE_POINTERS_FIELD_DESC = new org.apache.thrift.protocol.TField("checkpointWritePointers", org.apache.thrift.protocol.TType.LIST, (short)8);
- private static final org.apache.thrift.protocol.TField VISIBILITY_LEVEL_FIELD_DESC = new org.apache.thrift.protocol.TField("visibilityLevel", org.apache.thrift.protocol.TType.I32, (short)9);
-
- private static final Map<Class<? extends IScheme>, SchemeFactory> schemes = new HashMap<Class<? extends IScheme>, SchemeFactory>();
- static {
- schemes.put(StandardScheme.class, new TTransactionStandardSchemeFactory());
- schemes.put(TupleScheme.class, new TTransactionTupleSchemeFactory());
- }
-
- public long transactionId; // required
- public long readPointer; // required
- public List<Long> invalids; // required
- public List<Long> inProgress; // required
- public long firstShort; // required
- /**
- *
- * @see TTransactionType
- */
- public TTransactionType type; // required
- public long writePointer; // required
- public List<Long> checkpointWritePointers; // required
- /**
- *
- * @see TVisibilityLevel
- */
- public TVisibilityLevel visibilityLevel; // 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 {
- TRANSACTION_ID((short)1, "transactionId"),
- READ_POINTER((short)2, "readPointer"),
- INVALIDS((short)3, "invalids"),
- IN_PROGRESS((short)4, "inProgress"),
- FIRST_SHORT((short)5, "firstShort"),
- /**
- *
- * @see TTransactionType
- */
- TYPE((short)6, "type"),
- WRITE_POINTER((short)7, "writePointer"),
- CHECKPOINT_WRITE_POINTERS((short)8, "checkpointWritePointers"),
- /**
- *
- * @see TVisibilityLevel
- */
- VISIBILITY_LEVEL((short)9, "visibilityLevel");
-
- 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: // TRANSACTION_ID
- return TRANSACTION_ID;
- case 2: // READ_POINTER
- return READ_POINTER;
- case 3: // INVALIDS
- return INVALIDS;
- case 4: // IN_PROGRESS
- return IN_PROGRESS;
- case 5: // FIRST_SHORT
- return FIRST_SHORT;
- case 6: // TYPE
- return TYPE;
- case 7: // WRITE_POINTER
- return WRITE_POINTER;
- case 8: // CHECKPOINT_WRITE_POINTERS
- return CHECKPOINT_WRITE_POINTERS;
- case 9: // VISIBILITY_LEVEL
- return VISIBILITY_LEVEL;
- 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
- private static final int __TRANSACTIONID_ISSET_ID = 0;
- private static final int __READPOINTER_ISSET_ID = 1;
- private static final int __FIRSTSHORT_ISSET_ID = 2;
- private static final int __WRITEPOINTER_ISSET_ID = 3;
- private byte __isset_bitfield = 0;
- 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.TRANSACTION_ID, new org.apache.thrift.meta_data.FieldMetaData("transactionId", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
- tmpMap.put(_Fields.READ_POINTER, new org.apache.thrift.meta_data.FieldMetaData("readPointer", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
- tmpMap.put(_Fields.INVALIDS, new org.apache.thrift.meta_data.FieldMetaData("invalids", org.apache.thrift.TFieldRequirementType.DEFAULT,
- 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))));
- tmpMap.put(_Fields.IN_PROGRESS, new org.apache.thrift.meta_data.FieldMetaData("inProgress", org.apache.thrift.TFieldRequirementType.DEFAULT,
- 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))));
- tmpMap.put(_Fields.FIRST_SHORT, new org.apache.thrift.meta_data.FieldMetaData("firstShort", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
- tmpMap.put(_Fields.TYPE, new org.apache.thrift.meta_data.FieldMetaData("type", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, TTransactionType.class)));
- tmpMap.put(_Fields.WRITE_POINTER, new org.apache.thrift.meta_data.FieldMetaData("writePointer", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
- tmpMap.put(_Fields.CHECKPOINT_WRITE_POINTERS, new org.apache.thrift.meta_data.FieldMetaData("checkpointWritePointers", org.apache.thrift.TFieldRequirementType.DEFAULT,
- 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))));
- tmpMap.put(_Fields.VISIBILITY_LEVEL, new org.apache.thrift.meta_data.FieldMetaData("visibilityLevel", org.apache.thrift.TFieldRequirementType.DEFAULT,
- new org.apache.thrift.meta_data.EnumMetaData(org.apache.thrift.protocol.TType.ENUM, TVisibilityLevel.class)));
- metaDataMap = Collections.unmodifiableMap(tmpMap);
- org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(TTransaction.class, metaDataMap);
- }
-
- public TTransaction() {
- }
-
- public TTransaction(
- long transactionId,
- long readPointer,
- List<Long> invalids,
- List<Long> inProgress,
- long firstShort,
- TTransactionType type,
- long writePointer,
- List<Long> checkpointWritePointers,
- TVisibilityLevel visibilityLevel)
- {
- this();
- this.transactionId = transactionId;
- setTransactionIdIsSet(true);
- this.readPointer = readPointer;
- setReadPointerIsSet(true);
- this.invalids = invalids;
- this.inProgress = inProgress;
- this.firstShort = firstShort;
- setFirstShortIsSet(true);
- this.type = type;
- this.writePointer = writePointer;
- setWritePointerIsSet(true);
- this.checkpointWritePointers = checkpointWritePointers;
- this.visibilityLevel = visibilityLevel;
- }
-
- /**
- * Performs a deep copy on <i>other</i>.
- */
- public TTransaction(TTransaction other) {
- __isset_bitfield = other.__isset_bitfield;
- this.transactionId = other.transactionId;
- this.readPointer = other.readPointer;
- if (other.isSetInvalids()) {
- List<Long> __this__invalids = new ArrayList<Long>();
- for (Long other_element : other.invalids) {
- __this__invalids.add(other_element);
- }
- this.invalids = __this__invalids;
- }
- if (other.isSetInProgress()) {
- List<Long> __this__inProgress = new ArrayList<Long>();
- for (Long other_element : other.inProgress) {
- __this__inProgress.add(other_element);
- }
- this.inProgress = __this__inProgress;
- }
- this.firstShort = other.firstShort;
- if (other.isSetType()) {
- this.type = other.type;
- }
- this.writePointer = other.writePointer;
- if (other.isSetCheckpointWritePointers()) {
- List<Long> __this__checkpointWritePointers = new ArrayList<Long>();
- for (Long other_element : other.checkpointWritePointers) {
- __this__checkpointWritePointers.add(other_element);
- }
- this.checkpointWritePointers = __this__checkpointWritePointers;
- }
- if (other.isSetVisibilityLevel()) {
- this.visibilityLevel = other.visibilityLevel;
- }
- }
-
- public TTransaction deepCopy() {
- return new TTransaction(this);
- }
-
- @Override
- public void clear() {
- setTransactionIdIsSet(false);
- this.transactionId = 0;
- setReadPointerIsSet(false);
- this.readPointer = 0;
- this.invalids = null;
- this.inProgress = null;
- setFirstShortIsSet(false);
- this.firstShort = 0;
- this.type = null;
- setWritePointerIsSet(false);
- this.writePointer = 0;
- this.checkpointWritePointers = null;
- this.visibilityLevel = null;
- }
-
- public long getTransactionId() {
- return this.transactionId;
- }
-
- public TTransaction setTransactionId(long transactionId) {
- this.transactionId = transactionId;
- setTransactionIdIsSet(true);
- return this;
- }
-
- public void unsetTransactionId() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TRANSACTIONID_ISSET_ID);
- }
-
- /** Returns true if field transactionId is set (has been assigned a value) and false otherwise */
- public boolean isSetTransactionId() {
- return EncodingUtils.testBit(__isset_bitfield, __TRANSACTIONID_ISSET_ID);
- }
-
- public void setTransactionIdIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TRANSACTIONID_ISSET_ID, value);
- }
-
- public long getReadPointer() {
- return this.readPointer;
- }
-
- public TTransaction setReadPointer(long readPointer) {
- this.readPointer = readPointer;
- setReadPointerIsSet(true);
- return this;
- }
-
- public void unsetReadPointer() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __READPOINTER_ISSET_ID);
- }
-
- /** Returns true if field readPointer is set (has been assigned a value) and false otherwise */
- public boolean isSetReadPointer() {
- return EncodingUtils.testBit(__isset_bitfield, __READPOINTER_ISSET_ID);
- }
-
- public void setReadPointerIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __READPOINTER_ISSET_ID, value);
- }
-
- public int getInvalidsSize() {
- return (this.invalids == null) ? 0 : this.invalids.size();
- }
-
- public java.util.Iterator<Long> getInvalidsIterator() {
- return (this.invalids == null) ? null : this.invalids.iterator();
- }
-
- public void addToInvalids(long elem) {
- if (this.invalids == null) {
- this.invalids = new ArrayList<Long>();
- }
- this.invalids.add(elem);
- }
-
- public List<Long> getInvalids() {
- return this.invalids;
- }
-
- public TTransaction setInvalids(List<Long> invalids) {
- this.invalids = invalids;
- return this;
- }
-
- public void unsetInvalids() {
- this.invalids = null;
- }
-
- /** Returns true if field invalids is set (has been assigned a value) and false otherwise */
- public boolean isSetInvalids() {
- return this.invalids != null;
- }
-
- public void setInvalidsIsSet(boolean value) {
- if (!value) {
- this.invalids = null;
- }
- }
-
- public int getInProgressSize() {
- return (this.inProgress == null) ? 0 : this.inProgress.size();
- }
-
- public java.util.Iterator<Long> getInProgressIterator() {
- return (this.inProgress == null) ? null : this.inProgress.iterator();
- }
-
- public void addToInProgress(long elem) {
- if (this.inProgress == null) {
- this.inProgress = new ArrayList<Long>();
- }
- this.inProgress.add(elem);
- }
-
- public List<Long> getInProgress() {
- return this.inProgress;
- }
-
- public TTransaction setInProgress(List<Long> inProgress) {
- this.inProgress = inProgress;
- return this;
- }
-
- public void unsetInProgress() {
- this.inProgress = null;
- }
-
- /** Returns true if field inProgress is set (has been assigned a value) and false otherwise */
- public boolean isSetInProgress() {
- return this.inProgress != null;
- }
-
- public void setInProgressIsSet(boolean value) {
- if (!value) {
- this.inProgress = null;
- }
- }
-
- public long getFirstShort() {
- return this.firstShort;
- }
-
- public TTransaction setFirstShort(long firstShort) {
- this.firstShort = firstShort;
- setFirstShortIsSet(true);
- return this;
- }
-
- public void unsetFirstShort() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __FIRSTSHORT_ISSET_ID);
- }
-
- /** Returns true if field firstShort is set (has been assigned a value) and false otherwise */
- public boolean isSetFirstShort() {
- return EncodingUtils.testBit(__isset_bitfield, __FIRSTSHORT_ISSET_ID);
- }
-
- public void setFirstShortIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __FIRSTSHORT_ISSET_ID, value);
- }
-
- /**
- *
- * @see TTransactionType
- */
- public TTransactionType getType() {
- return this.type;
- }
-
- /**
- *
- * @see TTransactionType
- */
- public TTransaction setType(TTransactionType type) {
- this.type = type;
- return this;
- }
-
- public void unsetType() {
- this.type = null;
- }
-
- /** Returns true if field type is set (has been assigned a value) and false otherwise */
- public boolean isSetType() {
- return this.type != null;
- }
-
- public void setTypeIsSet(boolean value) {
- if (!value) {
- this.type = null;
- }
- }
-
- public long getWritePointer() {
- return this.writePointer;
- }
-
- public TTransaction setWritePointer(long writePointer) {
- this.writePointer = writePointer;
- setWritePointerIsSet(true);
- return this;
- }
-
- public void unsetWritePointer() {
- __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __WRITEPOINTER_ISSET_ID);
- }
-
- /** Returns true if field writePointer is set (has been assigned a value) and false otherwise */
- public boolean isSetWritePointer() {
- return EncodingUtils.testBit(__isset_bitfield, __WRITEPOINTER_ISSET_ID);
- }
-
- public void setWritePointerIsSet(boolean value) {
- __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __WRITEPOINTER_ISSET_ID, value);
- }
-
- public int getCheckpointWritePointersSize() {
- return (this.checkpointWritePointers == null) ? 0 : this.checkpointWritePointers.size();
- }
-
- public java.util.Iterator<Long> getCheckpointWritePointersIterator() {
- return (this.checkpointWritePointers == null) ? null : this.checkpointWritePointers.iterator();
- }
-
- public void addToCheckpointWritePointers(long elem) {
- if (this.checkpointWritePointers == null) {
- this.checkpointWritePointers = new ArrayList<Long>();
- }
- this.checkpointWritePointers.add(elem);
- }
-
- public List<Long> getCheckpointWritePointers() {
- return this.checkpointWritePointers;
- }
-
- public TTransaction setCheckpointWritePointers(List<Long> checkpointWritePointers) {
- this.checkpointWritePointers = checkpointWritePointers;
- return this;
- }
-
- public void unsetCheckpointWritePointers() {
- this.checkpointWritePointers = null;
- }
-
- /** Returns true if field checkpointWritePointers is set (has been assigned a value) and false otherwise */
- public boolean isSetCheckpointWritePointers() {
- return this.checkpointWritePointers != null;
- }
-
- public void setCheckpointWritePointersIsSet(boolean value) {
- if (!value) {
- this.checkpointWritePointers = null;
- }
- }
-
- /**
- *
- * @see TVisibilityLevel
- */
- public TVisibilityLevel getVisibilityLevel() {
- return this.visibilityLevel;
- }
-
- /**
- *
- * @see TVisibilityLevel
- */
- public TTransaction setVisibilityLevel(TVisibilityLevel visibilityLevel) {
- this.visibilityLevel = visibilityLevel;
- return this;
- }
-
- public void unsetVisibilityLevel() {
- this.visibilityLevel = null;
- }
-
- /** Returns true if field visibilityLevel is set (has been assigned a value) and false otherwise */
- public boolean isSetVisibilityLevel() {
- return this.visibilityLevel != null;
- }
-
- public void setVisibilityLevelIsSet(boolean value) {
- if (!value) {
- this.visibilityLevel = null;
- }
- }
-
- public void setFieldValue(_Fields field, Object value) {
- switch (field) {
- case TRANSACTION_ID:
- if (value == null) {
- unsetTransactionId();
- } else {
- setTransactionId((Long)value);
- }
- break;
-
- case READ_POINTER:
- if (value == null) {
- unsetReadPointer();
- } else {
- setReadPointer((Long)value);
- }
- break;
-
- case INVALIDS:
- if (value == null) {
- unsetInvalids();
- } else {
- setInvalids((List<Long>)value);
- }
- break;
-
- case IN_PROGRESS:
- if (value == null) {
- unsetInProgress();
- } else {
- setInProgress((List<Long>)value);
- }
- break;
-
- case FIRST_SHORT:
- if (value == null) {
- unsetFirstShort();
- } else {
- setFirstShort((Long)value);
- }
- break;
-
- case TYPE:
- if (value == null) {
- unsetType();
- } else {
- setType((TTransactionType)value);
- }
- break;
-
- case WRITE_POINTER:
- if (value == null) {
- unsetWritePointer();
- } else {
- setWritePointer((Long)value);
- }
- break;
-
- case CHECKPOINT_WRITE_POINTERS:
- if (value == null) {
- unsetCheckpointWritePointers();
- } else {
- setCheckpointWritePointers((List<Long>)value);
- }
- break;
-
- case VISIBILITY_LEVEL:
- if (value == null) {
- unsetVisibilityLevel();
- } else {
- setVisibilityLevel((TVisibilityLevel)value);
- }
- break;
-
- }
- }
-
- public Object getFieldValue(_Fields field) {
- switch (field) {
- case TRANSACTION_ID:
- return Long.valueOf(getTransactionId());
-
- case READ_POINTER:
- return Long.valueOf(getReadPointer());
-
- case INVALIDS:
- return getInvalids();
-
- case IN_PROGRESS:
- return getInProgress();
-
- case FIRST_SHORT:
- return Long.valueOf(getFirstShort());
-
- case TYPE:
- return getType();
-
- case WRITE_POINTER:
- return Long.valueOf(getWritePointer());
-
- case CHECKPOINT_WRITE_POINTERS:
- return getCheckpointWritePointers();
-
- case VISIBILITY_LEVEL:
- return getVisibilityLevel();
-
- }
- 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 TRANSACTION_ID:
- return isSetTransactionId();
- case READ_POINTER:
- return isSetReadPointer();
- case INVALIDS:
- return isSetInvalids();
- case IN_PROGRESS:
- return isSetInProgress();
- case FIRST_SHORT:
- return isSetFirstShort();
- case TYPE:
- return isSetType();
- case WRITE_POINTER:
- return isSetWritePointer();
- case CHECKPOINT_WRITE_POINTERS:
- return isSetCheckpointWritePointers();
- case VISIBILITY_LEVEL:
- return isSetVisibilityLevel();
- }
- throw new IllegalStateException();
- }
-
- @Override
- public boolean equals(Object that) {
- if (that == null)
- return false;
- if (that instanceof TTransaction)
- return this.equals((TTransaction)that);
- return false;
- }
-
- public boolean equals(TTransaction that) {
- if (that == null)
- return false;
-
- boolean this_present_transactionId = true;
- boolean that_present_transactionId = true;
- if (this_present_transactionId || that_present_transactionId) {
- if (!(this_present_transactionId && that_present_transactionId))
- return false;
- if (this.transactionId != that.transactionId)
- return false;
- }
-
- boolean this_present_readPointer = true;
- boolean that_present_readPointer = true;
- if (this_present_readPointer || that_present_readPointer) {
- if (!(this_present_readPointer && that_present_readPointer))
- return false;
- if (this.readPointer != that.readPointer)
- return false;
- }
-
- boolean this_present_invalids = true && this.isSetInvalids();
- boolean that_present_invalids = true && that.isSetInvalids();
- if (this_present_invalids || that_present_invalids) {
- if (!(this_present_invalids && that_present_invalids))
- return false;
- if (!this.invalids.equals(that.invalids))
- return false;
- }
-
- boolean this_present_inProgress = true && this.isSetInProgress();
- boolean that_present_inProgress = true && that.isSetInProgress();
- if (this_present_inProgress || that_present_inProgress) {
- if (!(this_present_inProgress && that_present_inProgress))
- return false;
- if (!this.inProgress.equals(that.inProgress))
- return false;
- }
-
- boolean this_present_firstShort = true;
- boolean that_present_firstShort = true;
- if (this_present_firstShort || that_present_firstShort) {
- if (!(this_present_firstShort && that_present_firstShort))
- return false;
- if (this.firstShort != that.firstShort)
- return false;
- }
-
- boolean this_present_type = true && this.isSetType();
- boolean that_present_type = true && that.isSetType();
- if (this_present_type || that_present_type) {
- if (!(this_present_type && that_present_type))
- return false;
- if (!this.type.equals(that.type))
- return false;
- }
-
- boolean this_present_writePointer = true;
- boolean that_present_writePointer = true;
- if (this_present_writePointer || that_present_writePointer) {
- if (!(this_present_writePointer && that_present_writePointer))
- return false;
- if (this.writePointer != that.writePointer)
- return false;
- }
-
- boolean this_present_checkpointWritePointers = true && this.isSetCheckpointWritePointers();
- boolean that_present_checkpointWritePointers = true && that.isSetCheckpointWritePointers();
- if (this_present_checkpointWritePointers || that_present_checkpointWritePointers) {
- if (!(this_present_checkpointWritePointers && that_present_checkpointWritePointers))
- return false;
- if (!this.checkpointWritePointers.equals(that.checkpointWritePointers))
- return false;
- }
-
- boolean this_present_visibilityLevel = true && this.isSetVisibilityLevel();
- boolean that_present_visibilityLevel = true && that.isSetVisibilityLevel();
- if (this_present_visibilityLevel || that_present_visibilityLevel) {
- if (!(this_present_visibilityLevel && that_present_visibilityLevel))
- return false;
- if (!this.visibilityLevel.equals(that.visibilityLevel))
- return false;
- }
-
- return true;
- }
-
- @Override
- public int hashCode() {
- return 0;
- }
-
- public int compareTo(TTransaction other) {
- if (!getClass().equals(other.getClass())) {
- return getClass().getName().compareTo(other.getClass().getName());
- }
-
- int lastComparison = 0;
- TTransaction typedOther = (TTransaction)other;
-
- lastComparison = Boolean.valueOf(isSetTransactionId()).compareTo(typedOther.isSetTransactionId());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetTransactionId()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.transactionId, typedOther.transactionId);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetReadPointer()).compareTo(typedOther.isSetReadPointer());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetReadPointer()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.readPointer, typedOther.readPointer);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetInvalids()).compareTo(typedOther.isSetInvalids());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetInvalids()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.invalids, typedOther.invalids);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetInProgress()).compareTo(typedOther.isSetInProgress());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetInProgress()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.inProgress, typedOther.inProgress);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetFirstShort()).compareTo(typedOther.isSetFirstShort());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetFirstShort()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.firstShort, typedOther.firstShort);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetType()).compareTo(typedOther.isSetType());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetType()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.type, typedOther.type);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetWritePointer()).compareTo(typedOther.isSetWritePointer());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetWritePointer()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.writePointer, typedOther.writePointer);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetCheckpointWritePointers()).compareTo(typedOther.isSetCheckpointWritePointers());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetCheckpointWritePointers()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.checkpointWritePointers, typedOther.checkpointWritePointers);
- if (lastComparison != 0) {
- return lastComparison;
- }
- }
- lastComparison = Boolean.valueOf(isSetVisibilityLevel()).compareTo(typedOther.isSetVisibilityLevel());
- if (lastComparison != 0) {
- return lastComparison;
- }
- if (isSetVisibilityLevel()) {
- lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.visibilityLevel, typedOther.visibilityLevel);
- 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("TTransaction(");
- boolean first = true;
-
- sb.append("transactionId:");
- sb.append(this.transactionId);
- first = false;
- if (!first) sb.append(", ");
- sb.append("readPointer:");
- sb.append(this.readPointer);
- first = false;
- if (!first) sb.append(", ");
- sb.append("invalids:");
- if (this.invalids == null) {
- sb.append("null");
- } else {
- sb.append(this.invalids);
- }
- first = false;
- if (!first) sb.append(", ");
- sb.append("inProgress:");
- if (this.inProgress == null) {
- sb.append("null");
- } else {
- sb.append(this.inProgress);
- }
- first = false;
- if (!first) sb.append(", ");
- sb.append("firstShort:");
- sb.append(this.firstShort);
- first = false;
- if (!first) sb.append(", ");
- sb.append("type:");
- if (this.type == null) {
- sb.append("null");
- } else {
- sb.append(this.type);
- }
- first = false;
- if (!first) sb.append(", ");
- sb.append("writePointer:");
- sb.append(this.writePointer);
- first = false;
- if (!first) sb.append(", ");
- sb.append("checkpointWritePointers:");
- if (this.checkpointWritePointers == null) {
- sb.append("null");
- } else {
- sb.append(this.checkpointWritePointers);
- }
- first = false;
- if (!first) sb.append(", ");
- sb.append("visibilityLevel:");
- if (this.visibilityLevel == null) {
- sb.append("null");
- } else {
- sb.append(this.visibilityLevel);
- }
- first = false;
- sb.append(")");
- return sb.toString();
- }
-
- public void validate() throws org.apache.thrift.TException {
- // check for required fields
- // 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 {
- // it doesn't seem like you should have to do this, but java serialization is wacky, and doesn't call the default constructor.
- __isset_bitfield = 0;
- 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 TTransactionStandardSchemeFactory implements SchemeFactory {
- public TTransactionStandardScheme getScheme() {
- return new TTransactionStandardScheme();
- }
- }
-
- private static class TTransactionStandardScheme extends StandardScheme<TTransaction> {
-
- public void read(org.apache.thrift.protocol.TProtocol iprot, TTransaction 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: // TRANSACTION_ID
- if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
- struct.transactionId = iprot.readI64();
- struct.setTransactionIdIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 2: // READ_POINTER
- if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
- struct.readPointer = iprot.readI64();
- struct.setReadPointerIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 3: // INVALIDS
- if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
- {
- org.apache.thrift.protocol.TList _list0 = iprot.readListBegin();
- struct.invalids = new ArrayList<Long>(_list0.size);
- for (int _i1 = 0; _i1 < _list0.size; ++_i1)
- {
- long _elem2; // required
- _elem2 = iprot.readI64();
- struct.invalids.add(_elem2);
- }
- iprot.readListEnd();
- }
- struct.setInvalidsIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 4: // IN_PROGRESS
- if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
- {
- org.apache.thrift.protocol.TList _list3 = iprot.readListBegin();
- struct.inProgress = new ArrayList<Long>(_list3.size);
- for (int _i4 = 0; _i4 < _list3.size; ++_i4)
- {
- long _elem5; // required
- _elem5 = iprot.readI64();
- struct.inProgress.add(_elem5);
- }
- iprot.readListEnd();
- }
- struct.setInProgressIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 5: // FIRST_SHORT
- if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
- struct.firstShort = iprot.readI64();
- struct.setFirstShortIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 6: // TYPE
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
- struct.type = TTransactionType.findByValue(iprot.readI32());
- struct.setTypeIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 7: // WRITE_POINTER
- if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
- struct.writePointer = iprot.readI64();
- struct.setWritePointerIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 8: // CHECKPOINT_WRITE_POINTERS
- if (schemeField.type == org.apache.thrift.protocol.TType.LIST) {
- {
- org.apache.thrift.protocol.TList _list6 = iprot.readListBegin();
- struct.checkpointWritePointers = new ArrayList<Long>(_list6.size);
- for (int _i7 = 0; _i7 < _list6.size; ++_i7)
- {
- long _elem8; // required
- _elem8 = iprot.readI64();
- struct.checkpointWritePointers.add(_elem8);
- }
- iprot.readListEnd();
- }
- struct.setCheckpointWritePointersIsSet(true);
- } else {
- org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
- }
- break;
- case 9: // VISIBILITY_LEVEL
- if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
- struct.visibilityLevel = TVisibilityLevel.findByValue(iprot.readI32());
- struct.setVisibilityLevelIsSet(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();
-
- // check for required fields of primitive type, which can't be checked in the validate method
- struct.validate();
- }
-
- public void write(org.apache.thrift.protocol.TProtocol oprot, TTransaction struct) throws org.apache.thrift.TException {
- struct.validate();
-
- oprot.writeStructBegin(STRUCT_DESC);
- oprot.writeFieldBegin(TRANSACTION_ID_FIELD_DESC);
- oprot.writeI64(struct.transactionId);
- oprot.writeFieldEnd();
- oprot.writeFieldBegin(READ_POINTER_FIELD_DESC);
- oprot.writeI64(struct.readPointer);
- oprot.writeFieldEnd();
- if (struct.invalids != null) {
- oprot.writeFieldBegin(INVALIDS_FIELD_DESC);
- {
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.invalids.size()));
- for (long _iter9 : struct.invalids)
- {
- oprot.writeI64(_iter9);
- }
- oprot.writeListEnd();
- }
- oprot.writeFieldEnd();
- }
- if (struct.inProgress != null) {
- oprot.writeFieldBegin(IN_PROGRESS_FIELD_DESC);
- {
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.inProgress.size()));
- for (long _iter10 : struct.inProgress)
- {
- oprot.writeI64(_iter10);
- }
- oprot.writeListEnd();
- }
- oprot.writeFieldEnd();
- }
- oprot.writeFieldBegin(FIRST_SHORT_FIELD_DESC);
- oprot.writeI64(struct.firstShort);
- oprot.writeFieldEnd();
- if (struct.type != null) {
- oprot.writeFieldBegin(TYPE_FIELD_DESC);
- oprot.writeI32(struct.type.getValue());
- oprot.writeFieldEnd();
- }
- oprot.writeFieldBegin(WRITE_POINTER_FIELD_DESC);
- oprot.writeI64(struct.writePointer);
- oprot.writeFieldEnd();
- if (struct.checkpointWritePointers != null) {
- oprot.writeFieldBegin(CHECKPOINT_WRITE_POINTERS_FIELD_DESC);
- {
- oprot.writeListBegin(new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, struct.checkpointWritePointers.size()));
- for (long _iter11 : struct.checkpointWritePointers)
- {
- oprot.writeI64(_iter11);
- }
- oprot.writeListEnd();
- }
- oprot.writeFieldEnd();
- }
- if (struct.visibilityLevel != null) {
- oprot.writeFieldBegin(VISIBILITY_LEVEL_FIELD_DESC);
- oprot.writeI32(struct.visibilityLevel.getValue());
- oprot.writeFieldEnd();
- }
- oprot.writeFieldStop();
- oprot.writeStructEnd();
- }
-
- }
-
- private static class TTransactionTupleSchemeFactory implements SchemeFactory {
- public TTransactionTupleScheme getScheme() {
- return new TTransactionTupleScheme();
- }
- }
-
- private static class TTransactionTupleScheme extends TupleScheme<TTransaction> {
-
- @Override
- public void write(org.apache.thrift.protocol.TProtocol prot, TTransaction struct) throws org.apache.thrift.TException {
- TTupleProtocol oprot = (TTupleProtocol) prot;
- BitSet optionals = new BitSet();
- if (struct.isSetTransactionId()) {
- optionals.set(0);
- }
- if (struct.isSetReadPointer()) {
- optionals.set(1);
- }
- if (struct.isSetInvalids()) {
- optionals.set(2);
- }
- if (struct.isSetInProgress()) {
- optionals.set(3);
- }
- if (struct.isSetFirstShort()) {
- optionals.set(4);
- }
- if (struct.isSetType()) {
- optionals.set(5);
- }
- if (struct.isSetWritePointer()) {
- optionals.set(6);
- }
- if (struct.isSetCheckpointWritePointers()) {
- optionals.set(7);
- }
- if (struct.isSetVisibilityLevel()) {
- optionals.set(8);
- }
- oprot.writeBitSet(optionals, 9);
- if (struct.isSetTransactionId()) {
- oprot.writeI64(struct.transactionId);
- }
- if (struct.isSetReadPointer()) {
- oprot.writeI64(struct.readPointer);
- }
- if (struct.isSetInvalids()) {
- {
- oprot.writeI32(struct.invalids.size());
- for (long _iter12 : struct.invalids)
- {
- oprot.writeI64(_iter12);
- }
- }
- }
- if (struct.isSetInProgress()) {
- {
- oprot.writeI32(struct.inProgress.size());
- for (long _iter13 : struct.inProgress)
- {
- oprot.writeI64(_iter13);
- }
- }
- }
- if (struct.isSetFirstShort()) {
- oprot.writeI64(struct.firstShort);
- }
- if (struct.isSetType()) {
- oprot.writeI32(struct.type.getValue());
- }
- if (struct.isSetWritePointer()) {
- oprot.writeI64(struct.writePointer);
- }
- if (struct.isSetCheckpointWritePointers()) {
- {
- oprot.writeI32(struct.checkpointWritePointers.size());
- for (long _iter14 : struct.checkpointWritePointers)
- {
- oprot.writeI64(_iter14);
- }
- }
- }
- if (struct.isSetVisibilityLevel()) {
- oprot.writeI32(struct.visibilityLevel.getValue());
- }
- }
-
- @Override
- public void read(org.apache.thrift.protocol.TProtocol prot, TTransaction struct) throws org.apache.thrift.TException {
- TTupleProtocol iprot = (TTupleProtocol) prot;
- BitSet incoming = iprot.readBitSet(9);
- if (incoming.get(0)) {
- struct.transactionId = iprot.readI64();
- struct.setTransactionIdIsSet(true);
- }
- if (incoming.get(1)) {
- struct.readPointer = iprot.readI64();
- struct.setReadPointerIsSet(true);
- }
- if (incoming.get(2)) {
- {
- org.apache.thrift.protocol.TList _list15 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.invalids = new ArrayList<Long>(_list15.size);
- for (int _i16 = 0; _i16 < _list15.size; ++_i16)
- {
- long _elem17; // required
- _elem17 = iprot.readI64();
- struct.invalids.add(_elem17);
- }
- }
- struct.setInvalidsIsSet(true);
- }
- if (incoming.get(3)) {
- {
- org.apache.thrift.protocol.TList _list18 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.inProgress = new ArrayList<Long>(_list18.size);
- for (int _i19 = 0; _i19 < _list18.size; ++_i19)
- {
- long _elem20; // required
- _elem20 = iprot.readI64();
- struct.inProgress.add(_elem20);
- }
- }
- struct.setInProgressIsSet(true);
- }
- if (incoming.get(4)) {
- struct.firstShort = iprot.readI64();
- struct.setFirstShortIsSet(true);
- }
- if (incoming.get(5)) {
- struct.type = TTransactionType.findByValue(iprot.readI32());
- struct.setTypeIsSet(true);
- }
- if (incoming.get(6)) {
- struct.writePointer = iprot.readI64();
- struct.setWritePointerIsSet(true);
- }
- if (incoming.get(7)) {
- {
- org.apache.thrift.protocol.TList _list21 = new org.apache.thrift.protocol.TList(org.apache.thrift.protocol.TType.I64, iprot.readI32());
- struct.checkpointWritePointers = new ArrayList<Long>(_list21.size);
- for (int _i22 = 0; _i22 < _list21.size; ++_i22)
- {
- long _elem23; // required
- _elem23 = iprot.readI64();
- struct.checkpointWritePointers.add(_elem23);
- }
- }
- struct.setCheckpointWritePointersIsSet(true);
- }
- if (incoming.get(8)) {
- struct.visibilityLevel = TVisibilityLevel.findByValue(iprot.readI32());
- struct.setVisibilityLevelIsSet(true);
- }
- }
- }
-
-}
-