Static StreamExtensions.AnyArrayHasSeqParStream Method Summary All Methods Static Methods Concrete Methods Modifier and TypeĪccumulateAnyArray( underlying)ĪccumulateDoubleArray(double underlying)ĪccumulateDoubleCollection( underlying)ĪccumulateIntCollection( underlying)ĪccumulateLongCollection( underlying).Constructor Summary Constructors Constructor and Description.
Val x = List(1L, 2L, 3L, 4L). // 10, potentially computed in parallel Val t = Array(2.0, 3.0, 4.0).parStream // DoubleStream Val s = Vector(1,2,3,4).parStream // Stream Not be limited by long sequential searching steps, and one can callĪnticipateParallelism to warn a Stepper that it will be used in a parallelĬontext and thus may wish to make different tradeoffs). Presence of the EfficientSubstep trait to know that parallel execution will Subdivide itself for parallel processing (though one can check for the These are provided regardless of whether a Stepper can efficiently Steppers also implement seqStream and parStream to generate Streams. To Scala collections with to or accumulation via accumulate. Of collections operations are defined on Steppers, including conversion Maps have keyStepper and valueStepper methods. Through has a stepper method implicitly provided.
With tryStep, which works like tryAdvance in .Įvery Scala collection that can be stepped NextStep, or can optionally retrieve and operate on a value if present Of a next element using hasStep, can retrieve the next value with In particular, they can test for the presence to implement Stream compatibility theseĪre called Steppers. Internally, Scala collections implement a hybrid of Iterator and Not the most efficient option: just create the Array directly. Note that if you wish toĬreate an array from a Stream, going through an Accumulator is To convert to standard Scala collections. Have custom accumulators with improved performance.Īccumulators have toArray, toList, iterator, and to methods Generic streams also gain an unboxed method that will convert to theĬorresponding unboxed primitive stream, if appropriate. Which is not part of the standard collections hierarchy, or into a named Into a custom high-performance 8.Accumulator, Streams gain accumulate and toScala methods, which collect the stream On Array, Array, or Array will produce the Traversable), then it gains neither method.Īrray also gains seqStream and parStream methods, and calling those If a collection cannot be stepped overĪt all (e.g. Some collections either intrinsically cannot be paralellized, orĬould be but an efficient implementation is missing. ParStream that allow them to be used as the source of a Stream. Scala collections gain extension methods seqStream and StreamConverters provides extension methods and other functionality toĮase interoperability of Scala collections with classes.
0 kommentar(er)
