flux query v2

``` flux
// Базовая выборка
base = from(bucket: "offer_request") |> range(start: -30d)

// Выборка из таблицы исходящих платёжных методов
pm_from = base |> filter(fn: (r) => r._measurement == "pm_from")

// Выборка из таблицы входящих платёжных платёжных методов
pm_to = base |> filter(fn: (r) => r._measurement == "pm_to")

// Выборка из таблицы типов источников
source_types = base |> filter(fn: (r) => r._measurement == "source_type")

// Объединение таблицы платёжных методов
pm_join_result = join(tables: {pm_from: pm_from, pm_to: pm_to}, on: ["request_id"])

// Объединение с таблицей типов иточников
join_result = join(tables: {pm_join_result: pm_join_result, source_types: source_types}, on: ["request_id"])
|> keep(columns: ["request_id"])
|> distinct()

// Базовая выборка из таблицы исходящих платёжных методов
entity_base = base |> filter(fn: (r) => r._measurement == "pm_from")

// Фильтрация исходящих платёжных методов по подходящим запросам
join(tables: {join_result: join_result, entity_base: entity_base}, on: ["request_id"]) |> yield()
```