search

ArroyoSystems / arroyo

Distributed stream processing engine in Rust
https://arroyo.dev
Apache License 2.0
3.81k stars 220 forks source link

minor: change ouput_schema #730

Closed zhuliquan closed 2 months ago

zhuliquan commented 2 months ago

It's may be not right for KeyCalculationExtension.output_schema. I notice that output_schema is depend on self.input.schema https://github.com/ArroyoSystems/arroyo/blob/68fb412bfd15e706e59cbaac8295942d30badfee/crates/arroyo-planner/src/extension/key_calculation.rs#L112-L115 But according to func new_named_and_trimmed, the schema of KeyCaclculationExtension may not equal to self.input.schema https://github.com/ArroyoSystems/arroyo/blob/68fb412bfd15e706e59cbaac8295942d30badfee/crates/arroyo-planner/src/extension/key_calculation.rs#L39-L57

zhuliquan commented 2 months ago

Sorry, wrong understand