Hbase state backend in Flink

2018-12-27 Thread Naveen Kumar
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

[IMPROVEMENT] Using ServiceLoader to load ExtendedParseStrategy

2024-04-03 Thread Naveen Kumar
ArrayList<>(); ServiceLoader extendedParseStrategies = ServiceLoader.load(ExtendedParseStrategy.class); for (ExtendedParseStrategy extendedParseStrategy : extendedParseStrategies) { parseStrategies.add(extendedParseStrategy); } return parseStrategies; } Please share your thoughts. Thanks, Naveen Kumar