Apache Flink

Looking for guidance on my code to extend `BucketAssigner` so we can allow users to partition data on Kafka event time or Flink processing time.

Seeing `The implementation of the BulkFormatBuilder is not serializable. The object probably contains or references non serializable fields.`

Untitled.cpp

using `DateTimeBucketAssigner("'year='yyyy/'month='M/'day='d")` seems to satisfy my requirement for how the data is partitioned but i want to be able to choose either the Kafka *event time* or the Flink *processing time* (when the Kafka event reaches Flink) as the timestamp for the partitioning

<@U03GGB2FH8W>, wonder if you might take a look? saw a response from you related to BucketAssigner when i searched Slack