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

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

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

IntStream.mapToObj介绍

[英]Returns an object-valued Stream consisting of the results of applying the given function to the elements of this stream.

This is an intermediate operation.
[中]返回一个对象值流，该流包含将给定函数应用于该流元素的结果。
这是一个intermediate operation。

代码示例

代码示例来源：origin: prestodb/presto

private String columnDefinitions(List<DataTypeTest.Input<?>> inputs)
  {
    List<String> columnTypeDefinitions = inputs.stream()
        .map(DataTypeTest.Input::getInsertType)
        .collect(toList());
    Stream<String> columnDefinitions = range(0, columnTypeDefinitions.size())
        .mapToObj(i -> format("col_%d %s", i, columnTypeDefinitions.get(i)));
    return Joiner.on(",\n").join(columnDefinitions.iterator());
  }
}

代码示例来源：origin: spring-projects/spring-framework

protected String formatInvokeError(String text, Object[] args) {
  String formattedArgs = IntStream.range(0, args.length)
      .mapToObj(i -> (args[i] != null ?
          "[" + i + "] [type=" + args[i].getClass().getName() + "] [value=" + args[i] + "]" :
          "[" + i + "] [null]"))
      .collect(Collectors.joining(",\n", " ", " "));
  return text + "\n" +
      "Endpoint [" + getBeanType().getName() + "]\n" +
      "Method [" + getBridgedMethod().toGenericString() + "] " +
      "with argument values:\n" + formattedArgs;
}

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

private static List<String> map( int[] ids, IntFunction<String> f )
{
  return Arrays.stream(ids).mapToObj( f ).collect( Collectors.toList());
}

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

private String doHandlePropertySet(DbSession dbSession, SetRequest request, @Nullable PropertyDefinition definition, Optional<ComponentDto> component) {
 validatePropertySet(request, definition);
 int[] fieldIds = IntStream.rangeClosed(1, request.getFieldValues().size()).toArray();
 String inlinedFieldKeys = IntStream.of(fieldIds).mapToObj(String::valueOf).collect(COMMA_JOINER);
 String key = persistedKey(request);
 Long componentId = component.isPresent() ? component.get().getId() : null;
 deleteSettings(dbSession, component, key);
 dbClient.propertiesDao().saveProperty(dbSession, new PropertyDto().setKey(key).setValue(inlinedFieldKeys).setResourceId(componentId));
 List<String> fieldValues = request.getFieldValues();
 IntStream.of(fieldIds).boxed()
  .flatMap(i -> readOneFieldValues(fieldValues.get(i - 1), request.getKey()).entrySet().stream()
   .map(entry -> new KeyValue(key + "." + i + "." + entry.getKey(), entry.getValue())))
  .forEach(keyValue -> dbClient.propertiesDao().saveProperty(dbSession, toFieldProperty(keyValue, componentId)));
 return inlinedFieldKeys;
}

代码示例来源：origin: real-logic/simple-binary-encoding

private static <T> Iterable<T> reversedList(final List<T> list)
{
  return
    () ->
    {
      if (list.isEmpty())
      {
        return list.stream().iterator();
      }
      final int maxIndex = list.size() - 1;
      return IntStream.rangeClosed(0, maxIndex).mapToObj((i) -> list.get(maxIndex - i)).iterator();
    };
}

代码示例来源：origin: apache/flink

@Test
public void testAllFieldSerializer() {
  @SuppressWarnings("unchecked")
  TypeSerializer<Object>[] fieldSerializers = TEST_FIELD_SERIALIZERS.stream()
    .map(t -> (TypeSerializer<Object>) t.f0)
    .toArray((IntFunction<TypeSerializer<Object>[]>) TypeSerializer[]::new);
  List<Object>[] instances = IntStream.range(0, TEST_FIELD_SERIALIZERS.get(0).f1.length)
    .mapToObj(CompositeSerializerTest::getTestCase)
    .toArray((IntFunction<List<Object>[]>) List[]::new);
  runTests(getLength(fieldSerializers), fieldSerializers, instances);
}

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

@Test
public void does_not_fail_on_100_projects() {
 List<String> keys = IntStream.rangeClosed(1, 100)
  .mapToObj(i -> db.components().insertPrivateProject())
  .map(ComponentDto::getDbKey)
  .collect(Collectors.toList());
 MetricDto metric = db.measures().insertMetric();
 call(keys, singletonList(metric.getKey()));
}

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

private Set<Value> randomStrings()
{
  return ThreadLocalRandom.current()
      .ints( nodesToCreate, 1, 200 )
      .mapToObj( this::randomString )
      .map( Values::of )
      .collect( toSet() );
}

代码示例来源：origin: prestodb/presto

public void checkPlanIsDeterministic(Session session, String sql)
{
  IntStream.range(1, MINIMUM_SUBSEQUENT_SAME_PLANS)
      .mapToObj(attempt -> getPlanText(session, sql))
      .map(planEquivalenceFunction)
      .reduce((previous, current) -> {
        assertEquals(previous, current);
        return current;
      });
}

代码示例来源：origin: prestodb/presto

private ZipFunction(int arity)
{
  this(IntStream.rangeClosed(1, arity).mapToObj(s -> "T" + s).collect(toImmutableList()));
}

代码示例来源：origin: prestodb/presto

@Override
protected Stream<String> getQueryResourcePaths()
{
  return IntStream.rangeClosed(1, 22)
      .mapToObj(i -> format("q%02d", i))
      .map(queryId -> format("/sql/presto/tpch/%s.sql", queryId));
}

代码示例来源：origin: google/guava

public void testForEachPair_parallel() {
 Stream<String> streamA = IntStream.range(0, 100000).mapToObj(String::valueOf).parallel();
 Stream<Integer> streamB = IntStream.range(0, 100000).mapToObj(i -> i).parallel();
 AtomicInteger count = new AtomicInteger(0);
 Streams.forEachPair(
   streamA,
   streamB,
   (a, b) -> {
    count.incrementAndGet();
    Truth.assertThat(a.equals(String.valueOf(b))).isTrue();
   });
 Truth.assertThat(count.get()).isEqualTo(100000);
 // of course, this test doesn't prove that anything actually happened in parallel...
}

代码示例来源：origin: prestodb/presto

@Override
public TestTable setupTestTable(List<DataTypeTest.Input<?>> inputs)
{
  List<String> columnValues = inputs.stream()
      .map(this::literalInExplicitCast)
      .collect(toList());
  Stream<String> columnValuesWithNames = range(0, columnValues.size())
      .mapToObj(i -> format("%s col_%d", columnValues.get(i), i));
  String selectBody = Joiner.on(",\n").join(columnValuesWithNames.iterator());
  String ddlTemplate = "CREATE TABLE {TABLE_NAME} AS SELECT\n" + selectBody;
  return new TestTable(sqlExecutor, tableNamePrefix, ddlTemplate);
}

代码示例来源：origin: apache/hbase

@Test
 public void testCreateUnassignProceduresForMergeFail() throws IOException {
  List<RegionInfo> regions = getPrimaryRegions();
  RegionInfo regionA = regions.get(0);
  RegionInfo regionB = regions.get(1);
  AM.getRegionStates().getRegionStateNode(regionB)
   .setProcedure(TransitRegionStateProcedure.unassign(ENV, regionB));
  try {
   AssignmentManagerUtil.createUnassignProceduresForSplitOrMerge(ENV,
    Stream.of(regionA, regionB), REGION_REPLICATION);
   fail("Should fail as the region is in transition");
  } catch (HBaseIOException e) {
   // expected
  }
  IntStream.range(0, REGION_REPLICATION)
   .mapToObj(i -> RegionReplicaUtil.getRegionInfoForReplica(regionA, i))
   .map(AM.getRegionStates()::getRegionStateNode).forEachOrdered(
    rn -> assertFalse("Should have unset the proc for " + rn, rn.isInTransition()));
 }
}

代码示例来源：origin: spring-projects/spring-framework

protected String formatInvokeError(String text, Object[] args) {
  String formattedArgs = IntStream.range(0, args.length)
      .mapToObj(i -> (args[i] != null ?
          "[" + i + "] [type=" + args[i].getClass().getName() + "] [value=" + args[i] + "]" :
          "[" + i + "] [null]"))
      .collect(Collectors.joining(",\n", " ", " "));
  return text + "\n" +
      "Controller [" + getBeanType().getName() + "]\n" +
      "Method [" + getBridgedMethod().toGenericString() + "] " +
      "with argument values:\n" + formattedArgs;
}

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

@Test
public void fail_if_more_than_100_project_keys() {
 List<String> keys = IntStream.rangeClosed(1, 101)
  .mapToObj(i -> db.components().insertPrivateProject())
  .map(ComponentDto::getDbKey)
  .collect(Collectors.toList());
 MetricDto metric = db.measures().insertMetric();
 expectedException.expect(IllegalArgumentException.class);
 expectedException.expectMessage("101 projects provided, more than maximum authorized (100)");
 call(keys, singletonList(metric.getKey()));
}

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

private String asString( int[] propertyIds )
  {
    List<String> strings = Arrays.stream( propertyIds ).mapToObj( i -> "" + i ).collect( Collectors.toList() );
    return String.join( ", ", strings );
  }
}

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

@Test
public void testAllDescriptionsEndsWithPeriod() {
  final Set<String> badDescriptions = Arrays.stream(TokenUtil.getAllTokenIds())
    .mapToObj(TokenUtil::getTokenName).map(TokenUtil::getShortDescription)
    .filter(desc -> desc.charAt(desc.length() - 1) != '.').collect(Collectors.toSet());
  assertEquals("Malformed TokenType descriptions", Collections.emptySet(), badDescriptions);
}

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

@Test
public void checkNode_returns_causes_of_all_NodeHealthCheck_whichever_their_status() {
 NodeHealthCheck[] nodeHealthChecks = IntStream.range(0, 1 + random.nextInt(20))
  .mapToObj(s -> new HardcodedHealthNodeCheck(IntStream.range(0, random.nextInt(3)).mapToObj(i -> randomAlphanumeric(3)).toArray(String[]::new)))
  .map(NodeHealthCheck.class::cast)
  .toArray(NodeHealthCheck[]::new);
 String[] expected = Arrays.stream(nodeHealthChecks).map(NodeHealthCheck::check).flatMap(s -> s.getCauses().stream()).toArray(String[]::new);
 HealthCheckerImpl underTest = new HealthCheckerImpl(webServer, nodeHealthChecks);
 assertThat(underTest.checkNode().getCauses()).containsOnly(expected);
}

代码示例来源：origin: prestodb/presto

@Test
public void testAscending()
{
  test(IntStream.range(0, INPUT_SIZE),
      IntStream.range(0, INPUT_SIZE).mapToObj(key -> Integer.toString(key * 2)),
      MAX_ELEMENTS_COMPARATOR,
      IntStream.range(INPUT_SIZE - OUTPUT_SIZE, INPUT_SIZE).mapToObj(key -> Integer.toString(key * 2)).iterator());
  test(IntStream.range(0, INPUT_SIZE),
      IntStream.range(0, INPUT_SIZE).mapToObj(key -> Integer.toString(key * 2)),
      MIN_ELEMENTS_COMPARATOR,
      IntStream.range(0, OUTPUT_SIZE).map(x -> OUTPUT_SIZE - 1 - x).mapToObj(key -> Integer.toString(key * 2)).iterator());
}

内容来源于网络，如有侵权，请联系作者删除！

IntStream

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    IntStream类方法

    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com