Examples of DoubleComparator

co.nubetech.crux.server.filter.types.DoubleComparator
eu.stratosphere.api.common.typeutils.base.DoubleComparator
org.apache.flink.api.common.typeutils.base.DoubleComparator
org.apache.hadoop.hbase.filter.DoubleComparator
org.apache.mahout.math.function.DoubleComparator
A comparison function which imposes a total ordering on some collection of elements. Comparators can be passed to a sort method (such as org.apache.mahout.math.Sorting.quickSort) to allow precise control over the sort order.
Note: It is generally a good idea for comparators to implement java.io.Serializable, as they may be used as ordering methods in serializable data structures. In order for the data structure to serialize successfully, the comparator (if provided) must implement Serializable.
@see java.util.Comparator @see org.apache.mahout.math.Sorting
org.neo4j.graphalgo.impl.util.DoubleComparator
org.opensphere.geometry.triangulation.DoubleComparator
Comparator of a map containing QuadEdge as key and Double as value (Double comparator). @author Eric Grosso
r.builtins.Order.DoubleComparator

Examples of org.apache.flink.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 org.apache.flink.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

Examples of org.apache.flink.api.common.typeutils.base.DoubleComparator

  protected GenericPairComparator<Tuple3<Integer, String, Double>, Tuple4<Integer, Float, Long, Double>> createComparator(boolean ascending) {
    int[] fields1 = new int[]{0, 2};
    int[] fields2 = new int[]{0, 3};
    TypeComparator[] comps1 = new TypeComparator[]{
        new IntComparator(ascending),
        new DoubleComparator(ascending)
    };
    TypeComparator[] comps2 = new TypeComparator[]{
        new IntComparator(ascending),
        new DoubleComparator(ascending)
    };
    TypeSerializer[] sers1 = new TypeSerializer[]{
        IntSerializer.INSTANCE,
        DoubleSerializer.INSTANCE
    };

View Full Code Here

Examples of org.apache.flink.api.common.typeutils.base.DoubleComparator

        new TypeComparator[] {
            new TupleComparator<Tuple2<String, Double>>(
                new int[] { 0, 1 },
                new TypeComparator[] {
                new StringComparator(ascending),
                new DoubleComparator(ascending) },
                new TypeSerializer[] {
                    StringSerializer.INSTANCE,
                    DoubleSerializer.INSTANCE }),
            new TupleComparator<Tuple2<Long, Long>>(
                new int[] { 0, 1 },

View Full Code Here

Examples of org.apache.flink.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 org.apache.flink.api.common.typeutils.base.DoubleComparator

        new TypeComparator[] {
            new TupleComparator<Tuple2<String, Double>>(
                new int[] { 0, 1 },
                new TypeComparator[] {
                new StringComparator(ascending),
                new DoubleComparator(ascending) },
                new TypeSerializer[] {
                    StringSerializer.INSTANCE,
                    DoubleSerializer.INSTANCE }),
            new TupleComparator<Tuple2<Long, Long>>(
                new int[] { 0, 1 },

View Full Code Here

Examples of org.apache.flink.api.common.typeutils.base.DoubleComparator

        new TypeComparator[] {
            new TupleComparator<Tuple2<String, Double>>(
                new int[] { 0, 1 },
                new TypeComparator[] {
                new StringComparator(ascending),
                new DoubleComparator(ascending) },
                new TypeSerializer[] {
                    StringSerializer.INSTANCE,
                    DoubleSerializer.INSTANCE }),
            new TupleComparator<Tuple2<Long, Long>>(
                new int[] { 0, 1 },

View Full Code Here

Examples of org.apache.flink.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 org.apache.flink.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 org.apache.hadoop.hbase.filter.DoubleComparator

    HTable table = new HTable(conf, userTableName);
    rangePutForIdx2WithDouble(table);
    FilterList masterFilter = new FilterList(Operator.MUST_PASS_ALL);
    SingleColumnValueFilter scvf =
        new SingleColumnValueFilter("cf1".getBytes(), "c1".getBytes(), CompareOp.LESS_OR_EQUAL,
            new DoubleComparator(Bytes.toBytes(-5.3d)));
    masterFilter.addFilter(scvf);
    Scan scan = new Scan();
    scan.setFilter(masterFilter);
    ResultScanner scanner = table.getScanner(scan);
    List<Result> testRes = new ArrayList<Result>();

View Full Code Here

0 1 2 3 4

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.