Construct a new `PlanPropertiesCache` from the
(
eq_properties: EquivalenceProperties,
partitioning: Partitioning,
emission_type: EmissionType,
boundedness: Boundedness,
)
| 1083 | impl PlanProperties { |
| 1084 | /// Construct a new `PlanPropertiesCache` from the |
| 1085 | pub fn new( |
| 1086 | eq_properties: EquivalenceProperties, |
| 1087 | partitioning: Partitioning, |
| 1088 | emission_type: EmissionType, |
| 1089 | boundedness: Boundedness, |
| 1090 | ) -> Self { |
| 1091 | // Output ordering can be derived from `eq_properties`. |
| 1092 | let output_ordering = eq_properties.output_ordering(); |
| 1093 | Self { |
| 1094 | eq_properties, |
| 1095 | partitioning, |
| 1096 | emission_type, |
| 1097 | boundedness, |
| 1098 | evaluation_type: EvaluationType::Lazy, |
| 1099 | scheduling_type: SchedulingType::NonCooperative, |
| 1100 | output_ordering, |
| 1101 | } |
| 1102 | } |
| 1103 | |
| 1104 | /// Overwrite output partitioning with its new value. |
| 1105 | pub fn with_partitioning(mut self, partitioning: Partitioning) -> Self { |
nothing calls this directly
no test coverage detected