Результаты поиска по запросу "apache-flink"
для получения дополнительной информации.
аюсь прочитать файл, используя: final ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment(); DataSet<String> line = env.readTextFile("file:///pathtofile/myfile.txt");Я получаю следующую ...
Глобальная сортировка в Apache Flink
Метод sortPartition набора данных сортирует набор данных локально на основе некоторых указанных полей. Как я могу эффективно отсортировать мой большой набор ...
Большое спасибо, пока!
ожусь в ситуации, когда я хочу, чтобы остановить / отменить работу Flink из кода. Это мой интеграционный тест, в котором я отправляю задание на мою работу Fl...
Что означает «потоковая передача» в Apache Spark и Apache Flink?
Как я пошел вApache Spark Streaming На сайте я увидел предложение:Spark Streaming позволяет легко создавать масштабируемые отказоустойчивые потоковые приложе...
Поток Apache Flink в кластере не разделяет работу с работниками
Моя цель - настроить кластер с высокой пропускной способностью, используя Kafka в качестве источника и Flink в качестве механизма обработки потоков. Вот что ...
Можно ли использовать Riak CS с Apache Flink?
Я хочу настроить