Function ndarray_to_block

python/ray/data/_internal/util.py:781–792

(
    ndarray: np.ndarray, ctx: DataContext
)

def ndarray_to_block(
    ndarray: np.ndarray, ctx: DataContext
) -> Tuple["Block", "BlockMetadataWithSchema"]:
    from ray.data.block import BlockAccessor, BlockExecStats, BlockMetadataWithSchema

    DataContext._set_current(ctx)

    stats = BlockExecStats.builder()
    block = BlockAccessor.batch_to_block({"data": ndarray})
    return block, BlockMetadataWithSchema.from_block(
        block, block_exec_stats=stats.build()
    )


def get_table_block_metadata_schema(