#NEWLINE# def __init__( self , work_item , coder ) : #NEWLINE# #INDENT# super ( KeyedWorkItem , self ) . __init__ ( ) #NEWLINE# self . work_item = work_item #NEWLINE# self . coder = coder #NEWLINE# self . key_coder = coder . key_coder ( ) #NEWLINE# value_coder = coder . value_coder ( ) #NEWLINE# self . wv_coder = coders . WindowedValueCoder ( value_coder ) #NEWLINE# self . key = self . key_coder . decode ( work_item . key ) #NEWLINE# from google.cloud.dataflow.internal import windmill_pb2 #NEWLINE# self . windmill_pb2 = windmill_pb2