Module Expr Str ImportFrom alias ImportFrom alias Import alias Import alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ImportFrom alias ClassDef bases NameLoad body Expr Str Assign NameStore Num Assign NameStore Num decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam defaults body Return BinOpMod Str TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call NameLoad BinOpAdd NameLoad AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad If UnaryOpNot NameLoad body Raise Call NameLoad Str If UnaryOpNot Call NameLoad NameLoad AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return BinOpMod Str TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call NameLoad BinOpAdd NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return BinOpMod Str AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call NameLoad BinOpAdd NameLoad AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return BinOpMod Str TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call NameLoad BinOpAdd NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str Pass decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str Pass decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str Pass decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str Pass decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Str Pass decorator_list NameLoad decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam defaults body Pass decorator_list FunctionDef arguments args NameParam defaults body Return Str decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body For NameStore NameLoad body If CompareNotEq AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Return CompareGtE NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Return CompareEq Call NameLoad NameLoad Call NameLoad NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore Call NameLoad Str NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad NameLoad body Assign AttributeStore NameLoad attr IfExp NameLoad Call NameLoad NameLoad NameLoad Assign AttributeStore NameLoad attr IfExp NameLoad Call NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore ListLoad If AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr BinOpMod Str AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr Return BinOpMod Str Call AttributeLoad Str attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return BoolOpAnd AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body If Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Call NameLoad NameLoad Str orelse Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Call NameLoad NameLoad Str decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body If Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Call NameLoad NameLoad Str orelse For NameStore NameLoad body If CompareNotEq AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Call NameLoad NameLoad Str decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body If Call AttributeLoad NameLoad attr NameLoad body Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Call NameLoad NameLoad Str orelse If CompareGtE NameLoad AttributeLoad NameLoad attr body Return NameLoad orelse If AttributeLoad NameLoad attr body Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Call NameLoad NameLoad Str orelse Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body If Call AttributeLoad NameLoad attr NameLoad body Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Call NameLoad NameLoad Str orelse If CompareGtE NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad Return UnaryOpNot AttributeLoad NameLoad attr orelse If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Call NameLoad NameLoad Str Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body If AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Call NameLoad NameLoad Str If AttributeLoad NameLoad attr body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Call NameLoad NameLoad Str decorator_list FunctionDef arguments args NameParam NameParam defaults body Return BoolOpAnd CompareEq Call NameLoad NameLoad Call NameLoad NameLoad CompareEq AttributeLoad NameLoad attr AttributeLoad NameLoad attr CompareEq AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Return Call NameLoad TupleLoad Call NameLoad NameLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore Call NameLoad Str Call AttributeLoad NameLoad attr FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return BinOpMod Str AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr Num decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Pass decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Return CompareGtE Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return BinOpMod Str AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body If Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad decorator_list decorator_list ClassDef bases NameLoad body Assign NameStore NameLoad FunctionDef arguments args NameParam defaults vararg body Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return BinOpMod Str TupleLoad AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad Str attr GeneratorExp Call NameLoad NameLoad comprehension NameStore AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Pass decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body For TupleStore NameStore NameStore Call NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad NameLoad Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body For TupleStore NameStore NameStore Call NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad NameLoad Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Return Call AttributeLoad NameLoad attr GeneratorExp Call AttributeLoad NameLoad attr NameLoad NameLoad Call AttributeLoad NameLoad attr NameLoad NameLoad comprehension TupleStore NameStore NameStore Call NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Assign NameStore ListLoad For TupleStore NameStore NameStore Call NameLoad AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr NameLoad NameLoad If Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad Return Call AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body For TupleStore NameStore NameStore Call NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call NameLoad NameLoad BinOpMod Str NameLoad decorator_list NameLoad decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore NameLoad decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore NameLoad decorator_list ClassDef bases NameLoad body Assign NameStore Call NameLoad Str Lambda arguments args NameParam defaults IfExp UnaryOpNot NameLoad Num Call NameLoad NameLoad FunctionDef arguments args NameParam defaults vararg body Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return BinOpMod Str TupleLoad AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad Str attr GeneratorExp Call NameLoad NameLoad comprehension NameStore AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr If CompareLt NameLoad Call NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr NameLoad NameLoad Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr If CompareLt NameLoad Call NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr NameLoad NameLoad Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr If CompareLt NameLoad Call NameLoad AttributeLoad NameLoad attr body Return Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr NameLoad NameLoad Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Assign NameStore Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr If CompareLt NameLoad Call NameLoad AttributeLoad NameLoad attr body If Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr NameLoad NameLoad Call AttributeLoad NameLoad attr NameLoad NameLoad body AugAssignAdd NameStore Num Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad Return CompareEq NameLoad Call NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr For TupleStore NameStore NameStore Call NameLoad AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad Call AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call NameLoad NameLoad BinOpMod Str NameLoad decorator_list NameLoad decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad Call NameLoad NameLoad NameLoad attr NameLoad NameLoad decorator_list decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpAdd AttributeLoad NameLoad attr NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr BinOpAdd AttributeLoad NameLoad attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Pass decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Pass decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Pass decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Pass decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults body Pass decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults body Pass decorator_list NameLoad FunctionDef arguments args NameParam NameParam defaults body Return Call NameLoad NameLoad NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults body Pass decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Pass decorator_list NameLoad decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore Call NameLoad Str FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr Dict Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body For NameStore Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body If Call NameLoad NameLoad NameLoad body Raise Call NameLoad BinOpMod Str NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign NameStore ListComp Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad comprehension NameStore Call AttributeLoad NameLoad attr NameLoad If Call NameLoad NameLoad NameLoad body Raise Call NameLoad BinOpMod Str NameLoad orelse If Call NameLoad NameLoad NameLoad body If UnaryOpNot NameLoad body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr orelse If CompareEq Call NameLoad NameLoad Num body Assign NameStore SubscriptLoad NameLoad Index Num orelse Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad orelse If Call NameLoad NameLoad NameLoad body Return ListComp NameLoad comprehension NameStore NameLoad comprehension NameStore NameLoad orelse If Call NameLoad NameLoad NameLoad body Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad orelse Raise Call NameLoad Str NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body For NameStore Call AttributeLoad NameLoad attr NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad If CompareIs NameLoad NameLoad body Delete SubscriptDel AttributeLoad NameLoad attr Index NameLoad Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body For NameStore NameLoad body If CompareNotEq NameLoad NameLoad body If CompareIn NameLoad AttributeLoad NameLoad attr body If CompareIn NameLoad AttributeLoad NameLoad attr body Assign NameStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad orelse Assign NameStore SubscriptStore AttributeLoad NameLoad attr Index NameLoad ListLoad Expr Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad Expr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Return Call AttributeLoad AttributeLoad NameLoad attr attr decorator_list FunctionDef arguments args NameParam NameParam defaults body For TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr body If CompareIn NameLoad NameLoad body Return NameLoad Raise Call NameLoad BinOpMod Str NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body If CompareIn NameLoad AttributeLoad NameLoad attr body Return SubscriptLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index Num orelse Assign NameStore Call AttributeLoad NameLoad attr Assign SubscriptStore AttributeLoad NameLoad attr Index NameLoad ListLoad NameLoad Expr Call AttributeLoad NameLoad attr Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad ListLoad decorator_list FunctionDef arguments args NameParam defaults body If UnaryOpNot AttributeLoad NameLoad attr body Assign AttributeStore NameLoad attr Num orelse If CompareIs AttributeLoad NameLoad attr NameLoad body Assign AttributeStore NameLoad attr Call NameLoad GeneratorExp NameLoad comprehension NameStore Call AttributeLoad AttributeLoad NameLoad attr attr comprehension NameStore NameLoad AugAssignAdd AttributeStore NameLoad attr Num Return AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam defaults body Return Call AttributeLoad Str attr BinOpAdd ListLoad Call NameLoad AttributeLoad NameLoad attr Call AttributeLoad Call NameLoad AttributeLoad NameLoad attr attr Str decorator_list decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad NameLoad body Expr Str If BoolOpAnd Call AttributeLoad NameLoad attr NameLoad body Assign NameStore Call NameLoad orelse Assign NameStore Call NameLoad NameLoad If NameLoad body Assign NameStore Call NameLoad NameLoad NameLoad Return NameLoad decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Pass decorator_list NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults body Pass decorator_list NameLoad decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore TupleLoad Call NameLoad FunctionDef arguments args NameParam defaults body Pass decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body If Call NameLoad NameLoad NameLoad body Assign NameStore ListComp AttributeLoad NameLoad attr comprehension NameStore NameLoad orelse ClassDef bases AttributeLoad NameLoad attr body FunctionDef arguments args NameParam defaults body For NameStore NameLoad body Assign NameStore AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad Expr Yield NameLoad decorator_list FunctionDef arguments args NameParam defaults body Return BinOpMod Str NameLoad decorator_list decorator_list Assign NameStore Call NameLoad Expr Yield Call NameLoad NameLoad NameLoad AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults body Raise Call NameLoad Str decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam NameParam defaults body Assign AttributeStore NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad For NameStore NameLoad body Expr Yield Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad NameLoad NameLoad For NameStore NameLoad body Expr Yield Call AttributeLoad NameLoad attr Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr decorator_list decorator_list ClassDef bases NameLoad body Expr Str Assign NameStore Call NameLoad Str Assign NameStore Call NameLoad Str Call AttributeLoad NameLoad attr FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr AttributeLoad NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call NameLoad Str AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body If AttributeLoad NameLoad attr body Assign NameStore Call NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad For NameStore NameLoad body For NameStore AttributeLoad NameLoad attr body Expr Call AttributeLoad SubscriptLoad NameLoad Index NameLoad attr TupleLoad AttributeLoad NameLoad attr AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Assign NameStore Call NameLoad Call AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr Call AttributeLoad NameLoad attr If CompareNotEq NameLoad NameLoad body Assign NameStore Dict ClassDef bases AttributeLoad NameLoad attr body FunctionDef arguments args NameParam NameParam NameParam defaults body For NameStore NameLoad body If CompareNotEq NameLoad NameLoad body Assign SubscriptStore NameLoad Index NameLoad NameLoad Expr Call AttributeLoad NameLoad attr NameLoad NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad Call AttributeLoad NameLoad attr NameLoad decorator_list decorator_list Expr Call AttributeLoad AttributeLoad NameLoad attr attr Call NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad For TupleStore NameStore NameStore Call AttributeLoad NameLoad attr body While CompareIn NameLoad NameLoad body Assign NameStore SubscriptLoad NameLoad Index NameLoad Expr Call AttributeLoad SubscriptLoad NameLoad Index NameLoad attr NameLoad Assign NameStore NameLoad For NameStore NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr For TupleStore NameStore NameStore Call AttributeLoad NameLoad attr body If Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr body Continue Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad GeneratorExp NameLoad comprehension NameStore GeneratorExp Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad comprehension TupleStore NameStore NameStore NameLoad CompareGtE NameLoad NameLoad If CompareIsNot NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad For TupleStore NameStore NameStore NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad Assign NameStore NameLoad If Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad Expr Yield Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam NameParam defaults body If AttributeLoad NameLoad attr body Assign NameStore Call NameLoad NameLoad Assign NameStore Call AttributeLoad NameLoad attr NameLoad If Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr body Return If CompareEq NameLoad AttributeLoad NameLoad attr body If BoolOpOr UnaryOpNot AttributeLoad NameLoad attr CompareIn NameLoad Call AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr NameLoad If Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad NameLoad Expr Yield Call AttributeLoad NameLoad attr NameLoad NameLoad NameLoad orelse Raise Call NameLoad BinOpMod Str NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Str Assign NameStore Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr If NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr Num orelse If CompareEq AttributeLoad NameLoad attr AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr Assign NameStore Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr If CompareIs NameLoad NameLoad body Assign NameStore AttributeLoad NameLoad attr orelse Expr Call AttributeLoad NameLoad attr NameLoad AttributeLoad NameLoad attr Return Call NameLoad NameLoad NameLoad TupleLoad NameLoad decorator_list decorator_list ClassDef bases NameLoad body Expr Str FunctionDef arguments args NameParam NameParam defaults NameLoad body Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Lambda arguments args defaults Call AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr Dict Assign AttributeStore NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assert Call NameLoad NameLoad NameLoad If AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign SubscriptStore AttributeLoad NameLoad attr Index AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults NameLoad body Return Call AttributeLoad AttributeLoad NameLoad attr attr AttributeLoad NameLoad attr NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam NameParam defaults body Assign SubscriptStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index TupleLoad NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Expr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr TupleLoad NameLoad NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults body Return NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body If AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr NameLoad If Call NameLoad NameLoad NameLoad body Assign SubscriptStore SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index AttributeLoad NameLoad attr NameLoad orelse If Call NameLoad NameLoad NameLoad body Expr Call AttributeLoad SubscriptLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index AttributeLoad NameLoad attr attr NameLoad orelse If Call NameLoad NameLoad NameLoad body Expr Call AttributeLoad SubscriptLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index AttributeLoad NameLoad attr attr NameLoad orelse If Call NameLoad NameLoad NameLoad body Expr Call AttributeLoad SubscriptLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index AttributeLoad NameLoad attr attr NameLoad orelse Raise Call NameLoad Str NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Assign NameStore SubscriptLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad Index AttributeLoad NameLoad attr If Call NameLoad NameLoad NameLoad body Return NameLoad orelse If Call NameLoad NameLoad NameLoad body Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad orelse If Call NameLoad NameLoad NameLoad body Return NameLoad orelse If Call NameLoad NameLoad NameLoad body Return Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad orelse Raise Call NameLoad Str NameLoad decorator_list FunctionDef arguments args NameParam NameParam NameParam defaults body Expr Call AttributeLoad SubscriptLoad AttributeLoad NameLoad attr Index NameLoad attr AttributeLoad NameLoad attr NameLoad If UnaryOpNot SubscriptLoad AttributeLoad NameLoad attr Index NameLoad body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad NameLoad decorator_list FunctionDef arguments args NameParam NameParam defaults NameLoad body Assign NameStore ListLoad For TupleStore NameStore NameStore Call NameLoad Call AttributeLoad AttributeLoad NameLoad attr attr body For TupleStore TupleStore NameStore NameStore NameStore Call NameLoad Call AttributeLoad NameLoad attr body If CompareLtE NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr TupleLoad NameLoad TupleLoad NameLoad NameLoad NameLoad Delete SubscriptDel NameLoad Index TupleLoad NameLoad NameLoad If UnaryOpNot NameLoad body Delete SubscriptDel AttributeLoad NameLoad attr Index NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Assign NameStore Call AttributeLoad Str attr GeneratorExp BinOpMod Str TupleLoad NameLoad Call NameLoad NameLoad comprehension TupleStore NameStore NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Return BinOpMod Str TupleLoad Call NameLoad AttributeLoad NameLoad attr NameLoad decorator_list decorator_list
N/A N/A Support for Dataflow triggers.

Triggers control when in processing time windows get emitted.
 abc ABCMeta abc abstractmethod N/A collections N/A copy google.cloud.dataflow.coders observable google.cloud.dataflow.transforms combiners google.cloud.dataflow.transforms core google.cloud.dataflow.transforms.timeutil MAX_TIMESTAMP google.cloud.dataflow.transforms.timeutil MIN_TIMESTAMP google.cloud.dataflow.transforms.timeutil TimeDomain google.cloud.dataflow.transforms.window GlobalWindow google.cloud.dataflow.transforms.window OutputTimeFn google.cloud.dataflow.transforms.window WindowedValue google.cloud.dataflow.transforms.window WindowFn AccumulationMode N/A object N/A N/A Controls what to do with data when a trigger fires multiple times.
   N/A DISCARDING 1 N/A ACCUMULATING 2 N/A StateTag N/A object N/A N/A An identifier used to store and retrieve typed, combinable state.

  The given tag must be unique for this stage.  If CombineFn is None then
  all elements will be returned as a list, otherwise the given CombineFn
  will be applied (possibly incrementally and eagerly) when adding elements.
   N/A __metaclass__ ABCMeta __init__ N/A N/A self tag N/A N/A N/A N/A self tag tag N/A N/A ValueStateTag N/A StateTag N/A N/A StateTag pointing to an element. __repr__ N/A N/A self N/A N/A N/A N/A ValueStateTag(%s, %s) N/A N/A self tag N/A self combine_fn N/A with_prefix N/A N/A self prefix N/A N/A N/A N/A ValueStateTag N/A prefix N/A self tag N/A N/A CombiningValueStateTag N/A StateTag N/A N/A StateTag pointing to an element, accumulated with a combiner. __init__ N/A N/A self tag combine_fn N/A N/A N/A N/A N/A N/A super CombiningValueStateTag self __init__ tag N/A N/A combine_fn N/A N/A N/A ValueError combine_fn must be specified. N/A N/A N/A isinstance combine_fn N/A core CombineFn N/A N/A combine_fn N/A N/A N/A core CombineFn from_callable combine_fn N/A N/A self combine_fn combine_fn N/A __repr__ N/A N/A self N/A N/A N/A N/A CombiningValueStateTag(%s, %s) N/A N/A self tag N/A self combine_fn N/A with_prefix N/A N/A self prefix N/A N/A N/A N/A CombiningValueStateTag N/A prefix N/A self tag N/A self combine_fn N/A N/A ListStateTag N/A StateTag N/A N/A StateTag pointing to a list of elements. __init__ N/A N/A self tag N/A N/A N/A N/A N/A N/A super ListStateTag self __init__ tag N/A __repr__ N/A N/A self N/A N/A N/A N/A ListStateTag(%s) N/A self tag N/A with_prefix N/A N/A self prefix N/A N/A N/A N/A ListStateTag N/A prefix N/A self tag N/A N/A WatermarkHoldStateTag N/A StateTag N/A __init__ N/A N/A self tag output_time_fn_impl N/A N/A N/A N/A N/A N/A super WatermarkHoldStateTag self __init__ tag N/A N/A self output_time_fn_impl output_time_fn_impl N/A __repr__ N/A N/A self N/A N/A N/A N/A WatermarkHoldStateTag(%s, %s) N/A N/A self tag N/A self output_time_fn_impl N/A with_prefix N/A N/A self prefix N/A N/A N/A N/A WatermarkHoldStateTag N/A prefix N/A self tag N/A self output_time_fn_impl N/A N/A TriggerFn N/A object N/A N/A A TriggerFn determines when window (panes) are emitted.

  See https://cloud.google.com/dataflow/model/triggers.
   N/A __metaclass__ ABCMeta on_element N/A N/A self element window context N/A N/A N/A Called when a new element arrives in a window.

    Args:
      element: the element being added
      window: the window to which the element is being added
      context: a context (e.g. a TriggerContext instance) for managing state
          and setting timers
     N/A N/A abstractmethod on_merge N/A N/A self to_be_merged merge_result context N/A N/A N/A Called when multiple windows are merged.

    Args:
      to_be_merged: the set of windows to be merged
      merge_result: the window into which the windows are being merged
      context: a context (e.g. a TriggerContext instance) for managing state
          and setting timers
     N/A N/A abstractmethod should_fire N/A N/A self watermark window context N/A N/A N/A Whether this trigger should cause the window to fire.

    Args:
      watermark: (a lower bound on) the watermark of the system
      window: the window whose trigger is being considered
      context: a context (e.g. a TriggerContext instance) for managing state
          and setting timers

    Returns:
      whether this trigger should cause a firing
     N/A N/A abstractmethod on_fire N/A N/A self watermark window context N/A N/A N/A Called when a trigger actually fires.

    Args:
      watermark: (a lower bound on) the watermark of the system
      window: the window whose trigger is being fired
      context: a context (e.g. a TriggerContext instance) for managing state
          and setting timers

    Returns:
      whether this trigger is finished
     N/A N/A abstractmethod reset N/A N/A self window context N/A N/A N/A Clear any state and timers used by this TriggerFn. N/A N/A abstractmethod N/A DefaultTrigger N/A TriggerFn N/A N/A Semantically Repeatedly(AfterWatermark()), but more optimized. __init__ N/A N/A self N/A N/A N/A N/A __repr__ N/A N/A self N/A N/A N/A DefaultTrigger() N/A on_element N/A N/A self element window context N/A N/A N/A N/A N/A context set_timer N/A TimeDomain WATERMARK N/A window end N/A on_merge N/A N/A self to_be_merged merge_result context N/A N/A N/A window to_be_merged N/A N/A N/A N/A window end N/A merge_result end N/A N/A N/A N/A context clear_timer N/A TimeDomain WATERMARK N/A should_fire N/A N/A self watermark window context N/A N/A N/A N/A watermark N/A window end N/A on_fire N/A N/A self watermark window context N/A N/A N/A False N/A reset N/A N/A self window context N/A N/A N/A N/A N/A context clear_timer N/A TimeDomain WATERMARK N/A __eq__ N/A N/A self other N/A N/A N/A N/A N/A type self N/A type other N/A N/A AfterWatermark N/A TriggerFn N/A N/A Fire exactly once when the watermark passes the end of the window.

  Args:
      early: if not None, a speculative trigger to repeatedly evaluate before
        the watermark passes the end of the window
      late: if not None, a speculative trigger to repeatedly evaluate after
        the watermark passes the end of the window
   N/A LATE_TAG N/A CombiningValueStateTag is_late any __init__ N/A N/A self early late N/A None None N/A N/A N/A self early N/A early N/A Repeatedly early None N/A N/A self late N/A late N/A Repeatedly late None N/A __repr__ N/A N/A self N/A N/A N/A qualifiers N/A N/A N/A self early N/A N/A N/A N/A qualifiers append N/A early=%s N/A self early N/A N/A self late N/A N/A N/A N/A qualifiers append late=%s N/A self late N/A N/A AfterWatermark(%s) N/A N/A ,  join qualifiers N/A is_late N/A N/A self context N/A N/A N/A N/A N/A self late N/A N/A context get_state N/A self LATE_TAG N/A on_element N/A N/A self element window context N/A N/A N/A N/A N/A self is_late context N/A N/A N/A N/A N/A self late on_element element window N/A NestedContext context late N/A N/A N/A N/A context set_timer N/A TimeDomain WATERMARK N/A window end N/A N/A self early N/A N/A N/A N/A N/A self early on_element element window N/A NestedContext context early N/A on_merge N/A N/A self to_be_merged merge_result context N/A N/A N/A N/A N/A self is_late context N/A N/A N/A N/A N/A self late on_merge to_be_merged merge_result N/A NestedContext context late N/A N/A window to_be_merged N/A N/A N/A N/A window end N/A merge_result end N/A N/A N/A N/A context clear_timer N/A TimeDomain WATERMARK N/A N/A self early N/A N/A N/A N/A N/A self early on_merge to_be_merged merge_result N/A NestedContext context early N/A should_fire N/A N/A self watermark window context N/A N/A N/A N/A N/A self is_late context N/A N/A N/A N/A N/A self late should_fire watermark window N/A NestedContext context late N/A N/A N/A watermark N/A window end N/A N/A True N/A N/A N/A self early N/A N/A N/A N/A N/A self early should_fire watermark window N/A NestedContext context early N/A N/A False N/A on_fire N/A N/A self watermark window context N/A N/A N/A N/A N/A self is_late context N/A N/A N/A N/A N/A self late on_fire watermark window N/A NestedContext context late N/A N/A N/A watermark N/A window end N/A N/A N/A N/A context add_state N/A self LATE_TAG True N/A N/A N/A self late N/A N/A N/A self early N/A N/A N/A N/A N/A self early on_fire watermark window N/A NestedContext context early N/A False N/A reset N/A N/A self window context N/A N/A N/A N/A self late N/A N/A N/A N/A context clear_state N/A self LATE_TAG N/A N/A self early N/A N/A N/A N/A N/A self early reset window N/A NestedContext context early N/A N/A self late N/A N/A N/A N/A N/A self late reset window N/A NestedContext context late N/A __eq__ N/A N/A self other N/A N/A N/A N/A N/A N/A type self N/A type other N/A N/A self early N/A other early N/A N/A self late N/A other late N/A __hash__ N/A N/A self N/A N/A N/A N/A hash N/A N/A type self N/A self early N/A self late N/A N/A AfterCount N/A TriggerFn N/A N/A Fire when there are at least count elements in this window pane. N/A COUNT_TAG N/A CombiningValueStateTag count N/A N/A combiners CountCombineFn __init__ N/A N/A self count N/A N/A N/A N/A self count count N/A __repr__ N/A N/A self N/A N/A N/A N/A AfterCount(%s) N/A self count N/A on_element N/A N/A self element window context N/A N/A N/A N/A N/A context add_state N/A self COUNT_TAG 1 N/A on_merge N/A N/A self to_be_merged merge_result context N/A N/A N/A N/A should_fire N/A N/A self watermark window context N/A N/A N/A N/A N/A N/A context get_state N/A self COUNT_TAG N/A self count N/A on_fire N/A N/A self watermark window context N/A N/A N/A True N/A reset N/A N/A self window context N/A N/A N/A N/A N/A context clear_state N/A self COUNT_TAG N/A N/A Repeatedly N/A TriggerFn N/A N/A Repeatedly invoke the given trigger, never finishing. __init__ N/A N/A self underlying N/A N/A N/A N/A self underlying underlying N/A __repr__ N/A N/A self N/A N/A N/A N/A Repeatedly(%s) N/A self underlying N/A on_element N/A N/A self element window context N/A N/A N/A N/A N/A N/A self underlying on_element element window context N/A on_merge N/A N/A self to_be_merged merge_result context N/A N/A N/A N/A N/A N/A self underlying on_merge to_be_merged merge_result context N/A should_fire N/A N/A self watermark window context N/A N/A N/A N/A N/A N/A self underlying should_fire watermark window context N/A on_fire N/A N/A self watermark window context N/A N/A N/A N/A N/A N/A self underlying on_fire watermark window context N/A N/A N/A N/A N/A self underlying reset window context N/A False N/A reset N/A N/A self window context N/A N/A N/A N/A N/A N/A self underlying reset window context N/A N/A ParallelTriggerFn N/A TriggerFn N/A N/A __metaclass__ ABCMeta __init__ N/A N/A self N/A triggers N/A N/A N/A self triggers triggers N/A __repr__ N/A N/A self N/A N/A N/A N/A %s(%s) N/A N/A N/A self __class__ __name__ N/A N/A ,  join N/A N/A str t N/A t N/A self triggers N/A combine_op N/A N/A self trigger_results N/A N/A N/A N/A abstractmethod on_element N/A N/A self element window context N/A N/A N/A N/A ix trigger N/A enumerate N/A self triggers N/A N/A N/A N/A trigger on_element element window N/A N/A self _sub_context context ix N/A on_merge N/A N/A self to_be_merged merge_result context N/A N/A N/A N/A ix trigger N/A enumerate N/A self triggers N/A N/A N/A N/A trigger on_merge to_be_merged merge_result N/A N/A self _sub_context context ix N/A should_fire N/A N/A self watermark window context N/A N/A N/A N/A N/A self combine_op N/A N/A N/A trigger should_fire watermark window N/A N/A self _sub_context context ix N/A N/A ix trigger N/A enumerate N/A self triggers N/A on_fire N/A N/A self watermark window context N/A N/A N/A finished N/A N/A N/A ix trigger N/A enumerate N/A self triggers N/A N/A nested_context N/A N/A self _sub_context context ix N/A N/A N/A trigger should_fire watermark window nested_context N/A N/A N/A N/A finished append N/A N/A trigger on_fire watermark window nested_context N/A N/A N/A self combine_op finished N/A reset N/A N/A self window context N/A N/A N/A N/A ix trigger N/A enumerate N/A self triggers N/A N/A N/A N/A trigger reset window N/A N/A self _sub_context context ix N/A _sub_context N/A N/A context index N/A N/A N/A N/A NestedContext context N/A %d/ index N/A staticmethod N/A AfterFirst N/A ParallelTriggerFn N/A N/A Fires when any subtrigger fires.

  Also finishes when any subtrigger finishes.
   N/A combine_op any N/A AfterAll N/A ParallelTriggerFn N/A N/A Fires when all subtriggers have fired.

  Also finishes when all subtriggers have finished.
   N/A combine_op all N/A AfterEach N/A TriggerFn N/A N/A INDEX_TAG N/A CombiningValueStateTag index N/A N/A N/A indices N/A N/A N/A indices 0 N/A max indices __init__ N/A N/A self N/A triggers N/A N/A N/A self triggers triggers N/A __repr__ N/A N/A self N/A N/A N/A N/A %s(%s) N/A N/A N/A self __class__ __name__ N/A N/A ,  join N/A N/A str t N/A t N/A self triggers N/A on_element N/A N/A self element window context N/A N/A N/A ix N/A N/A context get_state N/A self INDEX_TAG N/A N/A ix N/A len N/A self triggers N/A N/A N/A N/A N/A N/A self triggers N/A ix on_element element window N/A N/A self _sub_context context ix N/A on_merge N/A N/A self to_be_merged merge_result context N/A N/A N/A ix N/A N/A context get_state N/A self INDEX_TAG N/A N/A ix N/A len N/A self triggers N/A N/A N/A N/A N/A N/A self triggers N/A ix on_merge to_be_merged merge_result N/A N/A self _sub_context context ix N/A should_fire N/A N/A self watermark window context N/A N/A N/A ix N/A N/A context get_state N/A self INDEX_TAG N/A N/A ix N/A len N/A self triggers N/A N/A N/A N/A N/A N/A self triggers N/A ix should_fire watermark window N/A N/A self _sub_context context ix N/A on_fire N/A N/A self watermark window context N/A N/A N/A ix N/A N/A context get_state N/A self INDEX_TAG N/A N/A ix N/A len N/A self triggers N/A N/A N/A N/A N/A N/A self triggers N/A ix on_fire watermark window N/A N/A self _sub_context context ix N/A N/A ix 1 N/A N/A N/A context add_state N/A self INDEX_TAG ix N/A N/A ix N/A len N/A self triggers N/A reset N/A N/A self window context N/A N/A N/A N/A N/A context clear_state N/A self INDEX_TAG N/A N/A ix trigger N/A enumerate N/A self triggers N/A N/A N/A N/A trigger reset window N/A N/A self _sub_context context ix N/A _sub_context N/A N/A context index N/A N/A N/A N/A NestedContext context N/A %d/ index N/A staticmethod N/A OrFinally N/A AfterFirst N/A __init__ N/A N/A self body_trigger exit_trigger N/A N/A N/A N/A N/A N/A super OrFinally self __init__ body_trigger exit_trigger N/A N/A TriggerContext N/A object N/A __init__ N/A N/A self outer window N/A N/A N/A N/A self _outer outer N/A N/A self _window window N/A set_timer N/A N/A self name time_domain timestamp N/A N/A N/A N/A N/A N/A self _outer set_timer N/A self _window name time_domain timestamp N/A clear_timer N/A N/A self name time_domain N/A N/A N/A N/A N/A N/A self _outer clear_timer N/A self _window name time_domain N/A add_state N/A N/A self tag value N/A N/A N/A N/A N/A N/A self _outer add_state N/A self _window tag value N/A get_state N/A N/A self tag N/A N/A N/A N/A N/A N/A self _outer get_state N/A self _window tag N/A clear_state N/A N/A self tag N/A N/A N/A N/A N/A N/A self _outer clear_state N/A self _window tag N/A N/A NestedContext N/A object N/A N/A Namespaced context useful for defining composite triggers. __init__ N/A N/A self outer prefix N/A N/A N/A N/A self _outer outer N/A N/A self _prefix prefix N/A set_timer N/A N/A self name time_domain timestamp N/A N/A N/A N/A N/A N/A self _outer set_timer N/A N/A self _prefix name time_domain timestamp N/A clear_timer N/A N/A self name time_domain N/A N/A N/A N/A N/A N/A self _outer clear_timer N/A N/A self _prefix name time_domain N/A add_state N/A N/A self tag value N/A N/A N/A N/A N/A N/A self _outer add_state N/A N/A tag with_prefix N/A self _prefix value N/A get_state N/A N/A self tag N/A N/A N/A N/A N/A N/A self _outer get_state N/A N/A tag with_prefix N/A self _prefix N/A clear_state N/A N/A self tag N/A N/A N/A N/A N/A N/A self _outer clear_state N/A N/A tag with_prefix N/A self _prefix N/A N/A SimpleState N/A object N/A N/A Basic state storage interface used for triggering.

  Only timers must hold the watermark (by their timestamp).
   N/A __metaclass__ ABCMeta set_timer N/A N/A self window name time_domain timestamp N/A N/A N/A N/A abstractmethod get_window N/A N/A self window_id N/A N/A N/A N/A abstractmethod clear_timer N/A N/A self window name time_domain N/A N/A N/A N/A abstractmethod add_state N/A N/A self window tag value N/A N/A N/A N/A abstractmethod get_state N/A N/A self window tag N/A N/A N/A N/A abstractmethod clear_state N/A N/A self window tag N/A N/A N/A N/A abstractmethod at N/A N/A self window N/A N/A N/A N/A TriggerContext self window N/A N/A UnmergedState N/A SimpleState N/A N/A State suitable for use in TriggerDriver.

  This class must be implemented by each backend.
   set_global_state N/A N/A self tag value N/A N/A N/A N/A abstractmethod get_global_state N/A N/A self tag default N/A None N/A N/A N/A abstractmethod N/A MergeableStateAdapter N/A SimpleState N/A N/A Wraps an UnmergedState, tracking merged windows. N/A WINDOW_IDS N/A ValueStateTag window_ids __init__ N/A N/A self raw_state N/A N/A N/A N/A self raw_state raw_state N/A N/A self window_ids N/A N/A N/A self raw_state get_global_state N/A self WINDOW_IDS N/A N/A N/A self counter None N/A set_timer N/A N/A self window name time_domain timestamp N/A N/A N/A N/A N/A N/A self raw_state set_timer N/A N/A self _get_id window name time_domain timestamp N/A clear_timer N/A N/A self window name time_domain N/A N/A N/A window_id N/A N/A self _get_ids window N/A N/A N/A N/A N/A self raw_state clear_timer window_id name time_domain N/A add_state N/A N/A self window tag value N/A N/A N/A N/A isinstance tag ValueStateTag N/A N/A N/A ValueError N/A Merging requested for non-mergeable state tag: %r. tag N/A N/A N/A N/A self raw_state add_state N/A N/A self _get_id window tag value N/A get_state N/A N/A self window tag N/A N/A N/A values N/A N/A N/A N/A self raw_state get_state window_id tag N/A window_id N/A N/A self _get_ids window N/A N/A isinstance tag ValueStateTag N/A N/A N/A ValueError N/A Merging requested for non-mergeable state tag: %r. tag N/A N/A N/A isinstance tag CombiningValueStateTag N/A N/A N/A values N/A N/A accumulator N/A N/A N/A tag combine_fn create_accumulator N/A N/A N/A N/A len values 1 N/A N/A accumulator N/A values N/A 0 N/A N/A accumulator N/A N/A N/A tag combine_fn merge_accumulators values N/A N/A N/A N/A tag combine_fn extract_output accumulator N/A N/A N/A isinstance tag ListStateTag N/A N/A N/A v N/A vs values N/A v vs N/A N/A N/A isinstance tag WatermarkHoldStateTag N/A N/A N/A N/A N/A tag output_time_fn_impl combine_all values N/A N/A N/A ValueError Invalid tag. tag N/A clear_state N/A N/A self window tag N/A N/A N/A window_id N/A N/A self _get_ids window N/A N/A N/A N/A N/A self raw_state clear_state window_id tag N/A N/A tag None N/A N/A N/A N/A self window_ids N/A window N/A N/A N/A self _persist_window_ids N/A merge N/A N/A self to_be_merged merge_result N/A N/A N/A window to_be_merged N/A N/A N/A window merge_result N/A N/A N/A window N/A self window_ids N/A N/A N/A merge_result N/A self window_ids N/A N/A merge_window_ids N/A N/A self window_ids N/A merge_result N/A N/A merge_window_ids N/A N/A self window_ids N/A merge_result N/A N/A N/A N/A merge_window_ids extend N/A N/A N/A self window_ids pop window N/A N/A N/A self _persist_window_ids N/A known_windows N/A N/A self N/A N/A N/A N/A N/A N/A self window_ids keys N/A get_window N/A N/A self window_id N/A N/A N/A N/A window ids N/A N/A N/A self window_ids items N/A N/A N/A window_id ids N/A N/A window N/A N/A ValueError N/A No window for %s window_id N/A _get_id N/A N/A self window N/A N/A N/A N/A window N/A self window_ids N/A N/A N/A N/A N/A self window_ids N/A window N/A 0 N/A N/A window_id N/A N/A self _get_next_counter N/A N/A N/A self window_ids N/A window N/A window_id N/A N/A N/A self _persist_window_ids N/A window_id N/A _get_ids N/A N/A self window N/A N/A N/A N/A N/A N/A self window_ids get window N/A N/A _get_next_counter N/A N/A self N/A N/A N/A N/A N/A self window_ids N/A N/A N/A self counter 0 N/A N/A N/A N/A self counter None N/A N/A N/A self counter N/A max N/A k N/A ids N/A N/A N/A self window_ids values N/A k ids N/A N/A self counter 1 N/A N/A self counter N/A _persist_window_ids N/A N/A self N/A N/A N/A N/A N/A N/A self raw_state set_global_state N/A self WINDOW_IDS N/A self window_ids N/A __repr__ N/A N/A self N/A N/A N/A N/A N/A join N/A N/A N/A repr N/A self window_ids N/A N/A N/A repr N/A self raw_state split N/A N/A create_trigger_driver N/A N/A windowing is_batch phased_combine_fn N/A False None N/A N/A Create the TriggerDriver for the given windowing and options. N/A N/A N/A N/A windowing is_default is_batch N/A N/A driver N/A DefaultGlobalBatchTriggerDriver N/A N/A driver N/A GeneralTriggerDriver windowing N/A phased_combine_fn N/A N/A driver N/A CombiningTriggerDriver phased_combine_fn driver N/A driver N/A TriggerDriver N/A object N/A N/A Breaks a series of bundle and timer firings into window (pane)s. N/A __metaclass__ ABCMeta process_elements N/A N/A self state windowed_values output_watermark N/A N/A N/A N/A abstractmethod process_timer N/A N/A self window_id name time_domain timestamp state N/A N/A N/A N/A abstractmethod N/A DefaultGlobalBatchTriggerDriver N/A TriggerDriver N/A N/A Breaks a bundles into window (pane)s according to the default triggering.
   N/A GLOBAL_WINDOW_TUPLE N/A N/A GlobalWindow __init__ N/A N/A self N/A N/A N/A N/A process_elements N/A N/A self state windowed_values unused_output_watermark N/A N/A N/A N/A isinstance windowed_values list N/A N/A unwindowed N/A N/A wv value N/A wv windowed_values N/A UnwindowedValues N/A N/A observable ObservableMixin N/A __iter__ N/A N/A self N/A N/A N/A wv windowed_values N/A N/A unwindowed_value N/A wv value N/A N/A N/A self notify_observers unwindowed_value N/A N/A unwindowed_value N/A __repr__ N/A N/A self N/A N/A N/A N/A <UnwindowedValues of %s> windowed_values N/A N/A N/A unwindowed N/A UnwindowedValues N/A N/A N/A WindowedValue unwindowed MIN_TIMESTAMP N/A self GLOBAL_WINDOW_TUPLE N/A process_timer N/A N/A self window_id name time_domain timestamp state N/A N/A N/A N/A TypeError Triggers never set or called for batch default windowing. N/A N/A CombiningTriggerDriver N/A TriggerDriver N/A N/A Uses a phased_combine_fn to process output of wrapped TriggerDriver. __init__ N/A N/A self phased_combine_fn underlying N/A N/A N/A N/A self phased_combine_fn phased_combine_fn N/A N/A self underlying underlying N/A process_elements N/A N/A self state windowed_values output_watermark N/A N/A N/A uncombined N/A N/A N/A self underlying process_elements state windowed_values output_watermark N/A output uncombined N/A N/A N/A N/A N/A output with_value N/A N/A N/A self phased_combine_fn apply N/A output value N/A process_timer N/A N/A self window_id name time_domain timestamp state N/A N/A N/A uncombined N/A N/A N/A self underlying process_timer window_id name time_domain timestamp state N/A output uncombined N/A N/A N/A N/A N/A output with_value N/A N/A N/A self phased_combine_fn apply N/A output value N/A N/A GeneralTriggerDriver N/A TriggerDriver N/A N/A Breaks a series of bundle and timer firings into window (pane)s.

  Suitable for all variants of Windowing.
   N/A ELEMENTS N/A ListStateTag elements N/A TOMBSTONE N/A CombiningValueStateTag tombstone N/A N/A combiners CountCombineFn __init__ N/A N/A self windowing N/A N/A N/A N/A self window_fn N/A windowing windowfn N/A N/A self output_time_fn_impl N/A N/A OutputTimeFn get_impl N/A windowing output_time_fn N/A self window_fn N/A N/A self WATERMARK_HOLD N/A WatermarkHoldStateTag watermark N/A self output_time_fn_impl N/A N/A self trigger_fn N/A windowing triggerfn N/A N/A self accumulation_mode N/A windowing accumulation_mode N/A N/A self is_merging True N/A process_elements N/A N/A self state windowed_values output_watermark N/A N/A N/A N/A self is_merging N/A N/A state N/A MergeableStateAdapter state N/A windows_to_elements N/A N/A collections defaultdict list N/A wv windowed_values N/A N/A window N/A wv windows N/A N/A N/A N/A N/A windows_to_elements N/A window append N/A N/A wv value N/A wv timestamp N/A N/A self is_merging N/A N/A old_windows N/A set N/A N/A state known_windows N/A all_windows N/A N/A old_windows union N/A N/A windows_to_elements keys N/A N/A all_windows old_windows N/A N/A merged_away N/A TriggerMergeContext N/A N/A WindowFn MergeContext N/A merge N/A N/A _ to_be_merged merge_result N/A N/A N/A window to_be_merged N/A N/A N/A window merge_result N/A N/A N/A merged_away N/A window merge_result N/A N/A N/A state merge to_be_merged merge_result N/A N/A N/A N/A self trigger_fn on_merge to_be_merged merge_result N/A N/A state at merge_result N/A N/A N/A N/A N/A N/A self window_fn merge N/A TriggerMergeContext all_windows N/A merged_windows_to_elements N/A N/A collections defaultdict list N/A N/A window values N/A N/A windows_to_elements items N/A N/A N/A window merged_away N/A N/A window N/A merged_away N/A window N/A N/A N/A N/A merged_windows_to_elements N/A window extend values N/A windows_to_elements merged_windows_to_elements N/A window merged_away N/A N/A N/A N/A state clear_state window N/A self WATERMARK_HOLD N/A N/A window elements N/A N/A windows_to_elements items N/A N/A N/A N/A state get_state window N/A self TOMBSTONE N/A N/A N/A output_time N/A N/A N/A self output_time_fn_impl merge window N/A element_output_time N/A element_output_time N/A N/A N/A N/A self output_time_fn_impl assign_output_time window timestamp N/A N/A unused_value timestamp elements N/A element_output_time output_watermark N/A N/A output_time None N/A N/A N/A N/A state add_state window N/A self WATERMARK_HOLD output_time N/A context N/A N/A state at window N/A N/A value unused_timestamp elements N/A N/A N/A N/A state add_state window N/A self ELEMENTS value N/A N/A N/A N/A self trigger_fn on_element value window context N/A watermark MIN_TIMESTAMP N/A N/A N/A N/A self trigger_fn should_fire watermark window context N/A N/A finished N/A N/A N/A self trigger_fn on_fire watermark window context N/A N/A N/A N/A self _output window finished state N/A process_timer N/A N/A self window_id unused_name time_domain timestamp state N/A N/A N/A N/A self is_merging N/A N/A state N/A MergeableStateAdapter state N/A window N/A N/A state get_window window_id N/A N/A N/A state get_state window N/A self TOMBSTONE N/A N/A N/A N/A time_domain N/A TimeDomain WATERMARK N/A N/A N/A N/A N/A self is_merging N/A window N/A N/A state known_windows N/A N/A context N/A N/A state at window N/A N/A N/A N/A self trigger_fn should_fire timestamp window context N/A N/A finished N/A N/A N/A self trigger_fn on_fire timestamp window context N/A N/A N/A N/A self _output window finished state N/A N/A N/A Exception N/A Unexpected time domain: %s time_domain N/A _output N/A N/A self window finished state N/A N/A N/A Output window and clean up if appropriate. N/A values N/A N/A state get_state window N/A self ELEMENTS N/A finished N/A N/A N/A N/A state clear_state window N/A self ELEMENTS N/A N/A N/A state add_state window N/A self TOMBSTONE 1 N/A N/A N/A N/A self accumulation_mode N/A AccumulationMode DISCARDING N/A N/A N/A N/A state clear_state window N/A self ELEMENTS N/A timestamp N/A N/A state get_state window N/A self WATERMARK_HOLD N/A N/A timestamp None N/A N/A timestamp N/A window end N/A N/A N/A N/A state clear_state window N/A self WATERMARK_HOLD N/A N/A WindowedValue values timestamp N/A window N/A N/A InMemoryUnmergedState N/A UnmergedState N/A N/A In-memory implementation of UnmergedState.

  Used for batch and testing.
   __init__ N/A N/A self defensive_copy N/A True N/A N/A N/A self timers N/A N/A collections defaultdict dict N/A N/A self state N/A N/A collections defaultdict N/A N/A N/A N/A N/A N/A collections defaultdict list N/A N/A self global_state N/A N/A N/A self defensive_copy defensive_copy N/A set_global_state N/A N/A self tag value N/A N/A N/A N/A isinstance tag ValueStateTag N/A N/A self defensive_copy N/A N/A value N/A N/A copy deepcopy value N/A N/A N/A self global_state N/A N/A tag tag value N/A get_global_state N/A N/A self tag default N/A None N/A N/A N/A N/A N/A self global_state get N/A tag tag default N/A set_timer N/A N/A self window name time_domain timestamp N/A N/A N/A N/A N/A N/A self timers N/A window N/A N/A name time_domain timestamp N/A clear_timer N/A N/A self window name time_domain N/A N/A N/A N/A N/A N/A N/A self timers N/A window pop N/A name time_domain None N/A get_window N/A N/A self window_id N/A N/A N/A window_id N/A add_state N/A N/A self window tag value N/A N/A N/A N/A self defensive_copy N/A N/A value N/A N/A copy deepcopy value N/A N/A isinstance tag ValueStateTag N/A N/A N/A N/A N/A self state N/A window N/A N/A tag tag value N/A N/A N/A isinstance tag CombiningValueStateTag N/A N/A N/A N/A N/A N/A N/A self state N/A window N/A N/A tag tag append value N/A N/A N/A isinstance tag ListStateTag N/A N/A N/A N/A N/A N/A N/A self state N/A window N/A N/A tag tag append value N/A N/A N/A isinstance tag WatermarkHoldStateTag N/A N/A N/A N/A N/A N/A N/A self state N/A window N/A N/A tag tag append value N/A N/A N/A ValueError Invalid tag. tag N/A get_state N/A N/A self window tag N/A N/A N/A values N/A N/A N/A self state N/A window N/A N/A tag tag N/A N/A isinstance tag ValueStateTag N/A N/A values N/A N/A N/A isinstance tag CombiningValueStateTag N/A N/A N/A N/A N/A tag combine_fn apply values N/A N/A N/A isinstance tag ListStateTag N/A N/A values N/A N/A N/A isinstance tag WatermarkHoldStateTag N/A N/A N/A N/A N/A tag output_time_fn_impl combine_all values N/A N/A N/A ValueError Invalid tag. tag N/A clear_state N/A N/A self window tag N/A N/A N/A N/A N/A N/A N/A self state N/A window pop N/A tag tag None N/A N/A N/A N/A self state N/A window N/A N/A N/A N/A N/A self state pop window None N/A get_and_clear_timers N/A N/A self watermark N/A MAX_TIMESTAMP N/A N/A expired N/A N/A N/A window timers N/A list N/A N/A N/A self timers items N/A N/A N/A N/A name time_domain timestamp N/A list N/A N/A timers items N/A N/A N/A timestamp watermark N/A N/A N/A N/A expired append N/A window N/A name time_domain timestamp N/A N/A timers N/A N/A name time_domain N/A N/A timers N/A N/A N/A N/A self timers N/A window N/A expired N/A __repr__ N/A N/A self N/A N/A N/A state_str N/A N/A join N/A N/A %s: %s N/A key N/A dict state N/A N/A key state N/A N/A N/A self state items N/A N/A timers: %s
state: %s N/A N/A dict N/A self timers state_str N/A N/A