def to_arrow_schema()

in pypaimon/py4j/util/java_utils.py [0:0]

• 6 lines of code
• 1 McCabe index (conditional complexity)

def to_arrow_schema(j_row_type):
    # init arrow schema
    schema_bytes = get_gateway().jvm.SchemaUtil.getArrowSchema(j_row_type)
    schema_reader = pa.RecordBatchStreamReader(pa.BufferReader(schema_bytes))
    arrow_schema = schema_reader.schema
    schema_reader.close()
    return arrow_schema