get the average time to pull a record of a partition , which is stored in property '' topicname . partitionid . avg.record.millis '' . if state does n't contain this property , it returns defaultvalue . concode_field_sep PlaceHolder placeHolder concode_field_sep void setPartitionAvgRecordMillis concode_elem_sep KafkaPartition getPartition concode_elem_sep String getTopicName concode_elem_sep String getPartitionPropName concode_elem_sep List<KafkaPartition> getPartitions concode_elem_sep long getPartitionAvgRecordSize concode_elem_sep void setPartitionAvgRecordSize concode_elem_sep boolean containsPartitionAvgRecordMillis concode_elem_sep boolean containsPartitionAvgRecordSize
double function ( State arg0 , KafkaPartition arg1 ) { return arg0 . getPropAsDouble ( getPartitionPropName ( arg1 . getTopicName ( ) , arg1 . getId ( ) ) + "srini_string" + KafkaSource . AVG_RECORD_MILLIS ) ; }