阿里云文档 2024-12-04

事件模式的定义及常用类型

事件模式是事件总线EventBridge用来过滤相关事件的模式定义。事件总线EventBridge通过事件模式过滤事件并将事件路由到事件目标,事件模式必须和匹配的事件具有相同的结构。本文介绍事件模式的常用类型。

问答 2024-08-13 来自:开发者社区

如何在vvp作业中定义Kafka作为数据源(Source)的临时表?

如何在vvp作业中定义Kafka作为数据源(Source)的临时表?

问答 2022-02-15 来自:开发者社区

flink1.11 DDL定义kafka source报错了怎么办?

错误信息: Exception in thread "main" java.lang.IllegalStateException: No operators defined in streaming topology. Cannot generate StreamGraph. at org.apache.flink.table.planner.utils.ExecutorUtils.genera....

问答 2022-02-15 来自:开发者社区

如何定义kafka生产者以及发送消息?

如何定义kafka生产者以及发送消息?

问答 2022-02-15 来自:开发者社区

直接使用ddl定义kafka数据源出现了问题怎么办?

大家好,我直接使用ddl定义kafka数据源出现了问题。 kafka里是logstash采上来的json格式数据。 ddl如下: CREATE TABLE vpn_source ( c_real_ip VARCHAR, d_real_ip VARCHAR, c_real_port INT, d_real_port INT, logtype INT, user VARCHAR, ...

问答 2022-02-15 来自:开发者社区

请问Flink1.10怎么样定义kafka中消息为json数组对象的情况呀?

网上有非常多的资料显示Flink SQL怎样定义嵌套的json属性以及json中某个属性为json数组的示例, 但是对于整个消息为一个数组(json array)的应该怎么处理? json示例如下: [ { "a": "1", "b": 2 } ]*来自志愿者整理的FLINK邮件归档

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

云消息队列

涵盖 RocketMQ、Kafka、RabbitMQ、MQTT、轻量消息队列(原MNS) 的消息队列产品体系,全系产品 Serverless 化。RocketMQ 一站式学习:https://rocketmq.io/

+关注