accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject [05/10] Merge branch '1.4.5-SNAPSHOT' into 1.5.1-SNAPSHOT
Date Thu, 02 Jan 2014 17:42:32 GMT
http://git-wip-us.apache.org/repos/asf/accumulo/blob/8729dba7/proxy/src/main/java/org/apache/accumulo/proxy/thrift/Key.java
----------------------------------------------------------------------
diff --cc proxy/src/main/java/org/apache/accumulo/proxy/thrift/Key.java
index 1a677a1,0000000..80f2ecd
mode 100644,000000..100644
--- a/proxy/src/main/java/org/apache/accumulo/proxy/thrift/Key.java
+++ b/proxy/src/main/java/org/apache/accumulo/proxy/thrift/Key.java
@@@ -1,846 -1,0 +1,848 @@@
 +/*
 + * 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 org.apache.accumulo.proxy.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;
 +
 +@SuppressWarnings("all") public class Key implements org.apache.thrift.TBase<Key, Key._Fields>,
java.io.Serializable, Cloneable {
 +  private static final org.apache.thrift.protocol.TStruct STRUCT_DESC = new org.apache.thrift.protocol.TStruct("Key");
 +
 +  private static final org.apache.thrift.protocol.TField ROW_FIELD_DESC = new org.apache.thrift.protocol.TField("row",
org.apache.thrift.protocol.TType.STRING, (short)1);
 +  private static final org.apache.thrift.protocol.TField COL_FAMILY_FIELD_DESC = new org.apache.thrift.protocol.TField("colFamily",
org.apache.thrift.protocol.TType.STRING, (short)2);
 +  private static final org.apache.thrift.protocol.TField COL_QUALIFIER_FIELD_DESC = new
org.apache.thrift.protocol.TField("colQualifier", org.apache.thrift.protocol.TType.STRING,
(short)3);
 +  private static final org.apache.thrift.protocol.TField COL_VISIBILITY_FIELD_DESC = new
org.apache.thrift.protocol.TField("colVisibility", org.apache.thrift.protocol.TType.STRING,
(short)4);
 +  private static final org.apache.thrift.protocol.TField TIMESTAMP_FIELD_DESC = new org.apache.thrift.protocol.TField("timestamp",
org.apache.thrift.protocol.TType.I64, (short)5);
 +
 +  private static final Map<Class<? extends IScheme>, SchemeFactory> schemes
= new HashMap<Class<? extends IScheme>, SchemeFactory>();
 +  static {
 +    schemes.put(StandardScheme.class, new KeyStandardSchemeFactory());
 +    schemes.put(TupleScheme.class, new KeyTupleSchemeFactory());
 +  }
 +
 +  public ByteBuffer row; // required
 +  public ByteBuffer colFamily; // required
 +  public ByteBuffer colQualifier; // required
 +  public ByteBuffer colVisibility; // required
 +  public long timestamp; // optional
 +
 +  /** The set of fields this struct contains, along with convenience methods for finding
and manipulating them. */
 +  @SuppressWarnings("all") public enum _Fields implements org.apache.thrift.TFieldIdEnum
{
 +    ROW((short)1, "row"),
 +    COL_FAMILY((short)2, "colFamily"),
 +    COL_QUALIFIER((short)3, "colQualifier"),
 +    COL_VISIBILITY((short)4, "colVisibility"),
 +    TIMESTAMP((short)5, "timestamp");
 +
 +    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: // ROW
 +          return ROW;
 +        case 2: // COL_FAMILY
 +          return COL_FAMILY;
 +        case 3: // COL_QUALIFIER
 +          return COL_QUALIFIER;
 +        case 4: // COL_VISIBILITY
 +          return COL_VISIBILITY;
 +        case 5: // TIMESTAMP
 +          return TIMESTAMP;
 +        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 __TIMESTAMP_ISSET_ID = 0;
 +  private byte __isset_bitfield = 0;
 +  private _Fields optionals[] = {_Fields.TIMESTAMP};
 +  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.ROW, new org.apache.thrift.meta_data.FieldMetaData("row", org.apache.thrift.TFieldRequirementType.DEFAULT,

 +        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING
       , true)));
 +    tmpMap.put(_Fields.COL_FAMILY, new org.apache.thrift.meta_data.FieldMetaData("colFamily",
org.apache.thrift.TFieldRequirementType.DEFAULT, 
 +        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING
       , true)));
 +    tmpMap.put(_Fields.COL_QUALIFIER, new org.apache.thrift.meta_data.FieldMetaData("colQualifier",
org.apache.thrift.TFieldRequirementType.DEFAULT, 
 +        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING
       , true)));
 +    tmpMap.put(_Fields.COL_VISIBILITY, new org.apache.thrift.meta_data.FieldMetaData("colVisibility",
org.apache.thrift.TFieldRequirementType.DEFAULT, 
 +        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.STRING
       , true)));
 +    tmpMap.put(_Fields.TIMESTAMP, new org.apache.thrift.meta_data.FieldMetaData("timestamp",
org.apache.thrift.TFieldRequirementType.OPTIONAL, 
 +        new org.apache.thrift.meta_data.FieldValueMetaData(org.apache.thrift.protocol.TType.I64)));
 +    metaDataMap = Collections.unmodifiableMap(tmpMap);
 +    org.apache.thrift.meta_data.FieldMetaData.addStructMetaDataMap(Key.class, metaDataMap);
 +  }
 +
 +  public Key() {
++    this.timestamp = 9223372036854775807L;
++
 +  }
 +
 +  public Key(
 +    ByteBuffer row,
 +    ByteBuffer colFamily,
 +    ByteBuffer colQualifier,
 +    ByteBuffer colVisibility)
 +  {
 +    this();
 +    this.row = row;
 +    this.colFamily = colFamily;
 +    this.colQualifier = colQualifier;
 +    this.colVisibility = colVisibility;
 +  }
 +
 +  /**
 +   * Performs a deep copy on <i>other</i>.
 +   */
 +  public Key(Key other) {
 +    __isset_bitfield = other.__isset_bitfield;
 +    if (other.isSetRow()) {
 +      this.row = org.apache.thrift.TBaseHelper.copyBinary(other.row);
 +;
 +    }
 +    if (other.isSetColFamily()) {
 +      this.colFamily = org.apache.thrift.TBaseHelper.copyBinary(other.colFamily);
 +;
 +    }
 +    if (other.isSetColQualifier()) {
 +      this.colQualifier = org.apache.thrift.TBaseHelper.copyBinary(other.colQualifier);
 +;
 +    }
 +    if (other.isSetColVisibility()) {
 +      this.colVisibility = org.apache.thrift.TBaseHelper.copyBinary(other.colVisibility);
 +;
 +    }
 +    this.timestamp = other.timestamp;
 +  }
 +
 +  public Key deepCopy() {
 +    return new Key(this);
 +  }
 +
 +  @Override
 +  public void clear() {
 +    this.row = null;
 +    this.colFamily = null;
 +    this.colQualifier = null;
 +    this.colVisibility = null;
-     setTimestampIsSet(false);
-     this.timestamp = 0;
++    this.timestamp = 9223372036854775807L;
++
 +  }
 +
 +  public byte[] getRow() {
 +    setRow(org.apache.thrift.TBaseHelper.rightSize(row));
 +    return row == null ? null : row.array();
 +  }
 +
 +  public ByteBuffer bufferForRow() {
 +    return row;
 +  }
 +
 +  public Key setRow(byte[] row) {
 +    setRow(row == null ? (ByteBuffer)null : ByteBuffer.wrap(row));
 +    return this;
 +  }
 +
 +  public Key setRow(ByteBuffer row) {
 +    this.row = row;
 +    return this;
 +  }
 +
 +  public void unsetRow() {
 +    this.row = null;
 +  }
 +
 +  /** Returns true if field row is set (has been assigned a value) and false otherwise */
 +  public boolean isSetRow() {
 +    return this.row != null;
 +  }
 +
 +  public void setRowIsSet(boolean value) {
 +    if (!value) {
 +      this.row = null;
 +    }
 +  }
 +
 +  public byte[] getColFamily() {
 +    setColFamily(org.apache.thrift.TBaseHelper.rightSize(colFamily));
 +    return colFamily == null ? null : colFamily.array();
 +  }
 +
 +  public ByteBuffer bufferForColFamily() {
 +    return colFamily;
 +  }
 +
 +  public Key setColFamily(byte[] colFamily) {
 +    setColFamily(colFamily == null ? (ByteBuffer)null : ByteBuffer.wrap(colFamily));
 +    return this;
 +  }
 +
 +  public Key setColFamily(ByteBuffer colFamily) {
 +    this.colFamily = colFamily;
 +    return this;
 +  }
 +
 +  public void unsetColFamily() {
 +    this.colFamily = null;
 +  }
 +
 +  /** Returns true if field colFamily is set (has been assigned a value) and false otherwise
*/
 +  public boolean isSetColFamily() {
 +    return this.colFamily != null;
 +  }
 +
 +  public void setColFamilyIsSet(boolean value) {
 +    if (!value) {
 +      this.colFamily = null;
 +    }
 +  }
 +
 +  public byte[] getColQualifier() {
 +    setColQualifier(org.apache.thrift.TBaseHelper.rightSize(colQualifier));
 +    return colQualifier == null ? null : colQualifier.array();
 +  }
 +
 +  public ByteBuffer bufferForColQualifier() {
 +    return colQualifier;
 +  }
 +
 +  public Key setColQualifier(byte[] colQualifier) {
 +    setColQualifier(colQualifier == null ? (ByteBuffer)null : ByteBuffer.wrap(colQualifier));
 +    return this;
 +  }
 +
 +  public Key setColQualifier(ByteBuffer colQualifier) {
 +    this.colQualifier = colQualifier;
 +    return this;
 +  }
 +
 +  public void unsetColQualifier() {
 +    this.colQualifier = null;
 +  }
 +
 +  /** Returns true if field colQualifier is set (has been assigned a value) and false otherwise
*/
 +  public boolean isSetColQualifier() {
 +    return this.colQualifier != null;
 +  }
 +
 +  public void setColQualifierIsSet(boolean value) {
 +    if (!value) {
 +      this.colQualifier = null;
 +    }
 +  }
 +
 +  public byte[] getColVisibility() {
 +    setColVisibility(org.apache.thrift.TBaseHelper.rightSize(colVisibility));
 +    return colVisibility == null ? null : colVisibility.array();
 +  }
 +
 +  public ByteBuffer bufferForColVisibility() {
 +    return colVisibility;
 +  }
 +
 +  public Key setColVisibility(byte[] colVisibility) {
 +    setColVisibility(colVisibility == null ? (ByteBuffer)null : ByteBuffer.wrap(colVisibility));
 +    return this;
 +  }
 +
 +  public Key setColVisibility(ByteBuffer colVisibility) {
 +    this.colVisibility = colVisibility;
 +    return this;
 +  }
 +
 +  public void unsetColVisibility() {
 +    this.colVisibility = null;
 +  }
 +
 +  /** Returns true if field colVisibility is set (has been assigned a value) and false otherwise
*/
 +  public boolean isSetColVisibility() {
 +    return this.colVisibility != null;
 +  }
 +
 +  public void setColVisibilityIsSet(boolean value) {
 +    if (!value) {
 +      this.colVisibility = null;
 +    }
 +  }
 +
 +  public long getTimestamp() {
 +    return this.timestamp;
 +  }
 +
 +  public Key setTimestamp(long timestamp) {
 +    this.timestamp = timestamp;
 +    setTimestampIsSet(true);
 +    return this;
 +  }
 +
 +  public void unsetTimestamp() {
 +    __isset_bitfield = EncodingUtils.clearBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
 +  }
 +
 +  /** Returns true if field timestamp is set (has been assigned a value) and false otherwise
*/
 +  public boolean isSetTimestamp() {
 +    return EncodingUtils.testBit(__isset_bitfield, __TIMESTAMP_ISSET_ID);
 +  }
 +
 +  public void setTimestampIsSet(boolean value) {
 +    __isset_bitfield = EncodingUtils.setBit(__isset_bitfield, __TIMESTAMP_ISSET_ID, value);
 +  }
 +
 +  public void setFieldValue(_Fields field, Object value) {
 +    switch (field) {
 +    case ROW:
 +      if (value == null) {
 +        unsetRow();
 +      } else {
 +        setRow((ByteBuffer)value);
 +      }
 +      break;
 +
 +    case COL_FAMILY:
 +      if (value == null) {
 +        unsetColFamily();
 +      } else {
 +        setColFamily((ByteBuffer)value);
 +      }
 +      break;
 +
 +    case COL_QUALIFIER:
 +      if (value == null) {
 +        unsetColQualifier();
 +      } else {
 +        setColQualifier((ByteBuffer)value);
 +      }
 +      break;
 +
 +    case COL_VISIBILITY:
 +      if (value == null) {
 +        unsetColVisibility();
 +      } else {
 +        setColVisibility((ByteBuffer)value);
 +      }
 +      break;
 +
 +    case TIMESTAMP:
 +      if (value == null) {
 +        unsetTimestamp();
 +      } else {
 +        setTimestamp((Long)value);
 +      }
 +      break;
 +
 +    }
 +  }
 +
 +  public Object getFieldValue(_Fields field) {
 +    switch (field) {
 +    case ROW:
 +      return getRow();
 +
 +    case COL_FAMILY:
 +      return getColFamily();
 +
 +    case COL_QUALIFIER:
 +      return getColQualifier();
 +
 +    case COL_VISIBILITY:
 +      return getColVisibility();
 +
 +    case TIMESTAMP:
 +      return Long.valueOf(getTimestamp());
 +
 +    }
 +    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 ROW:
 +      return isSetRow();
 +    case COL_FAMILY:
 +      return isSetColFamily();
 +    case COL_QUALIFIER:
 +      return isSetColQualifier();
 +    case COL_VISIBILITY:
 +      return isSetColVisibility();
 +    case TIMESTAMP:
 +      return isSetTimestamp();
 +    }
 +    throw new IllegalStateException();
 +  }
 +
 +  @Override
 +  public boolean equals(Object that) {
 +    if (that == null)
 +      return false;
 +    if (that instanceof Key)
 +      return this.equals((Key)that);
 +    return false;
 +  }
 +
 +  public boolean equals(Key that) {
 +    if (that == null)
 +      return false;
 +
 +    boolean this_present_row = true && this.isSetRow();
 +    boolean that_present_row = true && that.isSetRow();
 +    if (this_present_row || that_present_row) {
 +      if (!(this_present_row && that_present_row))
 +        return false;
 +      if (!this.row.equals(that.row))
 +        return false;
 +    }
 +
 +    boolean this_present_colFamily = true && this.isSetColFamily();
 +    boolean that_present_colFamily = true && that.isSetColFamily();
 +    if (this_present_colFamily || that_present_colFamily) {
 +      if (!(this_present_colFamily && that_present_colFamily))
 +        return false;
 +      if (!this.colFamily.equals(that.colFamily))
 +        return false;
 +    }
 +
 +    boolean this_present_colQualifier = true && this.isSetColQualifier();
 +    boolean that_present_colQualifier = true && that.isSetColQualifier();
 +    if (this_present_colQualifier || that_present_colQualifier) {
 +      if (!(this_present_colQualifier && that_present_colQualifier))
 +        return false;
 +      if (!this.colQualifier.equals(that.colQualifier))
 +        return false;
 +    }
 +
 +    boolean this_present_colVisibility = true && this.isSetColVisibility();
 +    boolean that_present_colVisibility = true && that.isSetColVisibility();
 +    if (this_present_colVisibility || that_present_colVisibility) {
 +      if (!(this_present_colVisibility && that_present_colVisibility))
 +        return false;
 +      if (!this.colVisibility.equals(that.colVisibility))
 +        return false;
 +    }
 +
 +    boolean this_present_timestamp = true && this.isSetTimestamp();
 +    boolean that_present_timestamp = true && that.isSetTimestamp();
 +    if (this_present_timestamp || that_present_timestamp) {
 +      if (!(this_present_timestamp && that_present_timestamp))
 +        return false;
 +      if (this.timestamp != that.timestamp)
 +        return false;
 +    }
 +
 +    return true;
 +  }
 +
 +  @Override
 +  public int hashCode() {
 +    return 0;
 +  }
 +
 +  public int compareTo(Key other) {
 +    if (!getClass().equals(other.getClass())) {
 +      return getClass().getName().compareTo(other.getClass().getName());
 +    }
 +
 +    int lastComparison = 0;
 +    Key typedOther = (Key)other;
 +
 +    lastComparison = Boolean.valueOf(isSetRow()).compareTo(typedOther.isSetRow());
 +    if (lastComparison != 0) {
 +      return lastComparison;
 +    }
 +    if (isSetRow()) {
 +      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.row, typedOther.row);
 +      if (lastComparison != 0) {
 +        return lastComparison;
 +      }
 +    }
 +    lastComparison = Boolean.valueOf(isSetColFamily()).compareTo(typedOther.isSetColFamily());
 +    if (lastComparison != 0) {
 +      return lastComparison;
 +    }
 +    if (isSetColFamily()) {
 +      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.colFamily, typedOther.colFamily);
 +      if (lastComparison != 0) {
 +        return lastComparison;
 +      }
 +    }
 +    lastComparison = Boolean.valueOf(isSetColQualifier()).compareTo(typedOther.isSetColQualifier());
 +    if (lastComparison != 0) {
 +      return lastComparison;
 +    }
 +    if (isSetColQualifier()) {
 +      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.colQualifier, typedOther.colQualifier);
 +      if (lastComparison != 0) {
 +        return lastComparison;
 +      }
 +    }
 +    lastComparison = Boolean.valueOf(isSetColVisibility()).compareTo(typedOther.isSetColVisibility());
 +    if (lastComparison != 0) {
 +      return lastComparison;
 +    }
 +    if (isSetColVisibility()) {
 +      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.colVisibility, typedOther.colVisibility);
 +      if (lastComparison != 0) {
 +        return lastComparison;
 +      }
 +    }
 +    lastComparison = Boolean.valueOf(isSetTimestamp()).compareTo(typedOther.isSetTimestamp());
 +    if (lastComparison != 0) {
 +      return lastComparison;
 +    }
 +    if (isSetTimestamp()) {
 +      lastComparison = org.apache.thrift.TBaseHelper.compareTo(this.timestamp, typedOther.timestamp);
 +      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("Key(");
 +    boolean first = true;
 +
 +    sb.append("row:");
 +    if (this.row == null) {
 +      sb.append("null");
 +    } else {
 +      org.apache.thrift.TBaseHelper.toString(this.row, sb);
 +    }
 +    first = false;
 +    if (!first) sb.append(", ");
 +    sb.append("colFamily:");
 +    if (this.colFamily == null) {
 +      sb.append("null");
 +    } else {
 +      org.apache.thrift.TBaseHelper.toString(this.colFamily, sb);
 +    }
 +    first = false;
 +    if (!first) sb.append(", ");
 +    sb.append("colQualifier:");
 +    if (this.colQualifier == null) {
 +      sb.append("null");
 +    } else {
 +      org.apache.thrift.TBaseHelper.toString(this.colQualifier, sb);
 +    }
 +    first = false;
 +    if (!first) sb.append(", ");
 +    sb.append("colVisibility:");
 +    if (this.colVisibility == null) {
 +      sb.append("null");
 +    } else {
 +      org.apache.thrift.TBaseHelper.toString(this.colVisibility, sb);
 +    }
 +    first = false;
 +    if (isSetTimestamp()) {
 +      if (!first) sb.append(", ");
 +      sb.append("timestamp:");
 +      sb.append(this.timestamp);
 +      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 KeyStandardSchemeFactory implements SchemeFactory {
 +    public KeyStandardScheme getScheme() {
 +      return new KeyStandardScheme();
 +    }
 +  }
 +
 +  private static class KeyStandardScheme extends StandardScheme<Key> {
 +
 +    public void read(org.apache.thrift.protocol.TProtocol iprot, Key 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: // ROW
 +            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
 +              struct.row = iprot.readBinary();
 +              struct.setRowIsSet(true);
 +            } else { 
 +              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
 +            }
 +            break;
 +          case 2: // COL_FAMILY
 +            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
 +              struct.colFamily = iprot.readBinary();
 +              struct.setColFamilyIsSet(true);
 +            } else { 
 +              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
 +            }
 +            break;
 +          case 3: // COL_QUALIFIER
 +            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
 +              struct.colQualifier = iprot.readBinary();
 +              struct.setColQualifierIsSet(true);
 +            } else { 
 +              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
 +            }
 +            break;
 +          case 4: // COL_VISIBILITY
 +            if (schemeField.type == org.apache.thrift.protocol.TType.STRING) {
 +              struct.colVisibility = iprot.readBinary();
 +              struct.setColVisibilityIsSet(true);
 +            } else { 
 +              org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
 +            }
 +            break;
 +          case 5: // TIMESTAMP
 +            if (schemeField.type == org.apache.thrift.protocol.TType.I64) {
 +              struct.timestamp = iprot.readI64();
 +              struct.setTimestampIsSet(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, Key struct) throws org.apache.thrift.TException
{
 +      struct.validate();
 +
 +      oprot.writeStructBegin(STRUCT_DESC);
 +      if (struct.row != null) {
 +        oprot.writeFieldBegin(ROW_FIELD_DESC);
 +        oprot.writeBinary(struct.row);
 +        oprot.writeFieldEnd();
 +      }
 +      if (struct.colFamily != null) {
 +        oprot.writeFieldBegin(COL_FAMILY_FIELD_DESC);
 +        oprot.writeBinary(struct.colFamily);
 +        oprot.writeFieldEnd();
 +      }
 +      if (struct.colQualifier != null) {
 +        oprot.writeFieldBegin(COL_QUALIFIER_FIELD_DESC);
 +        oprot.writeBinary(struct.colQualifier);
 +        oprot.writeFieldEnd();
 +      }
 +      if (struct.colVisibility != null) {
 +        oprot.writeFieldBegin(COL_VISIBILITY_FIELD_DESC);
 +        oprot.writeBinary(struct.colVisibility);
 +        oprot.writeFieldEnd();
 +      }
 +      if (struct.isSetTimestamp()) {
 +        oprot.writeFieldBegin(TIMESTAMP_FIELD_DESC);
 +        oprot.writeI64(struct.timestamp);
 +        oprot.writeFieldEnd();
 +      }
 +      oprot.writeFieldStop();
 +      oprot.writeStructEnd();
 +    }
 +
 +  }
 +
 +  private static class KeyTupleSchemeFactory implements SchemeFactory {
 +    public KeyTupleScheme getScheme() {
 +      return new KeyTupleScheme();
 +    }
 +  }
 +
 +  private static class KeyTupleScheme extends TupleScheme<Key> {
 +
 +    @Override
 +    public void write(org.apache.thrift.protocol.TProtocol prot, Key struct) throws org.apache.thrift.TException
{
 +      TTupleProtocol oprot = (TTupleProtocol) prot;
 +      BitSet optionals = new BitSet();
 +      if (struct.isSetRow()) {
 +        optionals.set(0);
 +      }
 +      if (struct.isSetColFamily()) {
 +        optionals.set(1);
 +      }
 +      if (struct.isSetColQualifier()) {
 +        optionals.set(2);
 +      }
 +      if (struct.isSetColVisibility()) {
 +        optionals.set(3);
 +      }
 +      if (struct.isSetTimestamp()) {
 +        optionals.set(4);
 +      }
 +      oprot.writeBitSet(optionals, 5);
 +      if (struct.isSetRow()) {
 +        oprot.writeBinary(struct.row);
 +      }
 +      if (struct.isSetColFamily()) {
 +        oprot.writeBinary(struct.colFamily);
 +      }
 +      if (struct.isSetColQualifier()) {
 +        oprot.writeBinary(struct.colQualifier);
 +      }
 +      if (struct.isSetColVisibility()) {
 +        oprot.writeBinary(struct.colVisibility);
 +      }
 +      if (struct.isSetTimestamp()) {
 +        oprot.writeI64(struct.timestamp);
 +      }
 +    }
 +
 +    @Override
 +    public void read(org.apache.thrift.protocol.TProtocol prot, Key struct) throws org.apache.thrift.TException
{
 +      TTupleProtocol iprot = (TTupleProtocol) prot;
 +      BitSet incoming = iprot.readBitSet(5);
 +      if (incoming.get(0)) {
 +        struct.row = iprot.readBinary();
 +        struct.setRowIsSet(true);
 +      }
 +      if (incoming.get(1)) {
 +        struct.colFamily = iprot.readBinary();
 +        struct.setColFamilyIsSet(true);
 +      }
 +      if (incoming.get(2)) {
 +        struct.colQualifier = iprot.readBinary();
 +        struct.setColQualifierIsSet(true);
 +      }
 +      if (incoming.get(3)) {
 +        struct.colVisibility = iprot.readBinary();
 +        struct.setColVisibilityIsSet(true);
 +      }
 +      if (incoming.get(4)) {
 +        struct.timestamp = iprot.readI64();
 +        struct.setTimestampIsSet(true);
 +      }
 +    }
 +  }
 +
 +}
 +

http://git-wip-us.apache.org/repos/asf/accumulo/blob/8729dba7/proxy/src/main/thrift/proxy.thrift
----------------------------------------------------------------------
diff --cc proxy/src/main/thrift/proxy.thrift
index 8d3c87d,0000000..7fd2c3f
mode 100644,000000..100644
--- a/proxy/src/main/thrift/proxy.thrift
+++ b/proxy/src/main/thrift/proxy.thrift
@@@ -1,342 -1,0 +1,344 @@@
 +/*
 +* 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.
 +*/
 +namespace cpp accumulo
 +namespace java org.apache.accumulo.proxy.thrift
++namespace rb Accumulo
++namespace py accumulo
 +
 +struct Key {
 +  1:binary row;
 +  2:binary colFamily;
 +  3:binary colQualifier;
 +  4:binary colVisibility;
-   5:optional i64 timestamp
++  5:optional i64 timestamp = 0x7FFFFFFFFFFFFFFF
 +}
 +
 +enum PartialKey {
 +  ROW,
 +  ROW_COLFAM,
 +  ROW_COLFAM_COLQUAL,
 +  ROW_COLFAM_COLQUAL_COLVIS,
 +  ROW_COLFAM_COLQUAL_COLVIS_TIME,
 +  ROW_COLFAM_COLQUAL_COLVIS_TIME_DEL
 +}
 +
 +struct ColumnUpdate {
 +  1:binary colFamily,
 +  2:binary colQualifier,
 +  3:optional binary colVisibility,
 +  4:optional i64 timestamp,
 +  5:optional binary value,
 +  6:optional bool deleteCell
 +}
 +
 +struct KeyValue {
 +  1:Key key,
 +  2:binary value
 +}
 +
 +struct ScanResult {
 +  1:list<KeyValue> results,
 +  2:bool more
 +}
 +
 +struct Range {
 +  1:Key start,
 +  2:bool startInclusive
 +  3:Key stop,
 +  4:bool stopInclusive
 +}
 +
 +struct ScanColumn {
 +  1:binary colFamily,
 +  2:optional binary colQualifier
 +}
 +
 +struct IteratorSetting {
 +  1: i32 priority,
 +  2: string name,
 +  3: string iteratorClass,
 +  4: map<string,string> properties
 +}
 +
 +struct ScanOptions {
 +  1:optional set<binary> authorizations;
 +  2:optional Range range,
 +  3:optional list<ScanColumn> columns;
 +  4:optional list<IteratorSetting> iterators;
 +  5:optional i32 bufferSize;
 +} 
 +
 +struct BatchScanOptions {
 +  1:optional set<binary> authorizations;
 +  2:optional list<Range> ranges;
 +  3:optional list<ScanColumn> columns;
 +  4:optional list<IteratorSetting> iterators;
 +  5:optional i32 threads;
 +} 
 +
 +struct KeyValueAndPeek {
 +  1:KeyValue keyValue,
 +  2:bool hasNext
 +}
 +
 +enum TablePermission {
 +  READ = 2,
 +  WRITE = 3,
 +  BULK_IMPORT = 4,
 +  ALTER_TABLE = 5,
 +  GRANT = 6,
 +  DROP_TABLE = 7,
 +}
 +
 +enum SystemPermission {
 +  GRANT = 0,
 +  CREATE_TABLE = 1,
 +  DROP_TABLE = 2,
 +  ALTER_TABLE = 3,
 +  CREATE_USER = 4,
 +  DROP_USER = 5,
 +  ALTER_USER = 6,
 +  SYSTEM = 7,
 +}
 +
 +enum ScanType {
 +    SINGLE,
 +    BATCH
 +}
 +
 +enum ScanState {
 +    IDLE,
 +    RUNNING,
 +    QUEUED
 +}
 +
 +struct KeyExtent {
 +  1:string tableId,
 +  2:binary endRow,
 +  3:binary prevEndRow
 +}
 +
 +struct Column {
 +  1:binary colFamily;
 +  2:binary colQualifier;
 +  3:binary colVisibility;
 +}
 +
 +struct ActiveScan {
 +  1:string client
 +  2:string user
 +  3:string table
 +  4:i64 age
 +  5:i64 idleTime
 +  6:ScanType type
 +  7:ScanState state
 +  8:KeyExtent extent
 +  9:list<Column> columns
 +  10:list<IteratorSetting> iterators
 +  11:list<binary> authorizations
 +}
 +
 +enum CompactionType {
 +   MINOR,
 +   MERGE,
 +   MAJOR,
 +   FULL
 +}
 +
 +enum CompactionReason {
 +   USER,
 +   SYSTEM,
 +   CHOP,
 +   IDLE,
 +   CLOSE
 +}
 +
 +struct ActiveCompaction {
 +  1:KeyExtent extent
 +  2:i64 age
 +  3:list<string> inputFiles
 +  4:string outputFile
 +  5:CompactionType type
 +  6:CompactionReason reason
 +  7:string localityGroup
 +  8:i64 entriesRead
 +  9:i64 entriesWritten
 +  10:list<IteratorSetting> iterators;
 +}
 +
 +struct WriterOptions {
 + 1:i64 maxMemory
 + 2:i64 latencyMs
 + 3:i64 timeoutMs
 + 4:i32 threads
 +}
 +
 +enum IteratorScope {
 +  MINC,
 +  MAJC,
 +  SCAN
 +}
 +
 +enum TimeType {
 +  LOGICAL,
 +  MILLIS
 +}
 +
 +exception UnknownScanner {
 +  1:string msg
 +}
 +
 +exception UnknownWriter {
 +  1:string msg
 +}
 +
 +exception NoMoreEntriesException {
 +  1:string msg
 +}
 +
 +exception AccumuloException {
 +  1:string msg
 +}
 +
 +exception AccumuloSecurityException {
 +  1:string msg
 +}
 +
 +exception TableNotFoundException {
 +  1:string msg
 +}
 +
 +exception TableExistsException {
 +  1:string msg
 +}
 +
 +exception MutationsRejectedException {
 +  1:string msg
 +}
 +
 +service AccumuloProxy
 +{
 +  // get an authentication token
 +  binary login(1:string principal, 2:map<string, string> loginProperties)        
                     throws (1:AccumuloSecurityException ouch2);
 +
 +  // table operations
 +  i32 addConstraint (1:binary login, 2:string tableName, 3:string constraintClassName) 
               throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  void addSplits (1:binary login, 2:string tableName, 3:set<binary> splits)      
                     throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2,
3:TableNotFoundException ouch3);
 +  void attachIterator (1:binary login, 2:string tableName, 3:IteratorSetting setting, 
 +                       4:set<IteratorScope> scopes) 
 +                                                                                       
               throws (1:AccumuloSecurityException ouch1, 2:AccumuloException ouch2, 3:TableNotFoundException
ouch3);
 +  void checkIteratorConflicts (1:binary login, 2:string tableName, 3:IteratorSetting setting,

 +                               4:set<IteratorScope> scopes) 
 +                                                                                       
               throws (1:AccumuloSecurityException ouch1, 2:AccumuloException ouch2, 3:TableNotFoundException
ouch3);
 +  void clearLocatorCache (1:binary login, 2:string tableName)                          
               throws (1:TableNotFoundException ouch1);
 +  void cloneTable (1:binary login, 2:string tableName, 3:string newTableName, 4:bool flush,

 +                   5:map<string,string> propertiesToSet, 6:set<string> propertiesToExclude)

 +                                                                                       
               throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3, 4:TableExistsException ouch4);
 +  void compactTable (1:binary login, 2:string tableName, 3:binary startRow, 4:binary endRow,

 +		     5:list<IteratorSetting> iterators, 6:bool flush, 7:bool wait)             
               throws (1:AccumuloSecurityException ouch1, 2:TableNotFoundException ouch2,
3:AccumuloException ouch3);
 +  void cancelCompaction(1:binary login, 2:string tableName)                            
               throws (1:AccumuloSecurityException ouch1, 2:TableNotFoundException ouch2,
3:AccumuloException ouch3);
 +                                                                                       
                    
 +  void createTable (1:binary login, 2:string tableName, 3:bool versioningIter, 4:TimeType
type)        throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableExistsException
ouch3);
 +  void deleteTable (1:binary login, 2:string tableName)                                
               throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  void deleteRows (1:binary login, 2:string tableName, 3:binary startRow, 4:binary endRow)
            throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  void exportTable (1:binary login, 2:string tableName, 3:string exportDir)            
               throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  void flushTable (1:binary login, 2:string tableName, 3:binary startRow, 4:binary endRow,

 +                   5:bool wait)
 +                                                                                       
               throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  map<string,set<string>> getLocalityGroups (1:binary login, 2:string tableName)
                      throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2,
3:TableNotFoundException ouch3);
 +  IteratorSetting getIteratorSetting (1:binary login, 2:string tableName, 
 +                                      3:string iteratorName, 4:IteratorScope scope) 
 +                                                                                       
               throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  binary getMaxRow (1:binary login, 2:string tableName, 3:set<binary> auths, 4:binary
startRow, 
 +                    5:bool startInclusive, 6:binary endRow, 7:bool endInclusive) 
 +                                                                                       
               throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  map<string,string> getTableProperties (1:binary login, 2:string tableName)     
                     throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2,
3:TableNotFoundException ouch3);
 +  void importDirectory (1:binary login, 2:string tableName, 3:string importDir, 
 +                        4:string failureDir, 5:bool setTime) 
 +                                                                                       
               throws (1:TableNotFoundException ouch1, 2:AccumuloException ouch3, 3:AccumuloSecurityException
ouch4);
 +  void importTable (1:binary login, 2:string tableName, 3:string importDir)            
               throws (1:TableExistsException ouch1, 2:AccumuloException ouch2, 3:AccumuloSecurityException
ouch3);
 +  list<binary> listSplits (1:binary login, 2:string tableName, 3:i32 maxSplits)  
                     throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2,
3:TableNotFoundException ouch3);
 +  set<string> listTables (1:binary login);
 +  map<string,set<IteratorScope>> listIterators (1:binary login, 2:string tableName)
                   throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  map<string,i32> listConstraints (1:binary login, 2:string tableName)           
                     throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2,
3:TableNotFoundException ouch3);
 +  void mergeTablets (1:binary login, 2:string tableName, 3:binary startRow, 4:binary endRow)
          throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  void offlineTable (1:binary login, 2:string tableName)                               
               throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  void onlineTable (1:binary login, 2:string tableName)                                
               throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  void removeConstraint (1:binary login, 2:string tableName, 3:i32 constraint)         
               throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  void removeIterator (1:binary login, 2:string tableName, 3:string iterName, 
 +                       4:set<IteratorScope> scopes)
 +                                                                                       
               throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  void removeTableProperty (1:binary login, 2:string tableName, 3:string property)     
               throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  void renameTable (1:binary login, 2:string oldTableName, 3:string newTableName)      
               throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3, 4:TableExistsException ouch4);
 +  void setLocalityGroups (1:binary login, 2:string tableName, 3:map<string,set<string>>
groups)        throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  void setTableProperty (1:binary login, 2:string tableName, 3:string property, 4:string
value)        throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  set<Range> splitRangeByTablets (1:binary login, 2:string tableName, 3:Range range,
4:i32 maxSplits)  throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  bool tableExists (1:binary login, 2:string tableName);
 +  map<string,string> tableIdMap (1:binary login);
 +  bool testTableClassLoad (1:binary login, 2:string tableName, 3:string className      
              
 +                           , 4:string asTypeName)                                      
               throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +
 +  // instance operations
 +  void pingTabletServer(1:binary login, 2:string tserver)                              
             throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  list<ActiveScan> getActiveScans (1:binary login, 2:string tserver)             
                   throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  list<ActiveCompaction> getActiveCompactions(1:binary login, 2:string tserver)  
                   throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  map<string,string> getSiteConfiguration (1:binary login)                       
                   throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  map<string,string> getSystemConfiguration (1:binary login)                     
                   throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  list<string> getTabletServers (1:binary login);
 +  void removeProperty (1:binary login, 2:string property)                              
             throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  void setProperty (1:binary login, 2:string property, 3:string value)                 
             throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  bool testClassLoad (1:binary login, 2:string className, 3:string asTypeName)         
             throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +
 +  // security operations
 +  bool authenticateUser (1:binary login, 2:string user, 3:map<string, string> properties)
           throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  void changeUserAuthorizations (1:binary login, 2:string user, 3:set<binary> authorizations)
       throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  void changeLocalUserPassword (1:binary login, 2:string user, 3:binary password)      
             throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  void createLocalUser (1:binary login, 2:string user, 3:binary password)              
             throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  void dropLocalUser (1:binary login, 2:string user)                                   
             throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  list<binary> getUserAuthorizations (1:binary login, 2:string user)             
                   throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  void grantSystemPermission (1:binary login, 2:string user, 3:SystemPermission perm)  
             throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  void grantTablePermission (1:binary login, 2:string user, 3:string table, 4:TablePermission
perm)  throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  bool hasSystemPermission (1:binary login, 2:string user, 3:SystemPermission perm)    
             throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  bool hasTablePermission (1:binary login, 2:string user, 3:string table, 4:TablePermission
perm)    throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  set<string> listLocalUsers (1:binary login)                                    
                   throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  void revokeSystemPermission (1:binary login, 2:string user, 3:SystemPermission perm) 
             throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2);
 +  void revokeTablePermission (1:binary login, 2:string user, 3:string table, 4:TablePermission
perm) throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +
 +
 +  // scanning
 +  string createBatchScanner(1:binary login, 2:string tableName, 3:BatchScanOptions options)
         throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +  string createScanner(1:binary login, 2:string tableName, 3:ScanOptions options)      
             throws (1:AccumuloException ouch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +
 +  // use the scanner
 +  bool hasNext(1:string scanner)                        throws(1:UnknownScanner ouch1);
 +  KeyValueAndPeek nextEntry(1:string scanner)           throws(1:NoMoreEntriesException
ouch1, 2:UnknownScanner ouch2, 3:AccumuloSecurityException ouch3);
 +  ScanResult nextK(1:string scanner, 2:i32 k)           throws(1:NoMoreEntriesException
ouch1, 2:UnknownScanner ouch2, 3:AccumuloSecurityException ouch3);
 +  void closeScanner(1:string scanner)                   throws(1:UnknownScanner ouch1);
 +
 +  // writing
 +  void updateAndFlush(1:binary login, 2:string tableName, 3:map<binary, list<ColumnUpdate>>
cells) throws(1:AccumuloException outch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3, 4:MutationsRejectedException ouch4);
 +  string createWriter(1:binary login, 2:string tableName, 3:WriterOptions opts)        
           throws(1:AccumuloException outch1, 2:AccumuloSecurityException ouch2, 3:TableNotFoundException
ouch3);
 +
 +  // use the writer
 +  oneway void update(1:string writer, 2:map<binary, list<ColumnUpdate>> cells);
 +  void flush(1:string writer)                                                          
           throws (1:UnknownWriter ouch1, 2:MutationsRejectedException ouch2);
 +  void closeWriter(1:string writer)                                                    
           throws (1:UnknownWriter ouch1, 2:MutationsRejectedException ouch2);
 +
 +  // utilities
 +  Range getRowRange(1:binary row);
 +  Key getFollowing(1:Key key, 2:PartialKey part);
 +}


Mime
View raw message