Base interface for the Data Step.


identity_ptransform(pipeline: apache_beam.pipeline.Pipeline) :


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.

    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


### Methods