@Override
	public void nextTuple() {
		//If there is a place to place item on queue
		if(TempEmptyBucketsQueue.getRemainingCapacity() > 0){
			TempBucket tempBucket = getTempBucket();
			Values tupleValues = new Values(tempBucket);
			collector.emit(tupleValues);
		}else{
			Utils.sleep(1000);
		}
		
		
	}