Hi,

I am trying to implement a custom range partitioner in the Flink Iceberg
sink. Want to publish some counter metrics for certain scenarios. This is
like the network metrics exposed in `TaskIOMetricGroup`.

This requires adding a new setup method to the custom `Partitioner`
interface. Like to get feedback from the community. More details can be
found in the jira issue [1].

Thanks,
Steven

[1] https://issues.apache.org/jira/browse/FLINK-35384

Reply via email to