define an input or output of a pipeline step.
Attributes
| Name | Type | Description |
|---|---|---|
| dataframe | str | name of the dataframe to connect input and output, used in context.dafaframes |
| mapping | dict | mapping to rename dataframe column from key to value. |
| drops | list | list of columns to drop from dataframe. |
| columns | list | list of columns to select from dataframe and exclude others. |
Methods
api_id()
return current object id on Web API format.
endpoint()
return endpoint name used to contact backend.
from_json()
load the object from a dict originating of a JSON format.
| Name | Type | Default | Description |
|---|---|---|---|
| obj | object to load information from. |
prepare()
prepare the dataframe based in information from this pipeline I/O definition.
perform mapping, selection and drops.
| Name | Type | Default | Description |
|---|---|---|---|
| df | DataFrame |
return: prepared dataframe.
set_id()
specify the id_value neutrally
| Name | Type | Default | Description |
|---|---|---|---|
| id_value |
return:
to_json()
transform current object into a dict that could be JSONIFY.
| Name | Type | Default | Description |
|---|---|---|---|
| target | str | None |
return: dumpable dict.