1. 包列表
  2. 类列表
  3. org.apache.hadoop.hbase.avro.generated.AIllegalArgument

Java 类org.apache.hadoop.hbase.avro.generated.AIllegalArgument 实例源码

项目：LCIndex-HBase-0.94.16    文件：AvroServer.java    
public Void scannerClose(int scannerId) throws AIOError, AIllegalArgument {
     try {
       ResultScanner scanner = getScanner(scannerId);
       if (scanner == null) {
          AIllegalArgument aie = new AIllegalArgument();
  aie.message = new Utf8("scanner ID is invalid: " + scannerId);
         throw aie;
       }
       scanner.close();
       removeScanner(scannerId);
       return null;
     } catch (IOException e) {
    AIOError ioe = new AIOError();
ioe.message = new Utf8(e.getMessage());
       throw ioe;
     }
   }
项目：LCIndex-HBase-0.94.16    文件：AvroUtil.java    
static public HTableDescriptor atdToHTD(ATableDescriptor atd) throws IOException, AIllegalArgument {
   HTableDescriptor htd = new HTableDescriptor(Bytes.toBytes(atd.name));
   if (atd.families != null && atd.families.size() > 0) {
     for (AFamilyDescriptor afd : atd.families) {
htd.addFamily(afdToHCD(afd));
     }
   }
   if (atd.maxFileSize != null) {
     htd.setMaxFileSize(atd.maxFileSize);
   }
   if (atd.memStoreFlushSize != null) {
     htd.setMemStoreFlushSize(atd.memStoreFlushSize);
   }
   if (atd.readOnly != null) {
     htd.setReadOnly(atd.readOnly);
   }
   if (atd.deferredLogFlush != null) {
     htd.setDeferredLogFlush(atd.deferredLogFlush);
   }
   if (atd.rootRegion != null || atd.metaRegion != null || atd.metaTable != null) {
     AIllegalArgument aie = new AIllegalArgument();
     aie.message = new Utf8("Can't set root or meta flag on create table.");
     throw aie;
   }
   return htd;
 }
项目：IRIndex    文件：AvroServer.java    
public Void scannerClose(int scannerId) throws AIOError, AIllegalArgument {
     try {
       ResultScanner scanner = getScanner(scannerId);
       if (scanner == null) {
          AIllegalArgument aie = new AIllegalArgument();
  aie.message = new Utf8("scanner ID is invalid: " + scannerId);
         throw aie;
       }
       scanner.close();
       removeScanner(scannerId);
       return null;
     } catch (IOException e) {
    AIOError ioe = new AIOError();
ioe.message = new Utf8(e.getMessage());
       throw ioe;
     }
   }
项目：IRIndex    文件：AvroUtil.java    
static public HTableDescriptor atdToHTD(ATableDescriptor atd) throws IOException, AIllegalArgument {
   HTableDescriptor htd = new HTableDescriptor(Bytes.toBytes(atd.name));
   if (atd.families != null && atd.families.size() > 0) {
     for (AFamilyDescriptor afd : atd.families) {
htd.addFamily(afdToHCD(afd));
     }
   }
   if (atd.maxFileSize != null) {
     htd.setMaxFileSize(atd.maxFileSize);
   }
   if (atd.memStoreFlushSize != null) {
     htd.setMemStoreFlushSize(atd.memStoreFlushSize);
   }
   if (atd.readOnly != null) {
     htd.setReadOnly(atd.readOnly);
   }
   if (atd.deferredLogFlush != null) {
     htd.setDeferredLogFlush(atd.deferredLogFlush);
   }
   if (atd.rootRegion != null || atd.metaRegion != null || atd.metaTable != null) {
     AIllegalArgument aie = new AIllegalArgument();
     aie.message = new Utf8("Can't set root or meta flag on create table.");
     throw aie;
   }
   return htd;
 }
项目：RStore    文件：AvroServer.java    
public Void scannerClose(int scannerId) throws AIOError, AIllegalArgument {
     try {
       ResultScanner scanner = getScanner(scannerId);
       if (scanner == null) {
          AIllegalArgument aie = new AIllegalArgument();
  aie.message = new Utf8("scanner ID is invalid: " + scannerId);
         throw aie;
       }
       scanner.close();
       removeScanner(scannerId);
       return null;
     } catch (IOException e) {
    AIOError ioe = new AIOError();
ioe.message = new Utf8(e.getMessage());
       throw ioe;
     }
   }
项目：RStore    文件：AvroUtil.java    
static public HTableDescriptor atdToHTD(ATableDescriptor atd) throws IOException, AIllegalArgument {
   HTableDescriptor htd = new HTableDescriptor(Bytes.toBytes(atd.name));
   if (atd.families != null && atd.families.size() > 0) {
     for (AFamilyDescriptor afd : atd.families) {
htd.addFamily(afdToHCD(afd));
     }
   }
   if (atd.maxFileSize != null) {
     htd.setMaxFileSize(atd.maxFileSize);
   }
   if (atd.memStoreFlushSize != null) {
     htd.setMemStoreFlushSize(atd.memStoreFlushSize);
   }
   if (atd.readOnly != null) {
     htd.setReadOnly(atd.readOnly);
   }
   if (atd.deferredLogFlush != null) {
     htd.setDeferredLogFlush(atd.deferredLogFlush);
   }
   if (atd.rootRegion != null || atd.metaRegion != null || atd.metaTable != null) {
     AIllegalArgument aie = new AIllegalArgument();
     aie.message = new Utf8("Can't set root or meta flag on create table.");
     throw aie;
   }
   return htd;
 }
项目：HBase-Research    文件：AvroServer.java    
public Void scannerClose(int scannerId) throws AIOError, AIllegalArgument {
     try {
       ResultScanner scanner = getScanner(scannerId);
       if (scanner == null) {
          AIllegalArgument aie = new AIllegalArgument();
  aie.message = new Utf8("scanner ID is invalid: " + scannerId);
         throw aie;
       }
       scanner.close();
       removeScanner(scannerId);
       return null;
     } catch (IOException e) {
    AIOError ioe = new AIOError();
ioe.message = new Utf8(e.getMessage());
       throw ioe;
     }
   }
项目：HBase-Research    文件：AvroUtil.java    
static public HTableDescriptor atdToHTD(ATableDescriptor atd) throws IOException, AIllegalArgument {
   HTableDescriptor htd = new HTableDescriptor(Bytes.toBytes(atd.name));
   if (atd.families != null && atd.families.size() > 0) {
     for (AFamilyDescriptor afd : atd.families) {
htd.addFamily(afdToHCD(afd));
     }
   }
   if (atd.maxFileSize != null) {
     htd.setMaxFileSize(atd.maxFileSize);
   }
   if (atd.memStoreFlushSize != null) {
     htd.setMemStoreFlushSize(atd.memStoreFlushSize);
   }
   if (atd.readOnly != null) {
     htd.setReadOnly(atd.readOnly);
   }
   if (atd.deferredLogFlush != null) {
     htd.setDeferredLogFlush(atd.deferredLogFlush);
   }
   if (atd.rootRegion != null || atd.metaRegion != null || atd.metaTable != null) {
     AIllegalArgument aie = new AIllegalArgument();
     aie.message = new Utf8("Can't set root or meta flag on create table.");
     throw aie;
   }
   return htd;
 }
项目：hbase-0.94.8-qod    文件：AvroServer.java    
public Void scannerClose(int scannerId) throws AIOError, AIllegalArgument {
     try {
       ResultScanner scanner = getScanner(scannerId);
       if (scanner == null) {
          AIllegalArgument aie = new AIllegalArgument();
  aie.message = new Utf8("scanner ID is invalid: " + scannerId);
         throw aie;
       }
       scanner.close();
       removeScanner(scannerId);
       return null;
     } catch (IOException e) {
    AIOError ioe = new AIOError();
ioe.message = new Utf8(e.getMessage());
       throw ioe;
     }
   }
项目：hbase-0.94.8-qod    文件：AvroUtil.java    
static public HTableDescriptor atdToHTD(ATableDescriptor atd) throws IOException, AIllegalArgument {
   HTableDescriptor htd = new HTableDescriptor(Bytes.toBytes(atd.name));
   if (atd.families != null && atd.families.size() > 0) {
     for (AFamilyDescriptor afd : atd.families) {
htd.addFamily(afdToHCD(afd));
     }
   }
   if (atd.maxFileSize != null) {
     htd.setMaxFileSize(atd.maxFileSize);
   }
   if (atd.memStoreFlushSize != null) {
     htd.setMemStoreFlushSize(atd.memStoreFlushSize);
   }
   if (atd.readOnly != null) {
     htd.setReadOnly(atd.readOnly);
   }
   if (atd.deferredLogFlush != null) {
     htd.setDeferredLogFlush(atd.deferredLogFlush);
   }
   if (atd.rootRegion != null || atd.metaRegion != null || atd.metaTable != null) {
     AIllegalArgument aie = new AIllegalArgument();
     aie.message = new Utf8("Can't set root or meta flag on create table.");
     throw aie;
   }
   return htd;
 }
项目：hbase-0.94.8-qod    文件：AvroServer.java    
public Void scannerClose(int scannerId) throws AIOError, AIllegalArgument {
     try {
       ResultScanner scanner = getScanner(scannerId);
       if (scanner == null) {
          AIllegalArgument aie = new AIllegalArgument();
  aie.message = new Utf8("scanner ID is invalid: " + scannerId);
         throw aie;
       }
       scanner.close();
       removeScanner(scannerId);
       return null;
     } catch (IOException e) {
    AIOError ioe = new AIOError();
ioe.message = new Utf8(e.getMessage());
       throw ioe;
     }
   }
项目：hbase-0.94.8-qod    文件：AvroUtil.java    
static public HTableDescriptor atdToHTD(ATableDescriptor atd) throws IOException, AIllegalArgument {
   HTableDescriptor htd = new HTableDescriptor(Bytes.toBytes(atd.name));
   if (atd.families != null && atd.families.size() > 0) {
     for (AFamilyDescriptor afd : atd.families) {
htd.addFamily(afdToHCD(afd));
     }
   }
   if (atd.maxFileSize != null) {
     htd.setMaxFileSize(atd.maxFileSize);
   }
   if (atd.memStoreFlushSize != null) {
     htd.setMemStoreFlushSize(atd.memStoreFlushSize);
   }
   if (atd.readOnly != null) {
     htd.setReadOnly(atd.readOnly);
   }
   if (atd.deferredLogFlush != null) {
     htd.setDeferredLogFlush(atd.deferredLogFlush);
   }
   if (atd.rootRegion != null || atd.metaRegion != null || atd.metaTable != null) {
     AIllegalArgument aie = new AIllegalArgument();
     aie.message = new Utf8("Can't set root or meta flag on create table.");
     throw aie;
   }
   return htd;
 }
项目：hindex    文件：AvroServer.java    
public Void scannerClose(int scannerId) throws AIOError, AIllegalArgument {
     try {
       ResultScanner scanner = getScanner(scannerId);
       if (scanner == null) {
          AIllegalArgument aie = new AIllegalArgument();
  aie.message = new Utf8("scanner ID is invalid: " + scannerId);
         throw aie;
       }
       scanner.close();
       removeScanner(scannerId);
       return null;
     } catch (IOException e) {
    AIOError ioe = new AIOError();
ioe.message = new Utf8(e.getMessage());
       throw ioe;
     }
   }
项目：hindex    文件：AvroUtil.java    
static public HTableDescriptor atdToHTD(ATableDescriptor atd) throws IOException, AIllegalArgument {
   HTableDescriptor htd = new HTableDescriptor(Bytes.toBytes(atd.name));
   if (atd.families != null && atd.families.size() > 0) {
     for (AFamilyDescriptor afd : atd.families) {
htd.addFamily(afdToHCD(afd));
     }
   }
   if (atd.maxFileSize != null) {
     htd.setMaxFileSize(atd.maxFileSize);
   }
   if (atd.memStoreFlushSize != null) {
     htd.setMemStoreFlushSize(atd.memStoreFlushSize);
   }
   if (atd.readOnly != null) {
     htd.setReadOnly(atd.readOnly);
   }
   if (atd.deferredLogFlush != null) {
     htd.setDeferredLogFlush(atd.deferredLogFlush);
   }
   if (atd.rootRegion != null || atd.metaRegion != null || atd.metaTable != null) {
     AIllegalArgument aie = new AIllegalArgument();
     aie.message = new Utf8("Can't set root or meta flag on create table.");
     throw aie;
   }
   return htd;
 }
项目：LCIndex-HBase-0.94.16    文件：AvroServer.java    
public GenericArray<AResult> scannerGetRows(int scannerId, int numberOfRows) throws AIOError, AIllegalArgument {
     try {
       ResultScanner scanner = getScanner(scannerId);
       if (scanner == null) {
          AIllegalArgument aie = new AIllegalArgument();
  aie.message = new Utf8("scanner ID is invalid: " + scannerId);
         throw aie;
       }
       return AvroUtil.resultsToAResults(scanner.next(numberOfRows));
     } catch (IOException e) {
    AIOError ioe = new AIOError();
ioe.message = new Utf8(e.getMessage());
       throw ioe;
     }
   }
项目：IRIndex    文件：AvroServer.java    
public GenericArray<AResult> scannerGetRows(int scannerId, int numberOfRows) throws AIOError, AIllegalArgument {
     try {
       ResultScanner scanner = getScanner(scannerId);
       if (scanner == null) {
          AIllegalArgument aie = new AIllegalArgument();
  aie.message = new Utf8("scanner ID is invalid: " + scannerId);
         throw aie;
       }
       return AvroUtil.resultsToAResults(scanner.next(numberOfRows));
     } catch (IOException e) {
    AIOError ioe = new AIOError();
ioe.message = new Utf8(e.getMessage());
       throw ioe;
     }
   }
项目：RStore    文件：AvroServer.java    
public GenericArray<AResult> scannerGetRows(int scannerId, int numberOfRows) throws AIOError, AIllegalArgument {
     try {
       ResultScanner scanner = getScanner(scannerId);
       if (scanner == null) {
          AIllegalArgument aie = new AIllegalArgument();
  aie.message = new Utf8("scanner ID is invalid: " + scannerId);
         throw aie;
       }
       return AvroUtil.resultsToAResults(scanner.next(numberOfRows));
     } catch (IOException e) {
    AIOError ioe = new AIOError();
ioe.message = new Utf8(e.getMessage());
       throw ioe;
     }
   }
项目：HBase-Research    文件：AvroServer.java    
public GenericArray<AResult> scannerGetRows(int scannerId, int numberOfRows) throws AIOError, AIllegalArgument {
     try {
       ResultScanner scanner = getScanner(scannerId);
       if (scanner == null) {
          AIllegalArgument aie = new AIllegalArgument();
  aie.message = new Utf8("scanner ID is invalid: " + scannerId);
         throw aie;
       }
       return AvroUtil.resultsToAResults(scanner.next(numberOfRows));
     } catch (IOException e) {
    AIOError ioe = new AIOError();
ioe.message = new Utf8(e.getMessage());
       throw ioe;
     }
   }
项目：hbase-0.94.8-qod    文件：AvroServer.java    
public GenericArray<AResult> scannerGetRows(int scannerId, int numberOfRows) throws AIOError, AIllegalArgument {
     try {
       ResultScanner scanner = getScanner(scannerId);
       if (scanner == null) {
          AIllegalArgument aie = new AIllegalArgument();
  aie.message = new Utf8("scanner ID is invalid: " + scannerId);
         throw aie;
       }
       return AvroUtil.resultsToAResults(scanner.next(numberOfRows));
     } catch (IOException e) {
    AIOError ioe = new AIOError();
ioe.message = new Utf8(e.getMessage());
       throw ioe;
     }
   }
项目：hbase-0.94.8-qod    文件：AvroServer.java    
public GenericArray<AResult> scannerGetRows(int scannerId, int numberOfRows) throws AIOError, AIllegalArgument {
     try {
       ResultScanner scanner = getScanner(scannerId);
       if (scanner == null) {
          AIllegalArgument aie = new AIllegalArgument();
  aie.message = new Utf8("scanner ID is invalid: " + scannerId);
         throw aie;
       }
       return AvroUtil.resultsToAResults(scanner.next(numberOfRows));
     } catch (IOException e) {
    AIOError ioe = new AIOError();
ioe.message = new Utf8(e.getMessage());
       throw ioe;
     }
   }
项目：hindex    文件：AvroServer.java    
public GenericArray<AResult> scannerGetRows(int scannerId, int numberOfRows) throws AIOError, AIllegalArgument {
     try {
       ResultScanner scanner = getScanner(scannerId);
       if (scanner == null) {
          AIllegalArgument aie = new AIllegalArgument();
  aie.message = new Utf8("scanner ID is invalid: " + scannerId);
         throw aie;
       }
       return AvroUtil.resultsToAResults(scanner.next(numberOfRows));
     } catch (IOException e) {
    AIOError ioe = new AIOError();
ioe.message = new Utf8(e.getMessage());
       throw ioe;
     }
   }