Introduction Support Those Engines API Event Data API Event Listener API Event Collect API Configuration Listener Zeta Engine Flink Engine Spark Engine Introduction The...
Metrics This feature is available only in Redisson PRO Monitoring systems integration Redisson provides integration the most popular monitoring systems through Micrometer fram...
Set Flink configuration information in the job How to set up a simple Flink job How to run a job in a project Flink is a powerful high-performance distributed stream processing...
Spark Writes To use Iceberg in Spark, first configure Spark catalogs . Some plans are only available when using Iceberg SQL extensions in Spark 3. Iceberg uses Apache Spark’s D...
Object holder Java implementation of Redis or Valkey based RBucket object is a holder for any type of object. Size is limited to 512Mb. Code example: RBucket < AnyObject > buc...
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...
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 ...
Spark Structured Streaming Iceberg uses Apache Spark’s DataSourceV2 API for data source and catalog implementations. Spark DSv2 is an evolving API with different levels of support...