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

static public Scan ascanToScan(AScan ascan) throws IOException {
   Scan scan = new Scan();
   if (ascan.startRow != null) {
     scan.setStartRow(Bytes.toBytes(ascan.startRow));
   }
   if (ascan.stopRow != null) {
     scan.setStopRow(Bytes.toBytes(ascan.stopRow));
   }
   if (ascan.columns != null) {
     for (AColumn acolumn : ascan.columns) {
if (acolumn.qualifier != null) {
  scan.addColumn(Bytes.toBytes(acolumn.family), Bytes.toBytes(acolumn.qualifier));
} else {
  scan.addFamily(Bytes.toBytes(acolumn.family));
}
     }
   }
   if (ascan.timestamp != null) {
     scan.setTimeStamp(ascan.timestamp);
   }
   if (ascan.timerange != null) {
     scan.setTimeRange(ascan.timerange.minStamp, ascan.timerange.maxStamp);
   }
   if (ascan.maxVersions != null) {
     scan.setMaxVersions(ascan.maxVersions);
   }
   return scan;
 }

static public Scan ascanToScan(AScan ascan) throws IOException {
   Scan scan = new Scan();
   if (ascan.startRow != null) {
     scan.setStartRow(Bytes.toBytes(ascan.startRow));
   }
   if (ascan.stopRow != null) {
     scan.setStopRow(Bytes.toBytes(ascan.stopRow));
   }
   if (ascan.columns != null) {
     for (AColumn acolumn : ascan.columns) {
if (acolumn.qualifier != null) {
  scan.addColumn(Bytes.toBytes(acolumn.family), Bytes.toBytes(acolumn.qualifier));
} else {
  scan.addFamily(Bytes.toBytes(acolumn.family));
}
     }
   }
   if (ascan.timestamp != null) {
     scan.setTimeStamp(ascan.timestamp);
   }
   if (ascan.timerange != null) {
     scan.setTimeRange(ascan.timerange.minStamp, ascan.timerange.maxStamp);
   }
   if (ascan.maxVersions != null) {
     scan.setMaxVersions(ascan.maxVersions);
   }
   return scan;
 }

static public Scan ascanToScan(AScan ascan) throws IOException {
   Scan scan = new Scan();
   if (ascan.startRow != null) {
     scan.setStartRow(Bytes.toBytes(ascan.startRow));
   }
   if (ascan.stopRow != null) {
     scan.setStopRow(Bytes.toBytes(ascan.stopRow));
   }
   if (ascan.columns != null) {
     for (AColumn acolumn : ascan.columns) {
if (acolumn.qualifier != null) {
  scan.addColumn(Bytes.toBytes(acolumn.family), Bytes.toBytes(acolumn.qualifier));
} else {
  scan.addFamily(Bytes.toBytes(acolumn.family));
}
     }
   }
   if (ascan.timestamp != null) {
     scan.setTimeStamp(ascan.timestamp);
   }
   if (ascan.timerange != null) {
     scan.setTimeRange(ascan.timerange.minStamp, ascan.timerange.maxStamp);
   }
   if (ascan.maxVersions != null) {
     scan.setMaxVersions(ascan.maxVersions);
   }
   return scan;
 }

static public Scan ascanToScan(AScan ascan) throws IOException {
   Scan scan = new Scan();
   if (ascan.startRow != null) {
     scan.setStartRow(Bytes.toBytes(ascan.startRow));
   }
   if (ascan.stopRow != null) {
     scan.setStopRow(Bytes.toBytes(ascan.stopRow));
   }
   if (ascan.columns != null) {
     for (AColumn acolumn : ascan.columns) {
if (acolumn.qualifier != null) {
  scan.addColumn(Bytes.toBytes(acolumn.family), Bytes.toBytes(acolumn.qualifier));
} else {
  scan.addFamily(Bytes.toBytes(acolumn.family));
}
     }
   }
   if (ascan.timestamp != null) {
     scan.setTimeStamp(ascan.timestamp);
   }
   if (ascan.timerange != null) {
     scan.setTimeRange(ascan.timerange.minStamp, ascan.timerange.maxStamp);
   }
   if (ascan.maxVersions != null) {
     scan.setMaxVersions(ascan.maxVersions);
   }
   return scan;
 }

static public Scan ascanToScan(AScan ascan) throws IOException {
   Scan scan = new Scan();
   if (ascan.startRow != null) {
     scan.setStartRow(Bytes.toBytes(ascan.startRow));
   }
   if (ascan.stopRow != null) {
     scan.setStopRow(Bytes.toBytes(ascan.stopRow));
   }
   if (ascan.columns != null) {
     for (AColumn acolumn : ascan.columns) {
if (acolumn.qualifier != null) {
  scan.addColumn(Bytes.toBytes(acolumn.family), Bytes.toBytes(acolumn.qualifier));
} else {
  scan.addFamily(Bytes.toBytes(acolumn.family));
}
     }
   }
   if (ascan.timestamp != null) {
     scan.setTimeStamp(ascan.timestamp);
   }
   if (ascan.timerange != null) {
     scan.setTimeRange(ascan.timerange.minStamp, ascan.timerange.maxStamp);
   }
   if (ascan.maxVersions != null) {
     scan.setMaxVersions(ascan.maxVersions);
   }
   return scan;
 }

static public Scan ascanToScan(AScan ascan) throws IOException {
   Scan scan = new Scan();
   if (ascan.startRow != null) {
     scan.setStartRow(Bytes.toBytes(ascan.startRow));
   }
   if (ascan.stopRow != null) {
     scan.setStopRow(Bytes.toBytes(ascan.stopRow));
   }
   if (ascan.columns != null) {
     for (AColumn acolumn : ascan.columns) {
if (acolumn.qualifier != null) {
  scan.addColumn(Bytes.toBytes(acolumn.family), Bytes.toBytes(acolumn.qualifier));
} else {
  scan.addFamily(Bytes.toBytes(acolumn.family));
}
     }
   }
   if (ascan.timestamp != null) {
     scan.setTimeStamp(ascan.timestamp);
   }
   if (ascan.timerange != null) {
     scan.setTimeRange(ascan.timerange.minStamp, ascan.timerange.maxStamp);
   }
   if (ascan.maxVersions != null) {
     scan.setMaxVersions(ascan.maxVersions);
   }
   return scan;
 }

static public Scan ascanToScan(AScan ascan) throws IOException {
   Scan scan = new Scan();
   if (ascan.startRow != null) {
     scan.setStartRow(Bytes.toBytes(ascan.startRow));
   }
   if (ascan.stopRow != null) {
     scan.setStopRow(Bytes.toBytes(ascan.stopRow));
   }
   if (ascan.columns != null) {
     for (AColumn acolumn : ascan.columns) {
if (acolumn.qualifier != null) {
  scan.addColumn(Bytes.toBytes(acolumn.family), Bytes.toBytes(acolumn.qualifier));
} else {
  scan.addFamily(Bytes.toBytes(acolumn.family));
}
     }
   }
   if (ascan.timestamp != null) {
     scan.setTimeStamp(ascan.timestamp);
   }
   if (ascan.timerange != null) {
     scan.setTimeRange(ascan.timerange.minStamp, ascan.timerange.maxStamp);
   }
   if (ascan.maxVersions != null) {
     scan.setMaxVersions(ascan.maxVersions);
   }
   return scan;
 }