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 . concode_field_sep Logger LOG concode_elem_sep String mTopicFilter concode_elem_sep SecorConfig mConfig concode_elem_sep ZookeeperConnector mZookeeperConnector concode_elem_sep FileRegistry mFileRegistry concode_elem_sep OffsetTracker mOffsetTracker concode_elem_sep UploadManager mUploadManager concode_elem_sep MetricCollector mMetricCollector concode_field_sep void init concode_elem_sep void init concode_elem_sep void uploadFiles concode_elem_sep void trim concode_elem_sep FileReader createReader concode_elem_sep boolean isRequiredToUploadAtTime concode_elem_sep void trimFiles concode_elem_sep void checkTopicPartition
void function ( ) { Collection < TopicPartition > loc0 = mFileRegistry . getTopicPartitions ( ) ; for ( TopicPartition loc1 : loc0 ) { checkTopicPartition ( loc1 ) ; } }