com.facebook.presto.spi.predicate.Range.getType()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(8.7k)|赞(0)|评价(0)|浏览(82)

本文整理了Java中com.facebook.presto.spi.predicate.Range.getType方法的一些代码示例，展示了Range.getType的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Range.getType方法的具体详情如下：
包路径：com.facebook.presto.spi.predicate.Range
类名称：Range
方法名：getType

Range.getType介绍

暂无

代码示例

代码示例来源：origin: prestodb/presto

private void checkTypeCompatibility(Range range)
{
  if (!getType().equals(range.getType())) {
    throw new IllegalArgumentException(String.format("Mismatched Range types: %s vs %s", getType(), range.getType()));
  }
}

代码示例来源：origin: prestodb/presto

Builder add(Range range)
{
  if (!type.equals(range.getType())) {
    throw new IllegalArgumentException(String.format("Range type %s does not match builder type %s", range.getType(), type));
  }
  ranges.add(range);
  return this;
}

代码示例来源：origin: prestodb/presto

private void checkTypeCompatibility(Marker marker)
{
  if (!getType().equals(marker.getType())) {
    throw new IllegalArgumentException(String.format("Marker of %s does not match Range of %s", marker.getType(), getType()));
  }
}

代码示例来源：origin: prestodb/presto

/**
 * Provided Ranges are unioned together to form the SortedRangeSet
 */
static SortedRangeSet of(Range first, Range... rest)
{
  List<Range> rangeList = new ArrayList<>(rest.length + 1);
  rangeList.add(first);
  for (Range range : rest) {
    rangeList.add(range);
  }
  return copyOf(first.getType(), rangeList);
}

代码示例来源：origin: prestodb/presto

Text split = new Text(serializer.encode(prestoRange.getType(), prestoRange.getSingleValue()));
accumuloRange = new Range(split);
  Text split = new Text(serializer.encode(prestoRange.getType(), prestoRange.getHigh().getValue()));
  accumuloRange = new Range(null, false, split, inclusive);
  Text split = new Text(serializer.encode(prestoRange.getType(), prestoRange.getLow().getValue()));
  accumuloRange = new Range(split, inclusive, null, false);
  Text startSplit = new Text(serializer.encode(prestoRange.getType(), prestoRange.getLow().getValue()));
  Text endSplit = new Text(serializer.encode(prestoRange.getType(), prestoRange.getHigh().getValue()));
  accumuloRange = new Range(startSplit, startKeyInclusive, endSplit, endKeyInclusive);

代码示例来源：origin: prestodb/presto

@Test
public void testLessThanRange()
{
  Range range = Range.lessThan(BIGINT, 1L);
  assertEquals(range.getLow(), Marker.lowerUnbounded(BIGINT));
  assertEquals(range.getHigh(), Marker.below(BIGINT, 1L));
  assertFalse(range.isSingleValue());
  assertFalse(range.isAll());
  assertEquals(range.getType(), BIGINT);
  assertTrue(range.includes(Marker.lowerUnbounded(BIGINT)));
  assertFalse(range.includes(Marker.exactly(BIGINT, 1L)));
  assertTrue(range.includes(Marker.exactly(BIGINT, 0L)));
  assertFalse(range.includes(Marker.upperUnbounded(BIGINT)));
}

代码示例来源：origin: prestodb/presto

@Test
public void testGreaterThanRange()
{
  Range range = Range.greaterThan(BIGINT, 1L);
  assertEquals(range.getLow(), Marker.above(BIGINT, 1L));
  assertEquals(range.getHigh(), Marker.upperUnbounded(BIGINT));
  assertFalse(range.isSingleValue());
  assertFalse(range.isAll());
  assertEquals(range.getType(), BIGINT);
  assertFalse(range.includes(Marker.lowerUnbounded(BIGINT)));
  assertFalse(range.includes(Marker.exactly(BIGINT, 1L)));
  assertTrue(range.includes(Marker.exactly(BIGINT, 2L)));
  assertTrue(range.includes(Marker.upperUnbounded(BIGINT)));
}

代码示例来源：origin: prestodb/presto

@Test
public void testLessThanOrEqualRange()
{
  Range range = Range.lessThanOrEqual(BIGINT, 1L);
  assertEquals(range.getLow(), Marker.lowerUnbounded(BIGINT));
  assertEquals(range.getHigh(), Marker.exactly(BIGINT, 1L));
  assertFalse(range.isSingleValue());
  assertFalse(range.isAll());
  assertEquals(range.getType(), BIGINT);
  assertTrue(range.includes(Marker.lowerUnbounded(BIGINT)));
  assertFalse(range.includes(Marker.exactly(BIGINT, 2L)));
  assertTrue(range.includes(Marker.exactly(BIGINT, 1L)));
  assertTrue(range.includes(Marker.exactly(BIGINT, 0L)));
  assertFalse(range.includes(Marker.upperUnbounded(BIGINT)));
}

代码示例来源：origin: prestodb/presto

@Test
public void testEqualRange()
{
  Range range = Range.equal(BIGINT, 1L);
  assertEquals(range.getLow(), Marker.exactly(BIGINT, 1L));
  assertEquals(range.getHigh(), Marker.exactly(BIGINT, 1L));
  assertTrue(range.isSingleValue());
  assertFalse(range.isAll());
  assertEquals(range.getType(), BIGINT);
  assertFalse(range.includes(Marker.lowerUnbounded(BIGINT)));
  assertFalse(range.includes(Marker.exactly(BIGINT, 0L)));
  assertTrue(range.includes(Marker.exactly(BIGINT, 1L)));
  assertFalse(range.includes(Marker.exactly(BIGINT, 2L)));
  assertFalse(range.includes(Marker.upperUnbounded(BIGINT)));
}

代码示例来源：origin: prestodb/presto

@Test
public void testAllRange()
{
  Range range = Range.all(BIGINT);
  assertEquals(range.getLow(), Marker.lowerUnbounded(BIGINT));
  assertEquals(range.getHigh(), Marker.upperUnbounded(BIGINT));
  assertFalse(range.isSingleValue());
  assertTrue(range.isAll());
  assertEquals(range.getType(), BIGINT);
  assertTrue(range.includes(Marker.lowerUnbounded(BIGINT)));
  assertTrue(range.includes(Marker.below(BIGINT, 1L)));
  assertTrue(range.includes(Marker.exactly(BIGINT, 1L)));
  assertTrue(range.includes(Marker.above(BIGINT, 1L)));
  assertTrue(range.includes(Marker.upperUnbounded(BIGINT)));
}

代码示例来源：origin: prestodb/presto

@Test
public void testGreaterThanOrEqualRange()
{
  Range range = Range.greaterThanOrEqual(BIGINT, 1L);
  assertEquals(range.getLow(), Marker.exactly(BIGINT, 1L));
  assertEquals(range.getHigh(), Marker.upperUnbounded(BIGINT));
  assertFalse(range.isSingleValue());
  assertFalse(range.isAll());
  assertEquals(range.getType(), BIGINT);
  assertFalse(range.includes(Marker.lowerUnbounded(BIGINT)));
  assertFalse(range.includes(Marker.exactly(BIGINT, 0L)));
  assertTrue(range.includes(Marker.exactly(BIGINT, 1L)));
  assertTrue(range.includes(Marker.exactly(BIGINT, 2L)));
  assertTrue(range.includes(Marker.upperUnbounded(BIGINT)));
}

代码示例来源：origin: prestodb/presto

@Test
public void testRange()
{
  Range range = Range.range(BIGINT, 0L, false, 2L, true);
  assertEquals(range.getLow(), Marker.above(BIGINT, 0L));
  assertEquals(range.getHigh(), Marker.exactly(BIGINT, 2L));
  assertFalse(range.isSingleValue());
  assertFalse(range.isAll());
  assertEquals(range.getType(), BIGINT);
  assertFalse(range.includes(Marker.lowerUnbounded(BIGINT)));
  assertFalse(range.includes(Marker.exactly(BIGINT, 0L)));
  assertTrue(range.includes(Marker.exactly(BIGINT, 1L)));
  assertTrue(range.includes(Marker.exactly(BIGINT, 2L)));
  assertFalse(range.includes(Marker.exactly(BIGINT, 3L)));
  assertFalse(range.includes(Marker.upperUnbounded(BIGINT)));
}

代码示例来源：origin: com.facebook.presto/presto-spi

private void checkTypeCompatibility(Range range)
{
  if (!getType().equals(range.getType())) {
    throw new IllegalArgumentException(String.format("Mismatched Range types: %s vs %s", getType(), range.getType()));
  }
}

代码示例来源：origin: com.facebook.presto/presto-spi

Builder add(Range range)
{
  if (!type.equals(range.getType())) {
    throw new IllegalArgumentException(String.format("Range type %s does not match builder type %s", range.getType(), type));
  }
  ranges.add(range);
  return this;
}

代码示例来源：origin: com.facebook.presto/presto-spi

private void checkTypeCompatibility(Marker marker)
{
  if (!getType().equals(marker.getType())) {
    throw new IllegalArgumentException(String.format("Marker of %s does not match Range of %s", marker.getType(), getType()));
  }
}

代码示例来源：origin: com.facebook.presto/presto-spi

/**
 * Provided Ranges are unioned together to form the SortedRangeSet
 */
static SortedRangeSet of(Range first, Range... rest)
{
  List<Range> rangeList = new ArrayList<>(rest.length + 1);
  rangeList.add(first);
  for (Range range : rest) {
    rangeList.add(range);
  }
  return copyOf(first.getType(), rangeList);
}

代码示例来源：origin: harbby/presto-connectors

getRangesFromDomain(cd.getDomain()).forEach(range -> {
  checkArgument(range.isSingleValue(), "dsl is must [=] demo where _dsl = \"..dsl string\"");
  checkArgument(range.getType() instanceof VarcharType, "_dsl filter is not string");
  String dsl = ((Slice) range.getSingleValue()).toStringUtf8();
  dslCacher.put(columnName, dsl);
  checkArgument(column.getType().equals(range.getType()), "filter type is " + range.getType() + " but column [" + columnName + "] type is " + column.getType());
  QueryBuilder queryBuilder = getQueryBuilderFromPrestoRange(columnName, range);
  addEsQueryFilter(mergeDslMap, queryBuilder.toString());

代码示例来源：origin: harbby/presto-connectors

private static QueryBuilder getQueryBuilderFromPrestoRange(String columnName, Range prestoRange)
    throws TableNotFoundException
  Type type = prestoRange.getType();
  BoolQueryBuilder qb = QueryBuilders.boolQuery();
  if (prestoRange.isAll()) { //全表扫描  all rowkey

代码示例来源：origin: harbby/presto-connectors

private static QueryBuilder getQueryBuilderFromPrestoRange(String columnName, Range prestoRange)
    throws TableNotFoundException
  Type type = prestoRange.getType();
  BoolQueryBuilder qb = QueryBuilders.boolQuery();
  if (prestoRange.isAll()) { //全表扫描  all rowkey

代码示例来源：origin: harbby/presto-connectors

private static QueryBuilder getQueryBuilderFromPrestoRange(String columnName, Range prestoRange)
    throws TableNotFoundException
  Type type = prestoRange.getType();
  BoolQueryBuilder qb = QueryBuilders.boolQuery();
  if (prestoRange.isAll()) { //全表扫描  all rowkey

内容来源于网络，如有侵权，请联系作者删除！

range

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com