code: def write(self, bucket, rows):
          
  
          # Write buffer
          BUFFER_SIZE = 10000
  
          # Prepare schema, fallbacks
          schema = tableschema.Schema(self.describe(bucket))
          fallbacks = self.__fallbacks.get(bucket, [])
  
          # Write data
          rows_buffer = []
          for row in rows:
              row = self.__mapper.convert_row(row, schema=schema, fallbacks=fallbacks)
              rows_buffer.append(row)
              if len(rows_buffer) > BUFFER_SIZE:
                  self.__write_rows_buffer(bucket, rows_buffer)
                  rows_buffer = []
          if len(rows_buffer) > 0:
              self.__write_rows_buffer(bucket, rows_buffer)
docs: https://github.com/frictionlessdata/tableschema-bigquery-py#storage