简介 Apache Dubbo 是一个款微服务开发框架,它提供了 RPC通信 与 微服务治理 两大关键能力。这意味...[作者空间]
简介 TubeMQ 是腾讯在 2013 年自研的分布式消息中间件系统,专注服务大数据场景下海量数据的高性能存储和传...[作者空间]
延迟任务是啥 我们把需要延迟执行的任务叫做延迟任务。也就是说当发生某个事件之后或者之前的某个特定的时间点执行的一系...[作者空间]
概述 Kafka Connect 是一款可扩展并且可靠地在 Apache Kafka 和其他系统之间进行数据传输的...[作者空间]
简介 Apache Calcite是一个动态数据管理框架。它包含了许多组成典型数据管理系统的经典模块,但省略了一些...[作者空间]
TableSource提供对存储在外部系统,例如数据库,键值存储,消息队列或文件中的数据的访问。TableSink...[作者空间]
当任务失败时,Flink需要重新启动失败的任务和其他受影响的任务,以将作业恢复到正常状态。 重新启动策略和故障转移...[作者空间]
用户自定义的函数是一个重要的特性,因为它们展示扩展了查询的表达能力。 注册用户自定义的函数 在大多数情况下,必须先...[作者空间]
动态表 数据流上的关系查询 下表比较了传统的关系型数据库和流处理在输入数据、执行和输出结果方面的不同。 SQL流处...[作者空间]
服务器信息 IPhostname1.1.1.1hostname12.2.2.2hostname23.3.3.3ho...[作者空间]
状态 状态性的函数和操作通过处理单个(元素/事件)存储数据,使任何类型的state可以构建更复杂的操作。flink...[作者空间]
时间概念 Flink在流程序中支持三种时间概念: 处理时间(Processing Time):处理时间是指执行相应...[作者空间]
DataStream API DataSet API Table API & SQL 数据类型 有六种不同类别的数...[作者空间]
数据流编程模型 抽象层次 Flink提供不同级别的抽象来开发流/批处理应用程序。 stateful streami...[作者空间]
架构 Apache Flink是一个框架和分布式处理引擎,用于对无界和有界数据流进行有状态计算。Flink设计为在...[作者空间]
CREATE INSERT INTO SELECT ALTER ALTER查询仅支持* MergeTree族表引擎...[作者空间]
简介 Graphite是一种企业级监控工具。Graphite由三个组件组成:carbon - 一种侦听时间序列数据...[作者空间]
表引擎 对于大多数正式的任务,应该使用MergeTree族中的引擎。Clickhouse 中最强大的表引擎当属 M...[作者空间]
可以通过两种方式监控clickhouse: 监控硬件资源 ClickHouse服务器指标 监控硬件 监控服务器的处...[作者空间]
整型有符号整型:Int8, Int16, Int32, Int64无符号整型:UInt8, UInt16, UIn...[作者空间]