Skip to content

Better organize eventutilties_python modules

Ottomata requested to merge T336488_ga_refactor into main

This commit mostly just moves some code and modules around for better organization, but there are some functional changes.

  • stream manager related code now lives in the 'stream' module.

  • stream module exports public symboles using all and init.py Users should import stream manager symbols like: from eventutilities_python.stream import stream_manager, load_config, etc.

  • Stream.close has been removed from the interface. Closing is handled by stream_manager.

  • flink.py should contain only contain Flink specific things. As such, EventStreamDescriptor has been removed (importing it would cause a circular import). This lower level APIs use stream_name and schema_version, similar to the Java interface. If we want to make EventStreamDescriptor a top level Java interface, we can. Or use and wrap java EventStream class instead.

Bug: T336488

Merge request reports