kafka-jira mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Damian Guy (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-5819) Add Joined class and relevant KStream join overloads
Date Fri, 01 Sep 2017 09:46:01 GMT
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)

Mime
View raw message