SystemStreamPartitionMapper (samza-api 1.9.0-SNAPSHOT API)
JavaScript is disabled on your browser.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev Class
Next Class
Frames
No Frames
All Classes
Summary: 
Nested | 
Field | 
Constr | 
Method
Detail: 
Field | 
Constr | 
Method
org.apache.samza.container.grouper.stream
Interface SystemStreamPartitionMapper
public interface SystemStreamPartitionMapper
Input streams of a samza job can be either expanded or contracted by the user.
This abstraction determines the previous SystemStreamPartition for a SystemStreamPartition
of a input stream after the stream expansion or contraction.
Method Summary
All Methods Instance Methods Abstract Methods 
Modifier and Type
Method and Description
SystemStreamPartition
getPreviousSSP(SystemStreamPartition currentSystemStreamPartition,
int previousPartitionCount,
int currentPartitionCount)
Determines the previous SystemStreamPartition for a SystemStreamPartition
of a input stream after the stream expansion or contraction.
Method Detail
getPreviousSSP
SystemStreamPartition getPreviousSSP(SystemStreamPartition currentSystemStreamPartition,
int previousPartitionCount,
int currentPartitionCount)
Determines the previous SystemStreamPartition for a SystemStreamPartition
of a input stream after the stream expansion or contraction.
Parameters:
currentSystemStreamPartition - denotes the current partition after the stream partition count change.
previousPartitionCount - the partition count of the stream before the stream partition count change.
currentPartitionCount - the partition count of the stream after the stream partition count change.
Returns:
the mapped SystemStreamPartition.
Skip navigation links
Overview
Package
Class
Tree
Deprecated
Index
Help
Prev Class
Next Class
Frames
No Frames
All Classes
Summary: 
Nested | 
Field | 
Constr | 
Method
Detail: 
Field | 
Constr | 
Method