Steven Zhen Wu

API: add Histogram metric type

1

@rdblue here is the metrics PR. As we discussed, Flink Iceberg sink would need Gauge (e.g. last commit duration) and Histogram (e.g. file size distribution) metrics. cc @danielcweeks @nastra for...

Implements the Flink source based on the new FLIP-27 interface

7

Flink 1.11 release included a new source interface ([FLIP-27](https://cwiki.apache.org/confluence/display/FLINK/FLIP-27%3A+Refactor+Source+Interface)) that works better with Iceberg It has two logical components - A split enumerator that runs on the jobmanager (driver) -...

replaced with link to Java implementation and note for additional context.

issue #9597 Java implementation only adds serialization for `StaticDataTask`. Other task types should be added in a follow-up PR , which is ready in my fork. with the additional parsers,...

## Feature request **Is your feature request related to a problem? Please describe.** Just like SQL is everywhere, Python is widely used in the big data and ML community. In...

This can happen in the FileIOParser serialization and deserialization scenario. FileIOParser doesn't serialize and deserialize the Hadoop configuration. the deserialized io object is not valid because hadoopConf is null. NPE...