apache-flink

1зной

1ответ

writeAsCSV() и writeAsText() неожиданно

Я использую apache flink через Scala API, и в какой-то момент я получаю DataSet[(Int, Int, Int)]. Результат использования методов writeAsCSV() и writeAsText() является неожиданным. Он создает каталог.

scala writetofile apache-flink 2015-09-15

---

0зной

1ответ

Альтернативные конвейеры для Google Cloud Dataflow

Я прочитал, что бегун для проводника Google Cloud Dataflow для запуска на Spark, а также Data Artisans adapted, он запускается на Flink. Неясно, реализовал ли Cloudera как пакетную, так и оконную пото

apache-spark google-cloud-dataflow apache-flink 2015-09-15

---

4зной

1ответ

Перевести Flink в Java Скала

Док Flink дает пример SCALA для алгоритма SVM: val trainingDS: DataSet[LabeledVector] = env.readLibSVM(pathToTrainingFile) val svm = SVM() .setBlocks(10) // Learn the SVM model svm.fit(trainingDS

java scala apache-flink 2015-09-15

---

1зной

2ответ

Что такое рекомендуемый стек для работы с Flink и Scala?

Моя текущая попытка:. Затмение 4.4.2 Luna с-язя Scala плагин Rebuild Flink для Скале 2.11 (по умолчанию Maven загрузки официальный Flink построить что для Скале 2.10 Это приводит некоторые проблемы с

eclipse scala apache-flink 2015-09-15

---

5зной

1ответ

Flink: выходы DataSource вызвали ошибку: не удалось прочитать оболочку кода пользователя

Я только начинаю флинк. Я написал следующий код и получил «выходов DATASOURCE вызвали ошибку: Не удалось прочитать код обертки пользователя» Ошибка Есть ли что я делаю неправильно? версия: Flink v 0.9

apache-flink 2015-09-24

---