question: this method is called in teardown method of the operator concode_field_sep ArrayBlockingQueue<Pair<String,Record>> holdingBuffer concode_elem_sep Integer recordsLimit concode_elem_sep boolean isAlive concode_elem_sep HashSet<Shard> simpleConsumerThreads concode_elem_sep Set<String> shardIds concode_elem_sep ConcurrentHashMap<String,String> partitionStats concode_elem_sep int bufferSize concode_elem_sep String streamName concode_elem_sep Set<Shard> closedShards concode_elem_sep long recordsCheckInterval concode_elem_sep KinesisShardStats stats concode_elem_sep String initialOffset concode_elem_sep Logger logger concode_elem_sep ExecutorService consumerThreadExecutor concode_elem_sep ConcurrentHashMap<String,String> shardPosition concode_field_sep void setShardIds concode_elem_sep int getQueueSize concode_elem_sep void setStreamName concode_elem_sep void updateShardStats concode_elem_sep void setInitialOffset concode_elem_sep Set<Shard> getClosedShards concode_elem_sep void putRecord concode_elem_sep void create concode_elem_sep Map<String,String> getShardPosition concode_elem_sep void close concode_elem_sep ShardIteratorType getIteratorType concode_elem_sep Integer getRecordsLimit concode_elem_sep void setQueueSize concode_elem_sep String getStreamName concode_elem_sep String getInitialOffset concode_elem_sep void start concode_elem_sep Pair<String,Record> pollRecord concode_elem_sep void setRecordsLimit concode_elem_sep Integer getNumOfShards concode_elem_sep Map<String,String> getShardStatsForPartitions concode_elem_sep boolean isAlive concode_elem_sep KinesisShardStats getConsumerStats concode_elem_sep void stop concode_elem_sep Set<String> getShardIds concode_elem_sep void resetShardPositions concode_elem_sep void setAlive
target: void function ( ) { holdingBuffer . clear ( ) ; }