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

DoubleStream.mapToLong介绍

[英]Returns a LongStream consisting of the results of applying the given function to the elements of this stream.

This is an intermediate operation.
[中]返回由将给定函数应用于此流元素的结果组成的LongStream。
这是一个intermediate operation。

代码示例

代码示例来源：origin: speedment/speedment

public DoubleMapToLongAction(DoubleToLongFunction mapper) {
  super(s -> s.mapToLong(requireNonNull(mapper)), LongStream.class, MAP_TO);
}

代码示例来源：origin: speedment/speedment

@Override
  public LongStream build(boolean parallel) {
    return previous().build(parallel).mapToLong(mapper);
  }
}

代码示例来源：origin: speedment/speedment

@Override
public LongStream mapToLong(DoubleToLongFunction mapper) {
  return wrap(stream().mapToLong(mapper));
}

代码示例来源：origin: com.speedment.runtime/runtime-core

public DoubleMapToLongAction(DoubleToLongFunction mapper) {
  super(s -> s.mapToLong(requireNonNull(mapper)), LongStream.class, MAP_TO);
}

代码示例来源：origin: net.dongliu/commons-lang

@Override
public ExLongStream mapToLong(DoubleToLongFunction mapper) {
  return ExLongStream.of(stream.mapToLong(mapper));
}

代码示例来源：origin: se.ugli.ugli-commons/ugli-commons

@Override
public LongStream mapToLong(final DoubleToLongFunction mapper) {
  return new LongResourceStream(stream.mapToLong(mapper), closeOnTerminalOperation, resources);
}

代码示例来源：origin: org.apache.flink/flink-runtime_2.11

@Override
public long[] getValues() {
  return Arrays.stream(descriptiveStatistics.getValues()).mapToLong(i -> (long) i).toArray();
}

代码示例来源：origin: org.apache.flink/flink-runtime

@Override
public long[] getValues() {
  return Arrays.stream(descriptiveStatistics.getValues()).mapToLong(i -> (long) i).toArray();
}

代码示例来源：origin: com.alibaba.blink/flink-runtime

@Override
public long[] getValues() {
  return Arrays.stream(descriptiveStatistics.getValues()).mapToLong(i -> (long) i).toArray();
}

代码示例来源：origin: com.speedment.runtime/runtime-core

@Override
public LongStream mapToLong(DoubleToLongFunction mapper) {
  return wrap(stream().mapToLong(mapper));
}

代码示例来源：origin: one.util/streamex

@Override
public LongStreamEx mapToLong(DoubleToLongFunction mapper) {
  return new LongStreamEx(stream().mapToLong(mapper), context);
}

代码示例来源：origin: one.util/streamex

/**
 * Returns a stream consisting of the elements of this stream in reverse
 * sorted order. The elements are compared for equality according to
 * {@link java.lang.Double#compare(double, double)}.
 *
 * <p>
 * This is a stateful intermediate operation.
 *
 * @return the new stream
 * @since 0.0.8
 */
public DoubleStreamEx reverseSorted() {
  return new DoubleStreamEx(stream().mapToLong(d -> {
    long l = Double.doubleToRawLongBits(d);
    return l ^ (((l >>> 63) - 1) | Long.MIN_VALUE);
  }).sorted().mapToDouble(l -> Double.longBitsToDouble(l ^ ((-(l >>> 63)) | Long.MIN_VALUE))), context);
}

代码示例来源：origin: mzheravin/exchange-core

public static Map<String, String> createLatencyReportFast(IntLongHashMap latencies) {
  long size = latencies.values().sum();
  TreeMap<Integer, Long> grouped = new TreeMap<>();
  latencies.forEachKeyValue(grouped::put);
  int worstLatency = grouped.lastEntry().getKey();
  long[] percentileC = Arrays.stream(PERCENTILES).mapToLong(p -> (long) (size * p / 100.0)).toArray();
  Map<String, String> fmt = new LinkedHashMap<>();
  int stage = 0;
  long accum = 0;
  for (Map.Entry<Integer, Long> entry : grouped.entrySet()) {
    Long v = entry.getValue();
    accum += v;
    if (accum > percentileC[stage]) {
      String formattedValue = formatLatencyValueAsTime(entry.getKey());
      fmt.put((PERCENTILES[stage]) + "%", formattedValue);
      if (++stage >= percentileC.length) {
        break;
      }
    }
  }
  fmt.put("W", formatLatencyValueAsTime(worstLatency));
  return fmt;
}