[SAMZA-2299] StreamTableJoin Operator should invoke user join function only once

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.3
• Assignee: Bharath Kumarasubramanian
• Reporter: Bharath Kumarasubramanian
• Created: 09/Aug/19 22:22
• Updated: 07/Nov/19 00:05
• Resolved: 12/Aug/19 23:44

Description

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.

 

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

Issue Links

• links to: GitHub Pull Request #1135