Hi I am evaluating flink with use case where we need to create a basic flink pipeline, and inject the classes for map, reduce, process, etc via some xml configuration (or something equivalent). Eg:
stream.keyBy(value -> value.getKey()) .window(TumblingProcessingWindow.of(Time.miuntes(1))) .process(new MyInjectedClass()); Is something like this possible, where a developer can just write MyInjectedClass, and configure it without writing code in flink app? The developer needs to write just the process class, and specify which step in pipeline to inject the class.
