hg: lambda/lambda/jdk: 8 new changesets

mike.duigou at oracle.com mike.duigou at oracle.com
Mon Oct 15 16:11:15 PDT 2012 

Changeset: 6e0ca4cca828
Author:    psandoz
Date:      2012-10-15 15:06 -0700
URL:       http://hg.openjdk.java.net/lambda/lambda/jdk/rev/6e0ca4cca828

Replace ParallelOp with EvaluableOp for sequential and parallel evaluation. Remove ParallelPipelineHelper.suggestedDepth as AbstractPipeline should, in the future, decide whether to evaluate sequentially or in parallel.

! src/share/classes/java/util/streams/AbstractPipeline.java
! src/share/classes/java/util/streams/ParallelPipelineHelper.java
! src/share/classes/java/util/streams/PipelineHelper.java
! src/share/classes/java/util/streams/ops/AbstractTask.java
! src/share/classes/java/util/streams/ops/ConcatOp.java
! src/share/classes/java/util/streams/ops/CumulateOp.java
+ src/share/classes/java/util/streams/ops/EvaluableOp.java
! src/share/classes/java/util/streams/ops/FindAnyOp.java
! src/share/classes/java/util/streams/ops/FindFirstOp.java
! src/share/classes/java/util/streams/ops/FoldOp.java
! src/share/classes/java/util/streams/ops/ForEachOp.java
! src/share/classes/java/util/streams/ops/GroupByOp.java
! src/share/classes/java/util/streams/ops/LimitOp.java
! src/share/classes/java/util/streams/ops/MapLimitOp.java
! src/share/classes/java/util/streams/ops/MatchOp.java
- src/share/classes/java/util/streams/ops/ParallelOp.java
! src/share/classes/java/util/streams/ops/ReduceByOp.java
! src/share/classes/java/util/streams/ops/StatefulOp.java
! src/share/classes/java/util/streams/ops/TerminalOp.java
! src/share/classes/java/util/streams/ops/ToArrayOp.java
! src/share/classes/java/util/streams/ops/TreeUtils.java

Changeset: 9ee3890658f9
Author:    psandoz
Date:      2012-10-15 15:20 -0700
URL:       http://hg.openjdk.java.net/lambda/lambda/jdk/rev/9ee3890658f9

Add encounter order flag to stream accessors and operations. Implement GroupOp.evaluateParallel, which currently does not preserve encounter order.

! src/share/classes/java/util/LinkedHashMap.java
! src/share/classes/java/util/LinkedHashSet.java
! src/share/classes/java/util/List.java
! src/share/classes/java/util/Set.java
! src/share/classes/java/util/SortedMap.java
! src/share/classes/java/util/SortedSet.java
! src/share/classes/java/util/streams/AbstractPipeline.java
! src/share/classes/java/util/streams/Spliterator.java
! src/share/classes/java/util/streams/Stream.java
! src/share/classes/java/util/streams/StreamAccessor.java
! src/share/classes/java/util/streams/Streams.java
! src/share/classes/java/util/streams/ops/FlatMapOp.java
! src/share/classes/java/util/streams/ops/GroupByOp.java
! src/share/classes/java/util/streams/ops/SortedOp.java
! src/share/classes/java/util/streams/ops/ToArrayOp.java
! src/share/classes/java/util/streams/ops/TreeUtils.java

Changeset: c6f42702e95f
Author:    psandoz
Date:      2012-10-15 15:31 -0700
URL:       http://hg.openjdk.java.net/lambda/lambda/jdk/rev/c6f42702e95f

Implement UniqOp.evaluateParallel, which currently does not preserve encounter order. Extenstions to testing infrastructure.

! src/share/classes/java/util/streams/ops/UniqOp.java
! test-ng/tests/org/openjdk/tests/java/util/LambdaTestHelpers.java
! test-ng/tests/org/openjdk/tests/java/util/streams/ops/StreamOpTestCase.java
! test-ng/tests/org/openjdk/tests/java/util/streams/ops/UniqOpTest.java

Changeset: 121debc3d4be
Author:    psandoz
Date:      2012-10-15 15:35 -0700
URL:       http://hg.openjdk.java.net/lambda/lambda/jdk/rev/121debc3d4be

Declarative flags defined using an enum.

! src/share/classes/java/util/LinkedHashMap.java
! src/share/classes/java/util/LinkedHashSet.java
! src/share/classes/java/util/List.java
! src/share/classes/java/util/Set.java
! src/share/classes/java/util/SortedMap.java
! src/share/classes/java/util/SortedSet.java
! src/share/classes/java/util/streams/AbstractPipeline.java
! src/share/classes/java/util/streams/PipelineHelper.java
! src/share/classes/java/util/streams/Stream.java
! src/share/classes/java/util/streams/StreamAccessor.java
+ src/share/classes/java/util/streams/StreamOpFlags.java
! src/share/classes/java/util/streams/Streams.java
! src/share/classes/java/util/streams/ops/BiFilterOp.java
! src/share/classes/java/util/streams/ops/BiMapOp.java
! src/share/classes/java/util/streams/ops/BiTeeOp.java
! src/share/classes/java/util/streams/ops/ConcatOp.java
! src/share/classes/java/util/streams/ops/CumulateOp.java
! src/share/classes/java/util/streams/ops/FilterOp.java
! src/share/classes/java/util/streams/ops/FlatMapOp.java
! src/share/classes/java/util/streams/ops/GroupByOp.java
! src/share/classes/java/util/streams/ops/IntermediateOp.java
! src/share/classes/java/util/streams/ops/LimitOp.java
! src/share/classes/java/util/streams/ops/MapExtractKeysOp.java
! src/share/classes/java/util/streams/ops/MapExtractValuesOp.java
! src/share/classes/java/util/streams/ops/MapFilterKeysOp.java
! src/share/classes/java/util/streams/ops/MapFilterValuesOp.java
! src/share/classes/java/util/streams/ops/MapLimitOp.java
! src/share/classes/java/util/streams/ops/MapMapValuesOp.java
! src/share/classes/java/util/streams/ops/MapOp.java
! src/share/classes/java/util/streams/ops/MapSkipOp.java
! src/share/classes/java/util/streams/ops/MapSwapOp.java
! src/share/classes/java/util/streams/ops/MappedOp.java
! src/share/classes/java/util/streams/ops/SkipOp.java
! src/share/classes/java/util/streams/ops/SortedOp.java
! src/share/classes/java/util/streams/ops/TeeOp.java
! src/share/classes/java/util/streams/ops/ToArrayOp.java
! src/share/classes/java/util/streams/ops/TreeUtils.java
! src/share/classes/java/util/streams/ops/UniqOp.java
+ test-ng/tests/org/openjdk/tests/java/util/streams/StreamOpFlagsTest.java
! test-ng/tests/org/openjdk/tests/java/util/streams/ops/StreamOpTestCase.java
! test-ng/tests/org/openjdk/tests/java/util/streams/ops/ToArrayOpTest.java

Changeset: f55d346fb998
Author:    psandoz
Date:      2012-10-15 15:44 -0700
URL:       http://hg.openjdk.java.net/lambda/lambda/jdk/rev/f55d346fb998

Refactor StreamBuilder to be a NodeBuilder that extends from Node.

! src/share/classes/java/util/streams/AbstractPipeline.java
- src/share/classes/java/util/streams/StreamBuilder.java
- src/share/classes/java/util/streams/StreamBuilders.java
! src/share/classes/java/util/streams/ValuePipeline.java
! src/share/classes/java/util/streams/ops/ConcatOp.java
! src/share/classes/java/util/streams/ops/CumulateOp.java
! src/share/classes/java/util/streams/ops/FlatMapOp.java
! src/share/classes/java/util/streams/ops/GroupByOp.java
! src/share/classes/java/util/streams/ops/LimitOp.java
! src/share/classes/java/util/streams/ops/MapLimitOp.java
+ src/share/classes/java/util/streams/ops/Node.java
+ src/share/classes/java/util/streams/ops/NodeBuilder.java
+ src/share/classes/java/util/streams/ops/Nodes.java
! src/share/classes/java/util/streams/ops/StatefulOp.java
! src/share/classes/java/util/streams/ops/ToArrayOp.java
! src/share/classes/java/util/streams/ops/TreeUtils.java
! src/share/classes/java/util/streams/ops/UniqOp.java
- test-ng/tests/org/openjdk/tests/java/util/streams/StreamBuilderTest.java
+ test-ng/tests/org/openjdk/tests/java/util/streams/ops/NodeBuilderTest.java

Changeset: b04cf326ce82
Author:    psandoz
Date:      2012-10-15 15:45 -0700
URL:       http://hg.openjdk.java.net/lambda/lambda/jdk/rev/b04cf326ce82

Replace Spliterator.into with Spliterator.forEach. Sink protocol is embedded in ParallelPipelineHelper.

! src/share/classes/java/util/streams/ParallelPipelineHelper.java
! src/share/classes/java/util/streams/Spliterator.java
! src/share/classes/java/util/streams/Streams.java
! src/share/classes/java/util/streams/ops/AbstractTask.java
! src/share/classes/java/util/streams/ops/CumulateOp.java
! src/share/classes/java/util/streams/ops/FoldOp.java
! src/share/classes/java/util/streams/ops/ForEachOp.java
! src/share/classes/java/util/streams/ops/GroupByOp.java
! src/share/classes/java/util/streams/ops/MatchOp.java
! src/share/classes/java/util/streams/ops/Nodes.java
! src/share/classes/java/util/streams/ops/TreeUtils.java
! src/share/classes/java/util/streams/ops/UniqOp.java

Changeset: 8ab20b8fe27a
Author:    psandoz
Date:      2012-10-15 15:45 -0700
URL:       http://hg.openjdk.java.net/lambda/lambda/jdk/rev/8ab20b8fe27a

Replace StreamAccessor.into with StreamAccessor.forEach. Sink protocol is embedded in PipelineHelper.

! src/share/classes/java/util/streams/AbstractPipeline.java
! src/share/classes/java/util/streams/ParallelPipelineHelper.java
! src/share/classes/java/util/streams/PipelineHelper.java
! src/share/classes/java/util/streams/StreamAccessor.java
! src/share/classes/java/util/streams/Streams.java
! src/share/classes/java/util/streams/ops/StatefulOp.java

Changeset: c6ca097f901c
Author:    mduigou
Date:      2012-10-15 15:48 -0700
URL:       http://hg.openjdk.java.net/lambda/lambda/jdk/rev/c6ca097f901c

fixes for old build system (may it soon rest in peace)

! make/java/java/FILES_java.gmk

More information about the lambda-dev mailing list