com.google.common.collect.TreeRangeSet的实例源码

项目：javaide 文件：Formatter.java

/**
 * Converts zero-indexed,[closed,open) line ranges in the given source file to character ranges.
 */
public static RangeSet<Integer> lineRangestocharRanges(
        String input,RangeSet<Integer> lineRanges) {
    List<Integer> lines = new ArrayList<>();
    Iterators.addAll(lines,Newlines.lineOffsetIterator(input));
    lines.add(input.length() + 1);

    final RangeSet<Integer> characterRanges = TreeRangeSet.create();
    for (Range<Integer> lineRange :
            lineRanges.subRangeSet(Range.closedOpen(0,lines.size() - 1)).asRanges()) {
        int linestart = lines.get(lineRange.lowerEndpoint());
        // Exclude the trailing newline. This isn't strictly necessary,but handling blank lines
        // as empty ranges is convenient.
        int lineEnd = lines.get(lineRange.upperEndpoint()) - 1;
        Range<Integer> range = Range.closedOpen(linestart,lineEnd);
        characterRanges.add(range);
    }
    return characterRanges;
}

项目：hashsdn-controller 文件：FrontendShardDataTreeSnapshotMetadataTest.java

private static FrontendClientMetadata createFrontedClientMetadata(final long num) {
    final String index = String.valueOf(num);
    final String indexName = "test_" + index;
    final FrontendIdentifier frontendIdentifier = FrontendIdentifier.create(MemberName.forName(indexName),FrontendType.forName(index));
    final ClientIdentifier clientIdentifier = ClientIdentifier.create(frontendIdentifier,num);

    final RangeSet<UnsignedLong> purgedHistories = TreeRangeSet.create();
    purgedHistories.add(Range.closed(UnsignedLong.ZERO,UnsignedLong.ONE));

    final Collection<FrontendHistoryMetadata> currentHistories = Collections.singleton(
        new FrontendHistoryMetadata(num,num,true,ImmutableMap.of(UnsignedLong.ZERO,Boolean.TRUE),purgedHistories));

    return new FrontendClientMetadata(clientIdentifier,purgedHistories,currentHistories);
}

项目：bioasq 文件：TokenConceptAbstractQueryGenerator.java

@Override
public void process(JCas jcas) throws AnalysisEngineProcessException {
  Collection<Concept> concepts = TypeUtil.getConcepts(jcas);
  List<QueryConcept> qconcepts = ConceptAbstractQueryGenerator
          .createqueryConceptsFromConceptMentions(jcas,concepts,useType,useWeight);
  // filter tokens that are covered by concept mentions
  RangeSet<Integer> cmentionRanges = TreeRangeSet.create();
  concepts.stream().map(TypeUtil::getConceptMentions).flatMap(Collection::stream)
          .map(cmention -> Range.closedOpen(cmention.getBegin(),cmention.getEnd()))
          .forEach(cmentionRanges::add);
  // create an aquery using all tokens with POS in posTags set
  List<Token> tokens = TypeUtil.getorderedTokens(jcas).stream().filter(token -> !cmentionRanges
          .encloses(Range.closedOpen(token.getBegin(),token.getEnd()))).collect(toList());
  List<QueryConcept> qconceptTokens = TokenSelectionAbstractQueryGenerator
          .createqueryConceptsFromTokens(jcas,tokens,posTags,stoplist);
  qconceptTokens.addAll(qconcepts);
  AbstractQuery aquery = TypeFactory.createAbstractQuery(jcas,qconceptTokens);
  aquery.addToIndexes();
  // create a backup aquery using only nouns
  List<QueryConcept> qconceptNouns = TokenSelectionAbstractQueryGenerator
          .createqueryConceptsFromTokens(jcas,nounTags,stoplist);
  qconceptNouns.addAll(qconcepts);
  AbstractQuery aqueryNoun = TypeFactory.createAbstractQuery(jcas,qconceptNouns);
  aqueryNoun.addToIndexes();
}

项目：cerberus-serverless-components 文件：RateLimitingProcessorTest.java

@Test
public void testThatFilterandTruncateViolatorsFiltersIPsInDoNotBlockRangeSet() {
    config.setRateLimitViolationBlacklistPeriodInMinutes(1);
    RangeSet<Integer> doNotAutoBlockIpRangeSet = TreeRangeSet.create();

    subnetUtils subnetUtils = new subnetUtils("50.39.100.193/32");
    subnetUtils.setInclusiveHostCount(true);
    subnetUtils.subnetInfo subnetInfo = subnetUtils.getInfo();
    Integer lowIpAsInt = subnetInfo.asInteger(subnetInfo.getLowAddress());
    Integer highIpAsInt = subnetInfo.asInteger(subnetInfo.getHighAddress());
    doNotAutoBlockIpRangeSet.add(Range.closed(lowIpAsInt,highIpAsInt));

    Map<String,ViolationMetaData> violators = new HashMap<>();
    violators.put("50.39.100.193",new ViolationMetaData(new Date(),2));
    Map<String,ViolationMetaData> actual = processor.filterandTruncateViolators(config,doNotAutoBlockIpRangeSet,violators);

    assertTrue("The violators map should be empty after filtering",actual.size() == 0);
}

项目：cerberus-serverless-components 文件：RateLimitingProcessorTest.java

@Test
public void testThatFilterandTruncateViolatorsTruncatesTheLowestOffenders() {
    final int cidrLimit = 2;
    processor.setCidrLimitForIpSetoverride(cidrLimit);
    config.setRateLimitViolationBlacklistPeriodInMinutes(10);

    RangeSet<Integer> rangeSet = TreeRangeSet.create();

    Map<String,3));
    violators.put("50.39.100.191",1));
    violators.put("50.39.100.192",2));
    violators.put("50.39.100.194",4));
    Map<String,rangeSet,violators);

    assertTrue("The violators map should be the size of the cidr limit",actual.size() == cidrLimit);
    assertTrue("violators should contain 193 and 194 the highest offenders",actual.containsKey("50.39.100.193") && actual.containsKey("50.39.100.194"));
}

项目：proxl-web-app 文件：ProteinSequenceCoverage.java

/**
 * Add another protein sequence coverage object's ranges to this one's
 * 
 * @param coveragetoAdd
 */
public void addSequenceCoverageObject( ProteinSequenceCoverage coveragetoAdd ) throws Exception {

    if( this.ranges == null )
        this.ranges = TreeRangeSet.create();

    if( this.getProtein().getProteinSequenceVersionId() != coveragetoAdd.getProtein().getProteinSequenceVersionId() )
        throw new ProxlWebappInternalErrorException( "Attempted to add two coverage objects that do not describe the same protein." );

    if( coveragetoAdd.getRanges() == null )
        return;

    for( Range<Integer> r : coveragetoAdd.getRanges() ) {
        this.ranges.add( r );
    }
}

项目：google-java-format 文件：Formatter.java

/**
 * Converts zero-indexed,open) line ranges in the given source file to character ranges.
 */
public static RangeSet<Integer> lineRangestocharRanges(
    String input,RangeSet<Integer> lineRanges) {
  List<Integer> lines = new ArrayList<>();
  Iterators.addAll(lines,Newlines.lineOffsetIterator(input));
  lines.add(input.length() + 1);

  final RangeSet<Integer> characterRanges = TreeRangeSet.create();
  for (Range<Integer> lineRange :
      lineRanges.subRangeSet(Range.closedOpen(0,lines.size() - 1)).asRanges()) {
    int linestart = lines.get(lineRange.lowerEndpoint());
    // Exclude the trailing newline. This isn't strictly necessary,but handling blank lines
    // as empty ranges is convenient.
    int lineEnd = lines.get(lineRange.upperEndpoint()) - 1;
    Range<Integer> range = Range.closedOpen(linestart,lineEnd);
    characterRanges.add(range);
  }
  return characterRanges;
}

项目：calcite 文件：DruidDateTimeUtils.java

/**
 * Generates a list of {@link Interval}s equivalent to a given
 * expression. Assumes that all the predicates in the input
 * reference a single column: the timestamp column.
 */
public static List<Interval> createInterval(RexNode e,String timeZone) {
  final List<Range<TimestampString>> ranges =
      extractRanges(e,TimeZone.getTimeZone(timeZone),false);
  if (ranges == null) {
    // We did not succeed,bail out
    return null;
  }
  final TreeRangeSet condensedRanges = TreeRangeSet.create();
  for (Range r : ranges) {
    condensedRanges.add(r);
  }
  if (LOGGER.isDebugEnabled()) {
    LOGGER.debug("Inferred ranges on interval : " + condensedRanges);
  }
  return toInterval(
      ImmutableList.<Range>copyOf(condensedRanges.asRanges()));
}

项目：calcite 文件：DaterangeRules.java

private RexNode compareFloorCeil(sqlKind comparison,RexNode operand,RexLiteral timeLiteral,TimeUnitRange timeUnit,boolean floor) {
  RangeSet<Calendar> rangeSet = operandRanges.get(operand.toString());
  if (rangeSet == null) {
    rangeSet = ImmutableRangeSet.<Calendar>of().complement();
  }
  final RangeSet<Calendar> s2 = TreeRangeSet.create();
  final Calendar c = timestampValue(timeLiteral);
  final Range<Calendar> range = floor
      ? floorRange(timeUnit,comparison,c)
      : ceilRange(timeUnit,c);
  s2.add(range);
  // Intersect old range set with new.
  s2.removeAll(rangeSet.complement());
  operandRanges.put(operand.toString(),ImmutableRangeSet.copyOf(s2));
  if (range.isEmpty()) {
    return rexBuilder.makeLiteral(false);
  }
  return toRex(operand,range);
}

项目：peercentrum-core 文件：P2PBlobRangeSet.java

public P2PBlobRangeSet constrainMaximumSpan(int maximumSpanSize) {
  int currentSize=0;
  RangeSet<Integer> constrainedRange=TreeRangeSet.create();
  for(Range<Integer> r: ranges.asRanges()){
    int sizeOfRange=r.upperEndpoint()-r.lowerEndpoint()+1;
    if(currentSize+sizeOfRange<=maximumSpanSize){
      currentSize+=sizeOfRange;
      constrainedRange.add(r);
    }
    else{
      sizeOfRange=maximumSpanSize-currentSize-1;
      constrainedRange.add(Range.closed(r.lowerEndpoint(),r.lowerEndpoint()+sizeOfRange));
      break;
    }
  }
  return new P2PBlobRangeSet(constrainedRange);
}

项目：ngs 文件：AlignmentsTest.java

@Before
public void setUp() throws Exception {
    ranges = new ArrayList<Range<Long>>();
    ranges.add(Range.closedOpen(0L,0L));
    ranges.add(Range.closedOpen(0L,1L));
    ranges.add(Range.closedOpen(0L,43L));
    ranges.add(Range.closedOpen(1L,43L));

    rangeSet = TreeRangeSet.create();
    rangeSet.add(Range.closedOpen(0L,0L));
    rangeSet.add(Range.closedOpen(0L,1L));
    rangeSet.add(Range.closedOpen(0L,43L));
    rangeSet.add(Range.closedOpen(1L,43L));

    subject = DNATools.createGappedDNASequence("aaaattttaaaattttaaaa","subject");
    query = DNATools.createGappedDNASequence("aaaaccccaaaa----aaaa","query");
    substitutionMatrix = SubstitutionMatrix.getNuc4_4();
    alignmentPair = new AlignmentPair(query,subject,substitutionMatrix);
}

项目：tac-kbp-eal 文件：FancierDiffLogger.java

private String context(final String originalDocText,final Response response) {
  // [1,3],[2,5],[8,10] => [1,10]
  final List<CharOffsetSpan> charSpans = justificationSpans(response);
  final List<CharOffsetSpan> unitedSpans = Lists.newArrayList();

  // use RangeSet to do this
  final RangeSet<Integer> disconnected = TreeRangeSet.create();
  for (CharOffsetSpan charSpan : charSpans) {
    int startInclusive = charSpan.startInclusive();
    int endInclusive = charSpan.endInclusive();
    startInclusive = (startInclusive - 100) >= 0 ? startInclusive - 100 : 0;
    endInclusive =
        (endInclusive + 100) < originalDocText.length() ? endInclusive + 100 : endInclusive;
    disconnected.add(Range.closed(startInclusive,endInclusive));
  }
  for (Range<Integer> range : disconnected.asRanges()) {
    unitedSpans.add(CharOffsetSpan.fromOffsetsOnly(range.lowerEndpoint(),range.upperEndpoint()));
  }
  Collections.sort(unitedSpans);
  String justificationsstring = "";
  if (unitedSpans.get(0).startInclusive() != 0) {
    justificationsstring += "[.....]";
  }
  for (CharOffsetSpan span : unitedSpans) {
    justificationsstring +=
        originalDocText.substring(span.startInclusive(),span.endInclusive() + 1);
    justificationsstring += "[.....]";
  }
  return justificationsstring;
}

项目：javaide 文件：SnippetFormatter.java

/**
 * Runs the Google Java formatter on the given source,with only the given ranges specified.
 */
public List<Replacement> format(
        SnippetKind kind,String source,List<Range<Integer>> ranges,int initialIndent,boolean includeComments)
        throws FormatterException {
    RangeSet<Integer> rangeSet = TreeRangeSet.create();
    for (Range<Integer> range : ranges) {
        rangeSet.add(range);
    }
    if (includeComments) {
        if (kind != SnippetKind.COMPILATION_UNIT) {
            throw new IllegalArgumentException(
                    "comment formatting is only supported for compilation units");
        }
        return formatter.getFormatReplacements(source,ranges);
    }
    SnippetWrapper wrapper = snippetWrapper(kind,source,initialIndent);
    ranges = offsetRanges(ranges,wrapper.offset);

    String replacement = formatter.formatSource(wrapper.contents.toString(),ranges);
    replacement =
            replacement.substring(
                    wrapper.offset,replacement.length() - (wrapper.contents.length() - wrapper.offset - source.length()));

    List<Replacement> replacements = toReplacements(source,replacement);
    List<Replacement> filtered = new ArrayList<>();
    for (Replacement r : replacements) {
        if (rangeSet.encloses(r.getReplaceRange())) {
            filtered.add(r);
        }
    }
    return filtered;
}

项目：javaide 文件：JavaInput.java

public RangeSet<Integer> characterRangesToTokenRanges(Collection<Range<Integer>> characterRanges)
        throws FormatterException {
    RangeSet<Integer> tokenRangeSet = TreeRangeSet.create();
    for (Range<Integer> characterRange0 : characterRanges) {
        Range<Integer> characterRange = characterRange0.canonical(discreteDomain.integers());
        tokenRangeSet.add(
                characterRangetoTokenRange(
                        characterRange.lowerEndpoint(),characterRange.upperEndpoint() - characterRange.lowerEndpoint()));
    }
    return tokenRangeSet;
}

项目：athena 文件：EncodeddiscreteResources.java

static EncodeddiscreteResources of(Set<discreteResource> resources,discreteResourceCodec codec) {
    RangeSet<Integer> rangeSet = TreeRangeSet.create();
    resources.stream()
            .map(x -> x.valueAs(Object.class))
            .flatMap(Tools::stream)
            .map(x -> codec.encode(x))
            .map(Range::singleton)
            .map(x -> x.canonical(discreteDomain.integers()))
            .forEach(rangeSet::add);

    return new EncodeddiscreteResources(rangeSet,codec);
}

项目：athena 文件：EncodedResourcesSerializer.java

@Override
public EncodeddiscreteResources read(Kryo kryo,Input input,Class<EncodeddiscreteResources> cls) {
    @SuppressWarnings("unchecked")
    List<ClosedOpenRange> ranges = kryo.readobject(input,ArrayList.class);
    discreteResourceCodec codec = (discreteResourceCodec) kryo.readClassAndobject(input);

    RangeSet<Integer> rangeSet = TreeRangeSet.create();
    ranges.stream()
            .map(x -> Range.closedOpen(x.lowerBound(),x.upperBound()))
            .forEach(rangeSet::add);
    return new EncodeddiscreteResources(rangeSet,codec);
}

项目：hashsdn-controller 文件：FrontendHistoryMetadata.java

public static FrontendHistoryMetadata readFrom(final DataInput in) throws IOException {
    byte header = WritableObjects.readLongHeader(in);
    final long historyId = WritableObjects.readFirstLong(in,header);
    final long cookie = WritableObjects.readSecondLong(in,header);
    final boolean closed = in.readBoolean();

    header = WritableObjects.readLongHeader(in);
    long ls = WritableObjects.readFirstLong(in,header);
    Verify.verify(ls >= 0 && ls <= Integer.MAX_VALUE);
    final int csize = (int) ls;

    ls = WritableObjects.readSecondLong(in,header);
    Verify.verify(ls >= 0 && ls <= Integer.MAX_VALUE);
    final int psize = (int) ls;

    final Map<UnsignedLong,Boolean> closedTransactions = new HashMap<>(csize);
    for (int i = 0; i < csize; ++i) {
        final UnsignedLong key = UnsignedLong.fromLongBits(WritableObjects.readLong(in));
        final Boolean value = Boolean.valueOf(in.readBoolean());
        closedTransactions.put(key,value);
    }
    final RangeSet<UnsignedLong> purgedTransactions = TreeRangeSet.create();
    for (int i = 0; i < psize; ++i) {
        final byte h = WritableObjects.readLongHeader(in);
        final UnsignedLong l = UnsignedLong.fromLongBits(WritableObjects.readFirstLong(in,h));
        final UnsignedLong u = UnsignedLong.fromLongBits(WritableObjects.readSecondLong(in,h));
        purgedTransactions.add(Range.closed(l,u));
    }

    return new FrontendHistoryMetadata(historyId,cookie,closed,closedTransactions,purgedTransactions);
}