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/18 19:29:00 UTC
[jira] [Created] (SAMZA-2387) LocalTableDescriptor should provide
APIs to specify side inputs processor factory
Bharath Kumarasubramanian created SAMZA-2387:
------------------------------------------------
Summary: 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: Improvement
Reporter: Bharath Kumarasubramanian
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)