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

IntStream.max介绍

[英]Returns an OptionalInt describing the maximum element of this stream, or an empty optional if this stream is empty. This is a special case of a reduction and is equivalent to:

return reduce(Integer::max);

This is a terminal operation.
[中]返回描述此流的最大元素的Optionant，如果此流为空，则返回空可选值。这是reduction的一个特例，相当于：

return reduce(Integer::max);

这是一个terminal operation。

代码示例

代码示例来源：origin: twosigma/beakerx

public OptionalInt totalPoints(List<List<Number>> listData) {
 return listData.stream().
     mapToInt(List::size).
     max();
}

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

public BucketPartitionFunction(BucketFunction bucketFunction, int[] bucketToPartition)
{
  this.bucketFunction = requireNonNull(bucketFunction, "bucketFunction is null");
  this.bucketToPartition = requireNonNull(bucketToPartition, "bucketToPartition is null").clone();
  partitionCount = IntStream.of(bucketToPartition).max().getAsInt() + 1;
}

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

private int computeTotalMainWidth() {
  final List<AttributedString> mainLines = getMainLines();
  final List<AttributedString> mainHeaderLines = getMainHeaderLines();
  final int max1 = mainLines.stream().mapToInt(AttributedString::length).max().orElse(0);
  final int max2 = mainHeaderLines.stream().mapToInt(AttributedString::length).max().orElse(0);
  return Math.max(max1, max2);
}

代码示例来源：origin: confluentinc/ksql

private int getMultiLineStringLength(final String multiLineString) {
 final String[] split = multiLineString.split("\n");
 return Arrays.stream(split)
   .mapToInt(String::length)
   .max()
   .orElse(0);
}

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

public static WriteChecksumBuilder createWriteChecksumBuilder(Map<Integer, Type> readColumns)
{
  requireNonNull(readColumns, "readColumns is null");
  checkArgument(!readColumns.isEmpty(), "readColumns is empty");
  int columnCount = readColumns.keySet().stream()
      .mapToInt(Integer::intValue)
      .max().getAsInt() + 1;
  checkArgument(readColumns.size() == columnCount, "checksum requires all columns to be read");
  ImmutableList.Builder<Type> types = ImmutableList.builder();
  for (int column = 0; column < columnCount; column++) {
    Type type = readColumns.get(column);
    checkArgument(type != null, "checksum requires all columns to be read");
    types.add(type);
  }
  return new WriteChecksumBuilder(types.build());
}

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

public StatisticsValidation createWriteStatisticsBuilder(Map<Integer, Type> readColumns)
{
  requireNonNull(readColumns, "readColumns is null");
  checkArgument(!readColumns.isEmpty(), "readColumns is empty");
  int columnCount = readColumns.keySet().stream()
      .mapToInt(Integer::intValue)
      .max().getAsInt() + 1;
  checkArgument(readColumns.size() == columnCount, "statistics validation requires all columns to be read");
  ImmutableList.Builder<Type> types = ImmutableList.builder();
  for (int column = 0; column < columnCount; column++) {
    Type type = readColumns.get(column);
    checkArgument(type != null, "statistics validation requires all columns to be read");
    types.add(type);
  }
  return new StatisticsValidation(types.build());
}

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

public static WriteChecksumBuilder createWriteChecksumBuilder(Map<Integer, Type> readColumns)
{
  requireNonNull(readColumns, "readColumns is null");
  checkArgument(!readColumns.isEmpty(), "readColumns is empty");
  int columnCount = readColumns.keySet().stream()
      .mapToInt(Integer::intValue)
      .max().getAsInt() + 1;
  checkArgument(readColumns.size() == columnCount, "checksum requires all columns to be read");
  ImmutableList.Builder<Type> types = ImmutableList.builder();
  for (int column = 0; column < columnCount; column++) {
    Type type = readColumns.get(column);
    checkArgument(type != null, "checksum requires all columns to be read");
    types.add(type);
  }
  return new WriteChecksumBuilder(types.build());
}

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

private int extractMaxIndex(String key, String suffixPattern) {
  // extract index and property keys
  final String escapedKey = Pattern.quote(key);
  final Pattern pattern = Pattern.compile(escapedKey + "\\.(\\d+)" + suffixPattern);
  final IntStream indexes = properties.keySet().stream()
    .flatMapToInt(k -> {
      final Matcher matcher = pattern.matcher(k);
      if (matcher.find()) {
        return IntStream.of(Integer.valueOf(matcher.group(1)));
      }
      return IntStream.empty();
    });
  // determine max index
  return indexes.max().orElse(-1);
}

代码示例来源：origin: confluentinc/ksql

private int getColumnLength(final List<String> columnHeaders,
  final List<List<String>> rowValues,
  final int i) {
 return Math.max(
   columnHeaders.get(i).length(),
   rowValues
     .stream()
     .mapToInt(r -> getMultiLineStringLength(r.get(i)))
     .max()
     .orElse(0));
}

代码示例来源：origin: goldmansachs/gs-collections

@Benchmark
public int serial_lazy_intstream_jdk()
{
  return this.integersJDK.stream().mapToInt(Integer::intValue).max().getAsInt();
}

代码示例来源：origin: shekhargulati/99-problems

public static IntPair maximize_unsorted(int[] numbers) {
  OptionalInt min = IntStream.of(numbers).min();
  OptionalInt max = IntStream.of(numbers).max();
  return new IntPair(min.getAsInt(), max.getAsInt());
}

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

private static List<Type> toTypes(Map<Symbol, Integer> layout, LocalExecutionPlanContext context)
{
  // verify layout covers all values
  int channelCount = layout.values().stream().mapToInt(Integer::intValue).max().orElse(-1) + 1;
  checkArgument(
      layout.size() == channelCount && ImmutableSet.copyOf(layout.values()).containsAll(ContiguousSet.create(closedOpen(0, channelCount), integers())),
      "Layout does not have a symbol for every output channel: %s", layout);
  Map<Integer, Symbol> channelLayout = ImmutableBiMap.copyOf(layout).inverse();
  return range(0, channelCount)
      .mapToObj(channelLayout::get)
      .map(context.getTypes()::get)
      .collect(toImmutableList());
}

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

@Override
public int length() {
  return IntStream.concat(
      IntStream.of(baseGraph.getAllEdges().length() - 1),
      extraEdges.stream().mapToInt(VirtualEdgeIteratorState::getEdge))
      .max().getAsInt()+1;
}

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

int getMaxValue(final List<int[]> vals)
{
 return vals
   .stream()
   .mapToInt(array -> IntStream.of(array).max().orElse(0))
   .max()
   .orElseThrow(NoSuchElementException::new);
}

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

private static VarcharType varcharType(List<String> values)
{
  if (values.stream().anyMatch(Objects::isNull)) {
    return VARCHAR;
  }
  return createVarcharType(values.stream().mapToInt(String::length).max().getAsInt());
}

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

private int maxValue()
  {
    return Arrays.stream( elements )
        .mapToInt( value ->  NumberUtils.toInt( value, 0 )).max().getAsInt();
  }
}

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

@Override
public int getNodes() {
  return IntStream.concat(
      IntStream.of(baseGraph.getNodes()-1),
      extraEdges.stream().flatMapToInt(edge -> IntStream.of(edge.getBaseNode(), edge.getAdjNode())))
      .max().getAsInt()+1;
}

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

@Override
public int getNodes() {
  return IntStream.concat(
      IntStream.of(graphHopperStorage.getNodes()-1),
      additionalEdges.stream().flatMapToInt(edge -> IntStream.of(edge.getBaseNode(), edge.getAdjNode())))
      .max().getAsInt()+1;
}

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

private int insertPublicProjectsWithBranches(OrganizationDto org, MetricDto ncloc, int minimumNcloc) {
 // private project
 ComponentDto project1 = db.components().insertPublicProject(org);
 return Math.max(
  // Create the ncloc on main branch
  insertLiveMeasures(project1, ncloc, minimumNcloc),
  // Create 5 branches and set the ncloc on them
  IntStream.range(1, 5)
   .map(i -> insertLiveMeasures(db.components().insertProjectBranch(project1), ncloc, minimumNcloc))
   .max().orElse(0)
 );
}

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

private int insertPrivateProjectsWithBranches(OrganizationDto org, MetricDto ncloc) {
 // private project
 ComponentDto project1 = db.components().insertMainBranch(org);
 return Math.max(
  // Create the ncloc on main branch
  insertLiveMeasures(project1, ncloc, 0),
  // Create 5 branches and set the ncloc on them
  IntStream.range(1, 5)
  .map(i -> insertLiveMeasures(db.components().insertProjectBranch(project1), ncloc, 0))
  .max().orElse(0)
 );
}