DataFrameMaker

class torchdata.datapipes.iter.DataFrameMaker(source_dp: IterDataPipe[T_co], dataframe_size: int = 1000, dtype=None, columns: Optional[List[str]] = None, device: str = '')

Takes rows of data, batches a number of them together and creates TorchArrow DataFrames (functional name: dataframe).

Note

There is a trade-off between having a large number of rows within a DataFrame and usage of memory. Please choose a value carefully.

Parameters:

• source_dp – IterDataPipe containing rows of data

• dataframe_size – number of rows of data within each DataFrame, page size can be option

• dtype – specify the TorchArrow dtype for the DataFrame, use torcharrow.dtypes.DType

• columns – List of str that specifies the column names of the DataFrame

• device – specify the device on which the DataFrame will be stored

Example

>>> from torchdata.datapipes.iter import IterableWrapper
>>> import torcharrow.dtypes as dt
>>> source_data = [(i,) for i in range(3)]
>>> source_dp = IterableWrapper(source_data)
>>> DTYPE = dt.Struct([dt.Field("Values", dt.int32)])
>>> df_dp = source_dp.dataframe(dtype=DTYPE)
>>> list(df_dp)[0]
  index    Values
-------  --------
      0         0
      1         1
      2         2
dtype: Struct([Field('Values', int32)]), count: 3, null_count: 0