Module Expr Str Import alias ImportFrom alias Import alias identifier ImportFrom alias Assign NameStore Call AttributeLoad NameLoad attr Str ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults ListLoad Num body Expr Str Expr Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad If NameLoad body Assign AttributeStore NameLoad attr Call NameLoad NameLoad orelse Assign AttributeStore NameLoad attr Call NameLoad ListLoad Num decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body If BoolOpAnd NameLoad CompareNotEq AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Call AttributeLoad Str attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad If UnaryOpNot NameLoad body Return Call AttributeLoad AttributeLoad NameLoad attr attr orelse Return AttributeLoad NameLoad attr decorator_list decorator_list
N/A N/A 
Created on Sun Oct  5 14:38:22 2014

@author: xm
 N/A logging kafka.partitioner.base Partitioner N/A monk.core.api monkapi itertools cycle N/A logger N/A N/A logging getLogger monk.network.partitioner UserPartitioner N/A Partitioner N/A N/A 
    With fixed partition output for the key (user)
    Assumption: monkapi is initialized first
     __init__ N/A N/A self partitions N/A N/A 0 N/A N/A 
        Initialize the partitioner
        partitions - A list of available partitions to round robin when no partition found for the user
         N/A N/A N/A self _set_partition partitions N/A _set_partition N/A N/A self partitions N/A N/A N/A N/A self partitions partitions N/A partitions N/A N/A N/A self iterpart N/A cycle partitions N/A N/A N/A self iterpart N/A cycle N/A 0 N/A partition N/A N/A self key partitions N/A None N/A N/A N/A partitions N/A N/A self partitions partitions N/A N/A N/A N/A self _set_partitions partitions N/A N/A N/A logger debug N/A N/A key {} format key N/A user N/A N/A monkapi load_user key N/A N/A user N/A N/A N/A N/A N/A self iterpart next N/A N/A N/A user partition N/A N/A