Skip to content

Some slight parameter refactorization

Ottomata requested to merge refactor0 into main

  • EventDataStreamFactory extends pyflink JavaFunctionWrapper This will allow us to make EventDataStreamFactory more closely work like other Flink Java wrappers, and help us get the API a little cleaner.

  • EventDataStreamFactory no longer keeps a reference to StreamExecutionEnvironment. Its close() method has been removed.

  • Global os.environ reading for things like STREAM_CONFIG_URI has been removed. These are still used as they were before, but they aren't set with any defaults until used in stream_manager. Future improvement will also refactor this.

Still a lot of TODOs around parameterization, but this is a first step.

Merge request reports