this method is called in setup method of the operator concode_field_sep ArrayBlockingQueue<Message> holdingBuffer concode_elem_sep String topic concode_elem_sep Map<Integer,long[]> _1_min_msg_sum_par concode_elem_sep boolean isAlive concode_elem_sep Map<Integer,long[]> _1_min_byte_sum_par concode_elem_sep Map<Integer,double[]> _1minMovingAvgPerPartition concode_elem_sep Set<String> brokerSet concode_elem_sep long[] bytesSec concode_elem_sep long serialVersionUID concode_elem_sep short last concode_elem_sep String initialOffset concode_elem_sep long[] msgSec concode_elem_sep ScheduledExecutorService service concode_elem_sep int cursor concode_elem_sep String SIMPLE_CONSUMER_ID_SUFFIX concode_elem_sep String HIGHLEVEL_CONSUMER_ID_SUFFIX concode_elem_sep SnapShot statsSnapShot concode_elem_sep int consumerBuffer concode_elem_sep double[] _1minMovingAvg concode_field_sep KafkaMeterStats getStats concode_elem_sep Set<String> getBrokerSet concode_elem_sep void set_1minMovingAvgPerPartition concode_elem_sep void setInitialOffset concode_elem_sep String getTopic concode_elem_sep double[] get_1minMovingAvg concode_elem_sep void _stop concode_elem_sep Map<Integer,double[]> get_1minMovingAvgPerPartition concode_elem_sep int messageSize concode_elem_sep void teardown concode_elem_sep void commitOffset concode_elem_sep String getInitialOffset concode_elem_sep void moveNext concode_elem_sep void start concode_elem_sep void start concode_elem_sep KafkaConsumer cloneConsumer concode_elem_sep KafkaConsumer cloneConsumer concode_elem_sep void putMessage concode_elem_sep void set_1minMovingAvg concode_elem_sep void setTopic concode_elem_sep Message pollMessage concode_elem_sep void setBrokerSet concode_elem_sep boolean isAlive concode_elem_sep KafkaMeterStats getConsumerStats concode_elem_sep void stop concode_elem_sep void stop concode_elem_sep Map<Integer,Long> getCurrentOffsets concode_elem_sep void setAlive concode_elem_sep void mark
void function ( ) { holdingBuffer = new ArrayBlockingQueue < Message > ( consumerBuffer ) ; }