Как оформить заказ по всей таблице с помощью Apache Flink Table API

Question

В следующем фрагменте я пытаюсь отсортировать таблицу по «значению»;однако сортировка происходит только внутри каждого раздела, что, по-видимому, является ожидаемым поведением согласно документации .

    Table result = aircraftsTable.join(flightsTable).where("tail_number = tailnum")
                .where("manufacturer === 'CESSNA'")
                .groupBy("manufacturer, model")
                .select("manufacturer + ' ' + model, manufacturer.count as value")
                .orderBy("value");

Как заказать по всей таблице?Я полагаю, что это достигается в API DataSet путем установки парализма на 1;однако, я не вижу подобной функции для API таблицы в документации.

Answer 1

Я полагаю, что вы неправильно читаете документацию, и это говорит о том, что сортировка является глобальной сортировкой всей таблицы.

Но для чего бы это ни стоило, вы можете установить параллелизм в ExecutionEnvironment так же, как и для любой другой работы, использующей DataSet API.