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)