-
Query based
Introduction Constructs QueryBasedSource QueryBasedExtractor build readRecord Configuration Introduction QueryBasedSource represents a category of sources whose data... -
Hive Distcp
Introduction Configure Hive Distcp Job Source and target metastores Database and tables to copy Target path computation Conflicting table and partitions treatment Deregisterin... -
Gobblin Modules
Introduction How it works gobblin-modules/ Gobblin flavor Current flavors and modules What’s next Introduction Gobblin-modules is a way to support customization of the gobb... -
Distributed publish/subscribe
Topic Java RTopic object implements Publish / Subscribe mechanism based on Redis Pub/Sub or Valkey Pub/Sub . It allows to subscribe on events published with multiple instances o... -
Transactions
Transactions management RMap , RMapCache , RLocalCachedMap , RSet , RSetCache and RBucket Redisson objects may participant in Transaction with ACID properties. It uses locks for... -
Queries
Spark Queries To use Iceberg in Spark, first configure Spark catalogs . Iceberg uses Apache Spark’s DataSourceV2 API for data source and catalog implementations. Querying with S... -
Tailwind CSS 动画和过渡效果
在现代 Web 应用中，合理使用动画和过渡效果可以大大提升用户体验。Tailwind CSS 提供了丰富的动画和过渡工具类，让我们能够轻松实现各种交互效果。本节将详细介绍如何在项目中运用这些特性。 过渡效果基础 基础过渡属性 Tailwind CSS 提供了几个核心的过渡工具类： <button class = "transition-all d... -
Daft
Daft Daft is a distributed query engine written in Python and Rust, two fast-growing ecosystems in the data engineering and machine learning industry. It exposes its flavor of t... -
Commands mapping
Redis or Valkey command Sync / Async APIRedisson.create(config) Reactive APIredisson.reactive() RxJava3 APIredisson.rxJava() AUTH Config.setPassword() - - APPEND ... -
gRPC Protocol
gRPC Protocol gRPC Consumer Stream Consumer Webhook Consumer gRPC Producer Asynchronous Producer Synchronous Producer Batch Producer gRPC Protocol EventMesh SDK for Java ...
