Examples of AggregateRequest

org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateRequest

Examples of org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateRequest

   *           & propagated to it.
   */
  public <R, S, P extends Message, Q extends Message, T extends Message> 
  R max(final Table table, final ColumnInterpreter<R, S, P, Q, T> ci,
      final Scan scan) throws Throwable {
    final AggregateRequest requestArg = validateArgAndGetPB(scan, ci, false);
    class MaxCallBack implements Batch.Callback<R> {
      R max = null;


      R getMax() {
        return max;

View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateRequest

   * @throws Throwable
   */
  public <R, S, P extends Message, Q extends Message, T extends Message> 
  R min(final Table table, final ColumnInterpreter<R, S, P, Q, T> ci,
      final Scan scan) throws Throwable {
    final AggregateRequest requestArg = validateArgAndGetPB(scan, ci, false);
    class MinCallBack implements Batch.Callback<R> {


      private R min = null;


      public R getMinimum() {

View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateRequest

   * @throws Throwable
   */
  public <R, S, P extends Message, Q extends Message, T extends Message> 
  long rowCount(final Table table,
      final ColumnInterpreter<R, S, P, Q, T> ci, final Scan scan) throws Throwable {
    final AggregateRequest requestArg = validateArgAndGetPB(scan, ci, true);
    class RowNumCallback implements Batch.Callback<Long> {
      private final AtomicLong rowCountL = new AtomicLong(0);


      public long getRowNumCount() {
        return rowCountL.get();

View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateRequest

   * @throws Throwable
   */
  public <R, S, P extends Message, Q extends Message, T extends Message> 
  S sum(final Table table, final ColumnInterpreter<R, S, P, Q, T> ci,
      final Scan scan) throws Throwable {
    final AggregateRequest requestArg = validateArgAndGetPB(scan, ci, false);
    
    class SumCallBack implements Batch.Callback<S> {
      S sumVal = null;


      public S getSumResult() {

View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateRequest

   * @throws Throwable
   */
  private <R, S, P extends Message, Q extends Message, T extends Message>
  Pair<S, Long> getAvgArgs(final Table table,
      final ColumnInterpreter<R, S, P, Q, T> ci, final Scan scan) throws Throwable {
    final AggregateRequest requestArg = validateArgAndGetPB(scan, ci, false);
    class AvgCallBack implements Batch.Callback<Pair<S, Long>> {
      S sum = null;
      Long rowCount = 0l;


      public synchronized Pair<S, Long> getAvgArgs() {

View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateRequest

   * @throws Throwable
   */
  private <R, S, P extends Message, Q extends Message, T extends Message>
  Pair<List<S>, Long> getStdArgs(final Table table,
      final ColumnInterpreter<R, S, P, Q, T> ci, final Scan scan) throws Throwable {
    final AggregateRequest requestArg = validateArgAndGetPB(scan, ci, false);
    class StdCallback implements Batch.Callback<Pair<List<S>, Long>> {
      long rowCountVal = 0l;
      S sumVal = null, sumSqVal = null;


      public synchronized Pair<List<S>, Long> getStdParams() {

View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateRequest

   */
  private <R, S, P extends Message, Q extends Message, T extends Message>
  Pair<NavigableMap<byte[], List<S>>, List<S>>
  getMedianArgs(final Table table,
      final ColumnInterpreter<R, S, P, Q, T> ci, final Scan scan) throws Throwable {
    final AggregateRequest requestArg = validateArgAndGetPB(scan, ci, false);
    final NavigableMap<byte[], List<S>> map =
      new TreeMap<byte[], List<S>>(Bytes.BYTES_COMPARATOR);
    class StdCallback implements Batch.Callback<List<S>> {
      S sumVal = null, sumWeights = null;

View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateRequest

   *           & propagated to it.
   */
  public <R, S, P extends Message, Q extends Message, T extends Message> 
  R max(final Table table, final ColumnInterpreter<R, S, P, Q, T> ci,
      final Scan scan) throws Throwable {
    final AggregateRequest requestArg = validateArgAndGetPB(scan, ci, false);
    class MaxCallBack implements Batch.Callback<R> {
      R max = null;


      R getMax() {
        return max;

View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateRequest

   * @throws Throwable
   */
  public <R, S, P extends Message, Q extends Message, T extends Message> 
  R min(final Table table, final ColumnInterpreter<R, S, P, Q, T> ci,
      final Scan scan) throws Throwable {
    final AggregateRequest requestArg = validateArgAndGetPB(scan, ci, false);
    class MinCallBack implements Batch.Callback<R> {


      private R min = null;


      public R getMinimum() {

View Full Code Here

Examples of org.apache.hadoop.hbase.protobuf.generated.AggregateProtos.AggregateRequest

   * @throws Throwable
   */
  public <R, S, P extends Message, Q extends Message, T extends Message> 
  long rowCount(final Table table,
      final ColumnInterpreter<R, S, P, Q, T> ci, final Scan scan) throws Throwable {
    final AggregateRequest requestArg = validateArgAndGetPB(scan, ci, true);
    class RowNumCallback implements Batch.Callback<Long> {
      private final AtomicLong rowCountL = new AtomicLong(0);


      public long getRowNumCount() {
        return rowCountL.get();

View Full Code Here

0 1 2

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.