io.prestosql.spi.predicate.Range.getSingleValue()方法的使用及代码示例

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

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

Range.getSingleValue介绍

暂无

代码示例

代码示例来源:origin: prestosql/presto

  1. @Override
  2. public Object getSingleValue()
  3. {
  4. if (!isSingleValue()) {
  5. throw new IllegalStateException("SortedRangeSet does not have just a single value");
  6. }
  7. return lowIndexedRanges.values().iterator().next().getSingleValue();
  8. }

代码示例来源:origin: prestosql/presto

  1. private static String createShardPredicate(ImmutableList.Builder<JDBCType> types, ImmutableList.Builder<Object> values, Domain domain, JDBCType jdbcType)
  2. {
  3. List<Range> ranges = domain.getValues().getRanges().getOrderedRanges();
  4. // only apply predicates if all ranges are single values
  5. if (ranges.isEmpty() || !ranges.stream().allMatch(Range::isSingleValue)) {
  6. return "true";
  7. }
  8. ImmutableList.Builder<Object> valuesBuilder = ImmutableList.builder();
  9. ImmutableList.Builder<JDBCType> typesBuilder = ImmutableList.builder();
  10. StringJoiner rangePredicate = new StringJoiner(" OR ");
  11. for (Range range : ranges) {
  12. Slice uuidText = (Slice) range.getSingleValue();
  13. try {
  14. Slice uuidBytes = uuidStringToBytes(uuidText);
  15. typesBuilder.add(jdbcType);
  16. valuesBuilder.add(uuidBytes);
  17. }
  18. catch (IllegalArgumentException e) {
  19. return "true";
  20. }
  21. rangePredicate.add("shard_uuid = ?");
  22. }
  23. types.addAll(typesBuilder.build());
  24. values.addAll(valuesBuilder.build());
  25. return rangePredicate.toString();
  26. }

代码示例来源:origin: io.prestosql/presto-orc

  1. @VisibleForTesting
  2. public static Optional<Collection<Object>> extractDiscreteValues(ValueSet valueSet)
  3. {
  4. return valueSet.getValuesProcessor().transform(
  5. ranges -> {
  6. ImmutableList.Builder<Object> discreteValues = ImmutableList.builder();
  7. for (Range range : ranges.getOrderedRanges()) {
  8. if (!range.isSingleValue()) {
  9. return Optional.empty();
  10. }
  11. discreteValues.add(range.getSingleValue());
  12. }
  13. return Optional.of(discreteValues.build());
  14. },
  15. discreteValues -> Optional.of(discreteValues.getValues()),
  16. allOrNone -> allOrNone.isAll() ? Optional.empty() : Optional.of(ImmutableList.of()));
  17. }

代码示例来源:origin: prestosql/presto

  1. @VisibleForTesting
  2. public static Optional<Collection<Object>> extractDiscreteValues(ValueSet valueSet)
  3. {
  4. return valueSet.getValuesProcessor().transform(
  5. ranges -> {
  6. ImmutableList.Builder<Object> discreteValues = ImmutableList.builder();
  7. for (Range range : ranges.getOrderedRanges()) {
  8. if (!range.isSingleValue()) {
  9. return Optional.empty();
  10. }
  11. discreteValues.add(range.getSingleValue());
  12. }
  13. return Optional.of(discreteValues.build());
  14. },
  15. discreteValues -> Optional.of(discreteValues.getValues()),
  16. allOrNone -> allOrNone.isAll() ? Optional.empty() : Optional.of(ImmutableList.of()));
  17. }

代码示例来源:origin: io.prestosql/presto-spi

  1. @Test
  2. public void testGetSingleValue()
  3. {
  4. assertEquals(Range.equal(BIGINT, 0L).getSingleValue(), 0L);
  5. try {
  6. Range.lessThan(BIGINT, 0L).getSingleValue();
  7. fail();
  8. }
  9. catch (IllegalStateException e) {
  10. }
  11. }

代码示例来源:origin: prestosql/presto

  1. @Test
  2. public void testGetSingleValue()
  3. {
  4. assertEquals(Range.equal(BIGINT, 0L).getSingleValue(), 0L);
  5. try {
  6. Range.lessThan(BIGINT, 0L).getSingleValue();
  7. fail();
  8. }
  9. catch (IllegalStateException e) {
  10. }
  11. }

代码示例来源:origin: prestosql/presto

  1. return ImmutableSet.of();
  2. Object value = range.getSingleValue();

代码示例来源:origin: io.prestosql/presto-main

  1. singleValues.add(literalEncoder.toExpression(range.getSingleValue(), type));
  2. continue;
  3. singleValuesInRange.add(literalEncoder.toExpression(singleValueExclusions.next().getSingleValue(), type));

代码示例来源:origin: prestosql/presto

  1. singleValues.add(literalEncoder.toExpression(range.getSingleValue(), type));
  2. continue;
  3. singleValuesInRange.add(literalEncoder.toExpression(singleValueExclusions.next().getSingleValue(), type));

代码示例来源:origin: prestosql/presto

  1. StringBuilder builder = new StringBuilder();
  2. if (range.isSingleValue()) {
  3. String value = castToVarchar(type, range.getSingleValue(), functionRegistry, session);
  4. builder.append('[').append(value).append(']');

代码示例来源:origin: io.prestosql/presto-main

  1. StringBuilder builder = new StringBuilder();
  2. if (range.isSingleValue()) {
  3. String value = castToVarchar(type, range.getSingleValue(), functionRegistry, session);
  4. builder.append('[').append(value).append(']');

代码示例来源:origin: prestosql/presto

  1. Object maxValue = null;
  2. if (range.isSingleValue()) {
  3. minValue = range.getSingleValue();
  4. maxValue = range.getSingleValue();

代码示例来源:origin: prestosql/presto

  1. singleValues.add(CassandraCqlUtils.cqlValue(toCQLCompatibleString(range.getSingleValue()),
  2. columnHandle.getCassandraType()));

代码示例来源:origin: prestosql/presto

  1. for (Range range : domain.getValues().getRanges().getOrderedRanges()) {
  2. if (range.isSingleValue()) {
  3. singleValues.add(translateValue(range.getSingleValue(), type));

相关文章