Запрос с использованием CASE WHEN в API таблицы Apache Flink

Я использую API таблицы Flink. Я хотел бы использовать CASE WHEN в запросе API таблицы. В моем запросе используются три поля: routeid, startlocation, distance, и я хочу использовать предложение CASE WHEN для определения факторов, основанных на значении distance, которые являются условиями, требуемыми для удовлетворения на основе routeid.Запрос с использованием CASE WHEN в API таблицы Apache Flink

Пример:

SELECT 
    routeid, 
    startlocation, 
    CASE WHEN (routeid=1) AND (distance > 0 AND distance <= 250) THEN 'oneday-distance'

Возможно ли это с таблицей API FLiNK в? Если да, как это можно сделать?

источник

2016-05-16 Akki

Почему вы не ставите все эти условия в предложение WHERE? – mitkosoft

Мой набор данных большой и важно У меня есть несколько условий для удовлетворения классов ... Если я использую CASE WHEN, это будет оптимизированный запрос ... Я также хочу использовать инструкцию UPDATE .. – Akki

Таблица API последней версии Flink версии 1.0.3 не поддерживает статьи CASE WHEN.

Для следующего выпуска (Flink 1.1.0) API таблицы переработан, расширен и поддерживается CASE WHEN. Мы можем попробовать версию 1.1-SNAPSHOT, чтобы попробовать эту функцию. Обратная связь приветствуется.

источник

2016-05-16 09:04:27

ok..Thanks @FabianHueske – Akki

Запрос с использованием CASE WHEN в API таблицы Apache Flink

ответ

Смежные вопросы