JackieTien97 opened a new pull request, #16980: URL: https://github.com/apache/iotdb/pull/16980
This pull request introduces support for partial result returning in the `AbstractIntoOperator` and its subclasses. The changes enable operators to return intermediate results when their internal buffers are full, improving efficiency and responsiveness in streaming scenarios. The most important changes are: **Core logic changes:** * Added a new abstract method `tryToReturnPartialResult()` to `AbstractIntoOperator`, and updated the `next()` method to use it when a full result is not ready. This allows subclasses to provide partial results when possible. [[1]](diffhunk://#diff-30b4cac60ef8df3266822160a5d68effd5016a01c07061a5d65bedac77ee4e27L155-R163) [[2]](diffhunk://#diff-30b4cac60ef8df3266822160a5d68effd5016a01c07061a5d65bedac77ee4e27R221-R222) **Subclass implementations:** * Implemented `tryToReturnPartialResult()` in `DeviceViewIntoOperator` to return a built `TsBlock` if the internal `resultTsBlockBuilder` is full, and reset the builder afterwards. * Provided a default implementation of `tryToReturnPartialResult()` in `IntoOperator` that always returns `null`, preserving existing behavior where partial results are not supported. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
