Devlive 开源社区 本次搜索耗时 0.617 秒,为您找到 1079 个相关结果.
  • 参数传递

    参数的引用 本地任务引用全局参数 上游任务传递给下游任务 任务样例 创建 SHELL 任务并设置参数 创建 SQL 任务并使用参数 保存工作流并设置全局参数 查看运行结果 Python 任务传递参数 SubProcess 任务传递参数 Kubernetes 任务传递参数 参数的引用 DolphinScheduler 提供参数间相互引...
  • What is Apache StreamPark™

    Apache StreamPark™ 🚀 What is Apache StreamPark™ Why Apache StreamPark™? 🎉 Features 🏳‍🌈 Architecture of Apache StreamPark™ 1️⃣ streampark-core 2️⃣ streampark-console Apache...
  • Spark Quick Start

    6202 2024-06-28 《Apache Hudi 0.15.0》
    Setup Spark 3 Support Matrix Spark Shell/SQL Setup project Create Table Insert data Query data Update data Merging Data Delete data Time Travel Query Incremental query ...
  • Redis Connector

    Redis Write Dependency Writing Redis the Regular Way 1.Access to source 2. Write to redis Apache StreamPark™ Writes to Redis 1. Configure policy and connection information 2. ...
  • 数据质量

    概述 任务类型介绍 注意事项 检查逻辑详解 任务操作指南 单表检查之空值检查 检查介绍 界面操作指南 单表检查之及时性检查 检查介绍 界面操作指南 单表检查之字段长度校验 检查介绍 界面操作指南 单表检查之唯一性校验 检查介绍 界面操作指南 单表检查之正则表达式校验 检查介绍 界面操作指南 单表检查之枚举值校验 检查介绍...
  • Replication

    6124 2024-06-22 《Apache Accumulo 2.x》
    Overview Configuration Site Configuration Instance Configuration Table Configuration Monitoring Work Assignment ReplicaSystems AccumuloReplicaSystem Other Configuration E...
  • Writing Tables

    6071 2024-07-01 《Apache Hudi 0.15.0》
    What are some ways to write a Hudi table? How is a Hudi writer job deployed? Can I implement my own logic for how input records are merged with record on storage? How do I delet...
  • Introduction

    6050 2024-06-24 《Apache Amoro 0.6.1》
    Architecture Supported table formats Supported engines Iceberg format Paimon format Mixed format User cases Self-managed streaming Lakehouse Stream-and-batch-fused data pipe...
  • 编程模型

    架构 编程模型 DataStream Flink Sql TableEnvironment StreamTableEnvironment RunTime Context StreamingContext TableContext StreamTableContext 生命周期 生命周期之 — init 生命周期之 — config 生...
  • Quick Start

    Quick Start Configure FLINK_HOME Configure Flink Cluster Start Flink Standalone Session on Server Configure Flink Cluster Create Job Main Parameters Create Job Save Job Bui...