support auth for scan

client/src/main/generated/EndSendCheckpointResponse.java

@@ -0,0 +1,283 @@
+/**
+ * Autogenerated by Thrift
+ *
+ * DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
+ *  @generated
+ */
+import java.util.List;
+import java.util.ArrayList;
+import java.util.Map;
+import java.util.HashMap;
+import java.util.Set;
+import java.util.HashSet;
+import java.util.Collections;
+import java.util.BitSet;
+import java.util.Arrays;
+import com.facebook.thrift.*;
+import com.facebook.thrift.annotations.*;
+import com.facebook.thrift.async.*;
+import com.facebook.thrift.meta_data.*;
+import com.facebook.thrift.server.*;
+import com.facebook.thrift.transport.*;
+import com.facebook.thrift.protocol.*;
+
+@SuppressWarnings({ "unused", "serial" })
+public class EndSendCheckpointResponse implements TBase, java.io.Serializable, Cloneable, Comparable<EndSendCheckpointResponse> {
+  private static final TStruct STRUCT_DESC = new TStruct("EndSendCheckpointResponse");
+  private static final TField ERROR_CODE_FIELD_DESC = new TField("error_code", TType.I32, (short)1);
+
+  /**
+   * 
+   * @see com.vesoft.nebula.ErrorCode
+   */
+  public com.vesoft.nebula.ErrorCode error_code;
+  public static final int ERROR_CODE = 1;
+
+  // isset id assignments
+
+  public static final Map<Integer, FieldMetaData> metaDataMap;
+
+  static {
+    Map<Integer, FieldMetaData> tmpMetaDataMap = new HashMap<Integer, FieldMetaData>();
+    tmpMetaDataMap.put(ERROR_CODE, new FieldMetaData("error_code", TFieldRequirementType.DEFAULT, 
+        new FieldValueMetaData(TType.I32)));
+    metaDataMap = Collections.unmodifiableMap(tmpMetaDataMap);
+  }
+
+  static {
+    FieldMetaData.addStructMetaDataMap(EndSendCheckpointResponse.class, metaDataMap);
+  }
+
+  public EndSendCheckpointResponse() {
+  }
+
+  public EndSendCheckpointResponse(
+      com.vesoft.nebula.ErrorCode error_code) {
+    this();
+    this.error_code = error_code;
+  }
+
+  public static class Builder {
+    private com.vesoft.nebula.ErrorCode error_code;
+
+    public Builder() {
+    }
+
+    public Builder setError_code(final com.vesoft.nebula.ErrorCode error_code) {
+      this.error_code = error_code;
+      return this;
+    }
+
+    public EndSendCheckpointResponse build() {
+      EndSendCheckpointResponse result = new EndSendCheckpointResponse();
+      result.setError_code(this.error_code);
+      return result;
+    }
+  }
+
+  public static Builder builder() {
+    return new Builder();
+  }
+
+  /**
+   * Performs a deep copy on <i>other</i>.
+   */
+  public EndSendCheckpointResponse(EndSendCheckpointResponse other) {
+    if (other.isSetError_code()) {
+      this.error_code = TBaseHelper.deepCopy(other.error_code);
+    }
+  }
+
+  public EndSendCheckpointResponse deepCopy() {
+    return new EndSendCheckpointResponse(this);
+  }
+
+  /**
+   * 
+   * @see com.vesoft.nebula.ErrorCode
+   */
+  public com.vesoft.nebula.ErrorCode getError_code() {
+    return this.error_code;
+  }
+
+  /**
+   * 
+   * @see com.vesoft.nebula.ErrorCode
+   */
+  public EndSendCheckpointResponse setError_code(com.vesoft.nebula.ErrorCode error_code) {
+    this.error_code = error_code;
+    return this;
+  }
+
+  public void unsetError_code() {
+    this.error_code = null;
+  }
+
+  // Returns true if field error_code is set (has been assigned a value) and false otherwise
+  public boolean isSetError_code() {
+    return this.error_code != null;
+  }
+
+  public void setError_codeIsSet(boolean __value) {
+    if (!__value) {
+      this.error_code = null;
+    }
+  }
+
+  public void setFieldValue(int fieldID, Object __value) {
+    switch (fieldID) {
+    case ERROR_CODE:
+      if (__value == null) {
+        unsetError_code();
+      } else {
+        setError_code((com.vesoft.nebula.ErrorCode)__value);
+      }
+      break;
+
+    default:
+      throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
+    }
+  }
+
+  public Object getFieldValue(int fieldID) {
+    switch (fieldID) {
+    case ERROR_CODE:
+      return getError_code();
+
+    default:
+      throw new IllegalArgumentException("Field " + fieldID + " doesn't exist!");
+    }
+  }
+
+  @Override
+  public boolean equals(Object _that) {
+    if (_that == null)
+      return false;
+    if (this == _that)
+      return true;
+    if (!(_that instanceof EndSendCheckpointResponse))
+      return false;
+    EndSendCheckpointResponse that = (EndSendCheckpointResponse)_that;
+
+    if (!TBaseHelper.equalsNobinary(this.isSetError_code(), that.isSetError_code(), this.error_code, that.error_code)) { return false; }
+
+    return true;
+  }
+
+  @Override
+  public int hashCode() {
+    return Arrays.deepHashCode(new Object[] {error_code});
+  }
+
+  @Override
+  public int compareTo(EndSendCheckpointResponse other) {
+    if (other == null) {
+      // See java.lang.Comparable docs
+      throw new NullPointerException();
+    }
+
+    if (other == this) {
+      return 0;
+    }
+    int lastComparison = 0;
+
+    lastComparison = Boolean.valueOf(isSetError_code()).compareTo(other.isSetError_code());
+    if (lastComparison != 0) {
+      return lastComparison;
+    }
+    lastComparison = TBaseHelper.compareTo(error_code, other.error_code);
+    if (lastComparison != 0) { 
+      return lastComparison;
+    }
+    return 0;
+  }
+
+  public void read(TProtocol iprot) throws TException {
+    TField __field;
+    iprot.readStructBegin(metaDataMap);
+    while (true)
+    {
+      __field = iprot.readFieldBegin();
+      if (__field.type == TType.STOP) { 
+        break;
+      }
+      switch (__field.id)
+      {
+        case ERROR_CODE:
+          if (__field.type == TType.I32) {
+            this.error_code = com.vesoft.nebula.ErrorCode.findByValue(iprot.readI32());
+          } else { 
+            TProtocolUtil.skip(iprot, __field.type);
+          }
+          break;
+        default:
+          TProtocolUtil.skip(iprot, __field.type);
+          break;
+      }
+      iprot.readFieldEnd();
+    }
+    iprot.readStructEnd();
+
+
+    // check for required fields of primitive type, which can't be checked in the validate method
+    validate();
+  }
+
+  public void write(TProtocol oprot) throws TException {
+    validate();
+
+    oprot.writeStructBegin(STRUCT_DESC);
+    if (this.error_code != null) {
+      oprot.writeFieldBegin(ERROR_CODE_FIELD_DESC);
+      oprot.writeI32(this.error_code == null ? 0 : this.error_code.getValue());
+      oprot.writeFieldEnd();
+    }
+    oprot.writeFieldStop();
+    oprot.writeStructEnd();
+  }
+
+  @Override
+  public String toString() {
+    return toString(1, true);
+  }
+
+  @Override
+  public String toString(int indent, boolean prettyPrint) {
+    String indentStr = prettyPrint ? TBaseHelper.getIndentedString(indent) : "";
+    String newLine = prettyPrint ? "\n" : "";
+    String space = prettyPrint ? " " : "";
+    StringBuilder sb = new StringBuilder("EndSendCheckpointResponse");
+    sb.append(space);
+    sb.append("(");
+    sb.append(newLine);
+    boolean first = true;
+
+    sb.append(indentStr);
+    sb.append("error_code");
+    sb.append(space);
+    sb.append(":").append(space);
+    if (this.getError_code() == null) {
+      sb.append("null");
+    } else {
+      String error_code_name = this.getError_code() == null ? "null" : this.getError_code().name();
+      if (error_code_name != null) {
+        sb.append(error_code_name);
+        sb.append(" (");
+      }
+      sb.append(this.getError_code());
+      if (error_code_name != null) {
+        sb.append(")");
+      }
+    }
+    first = false;
+    sb.append(newLine + TBaseHelper.reduceIndent(indentStr));
+    sb.append(")");
+    return sb.toString();
+  }
+
+  public void validate() throws TException {
+    // check for required fields
+  }
+
+}
+