GP
у тебя shc-core должна транзитивно все что надо тащить если на то пошло
Size: a a a
2019 May 22
GP
если на не тащит что-то - то сюда например заходи https://mvnrepository.com/artifact/com.hortonworks.shc/shc-core/1.1.0.3.1.2.0-4
GP
смотри версии
GP
тут плохо что похереный артифакт
GP
но думаю можно догадаться какие версии
GP
hbase 2.0.2 + spark 2.4.0 нужно либе
DP
хорошо спасибо
PI
Ребята, подскажите, есть ли какой-то аналог apache beam который нормально с statefull streaming работает?
PI
у меня поток данных с gps идет, мне нужно с этого потока метрики собирать и фильтровать. Реализовал на спринг батче, но там это не очень удобно, он не предназначен для фильтрации на потоке....коряво выходит
GG
я бы предложил инфлакс, но слава Богу, что он сдох
PI
т.е. какой-то фреймворк при помощи которого я могу выстраивать цепочку reader -> filter<Input,Output>->filter<Input, Output>->writer
PI
внутри некоторых инстансов фильтров нужно иметь возможность хранить состояние и восстанавливать слепок этого состояния из бд, на случай если все упадет
PI
reader из кафки, ....думал про стимы от кафки, но оверхеад по-моему по сети гонять постоянно после каждого шага...
PI
да и тоже не уверен,что они подойдут
PI
я бы предложил инфлакс, но слава Богу, что он сдох
а ссылочку можно или название на англ,...хоть гляну, как можно было
PI
Нашел
PI
вроде живо еще
GG
это БД
