You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@samza.apache.org by "Bharath Kumarasubramanian (Jira)" <ji...@apache.org> on 2019/11/20 22:33:00 UTC

[jira] [Created] (SAMZA-2395) Introduce API to feed Side inputs through StreamDescriptor for Tables

Bharath Kumarasubramanian created SAMZA-2395:
------------------------------------------------

             Summary: Introduce API to feed Side inputs through StreamDescriptor for Tables
                 Key: SAMZA-2395
                 URL: https://issues.apache.org/jira/browse/SAMZA-2395
             Project: Samza
          Issue Type: Sub-task
            Reporter: Bharath Kumarasubramanian


The initial version of side inputs was introduced during the times when Descriptors and High level API was at its infancy. Now that the descriptor APIs have matured, it might be useful to introduce `withSideInputs(Collection<StreamDescriptor>...)` API for tables and deprecate `withSideInputs(List<String>...)`.

1. It strongly enforces types and eliminates tech debt around handling multiple "stream" formats like "systemname.streamname", "streamname" and having to do the guess work on our end to determine streamId
2. It allows application to specify stream level configurations for side inputs through code and makes it consistent w/ rest of the streams.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)