[Feature Request]: Ability to register translators with Flink Runners
- Dominant language
- Java
- Stars
- 8.7k
- Forks
- 4.7k
- Avg merge
- 1d 20h
- Merged PRs (30d)
- 196
Description
### What would you like to happen?
Currently the implementation for FlinkRunner is in a manner that it doesn't allow adding new translators from outside of the class **FlinkStreamingTransformTranslators**. There is a private TRANSLATORS hashmap which cannot be accessed outside of the class and the class doesn't expose any method to add a translator to that hashmap. This restricts the ability to add some custom translator to Flink runner unless someone makes changes to FlinkStreamingTransformTranslators class.
Other runners has exposed some methods or Registrars for this usecase:
- Dataflow runner has **DataflowPipelineTranslator.registerTransformTranslator()**
- SamzaRunner offers **SamzaTranslatorRegistrar** which allows registering translators.
Can we have expose some methods in Flink Runner which gives this functionality or is there a particular reason Flink Runner has been implemented in such a way ?
### Issue Priority
Priority: 2 (default / most feature requests should be filed as P2)
### Issue Components
- [ ] Component: Python SDK
- [ ] Component: Java SDK
- [ ] Component: Go SDK
- [ ] Component: Typescript SDK
- [ ] Component: IO connector
- [ ] Component: Beam examples
- [ ] Component: Beam playground
- [ ] Component: Beam katas
- [ ] Component: Website
- [ ] Component: Spark Runner
- [X] Component: Flink Runner
- [ ] Component: Samza Runner
- [ ] Component: Twister2 Runner
- [ ] Component: Hazelcast Jet Runner
- [ ] Component: Google Cloud Dataflow Runner
Contributor guide
Assessment
This issue has not been assessed yet.