本文整理了Java中java.util.stream.IntStream.mapToLong()
方法的一些代码示例,展示了IntStream.mapToLong()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。IntStream.mapToLong()
方法的具体详情如下:
包路径:java.util.stream.IntStream
类名称: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();
}
内容来源于网络,如有侵权,请联系作者删除!