Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
... After the rebalancing phase, before the start of processing each stream processor will register the details of
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
... After the rebalancing phase, before the start of processing each stream processor will register the details of
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
... After the rebalancing phase, before the start of processing each stream processor will register the details of
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
...
Modify the existing interfaces and classes as per the proposed solution.
Add unit tests to test and
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
... ZK Data Model to support host affinity: After the rebalancing phase, before the start of processing each stream
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
... In standalone landscape, the file system location to persist the local state should be provided by the users
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
...
Remove coordinator stream bindings from JobModel:
JobModel is a data access object used to represent
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
Status Current state: UNDER DISCUSSION Discussion thread: JIRA:
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
...
Remove coordinator stream bindings from JobModel:
JobModel is a data access object used to represent
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
... In standalone landscape, the file system location to persist the local state should be provided by the users
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
Status Current state: [ UNDER DISCUSSION | ACCEPTED | REJECTED ] Discussion thread:
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
... In standalone landscape, the file system location to persist the local state should be provided by the users
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
...
When low level StreamTask/AsyncStreamTask API is used:
Code Block
language
java
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
...
Code Block
language
java
// '+' denotes addition, '-' deletion.
public
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
... Every stream application in samza has many task instances which contains a custom user-defined function for
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
... This contains all the changes mentioned in proposed solution with a differing interface changes as listed below.
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
... If an optimal assignment for each task to a particular processor is generated in the JobModel as part of the
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
... In standalone landscape, the file system location to persist the local state should be provided by the users
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
... Local store spec in standalone: In standalone landscape, the file system location to persist the local state
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
Status Current state: [ UNDER DISCUSSION | ACCEPTED | REJECTED ] Discussion thread:
Title: Message Title
Shanthoosh Venkataraman edited a page
Host affinity in standalone.
... If an optimal assignment for each task to a particular processor is generated in the JobModel as part of the
