public void applyPolicy ( boolean forceUpload ) throws Exception { Collection < TopicPartition > topicPartitions = mFileRegistry . getTopicPartitions ( ) ; for ( TopicPartition topicPartition : topicPartitions ) { checkTopicPartition ( topicPartition , forceUpload ) ; } }
Apply the Uploader policy for pushing partition files to the underlying storage .