Function make_serialized

python/pyarrow/tests/test_cffi.py:119–124

(schema, batches)

def make_serialized(schema, batches):
    with pa.BufferOutputStream() as sink:
        with pa.ipc.new_stream(sink, schema) as out:
            for batch in batches:
                out.write(batch)
        return sink.getvalue()


@needs_cffi