Struct JoinStream 

pub struct JoinStream<Key, Out1: ExchangeData, Out2: ExchangeData, OperatorChain1, OperatorChain2, Keyer1, Keyer2>
where
    OperatorChain1: Operator<Out = Out1>,
    OperatorChain2: Operator<Out = Out2>,
    Keyer1: KeyerFn<Key, Out1>,
    Keyer2: KeyerFn<Key, Out2>,
{ /* private fields */ }

Intermediate stream type for building the join between two streams.

This type has methods for selecting the ship strategy of the join, later you will be able to select the local strategy, and finally the variant of the join.

Implementations

impl<Key: Data, Out1: ExchangeData, Out2: ExchangeData, OperatorChain1, OperatorChain2, Keyer1, Keyer2> JoinStream<Key, Out1, Out2, OperatorChain1, OperatorChain2, Keyer1, Keyer2>

where OperatorChain1: Operator<Out = Out1> + 'static, OperatorChain2: Operator<Out = Out2> + 'static, Keyer1: KeyerFn<Key, Out1>, Keyer2: KeyerFn<Key, Out2>,

pub fn ship_hash(self) -> JoinStreamShipHash<Key, Out1, Out2, Keyer1, Keyer2>

where Key: DataKey,

Use the Hash Repartition strategy.

With this strategy the two streams are shuffled (like a group-by), pointing the message with the same key to the same replica. The key must be hashable.

pub fn ship_broadcast_right( self, ) -> JoinStreamShipBroadcastRight<Key, Out1, Out2, Keyer1, Keyer2>

Use the Broadcast-Forward strategy.

The left side won’t be sent to the network, while the right side is broadcasted. This is recommended when the left side is really big and the left side really small.

This does not require the key to be hashable.