java类com.google.common.collect.ImmutableSortedMap的实例源码

@Override
public void run()
{
    logger.info("Blast Server Running");
    Stopwatch timer = Stopwatch.createStarted();

    while (m_keepRunning)
    {
        long now = System.currentTimeMillis();
        DataPoint dataPoint = m_longDataPointFactory.createDataPoint(now, 42);
        int row = RandomUtils.nextInt(0, m_numberOfRows);
        ImmutableSortedMap<String, String> tags = ImmutableSortedMap.of("row",
                String.valueOf(row), "host", "blast_server");

        try
        {
            m_datastore.putDataPoint(m_metricName, tags, dataPoint, m_ttl);
        }
        catch (DatastoreException e)
        {
            e.printStackTrace();
        }
        m_counter ++;

        if ((m_counter % 100000 == 0) && (timer.elapsed(TimeUnit.SECONDS) > m_durration))
            m_keepRunning = false;

    }
}

public static <T, K, V> Collector<T, ?, ImmutableSortedMap<K, V>> toSortedMap(Comparator<? super K> comparator, Function<? super T, ? extends K> keyMapper, Function<? super T, ? extends V> valueMapper) {
    return Collector.of(
            () -> new ImmutableSortedMap.Builder<K, V>(comparator),
            (builder, input) -> builder.put(keyMapper.apply(input), valueMapper.apply(input)),
            (l, r) -> l.putAll(r.build()),
            ImmutableSortedMap.Builder::build,
            Collector.Characteristics.UNORDERED
    );
}

@Inject
HealthChecker(
    UriInfo uriInfo,
    ServiceMetadata serviceMetadata,
    Map<String, HealthDependency> healthDependencies) {
  this.uriInfo = uriInfo;
  this.serviceMetadata = serviceMetadata;
  this.healthDependencies = ImmutableSortedMap.copyOf(healthDependencies);
}

protected AbstractReflectionThriftCodec(ThriftCodecManager manager, ThriftStructMetadata metadata)
{
    this.metadata = metadata;

    ImmutableSortedMap.Builder<Short, ThriftCodec<?>> fields = ImmutableSortedMap.naturalOrder();
    for (ThriftFieldMetadata fieldMetadata : metadata.getFields(THRIFT_FIELD)) {
        fields.put(fieldMetadata.getId(), manager.getCodec(fieldMetadata.getThriftType()));
    }
    this.fields = fields.build();
}

@Test
public void testConstructTermAnnotationToLabelsMap() {
  Map<TermId, Collection<String>> map = ImmutableSortedMap
      .copyOf(TermAnnotations.constructTermAnnotationToLabelsMap(ontology, annotations));
  assertEquals(
      "{ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000001]=[two, one], ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000002]=[two, three, one], ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000003]=[two, one], ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000004]=[two, one], ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000005]=[two, three, one]}",
      map.toString());
}

@Test
public void testConstructTermLabelToAnnotationsMap() {
  Map<String, Collection<TermId>> map = ImmutableSortedMap
      .copyOf(TermAnnotations.constructTermLabelToAnnotationsMap(ontology, annotations));
  assertEquals(
      "{one=[ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000002], ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000003], ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000004], ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000005], ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000001]], three=[ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000002], ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000005]], two=[ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000002], ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000003], ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000004], ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000005], ImmutableTermId [prefix=ImmutableTermPrefix [value=HP], id=0000001]]}",
      map.toString());
}

private void putInternalDataPoint(String metricName, ImmutableSortedMap<String, String> tags, DataPoint dataPoint)
{
    try
    {
        putDataPoint(metricName, tags, dataPoint, 0);
    }
    catch (DatastoreException e)
    {
        logger.error("", e);
    }
}

@GwtIncompatible // SerializableTester
public void testViewSerialization() {
  Map<String, Integer> map =
      ImmutableSortedMap.of("one", 1, "two", 2, "three", 3);
  SerializableTester.reserializeAndAssert(map.entrySet());
  SerializableTester.reserializeAndAssert(map.keySet());
  assertEquals(Lists.newArrayList(map.values()),
      Lists.newArrayList(SerializableTester.reserialize(map.values())));
}

public void putDataPoint(String metricName,
        ImmutableSortedMap<String, String> tags,
        DataPoint dataPoint, int ttl) throws DatastoreException
{
    //Add to datastore first.
    m_datastore.putDataPoint(metricName, tags, dataPoint, ttl);

    for (DataPointListener dataPointListener : m_dataPointListeners)
    {
        dataPointListener.dataPoint(metricName, tags, dataPoint);
    }
}

@Override
public SortedMap<String, String> create(Entry<String, String>[] entries) {
  ImmutableSortedMap.Builder<String, String> builder = ImmutableSortedMap.naturalOrder();
  for (Entry<String, String> entry : entries) {
    checkNotNull(entry);
    builder.put(entry.getKey(), entry.getValue());
  }
  return builder.build();
}