Function deeplake_planner

cpp/deeplake_pg/extension_init.cpp:1245–1269

}

static PlannedStmt*
deeplake_planner(Query* parse, const char* query_string, int32_t cursorOptions, ParamListInfo boundParams)
{
    pg::init_deeplake();

    // Transform ->> to jsonb_field_eq
    if (pg::support_json_index && parse && parse->jointree && parse->jointree->quals) {
        transform_jsonb_arrow_quals((Node**)&parse->jointree->quals);
    }

    PlannedStmt* planned_stmt = nullptr;
    if (pg::use_deeplake_executor && is_pure_select_statement(query_string)) {
        planned_stmt = deeplake_create_direct_execution_plan(parse, query_string, cursorOptions, boundParams);
    }

    if (!planned_stmt) {
        if (prev_planner_hook) {
            planned_stmt = prev_planner_hook(parse, query_string, cursorOptions, boundParams);
        } else {
            planned_stmt = standard_planner(parse, query_string, cursorOptions, boundParams);
        }
    }

    return planned_stmt;
}

static void executor_start(QueryDesc* query_desc, int32_t eflags)
{