Java 类org.apache.thrift.protocol.TProtocolException 实例源码

项目:fresco_floodlight    文件:DeleteRequestMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (storeName == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'storeName' was not present! Struct: " + toString());
  }
  if (key == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'key' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (version != null) {
    version.validate();
  }
}
项目:fresco_floodlight    文件:SyncOfferMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (store == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'store' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (store != null) {
    store.validate();
  }
}
项目:fresco_floodlight    文件:RegisterRequestMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (store == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'store' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (store != null) {
    store.validate();
  }
}
项目:fresco_floodlight    文件:ClusterJoinRequestMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (node == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'node' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (node != null) {
    node.validate();
  }
}
项目:fresco_floodlight    文件:PutRequestMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (storeName == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'storeName' was not present! Struct: " + toString());
  }
  if (key == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'key' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (versionedValue != null) {
    versionedValue.validate();
  }
}
项目:fresco_floodlight    文件:SyncValueMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (store == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'store' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (store != null) {
    store.validate();
  }
}
项目:fresco_floodlight    文件:GetRequestMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (storeName == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'storeName' was not present! Struct: " + toString());
  }
  if (key == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'key' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
}
项目:iTAP-controller    文件:DeleteRequestMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (storeName == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'storeName' was not present! Struct: " + toString());
  }
  if (key == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'key' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (version != null) {
    version.validate();
  }
}
项目:iTAP-controller    文件:SyncOfferMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (store == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'store' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (store != null) {
    store.validate();
  }
}
项目:iTAP-controller    文件:RegisterRequestMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (store == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'store' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (store != null) {
    store.validate();
  }
}
项目:iTAP-controller    文件:ClusterJoinRequestMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (node == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'node' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (node != null) {
    node.validate();
  }
}
项目:iTAP-controller    文件:PutRequestMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (storeName == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'storeName' was not present! Struct: " + toString());
  }
  if (key == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'key' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (versionedValue != null) {
    versionedValue.validate();
  }
}
项目:iTAP-controller    文件:SyncRequestMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (store == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'store' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (store != null) {
    store.validate();
  }
}
项目:iTAP-controller    文件:SyncValueMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (store == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'store' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (store != null) {
    store.validate();
  }
}
项目:iTAP-controller    文件:GetRequestMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  if (storeName == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'storeName' was not present! Struct: " + toString());
  }
  if (key == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'key' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
}
项目:iotdb-jdbc    文件:TSOpenSessionResp.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (status == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'status' was not present! Struct: " + toString());
  }
  if (serverProtocolVersion == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'serverProtocolVersion' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (status != null) {
    status.validate();
  }
  if (sessionHandle != null) {
    sessionHandle.validate();
  }
}
项目:ditb    文件:THBaseService.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (table == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'table' was not present! Struct: " + toString());
  }
  if (row == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'row' was not present! Struct: " + toString());
  }
  if (family == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'family' was not present! Struct: " + toString());
  }
  if (qualifier == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'qualifier' was not present! Struct: " + toString());
  }
  if (tput == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'tput' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (tput != null) {
    tput.validate();
  }
}
项目:ditb    文件:THBaseService.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (table == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'table' was not present! Struct: " + toString());
  }
  if (row == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'row' was not present! Struct: " + toString());
  }
  if (family == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'family' was not present! Struct: " + toString());
  }
  if (qualifier == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'qualifier' was not present! Struct: " + toString());
  }
  if (tdelete == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'tdelete' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (tdelete != null) {
    tdelete.validate();
  }
}
项目:ditb    文件:TMutation.java   
@Override
protected Object tupleSchemeReadValue(org.apache.thrift.protocol.TProtocol iprot, short fieldID) throws org.apache.thrift.TException {
  _Fields setField = _Fields.findByThriftId(fieldID);
  if (setField != null) {
    switch (setField) {
      case PUT:
        TPut put;
        put = new TPut();
        put.read(iprot);
        return put;
      case DELETE_SINGLE:
        TDelete deleteSingle;
        deleteSingle = new TDelete();
        deleteSingle.read(iprot);
        return deleteSingle;
      default:
        throw new IllegalStateException("setField wasn't null, but didn't match any of the case statements!");
    }
  } else {
    throw new TProtocolException("Couldn't find a field with field id " + fieldID);
  }
}
项目:fresco_floodlight    文件:GetResponseMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (error != null) {
    error.validate();
  }
}
项目:fresco_floodlight    文件:ErrorMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (error != null) {
    error.validate();
  }
}
项目:fresco_floodlight    文件:EchoReplyMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
}
项目:fresco_floodlight    文件:FullSyncRequestMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
}
项目:fresco_floodlight    文件:PutResponseMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
}
项目:fresco_floodlight    文件:KeyedVersions.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (key == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'key' was not present! Struct: " + toString());
  }
  if (versions == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'versions' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
}
项目:fresco_floodlight    文件:RegisterResponseMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
}
项目:fresco_floodlight    文件:VersionedValue.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (version == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'version' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (version != null) {
    version.validate();
  }
}
项目:fresco_floodlight    文件:KeyedValues.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (key == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'key' was not present! Struct: " + toString());
  }
  if (values == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'values' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
}
项目:fresco_floodlight    文件:EchoRequestMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
}
项目:ditb    文件:THBaseService.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (table == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'table' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
}
项目:fresco_floodlight    文件:SyncValueResponseMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
}
项目:fresco_floodlight    文件:CursorRequestMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
}
项目:ditb    文件:THBaseService.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (table == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'table' was not present! Struct: " + toString());
  }
  if (row == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'row' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
}
项目:fresco_floodlight    文件:Store.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (storeName == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'storeName' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
}
项目:ditb    文件:THBaseService.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (table == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'table' was not present! Struct: " + toString());
  }
  if (tscan == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'tscan' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (tscan != null) {
    tscan.validate();
  }
}
项目:fresco_floodlight    文件:ClusterJoinResponseMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
}
项目:ditb    文件:THBaseService.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (table == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'table' was not present! Struct: " + toString());
  }
  if (tdelete == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'tdelete' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (tdelete != null) {
    tdelete.validate();
  }
}
项目:ditb    文件:THBaseService.java   
public void read(org.apache.thrift.protocol.TProtocol iprot, getScannerRows_args 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: // SCANNER_ID
        if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
          struct.scannerId = iprot.readI32();
          struct.setScannerIdIsSet(true);
        } else { 
          org.apache.thrift.protocol.TProtocolUtil.skip(iprot, schemeField.type);
        }
        break;
      case 2: // NUM_ROWS
        if (schemeField.type == org.apache.thrift.protocol.TType.I32) {
          struct.numRows = iprot.readI32();
          struct.setNumRowsIsSet(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
  if (!struct.isSetScannerId()) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'scannerId' was not found in serialized data! Struct: " + toString());
  }
  struct.validate();
}
项目:iTAP-controller    文件:GetResponseMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (error != null) {
    error.validate();
  }
}
项目:iTAP-controller    文件:ErrorMessage.java   
public void validate() throws org.apache.thrift.TException {
  // check for required fields
  if (header == null) {
    throw new org.apache.thrift.protocol.TProtocolException("Required field 'header' was not present! Struct: " + toString());
  }
  // check for sub-struct validity
  if (header != null) {
    header.validate();
  }
  if (error != null) {
    error.validate();
  }
}