docstr: The class is a FIFO queue. Arrow tables are added to the queue. When read, rows are regrouped into Arrow
  tables of a fixed size specified during construction of the object. The order of the rows in the output tables
  is the same as the order of the rows in the input tables.
  
  :param batch_size: number of rows in tables that will be returned by the ``get`` method.
docstr_tok: ["The","class","is","a","FIFO","queue",".","Arrow","tables","are","added","to","the","queue",".","When","read",",","rows","are","regrouped","into","Arrow","tables","of","a","fixed","size","specified","during","construction","of","the","object",".","The","order","of","the","rows","in","the","output","tables","is","the","same","as","the","order","of","the","rows","in","the","input","tables",".",":","param","batch_size",":","number","of","rows","in","tables","that","will","be","returned","by","the","``","get","``","method","."]
code: def __init__(self, batch_size):
      """The class is a FIFO queue. Arrow tables are added to the queue. When read, rows are regrouped into Arrow
      tables of a fixed size specified during construction of the object. The order of the rows in the output tables
      is the same as the order of the rows in the input tables.
  
      :param batch_size: number of rows in tables that will be returned by the ``get`` method.
      """
      self._batch_size = batch_size
      self._buffer = deque()
      self._head_idx = 0
      self._cumulative_len = 0
  
imports: from collections import deque
  import pyarrow
label_desc: Use image node_id 1 to create a new BatchingTableQueue object from inherited base classes: object with example: obj = BatchingTableQueue(batch_size)