| Class | Description |
|---|---|
| AbstractPythonCorrelateRuleBase |
The abstract physical rule base is responsible for converting
FlinkLogicalCorrelate to
physical Python correlate RelNode. |
| AbstractPythonCorrelateRuleBase.PythonCorrelateFactoryBase |
The abstract factory is responsible for creating
DataSetPythonCorrelate or DataStreamPythonCorrelate. |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.