public static class Priority2StreamConverters.EnrichAnySteppableWithParKeyStream<A,S extends java.util.stream.BaseStream<?,S>,CC>
extends java.lang.Object
Constructor and Description |
---|
EnrichAnySteppableWithParKeyStream(CC cc,
scala.Function1<CC,MakesKeyValueStepper<A,?,EfficientSubstep>> steppize,
StreamShape<A,S> ss) |
Modifier and Type | Method and Description |
---|---|
S |
parKeyStream() |
public EnrichAnySteppableWithParKeyStream(CC cc, scala.Function1<CC,MakesKeyValueStepper<A,?,EfficientSubstep>> steppize, StreamShape<A,S> ss)
public S parKeyStream()