[jira] [Created] (KAFKA-5819) Add Joined class and relevant KStream join overloads

[Damian Guy (JIRA)]

Damian Guy created KAFKA-5819:
---------------------------------

             Summary: Add Joined class and relevant KStream join overloads
                 Key: KAFKA-5819
                 URL: https://issues.apache.org/jira/browse/KAFKA-5819
             Project: Kafka
          Issue Type: Sub-task
          Components: streams
            Reporter: Damian Guy
            Assignee: Damian Guy
             Fix For: 1.0.0


Add the {{Joined}} class as defined in KIP-182 and the following overloads to 
{{KStream}}
{code}
<VO, VR> KStream<K, VR> join(final KStream<K, VO> other, final ValueJoiner<? 
super V, ? super VO, ? extends VR> joiner, final JoinWindows windows, final 
Joined<K, V, VO> options);
 
<VT, VR> KStream<K, VR> join(final KTable<K, VT> other, final ValueJoiner<? 
super V, ? super VT, ? extends VR> joiner, final Joined<K, V, VT> options);
 
<VO, VR> KStream<K, VR> leftJoin(final KStream<K, VO> other, final 
ValueJoiner<? super V, ? super VO, ? extends VR> joiner, final JoinWindows 
windows, final Joined<K, V, VO> options);
 
<VT, VR> KStream<K, VR> leftJoin(final KTable<K, VT> other, final ValueJoiner<? 
super V, ? super VT, ? extends VR> joiner, final Joined<K, V, VT> options);
 
<VO, VR> KStream<K, VR> outerJoin(final KStream<K, VO> other, final 
ValueJoiner<? super V, ? super VO, ? extends VR> joiner, final JoinWindows 
windows, final Joined<K, V, VO> options);
{code}



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)