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/19 00:58:00 UTC

[jira] [Updated] (SAMZA-2387) LocalTableDescriptor should provide APIs to specify side inputs processor factory

     [ https://issues.apache.org/jira/browse/SAMZA-2387?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Bharath Kumarasubramanian updated SAMZA-2387:
---------------------------------------------
        Parent: SAMZA-2394
    Issue Type: Sub-task  (was: Improvement)

> LocalTableDescriptor should provide APIs to specify side inputs processor factory
> ---------------------------------------------------------------------------------
>
>                 Key: SAMZA-2387
>                 URL: https://issues.apache.org/jira/browse/SAMZA-2387
>             Project: Samza
>          Issue Type: Sub-task
>            Reporter: Bharath Kumarasubramanian
>            Priority: Major
>
> Currently, `LocalTableDescriptor` has APIs to specify the side inputs and side input processor. However, the API for side inputs processor only allows applications to provide a lambda/processor which doesn't have access to MetricsRegistry and Config during instantiation. 
> `SideInputsProcessorFactory` on the other hand, exposes MetricsRegistry and Config for applications to use during instantiation of `SideInputsProcessor`. We need to add an API that will allow applications to specify the `SideInputsProcessorFactory` if they want to hook into MetricsRegistry or use any config for their processors. 



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