Examples of LongComparator

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

205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
    ColumnFilter columnFilter = new ColumnFilter();
    columnFilter.setFilterType(type);
    columnFilter.setValue("123");
    columnFilter.setColumnAlias(alias);

    LongComparator expectedComp = new LongComparator(123l, 0, -1);
    SingleColumnValueFilter expectedFilter = new SingleColumnValueFilter(
        Bytes.toBytes("cf"), Bytes.toBytes("qualifier"),
        CompareOp.NOT_EQUAL, expectedComp);
    expectedFilter.setFilterIfMissing(true);

    SingleColumnValueFilter filterReturned = (SingleColumnValueFilter) HBaseFilterFactory
        .getColumnFilter(columnFilter);
    LongComparator returnedComparator = (LongComparator) filterReturned
        .getComparator();

    assertTrue(Bytes.compareTo(expectedComp.getValue(),
        returnedComparator.getValue()) == 0);
    assertTrue(Bytes.compareTo(expectedFilter.getFamily(),
        filterReturned.getFamily()) == 0);
    assertTrue(Bytes.compareTo(expectedFilter.getQualifier(),
        filterReturned.getQualifier()) == 0);
    assertTrue(filterReturned.getFilterIfMissing());
    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.LongComparator

246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
    ColumnFilter columnFilter = new ColumnFilter();
    columnFilter.setFilterType(type);
    columnFilter.setValue("123");
    columnFilter.setColumnAlias(alias);

    LongComparator expectedComp = new LongComparator(123l, 0, -1);
    SingleColumnValueFilter expectedFilter = new SingleColumnValueFilter(
        Bytes.toBytes("cf"), Bytes.toBytes("qualifier"),
        CompareOp.LESS, expectedComp);
    expectedFilter.setFilterIfMissing(true);

    SingleColumnValueFilter filterReturned = (SingleColumnValueFilter) HBaseFilterFactory
        .getColumnFilter(columnFilter);
    LongComparator returnedComparator = (LongComparator) filterReturned
        .getComparator();

    assertTrue(Bytes.compareTo(expectedComp.getValue(),
        returnedComparator.getValue()) == 0);
    assertTrue(Bytes.compareTo(expectedFilter.getFamily(),
        filterReturned.getFamily()) == 0);
    assertTrue(Bytes.compareTo(expectedFilter.getQualifier(),
        filterReturned.getQualifier()) == 0);
    assertTrue(filterReturned.getFilterIfMissing());
    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.LongComparator

287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
    ColumnFilter columnFilter = new ColumnFilter();
    columnFilter.setFilterType(type);
    columnFilter.setValue("123");
    columnFilter.setColumnAlias(alias);

    LongComparator expectedComp = new LongComparator(123l, 0, -1);
    SingleColumnValueFilter expectedFilter = new SingleColumnValueFilter(
        Bytes.toBytes("cf"), Bytes.toBytes("qualifier"),
        CompareOp.LESS_OR_EQUAL, expectedComp);
    expectedFilter.setFilterIfMissing(true);

    SingleColumnValueFilter filterReturned = (SingleColumnValueFilter) HBaseFilterFactory
        .getColumnFilter(columnFilter);
    LongComparator returnedComparator = (LongComparator) filterReturned
        .getComparator();

    assertTrue(Bytes.compareTo(expectedComp.getValue(),
        returnedComparator.getValue()) == 0);
    assertTrue(Bytes.compareTo(expectedFilter.getFamily(),
        filterReturned.getFamily()) == 0);
    assertTrue(Bytes.compareTo(expectedFilter.getQualifier(),
        filterReturned.getQualifier()) == 0);
    assertTrue(filterReturned.getFilterIfMissing());
    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.LongComparator

328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
    ColumnFilter columnFilter = new ColumnFilter();
    columnFilter.setFilterType(type);
    columnFilter.setValue("123");
    columnFilter.setColumnAlias(alias);

    LongComparator expectedComp = new LongComparator(123l, 0, -1);
    SingleColumnValueFilter expectedFilter = new SingleColumnValueFilter(
        Bytes.toBytes("cf"), Bytes.toBytes("qualifier"),
        CompareOp.GREATER_OR_EQUAL, expectedComp);
    expectedFilter.setFilterIfMissing(true);

    SingleColumnValueFilter filterReturned = (SingleColumnValueFilter) HBaseFilterFactory
        .getColumnFilter(columnFilter);
    LongComparator returnedComparator = (LongComparator) filterReturned
        .getComparator();

    assertTrue(Bytes.compareTo(expectedComp.getValue(),
        returnedComparator.getValue()) == 0);
    assertTrue(Bytes.compareTo(expectedFilter.getFamily(),
        filterReturned.getFamily()) == 0);
    assertTrue(Bytes.compareTo(expectedFilter.getQualifier(),
        filterReturned.getQualifier()) == 0);
    assertTrue(filterReturned.getFilterIfMissing());
    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.LongComparator

1818
1819
1820
1821
1822
1823
1824
1825
1826
1827
1828
1829
1830
1831
1832
1833
1834
1835
1836
1837
1838
1839
1840
1841
1842
    RowAliasFilter rowFilter = new RowAliasFilter();
    rowFilter.setFilterType(type);
    rowFilter.setValue("123");
    rowFilter.setRowAlias(alias);

    LongComparator expectedComp = new LongComparator(123l, 0, 8);
    RowFilter expectedFilter = new RowFilter(CompareOp.GREATER,
        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);
    LongComparator returnedComparator = (LongComparator) 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 eu.stratosphere.api.common.typeutils.base.LongComparator

43
44
45
46
47
48
49
50
51
52
  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 eu.stratosphere.api.common.typeutils.base.LongComparator

42
43
44
45
46
47
48
49
50
  protected TupleComparator<Tuple3<Integer, Long, Double>> createComparator(boolean ascending) {
    return new TupleComparator<Tuple3<Integer, Long, Double>>(
        new int[]{0, 1},
        new TypeComparator[]{
          new IntComparator(ascending),
          new LongComparator(ascending)
        },
        new TypeSerializer[]{ IntSerializer.INSTANCE, LongSerializer.INSTANCE });
  }
View Full Code Here

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

42
43
44
45
46
47
48
49
50
  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.LongComparator

40
41
42
43
44
45
46
47
48
  @Override
  protected TupleComparator<Tuple3<Integer, Long, Double>> createComparator(boolean ascending) {
    return new TupleComparator<Tuple3<Integer, Long, Double>>(
        new int[]{1},
        new TypeComparator[]{
          new LongComparator(ascending)
        },
    new TypeSerializer[]{  IntSerializer.INSTANCE, LongSerializer.INSTANCE });
  }
View Full Code Here

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

44
45
46
47
48
49
50
51
52
    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
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.