class_docstr: This will preoritically query data from cache-service
class_docstr_tok: ["This","will","preoritically","query","data","from","cache-service"]
code: def __init__(self, cache_svc_url, table_name, name_space):
      self.last_fetch_time = 0
      self.table_name = table_name
      # train, valid, test
      self.name_space = name_space
      self.end_signal = "end_position"
      self.cache_svc_url = cache_svc_url
      self.data_queue = queue.Queue(maxsize=10)
      self.stop_event = threading.Event()
      self.thread = threading.Thread(
          target=self.fetch_data, daemon=True
      )
      self.thread.start()
  
file_path: singa/examples/model_selection/TRAILS-Database-Native-Model-Selection/internal/ml/model_selection/src/dataset_utils/stream_dataloader.py
imports: import queue
  import threading
  import requests
  import time
  from src.logger import logger
label_desc: Use image node_id 1 to create a new StreamingDataLoader object  with example: obj = StreamingDataLoader(cache_svc_url, table_name, name_space)