Examples of DoubleComparator


Examples of co.nubetech.crux.server.filter.types.DoubleComparator

    RowAliasFilter rowFilter = new RowAliasFilter();
    rowFilter.setFilterType(type);
    rowFilter.setValue("123");
    rowFilter.setRowAlias(alias);

    DoubleComparator expectedComp = new DoubleComparator(123, 0, 8);
    RowFilter expectedFilter = new RowFilter(CompareOp.LESS, expectedComp);

    Mapping mapping = new Mapping();
    Map<String, RowAlias> rowAliases = new TreeMap<String, RowAlias>();
    rowAliases.put(alias.getAlias(), alias);
    mapping.setRowAlias(rowAliases);

    RowFilter filterReturned = HBaseFilterFactory.getRowFilter(rowFilter,
        mapping);
    DoubleComparator returnedComparator = (DoubleComparator) filterReturned
        .getComparator();

    assertTrue(Bytes.compareTo(expectedComp.getValue(),
        returnedComparator.getValue()) == 0);
    assertEquals(expectedFilter.getOperator(), filterReturned.getOperator());
    assertEquals(expectedComp.getLength(), returnedComparator.getLength());
    assertEquals(expectedComp.getOffset(), returnedComparator.getOffset());
  }
View Full Code Here

Examples of co.nubetech.crux.server.filter.types.DoubleComparator

    RowAliasFilter rowFilter = new RowAliasFilter();
    rowFilter.setFilterType(type);
    rowFilter.setValue("123");
    rowFilter.setRowAlias(alias);

    DoubleComparator expectedComp = new DoubleComparator(123, 0, 8);
    RowFilter expectedFilter = new RowFilter(CompareOp.LESS_OR_EQUAL,
        expectedComp);

    Mapping mapping = new Mapping();
    Map<String, RowAlias> rowAliases = new TreeMap<String, RowAlias>();
    rowAliases.put(alias.getAlias(), alias);
    mapping.setRowAlias(rowAliases);

    RowFilter filterReturned = HBaseFilterFactory.getRowFilter(rowFilter,
        mapping);
    DoubleComparator returnedComparator = (DoubleComparator) filterReturned
        .getComparator();

    assertTrue(Bytes.compareTo(expectedComp.getValue(),
        returnedComparator.getValue()) == 0);
    assertEquals(expectedFilter.getOperator(), filterReturned.getOperator());
    assertEquals(expectedComp.getLength(), returnedComparator.getLength());
    assertEquals(expectedComp.getOffset(), returnedComparator.getOffset());
  }
View Full Code Here

Examples of co.nubetech.crux.server.filter.types.DoubleComparator

    RowAliasFilter rowFilter = new RowAliasFilter();
    rowFilter.setFilterType(type);
    rowFilter.setValue("123");
    rowFilter.setRowAlias(alias);

    DoubleComparator expectedComp = new DoubleComparator(123, 0, 8);
    RowFilter expectedFilter = new RowFilter(CompareOp.GREATER_OR_EQUAL,
        expectedComp);

    Mapping mapping = new Mapping();
    Map<String, RowAlias> rowAliases = new TreeMap<String, RowAlias>();
    rowAliases.put(alias.getAlias(), alias);
    mapping.setRowAlias(rowAliases);

    RowFilter filterReturned = HBaseFilterFactory.getRowFilter(rowFilter,
        mapping);
    DoubleComparator returnedComparator = (DoubleComparator) filterReturned
        .getComparator();

    assertTrue(Bytes.compareTo(expectedComp.getValue(),
        returnedComparator.getValue()) == 0);
    assertEquals(expectedFilter.getOperator(), filterReturned.getOperator());
    assertEquals(expectedComp.getLength(), returnedComparator.getLength());
    assertEquals(expectedComp.getOffset(), returnedComparator.getOffset());
  }
View Full Code Here

Examples of co.nubetech.crux.server.filter.types.DoubleComparator

    RowAlias alias = new RowAlias();
    alias.setAlias("alias");
    alias.setValueType(valueType);
    alias.setLength(-1);

    DoubleComparator expectedComp = new DoubleComparator(123, 0, -1);
    DoubleComparator returnedComparator = (DoubleComparator) HBaseFilterFactory
        .getComparator(type, alias, "123", 0, -1);
    assertTrue(Bytes.compareTo(expectedComp.getValue(),
        returnedComparator.getValue()) == 0);
    assertEquals(expectedComp.getLength(), returnedComparator.getLength());
    assertEquals(expectedComp.getOffset(), returnedComparator.getOffset());
  }
View Full Code Here

Examples of eu.stratosphere.api.common.typeutils.base.DoubleComparator

    return new TupleComparator<Tuple3<Integer, String, Double>>(
        new int[]{0, 1, 2},
        new TypeComparator[]{
          new IntComparator(ascending),
          new StringComparator(ascending),
          new DoubleComparator(ascending)
        },
    new TypeSerializer[]{ IntSerializer.INSTANCE, StringSerializer.INSTANCE, DoubleSerializer.INSTANCE });
  }
View Full Code Here

Examples of eu.stratosphere.api.common.typeutils.base.DoubleComparator

    return new TupleComparator<Tuple3<Integer, Long, Double>>(
        new int[]{0, 1, 2},
        new TypeComparator[]{
          new IntComparator(ascending),
          new LongComparator(ascending),
          new DoubleComparator(ascending)
        },
    new TypeSerializer[]{ IntSerializer.INSTANCE, LongSerializer.INSTANCE, DoubleSerializer.INSTANCE });
  }
View Full Code Here

Examples of eu.stratosphere.api.common.typeutils.base.DoubleComparator

  @Override
  protected TupleComparator<Tuple3<Integer, Long, Double>> createComparator(boolean ascending) {
    return new TupleComparator<Tuple3<Integer, Long, Double>>(
        new int[]{2, 1},
        new TypeComparator[]{
          new DoubleComparator(ascending),
          new LongComparator(ascending)
        },
    new TypeSerializer[]{ IntSerializer.INSTANCE, DoubleSerializer.INSTANCE, LongSerializer.INSTANCE });
  }
View Full Code Here

Examples of eu.stratosphere.api.common.typeutils.base.DoubleComparator

  @Override
  protected TupleComparator<Tuple3<Integer, Long, Double>> createComparator(boolean ascending) {
    return new TupleComparator<Tuple3<Integer, Long, Double>>(
        new int[]{2, 0, 1},
        new TypeComparator[]{
          new DoubleComparator(ascending),
          new IntComparator(ascending),
          new LongComparator(ascending)
        },
    new TypeSerializer[]{ IntSerializer.INSTANCE, LongSerializer.INSTANCE, DoubleSerializer.INSTANCE });
  }
View Full Code Here

Examples of eu.stratosphere.api.common.typeutils.base.DoubleComparator

    return new TuplePairComparator<Tuple3<Integer, String, Double>, Tuple4<Integer, Float, Long, Double>>(
        new int[]{0, 2},
        new int[]{0, 3},
        new TypeComparator[]{
          new IntComparator(ascending),
          new DoubleComparator(ascending)
        },
        new TypeComparator[]{
          new IntComparator(ascending),
          new DoubleComparator(ascending)
        }
    );
  }
View Full Code Here

Examples of eu.stratosphere.api.common.typeutils.base.DoubleComparator

public class DoubleComparatorTest extends ComparatorTestBase<Double> {

  @Override
  protected TypeComparator<Double> createComparator(boolean ascending) {
    return new DoubleComparator(ascending);
  }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
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.