boolean function ( TopicPartition arg0 ) { final String loc0 = arg0 . getTopic ( ) ; if ( mTopicFilter == null || mTopicFilter . isEmpty ( ) ) { return false ; } if ( loc0 . matches ( mTopicFilter ) ) { if ( DateTime . now ( ) . minuteOfHour ( ) . get ( ) == mConfig . getUploadMinuteMark ( ) ) { return true ; } } return false ; }
if the topic is in the list of topics to upload at a specific time . for example at a minute mark . 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 void trimFiles concode_elem_sep void checkTopicPartition concode_elem_sep void applyPolicy