Source code for neosqlite.collection.temporary_table_aggregation.operators_base

from __future__ import annotations

from typing import Any




class OperatorsBaseMixin:
    # Attribute annotations for state supplied by
    # TemporaryTableAggregationProcessor.__init__. Declared on the shared base so every
    # mixin sees them via MRO. Values are assigned by the concrete processor subclass.
    collection: Any
    db: Any
    query_engine: Any
    expr_evaluator: Any
    sql_translator: Any
    _jsonb_supported: bool
    _jsonb_each_supported: bool
    _json_each_function: str
    _json_function_prefix: str
    json_group_array_function: str
    _has_sort_stage: bool
    _text_on_temp_table_warned: bool
    _has_unwind_in_pipeline: bool

    # Stub for the single method called across mixin boundaries
    # (_process_match_stage -> _process_text_search_stage). The real implementation lives
    # in OperatorsTextMixin; declaring it here lets static analysis resolve the call via MRO.


    def _process_text_search_stage(self, *args: Any, **kwargs: Any) -> Any: ...