sink = pa.InMemoryOutputStream()
stream_writer = pa.StreamWriter(sink, batch.schema)