See: Description
| Class | Description |
|---|---|
| EvaluationContext |
The
EvaluationContext is the result of a pipeline translation and can be used to evaluate / run the pipeline. |
| PipelineTranslator |
The pipeline translator translates a Beam
Pipeline into a Spark correspondence, that can
then be evaluated. |
| SparkSessionFactory | |
| TransformTranslator<InT extends PInput,OutT extends POutput,TransformT extends PTransform<? extends InT,OutT>> |
A
TransformTranslator provides the capability to translate a specific primitive or
composite PTransform into its Spark correspondence. |