torcharrow.dataframe¶
- torcharrow.dataframe(data: Optional[Union[Iterable, DType]] = None, dtype: Optional[DType] = None, columns: Optional[List[str]] = None, device: str = '')¶
创建 TorchArrow DataFrame。
- 参数:
data (dict 或 元组列表) – 定义 DataFrame 的内容。字典键用于列名,值用于列。使用 dtype 强制特定的列顺序。当 Data 为元组列表时,必须提供 dtype 来推断字段名。
dtype (dtype, 默认为 None) – 要强制的数据类型。如果为 None,则会在可能的情况下自动推断类型。应为 dt.Struct(),提供 dt.Fields 列表。
columns (字符串列表, 默认为 None) – 列的名称。在数据为元组列表且未提供自定义 dtype 时使用。当 data 和 dtype 均为 None 时,应将其保留为 None(语义是构建一个没有列的默认空 DataFrame)。
device (设备, 默认为 "") – 设备选择要从作用域中使用的运行时。TorchArrow 支持多个运行时(CPU 和 GPU)。如果未提供,则使用 Velox 矢量化运行时。有效值为“cpu”(Velox),“gpu”(即将推出)。
示例
DataFrame 只是一组命名且类型严格的等长列
>>> import torcharrow as ta >>> df = ta.dataframe({'a': list(range(7)), >>> 'b': list(reversed(range(7))), >>> 'c': list(range(7)) >>> }) >>> df index a b c ------- --- --- --- 0 0 6 0 1 1 5 1 2 2 4 2 3 3 3 3 4 4 2 4 5 5 1 5 6 6 0 6 dtype: Struct([Field('a', int64), Field('b', int64), Field('c', int64)]), count: 7, null_count: 0
DataFrame 是不可变的,除非您可以始终添加新列,前提是该列名尚未使用过。该列附加到现有列集的末尾
>>> df['d'] = ta.column(list(range(99, 99+7))) >>> df index a b c d ------- --- --- --- --- 0 0 6 0 99 1 1 5 1 100 2 2 4 2 101 3 3 3 3 102 4 4 2 4 103 5 5 1 5 104 6 6 0 6 105 dtype: Struct([Field('a', int64), Field('b', int64), Field('c', int64), Field('d', int64)]), count: 7, null_count: 0
构建嵌套 DataFrame
>>> df_inner = ta.dataframe({'b1': [11, 22, 33], 'b2':[111,222,333]}) >>> df_outer = ta.dataframe({'a': [1, 2, 3], 'b':df_inner}) >>> df_outer index a b ------- --- --------- 0 1 (11, 111) 1 2 (22, 222) 2 3 (33, 333) dtype: Struct([Field('a', int64), Field('b', Struct([Field('b1', int64), Field('b2', int64)]))]), count: 3, null_count: 0
从元组列表构建 DataFrame
>>> import torcharrow.dtypes as dt >>> l = [(1, 'a'), (2, 'b'), (3, 'c')] >>> ta.dataframe(l, dtype = dt.Struct([dt.Field('t1', dt.int64), dt.Field('t2', dt.string)])) index t1 t2 ------- ---- ---- 0 1 a 1 2 b 2 3 c dtype: Struct([Field('t1', int64), Field('t2', string)]), count: 3, null_count: 0
或
>>> ta.dataframe(l, columns=['t1', 't2']) index t1 t2 ------- ---- ---- 0 1 a 1 2 b 2 3 c dtype: Struct([Field('t1', int64), Field('t2', string)]), count: 3, null_count: 0