Использование Accumulo в качестве источника и приемника на Flink

Я хотел бы использовать Apache Accumulo для хранения данных о событиях и выполнения некоторых вычислений с помощью Apache Flink.

Я знаю, что это можно сделать с помощью Apache Spark, прочитать некоторые записи из Accumulo как RDD Чтение из Accumulo из оболочки Spark

можно ли использовать Accumulo в качестве источника и приемника на Apache Flink? Как правильно это сделать?


person aleksej523    schedule 07.11.2016    source источник
comment
Вы нашли решение своей проблемы? Мне было бы очень интересно узнать, как вы решили проблему и как интегрировали flink с accumulo.   -  person basiszwo    schedule 18.05.2017