org.apache.samza.container.grouper.stream

Class GrouperContext

java.lang.Object

org.apache.samza.container.grouper.stream.GrouperContext

@InterfaceStability.Evolving
public class GrouperContext
extends java.lang.Object

A Wrapper class that holds the necessary historical metadata of the samza job which is used by the SystemStreamPartitionGrouper to generate optimal task assignments.

Constructor Summary

Constructors

Constructor and Description
GrouperContext(java.util.Map<java.lang.String,LocationId> processorLocality, java.util.Map<TaskName,LocationId> taskLocality, java.util.Map<TaskName,java.util.Set<SystemStreamPartition>> previousTaskToSSPAssignments, java.util.Map<TaskName,java.lang.String> previousTaskToContainerAssignment)

Method Summary

Modifier and Type	Method and Description
java.util.Map<TaskName,java.lang.String>	getPreviousTaskToContainerAssignment()
java.util.Map<TaskName,java.util.Set<SystemStreamPartition>>	getPreviousTaskToSSPAssignment()
java.util.List<java.lang.String>	getProcessorIds()
java.util.Map<java.lang.String,LocationId>	getProcessorLocality()
java.util.Map<TaskName,LocationId>	getTaskLocality()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

GrouperContext

public GrouperContext(java.util.Map<java.lang.String,LocationId> processorLocality,
                      java.util.Map<TaskName,LocationId> taskLocality,
                      java.util.Map<TaskName,java.util.Set<SystemStreamPartition>> previousTaskToSSPAssignments,
                      java.util.Map<TaskName,java.lang.String> previousTaskToContainerAssignment)

Method Detail

getProcessorLocality

public java.util.Map<java.lang.String,LocationId> getProcessorLocality()

getTaskLocality

public java.util.Map<TaskName,LocationId> getTaskLocality()

getPreviousTaskToSSPAssignment

public java.util.Map<TaskName,java.util.Set<SystemStreamPartition>> getPreviousTaskToSSPAssignment()

getProcessorIds

public java.util.List<java.lang.String> getProcessorIds()

getPreviousTaskToContainerAssignment

public java.util.Map<TaskName,java.lang.String> getPreviousTaskToContainerAssignment()