JackieTien97 opened a new pull request, #16002: URL: https://github.com/apache/iotdb/pull/16002
This pull request introduces changes to improve the lifecycle management and concurrency handling of the `TableFunctionLeafOperator` class in the IoTDB query engine. The primary updates involve ensuring proper initialization of the processor and adding support for non-blocking operations. ### Enhancements to lifecycle management: - **Initialization flag and deferred processor start**: Added a `volatile boolean init` field to track whether the processor has been initialized. The `processor.beforeStart()` method is now invoked during the `isBlocked()` method instead of the constructor, ensuring deferred initialization. ### Support for non-blocking operations: - **`isBlocked` method implementation**: Introduced the `isBlocked()` method, returning a `ListenableFuture` to indicate non-blocked status. This aligns with the operator's lifecycle and concurrency requirements. ### Dependency update: - **Added `ListenableFuture` import**: Imported `ListenableFuture` from Guava to support the non-blocking behavior in the `isBlocked()` method. -- 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]
