Title: Message Title
There's 2 new edits on this page
SEP-18: Startpoints - Manipulating Starting Offsets for Input Streams
Shanthoosh Venkataraman edited this page
Title: Message Title
There's 4 new edits on this page
SEP-18: Startpoints - Manipulating Starting Offsets for Input Streams
Shanthoosh Venkataraman edited this page
Title: Message Title
There's 3 new edits on this page
SEP-18: Startpoints - Manipulating Starting Offsets for Input Streams
Shanthoosh Venkataraman edited this page
Title: Message Title
There's 2 new edits on this page
SEP-18: Startpoints - Manipulating Starting Offsets for Input Streams
Shanthoosh Venkataraman edited this page
Title: Message Title
Shanthoosh Venkataraman edited a page
Change comment: Reverted from v. 119
SEP-11: Host affinity in standalone.
...
LocationId denotes the physical execution
Title: Message Title
Shanthoosh Venkataraman edited a page
SEP-11: Host affinity in standalone.
... After the rebalancing phase, before the start of processing each stream processor will register the
Title: Message Title
Shanthoosh Venkataraman edited a page
SEP-11: Host affinity in standalone.
... After this change, we will have one method in TaskNameGrouper interface clearly defining the contract and
Title: Message Title
Shanthoosh Venkataraman edited a page
SEP-11: Host affinity in standalone.
... High level flow in standalone with HostAffinity Image Added ZK Data Model to
Title: Message Title
Shanthoosh Venkataraman edited a page
SEP-11: Host affinity in standalone.
... If an optimal assignment for each task to a particular processor is generated in the JobModel as part of
Title: Message Title
Shanthoosh Venkataraman edited a page
SEP-11: Host affinity in standalone.
Status Current state: UNDER DISCUSSION ... JIRA:
JIRA
server
ASF JIRA
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
