Hi,
I am exploring if we can plugin hbase as state backend in Flink. We have
need for streaming jobs with large window states, high throughput and
reliability.
I wanted to know if implementing Flink backend in Hbase or other
distributed KV store is possible. Any documentation or pointers will be
ArrayList<>();
ServiceLoader extendedParseStrategies =
ServiceLoader.load(ExtendedParseStrategy.class);
for (ExtendedParseStrategy extendedParseStrategy :
extendedParseStrategies) {
parseStrategies.add(extendedParseStrategy);
}
return parseStrategies;
}
Please share your thoughts.
Thanks,
Naveen Kumar