code: public void applyPolicy(boolean forceUpload) throws Exception {
          Collection<TopicPartition> topicPartitions = mFileRegistry.getTopicPartitions();
          for (TopicPartition topicPartition : topicPartitions) {
              checkTopicPartition(topicPartition, forceUpload);
          }
      }
docs: Apply the Uploader policy for pushing partition files to the underlying storage.
  
  For each of the partitions of the file registry, apply the policy for flushing
  them to the underlying storage.
  
  This method could be subclassed to provide an alternate policy. The custom uploader
  class name would need to be specified in the secor.upload.class.
  
  @throws Exception if any error occurs while appying the policy