python/ray/data/read_api.py
def from_arrow_refs(
    tables: Union[
        ObjectRef[Union["pyarrow.Table", bytes]],
        List[ObjectRef[Union["pyarrow.Table", bytes]]],
    ]
) -> Dataset[ArrowRow]:
    """Create a dataset from a set of Arrow tables.

    Args:
        tables: A Ray object reference to Arrow table, or list of Ray object
                references to Arrow tables, or its streaming format in bytes.

    Returns:
        Dataset holding Arrow records from the tables.
    """
    if isinstance(tables, ray.ObjectRef):
        tables = [tables]

    get_metadata = cached_remote_fn(_get_metadata)
    metadata = [get_metadata.remote(t) for t in tables]
    return Dataset(
        ExecutionPlan(
            BlockList(tables, ray.get(metadata)),
            DatasetStats(stages={"from_arrow_refs": metadata}, parent=None),
        ),
        0,
        False,
    )
Create a dataset from a set of Arrow tables.

    Args:
        tables: A Ray object reference to Arrow table, or list of Ray object
                references to Arrow tables, or its streaming format in bytes.

    Returns:
        Dataset holding Arrow records from the tables.
    
Create a dataset from a set of Arrow tables.
Create a dataset from a set of Arrow tables .
def from_arrow_refs(
    tables: Union[
        ObjectRef[Union["pyarrow.Table", bytes]],
        List[ObjectRef[Union["pyarrow.Table", bytes]]],
    ]
) -> Dataset[ArrowRow]:
    if isinstance(tables, ray.ObjectRef):
        tables = [tables]
    get_metadata = cached_remote_fn(_get_metadata)
    metadata = [get_metadata.remote(t) for t in tables]
    return Dataset(
        ExecutionPlan(
            BlockList(tables, ray.get(metadata)),
            DatasetStats(stages={"from_arrow_refs": metadata}, parent=None),
        ),
        0,
        False,
    )
def from_arrow_refs ( tables : Union [ ObjectRef [ Union [ "pyarrow.Table" , bytes ] ] , List [ ObjectRef [ Union [ "pyarrow.Table" , bytes ] ] ] , ] ) -> Dataset [ ArrowRow ] : if isinstance ( tables , ray . ObjectRef ) : tables = [ tables ] get_metadata = cached_remote_fn ( _get_metadata ) metadata = [ get_metadata . remote ( t ) for t in tables ] return Dataset ( ExecutionPlan ( BlockList ( tables , ray . get ( metadata ) ) , DatasetStats ( stages = { "from_arrow_refs" : metadata } , parent = None ) , ) , 0 , False , )
Create a dataset from a set of Arrow tables.
Create a dataset from a set of Arrow tables .
"""Create a dataset from a set of Arrow tables.

    Args:
        tables: A Ray object reference to Arrow table, or list of Ray object
                references to Arrow tables, or its streaming format in bytes.

    Returns:
        Dataset holding Arrow records from the tables.
    """
Dataset holding Arrow records from the tables.
Dataset holding Arrow records from the tables .
tables
Union[
        ObjectRef[Union["pyarrow.Table", bytes]],
        List[ObjectRef[Union["pyarrow.Table", bytes]]],
    ]
A Ray object reference to Arrow table, or list of Ray object
references to Arrow tables, or its streaming format in bytes.
A Ray object reference to Arrow table or list of Ray object references to Arrow tables or its streaming format in bytes .