#NEWLINE# def split( self , files ) : #NEWLINE# #INDENT# for filename in files : #NEWLINE# #INDENT# source = TraceDataSource ( self . receive , filename = filename , loop = False , realtime = False ) #NEWLINE# source . start ( ) #NEWLINE# #UNINDENT# self . records . sort ( key = itemgetter ( 'timestamp' ) ) #NEWLINE# for record in record . records : #NEWLINE# #INDENT# self . buckets [ self . _key_for_record ( record ) ] . append ( record ) #NEWLINE# #UNINDENT# return self . buckets