java.util.stream.IntStream.mapToLong()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(6.7k)|赞(0)|评价(0)|浏览(458)

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

IntStream.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 IntMapToLongAction(IntToLongFunction mapper) {
  super(s -> s.mapToLong(requireNonNull(mapper)), IntStream.class, MAP_TO);
}

代码示例来源:origin: apache/incubator-druid

@Override
public long estimateEncodedKeyComponentSize(int[] key)
{
 // string length is being accounted for each time they are referenced, based on dimension handler interface,
 // even though they are stored just once. It may overestimate the size by a bit, but we wanted to leave
 // more buffer to be safe
 long estimatedSize = key.length * Integer.BYTES;
 estimatedSize += Arrays.stream(key)
             .filter(element -> dimLookup.getValue(element) != null)
             .mapToLong(element -> dimLookup.getValue(element).length() * Character.BYTES)
             .sum();
 return estimatedSize;
}

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

@Override
public LongStream mapToLong(IntToLongFunction mapper) {
  requireNonNull(mapper);
  if (STRICT) {
    return toStream().mapToLong(mapper);
  }
  return SingletonLongStream.of(mapper.applyAsLong(element));
}

代码示例来源:origin: neo4j/neo4j

return IntStream.range( 0, array.length ).mapToLong( i -> array[i] );
return IntStream.range( 0, array.length ).mapToLong( i -> array[i] );
return IntStream.of( (int[]) list ).mapToLong( i -> i );

代码示例来源:origin: apache/ignite

/**
 * Generates pseudorandom discrete distribution.
 *
 * @param numOfValues Number of distinct values of pseudorandom variable.
 * @param seed Seed.
 * @return Probabilities array.
 */
public static double[] randomDistribution(int numOfValues, long seed) {
  A.ensure(numOfValues > 0, "numberOfValues > 0");
  Random random = new Random(seed);
  long[] rnd = IntStream.range(0, numOfValues)
    .mapToLong(i -> random.nextInt(Integer.MAX_VALUE))
    .limit(numOfValues)
    .toArray();
  long sum = Arrays.stream(rnd).sum();
  double[] res = new double[numOfValues];
  for (int i = 0; i < res.length; i++)
    res[i] = rnd[i] / Math.max(1.0, sum);
  return res;
}

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

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

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

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

代码示例来源:origin: ben-manes/caffeine

@Test(dataProvider = "snapshot")
public void snapshot(boolean ascending, int limit, long nanos, Function<Long, Long> transformer) {
 int count = 21;
 timerWheel.nanos = nanos;
 int expected = Math.min(limit, count);
 Comparator<Long> order = ascending ? Comparator.naturalOrder() : Comparator.reverseOrder();
 List<Long> times = IntStream.range(0, count).mapToLong(i -> {
  long time = nanos + TimeUnit.SECONDS.toNanos(2 << i);
  timerWheel.schedule(new Timer(time));
  return time;
 }).boxed().sorted(order).collect(toList()).subList(0, expected);
 when(transformer.apply(anyLong())).thenAnswer(invocation -> invocation.getArgument(0));
 assertThat(snapshot(ascending, limit, transformer), is(times));
 verify(transformer, times(expected)).apply(anyLong());
}

代码示例来源:origin: SonarSource/sonarqube

@Before
public void setUp() throws Exception {
 organization = db.organizations().insert();
 user = db.users().insertUser();
 group1 = db.users().insertGroup(organization, "group1");
 group2 = db.users().insertGroup(organization, "group2");
 randomExistingUserIds = IntStream.range(0, 1 + Math.abs(random.nextInt(5)))
  .map(i -> db.users().insertUser().getId())
  .boxed()
  .collect(MoreCollectors.toSet());
 randomPublicProjectIds = IntStream.range(0, 1 + Math.abs(random.nextInt(5)))
  .mapToLong(i -> db.components().insertPublicProject(organization).getId())
  .boxed()
  .collect(MoreCollectors.toSet());
 randomPrivateProjectIds = IntStream.range(0, 1 + Math.abs(random.nextInt(5)))
  .mapToLong(i -> db.components().insertPrivateProject(organization).getId())
  .boxed()
  .collect(MoreCollectors.toSet());
}

代码示例来源:origin: lenskit/lenskit

private LongList recommendWithPredicate(int n, LongPredicate filter) {
  LongList items = statistics.getItemsByPopularity();
  LongList list = new LongArrayList(items.size());
  LongStream str = IntStream.range(0, items.size()).mapToLong(items::getLong);
  if (filter != null) {
    str = str.filter(filter);
  }
  if (n > 0) {
    str = str.limit(n);
  }
  str.forEachOrdered(list::add);
  return list;
}

代码示例来源:origin: stackoverflow.com

int [] iArr = new int[]{2147483646 , 1 , 1};
Long sum = Arrays.stream(iArr)
    .mapToLong(Long::valueOf)
    .sum();
System.out.println(sum);

代码示例来源:origin: stackoverflow.com

int[] iarr = new int[] { 1, 2, 3, 4, 5, 6 };
 long[] larr = Arrays.stream(iarr)
           .mapToLong((i) -> (long) i)
           .toArray();
 System.out.println(Arrays.toString(larr));

代码示例来源:origin: jenetics/jenetics

/**
 * Returns a sequential stream of the alleles with this chromosome as its
 * source.
 *
 * @since 4.3
 *
 * @return a sequential stream of alleles
 */
public LongStream longStream() {
  return IntStream.range(0, length()).mapToLong(this::longValue);
}

代码示例来源:origin: com.simiacryptus/mindseye-cudnn

/**
 * Get seeds long [ ].
 *
 * @return the long [ ]
 */
public long[] getSeeds() {
 Random random = new Random(seed + layerSeed);
 return IntStream.range(0, this.samples).mapToLong(i -> random.nextLong()).toArray();
}

代码示例来源:origin: stackoverflow.com

IntStream istream = ... 
LongAccumulator acc = new LongAccumulator(Long::min, Long.MAX_VALUE);

if (istream.mapToLong(i -> i).peek(acc::accumulate).allMatch(i -> i > N)) {
  System.out.println("min was " + acc.get());
} else {
  System.out.println("a value was <= " + N);
}

代码示例来源:origin: com.simiacryptus/mindseye

/**
 * Get seeds long [ ].
 *
 * @return the long [ ]
 */
public long[] getSeeds() {
 Random random = new Random(seed + layerSeed);
 return IntStream.range(0, this.samples).mapToLong(i -> random.nextLong()).toArray();
}

代码示例来源:origin: org.elasticsearch/elasticsearch

IntStream
  .range(0, sourceMetaData.getNumberOfShards())
  .mapToLong(sourceMetaData::primaryTerm)
  .max()
  .getAsLong();

代码示例来源:origin: org.n52.janmayen/janmayen

/**
 * Returns a reversed stream of the array values. Note that the index boundaries are given using the original order.
 *
 * @param array          the array
 * @param startInclusive the lowest index (i.e. the last element to return)
 * @param endInclusive   index immediately past the highest index (i.e. the index after the first returned value
 *
 * @return the reversed stream
 */
public static LongStream reverseStream(long[] array, int startInclusive, int endInclusive) {
  return reverseRange(startInclusive, endInclusive).mapToLong(i -> array[i]);
}

代码示例来源:origin: com.simiacryptus/mindseye

/**
 * Get seeds long [ ].
 *
 * @return the long [ ]
 */
public long[] getSeeds() {
 Random random = new Random(seed + layerSeed);
 return IntStream.range(0, this.samples).mapToLong(i -> random.nextLong()).toArray();
}

代码示例来源:origin: Baqend/Orestes-Bloomfilter

@Override
public synchronized long getEstimatedCount(T element) {
  return IntStream.of(hash(toBytes(element))).mapToLong(this::count).min().getAsLong();
}

相关文章

微信公众号

最新文章

更多