Module core.steps.data.base_data_step

Base interface for the Data Step.

Functions

identity_ptransform(pipeline: apache_beam.pipeline.Pipeline) :

Classes

BaseDataStep(schema: Dict = None, **kwargs) : Base class for all data steps. These steps are used to specify a data source that is read from in a data or a training pipeline.

Base data step constructor. Custom data sources can be implemented
by defining classes that inherit from this class. Any custom data
source must implement the `read_from_source` method.

Args:
    schema: Optional schema of the data, a dict mapping feature names
     in the data to their respective data types.
    **kwargs: Additional keyword arguments.

### Ancestors (in MRO)

* zenml.core.steps.base_step.BaseStep

### Class variables

`STEP_TYPE`
:

### Methods

`convert_to_dict(self)`
:

`read_from_source(self)`
: