Bharath Kumarasubramanian created SAMZA-2299:
------------------------------------------------
Summary: StreamTableJoin Operator should invoke user join function
only once
Key: SAMZA-2299
URL: https://issues.apache.org/jira/browse/SAMZA-2299
Project: Samza
Issue Type: Bug
Reporter: Bharath Kumarasubramanian
Assignee: Bharath Kumarasubramanian
In StreamTableJoinOperator, we currently invoke the user join function again
with null record if the first call to join function returns a null. This is not
desirable in use cases for anti-join where subsequent invocation of join
function could result in different results.
{code:java}
Optional.ofNullable(value)
.map(val -> (R) KV.of(key, val)
.map(record -> joinOpSpec.getJoinFn().apply(message, record))
.orElseGet(() -> joinOpSpec.getJoinFn().apply(message, null)); // this is the
additional invocation that happens if the previous invocation returns a
null{code}
--
This message was sent by Atlassian JIRA
(v7.6.14#76016)
