paimon
paimon copied to clipboard
[FLINK-31190] Supports Spark call procedure command on Table Store
At present Hudi and Iceberg supports the Spark call procedure command to execute the table service action etc. Flink Table Store could also support Spark call procedure command to run compaction etc.
The brief change log
- Introduces
TableStoreSparkSessionExtensionsto extends the syntax and adds the rules ofSparkSessionExtensions, including the CALL statement.
Wow~ Thanks @SteNicholas for your contribution!
Can we just implement a CALL procedure for validation?
Maybe we can create a DropPartition procedure.