Flink Apache Iceberg supports both Apache Flink ‘s DataStream API and Table API. See the Multi-Engine Support page for the integration of Apache Flink. Feature support Flink...
Catalogs configuration Using Mixed-Format in a standalone catalog Using Mixed-Format in session catalog The high availability configuration Catalogs configuration Using Mixe...
_.countBy(collection, [iteratee=_.identity]) Since Arguments Returns Example _.every(collection, [predicate=_.identity]) Since Arguments Returns Example _.filter(collec...
Incremental collection Use in single connections Change incremental collection mode in session Typically, when a user submits a SELECT query to Spark SQL engine, the Driver cal...
Below are properties set in accumulo-client.properties that configure Accumulo clients . All properties have been part of the API since 2.0.0 (unless otherwise specified): Pr...
_.chunk(array, [size=1]) Since Arguments Returns Example _.compact(array) Since Arguments Returns Example _.concat(array, [values]) Since Arguments Returns Example ...
XML MetaData Annotations All variants of JDO support specification of persistence using XML MetaData. JDO 2.1+ adds on the ability to specify persistence using Java annotations....
Spark DataSource API Daft Spark DataSource API The hudi-spark module offers the DataSource API to read a Hudi table into a Spark DataFrame. A time-travel query example: val ...