Examples of LongComparator


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

                    StringSerializer.INSTANCE,
                    DoubleSerializer.INSTANCE }),
            new TupleComparator<Tuple2<Long, Long>>(
                new int[] { 0, 1 },
                new TypeComparator[] {
                new LongComparator(ascending),
                new LongComparator(ascending) },
                new TypeSerializer[] {
                    LongSerializer.INSTANCE,
                    LongSerializer.INSTANCE }),
            new TupleComparator<Tuple2<Integer, Long>>(
                new int[] {  0, 1 },
                new TypeComparator[] {
                new IntComparator(ascending),
                new LongComparator(ascending) },
                new TypeSerializer[] {
                    IntSerializer.INSTANCE,
                    LongSerializer.INSTANCE }) },
        new TypeSerializer[] {
            new TupleSerializer<Tuple2<String, Double>>(
View Full Code Here

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

                    StringSerializer.INSTANCE,
                    DoubleSerializer.INSTANCE }),
            new TupleComparator<Tuple2<Long, Long>>(
                new int[] { 0, 1 },
                new TypeComparator[] {
                new LongComparator(ascending),
                new LongComparator(ascending) },
                new TypeSerializer[] {
                    LongSerializer.INSTANCE,
                    LongSerializer.INSTANCE }),
            new TupleComparator<Tuple2<Integer, Long>>(
                new int[] {  0, 1 },
                new TypeComparator[] {
                new IntComparator(ascending),
                new LongComparator(ascending) },
                new TypeSerializer[] {
                    IntSerializer.INSTANCE,
                    LongSerializer.INSTANCE }) },
        new TypeSerializer[] {
            new TupleSerializer<Tuple2<String, Double>>(
View Full Code Here

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

  protected TupleComparator<Tuple3<Integer, Long, Double>> createComparator(boolean ascending) {
    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.LongComparator

      ht.put(put);
    }
    Scan scan = new Scan();
    scan.addFamily(FAMILY);
    Filter filter = new SingleColumnValueFilter(FAMILY, QUALIFIER, CompareOp.GREATER,
      new LongComparator(500));
    scan.setFilter(filter);
    ResultScanner scanner = ht.getScanner(scan);
    int expectedIndex = 0;
    for(Result result : ht.getScanner(scan)) {
      assertEquals(result.size(), 1);
View Full Code Here

Examples of org.apache.mahout.math.function.LongComparator

  }
 
  @Test
  public void testQuickSortLongs() {
   
    LongComparator revComp = new LongComparator() {
     
      @Override
      public int compare(long o1, long o2) {
        if (o2 < o1) {
          return -1;
View Full Code Here

Examples of org.apache.mahout.math.function.LongComparator

    Sorting.mergeSort(stuff, 100, stuff.length);
    for (int x = 100; x < (stuff.length - 1); x++) {
      assertTrue(stuff[x] <= stuff[x + 1]);
    }
   
    LongComparator revComp = new LongComparator() {
     
      @Override
      public int compare(long o1, long o2) {
        if (o2 < o1) {
          return -1;
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.