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.