PandasOperator
About 135 wordsLess than 1 minute
2025-10-09
📘 Overview
The PandasOperator applies a list of user-defined transformation functions to a DataFrame. Each function takes a DataFrame as input and returns a modified DataFrame, allowing for flexible and sequential data manipulation like adding columns, renaming, sorting, and more.
__init__ function
def __init__(self, process_fn: list):init Parameters
| Parameter Name | Type | Default Value | Description |
|---|---|---|---|
| process_fn | list | Required | A list of functions to apply to the DataFrame. Each function must accept a DataFrame and return a DataFrame. |
Prompt Template Descriptions
| Prompt Template Name | Primary Use | Applicable Scenarios | Feature Description |
|---|---|---|---|
run function
def run(self, storage: DataFlowStorage):Parameters
| Name | Type | Default Value | Description |
|---|---|---|---|
| storage | DataFlowStorage | Required | DataFlow storage instance for reading the input DataFrame and writing the modified DataFrame. |
🧠 Example Usage

