#NEWLINE# def _upload_local_files_to_hdfs( self ) : #NEWLINE# #INDENT# 'Copy files managed by self._upload_mgr to HDFS\n        ' #NEWLINE# self . fs . mkdir ( self . _upload_mgr . prefix ) #NEWLINE# log . info ( ( 'Copying local files to %s...' % self . _upload_mgr . prefix ) ) #NEWLINE# for ( path , uri ) in self . _upload_mgr . path_to_uri ( ) . items ( ) : #NEWLINE# #INDENT# self . _upload_to_hdfs ( uri , uri )