@Experimental public static interface KeyedPartitionStream.TwoKeyedPartitionStreams<K,T1,T2>
KeyedPartitionStream
. It will be used as
the return value of operation with two output.Modifier and Type | Method and Description |
---|---|
KeyedPartitionStream.ProcessConfigurableAndKeyedPartitionStream<K,T1> |
getFirst()
Get the first stream.
|
KeyedPartitionStream.ProcessConfigurableAndKeyedPartitionStream<K,T2> |
getSecond()
Get the second stream.
|
KeyedPartitionStream.ProcessConfigurableAndKeyedPartitionStream<K,T1> getFirst()
KeyedPartitionStream.ProcessConfigurableAndKeyedPartitionStream<K,T2> getSecond()
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.