Hi team, Language: Python (pyflink) Is it possible to write to different files (StreamingFileSink) based on some meta data like table_name or event_type in incoming data stream? As per this doc: https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/connectors/datastream/filesystem/#bucket-assignment pyflink only supports

DateTimeBucketAssigner

and

BasePathBucketAssigner

Is it not possible to write custom bucket assigner in python? or is there any better way to do this?