Hi Team,

Could you please help in answering below questions


1)In the Capability matrix we could not find any points related to below
features but wanted to know how are features that are inherent to apache
beam supported when used with DirectRunner?Features
example:Checkpointing,stateful processing,Windowing/Watermarking,Fault
Tolerance,Back pressure Handling, Load Balancing etc.
2)Beam SQL -can you expedite the Jira ticket for supporting non-equi joins
(for e.g. greater than(>),lesser than(<) operator?
3)How soon can we get any performance-related metrics available for Beam in
comparison to flink or any other procession engine?
4)Does Beam have any native support for Kubernetes?
5)Is it possible to switch runners based on use-cases
For e.g. use FlinkRunner for most of the use-cases and use spark runner for
some specific use-cases? How can we achieve it ? How to implement
portability for pipelines?


Thanks
Azhar

Reply via email to