paimon
paimon copied to clipboard
Apache Paimon is a lake format that enables building a Realtime Lakehouse Architecture with Flink and Spark for both streaming and batch operations.
*(Please specify the module before the PR name: [core] ... or [flink] ...)* ### Purpose *add test case for CoreOptions.testCreateFileFormat method* ### Tests *org.apache.paimon.FileFormatTest#testCreateFileFormat* ### API and Format *(Does this...
### Search before asking - [X] I searched in the [issues](https://github.com/apache/incubator-paimon/issues) and found nothing similar. ### Motivation This metric monitors how busy the writer is, and if it is too...
### Purpose If the table has no input now, the bounded stream will never end. Because there is no check for full scan snapshot. We should fix this: Bounded Stream...
### Purpose To directly consume changes from Flink CDC connectors, we need a special CDC sink for Paimon. ### Tests * FlinkCdcSinkITCase ### API and Format N/A ### Documentation N/A
### Purpose To support time travel syntax of Spark 3.3 (VERSION AS OF and TIMESTAMP AS OF). ### Tests `SparkTimeTravelITCase` ### API and Format No changes. ### Documentation how-to#Time Travel
@https://github.com/apache/incubator-paimon/issues/667 ### Purpose This PR aims to introduce presto reader for paimon. ### Tests TestPrestoITCase ### API and Format No changes. ### Documentation engines#presto
*(Please specify the module before the PR name: [core] ... or [flink] ...)* ### Purpose *(What is the purpose of the change, or the associated issue)* this pr closes #636...
When can Doris connect with paimon catlog
Now after renaming, paimon should be compatibility to table store 0.3 hive metastore.