apache-flink

0зной

1ответ

Функциональность трансляции в Apache Flink с использованием Java

Я пытаюсь реализовать Apache Flink - трансляцию. Как мы реализуем трансляцию для наборов данных с использованием Java. Просьба помочь.

dataset batch-processing apache-flink 2016-07-13

---

0зной

1ответ

FlinkKafkaConsumer09 снова и снова читает некоторые сообщения

Я написал простую программу для чтения данных из Kafka и печати в flink. Ниже приведен код. public static void main(String[] args) throws Exception { Options flinkPipelineOptions = PipelineOptio

java apache-kafka apache-flink flink-streaming 2016-07-15

---

1зной

1ответ

Flink Jobmanager не может видеть менеджеров задач

Итак, я установил кластер apache flink в нашей сети. Я сделал конфигурации, как показано ниже. Этот мастер (JobManager) запускается и отправляет команду запуска всем подчиненным с помощью ssh. Я вижу,

ssh cluster-computing apache-flink 2016-07-21

---

0зной

1ответ

Flatch пакетная обработка данных

Я оцениваю Flink для некоторых пакетов обработки данных. Как простой пример, у меня есть 2000 точек, которые я бы хотел пройти через FIR-фильтр, используя функциональность, предоставляемую scipy. Scip

python apache-flink 2016-07-22

---