Stream API
Stream API是一种处理流式数据的方法。通过Stream API，您可以在边缘节点上处理流式数据，例如音频和视频。Stream API可以将流式数据分块传输，提高数据传输效率。ReadableStream 定义：ReadableStream的定义，请参见MDN官方文档 ...
Stream API
Stream API是一种处理流式数据的方法。通过Stream API，您可以在边缘节点上处理流式数据，例如音频和视频。Stream API可以将流式数据分块传输，提高数据传输效率。ReadableStream 定义：ReadableStream的定义，请参见MDN官方文档 ...
Stream API
Stream API是一种处理流式数据的方法。通过Stream API，您可以在边缘节点上处理流式数据，例如音频和视频。Stream API可以将流式数据分块传输，提高数据传输效率。ReadableStream 定义：ReadableStream的定义，请参见MDN官方文档 ...
DROP STREAM
语法 DROP STREAM[IF EXISTS][catalog_name.][database_name.]stream_name 参数说明 参数 是否必选 说明 catalog_name 否 流表的Catalog。database_name 否 流表所属的数据库。stream_name 是 流表的名称，用于唯一指定一个流表。示例 删除...
Stream Load
本文为您介绍Stream Load导入的基本原理、使用示例和最佳实践。背景信息 Stream Load是一种同步的导入方式，通过发送HTTP请求将本地文件或数据流导入到StarRocks中。Stream Load同步执行导入并返回导入结果。您可以直接通过请求的返回值...
CREATE STREAM
语法 CREATE STREAM[IF NOT EXISTS][catalog_name.][db_name.]stream_name({|<metadata_column_definition>}[,.n][][,.n])[COMMENT table_comment][WITH(key1=val1,key2=val2,.)]<physical_column_definition>:column_name column_type[]...
CREATE STREAM
创建一张数据流表，表示一个无界的事件集合。...示例 CREATE STREAM users_original(registertime bigint,gender varchar,regionid varchar,userid varchar)WITH(stream_topic='users',value_format='JSON',key_value='userid');
STREAM语句
EMR-3.23.0版本开始支持STREAM语法。背景信息 E-MapReduce支持SET和STREAM两种方法配置WriteStream参数，推荐使用STREAM方法配置WriteStream的必要参数，包括checkpointLocation、outputMode、triggerType和triggerIntervalMs。语法 CREATE...
Stream模型
本文介绍Stream模型的功能及使用说明。背景信息 Stream模型提供子任务生产和消费处理分离的可持续生产消费模式。Produce接口按指定频率持续运行生成一批次子任务信息进入队列，基于缓冲队列框架持续分发子任务给当前业务集群处理。处理分发...
DROP STREAM
删除数据流表。语法 DROP STREAM(IF EXISTS)table_name;参数 参数 是否必选 说明 table_name 是 数据流表的名称。示例 DROP STREAM users_original;
Stream Load
Stream Load同步执行导入并返回导入结果。您可以直接通过请求的返回体判断本次导入是否成功。本文为您介绍Stream Load导入的基本原理、基本操作、系统配置以及最佳实践。适用场景 Stream Load主要适用于导入本地文件或通过程序导入数据流中...
Stream Load
本文为您介绍Stream Load导入的基本原理、使用示例和最佳实践。背景信息 Stream Load是一种同步的导入方式，通过发送HTTP请求将本地文件或数据流导入到StarRocks中。Stream Load同步执行导入并返回导入结果。您可以直接通过请求的返回值...
Stream Load
本文介绍如何通过Stream Load导入数据至 云数据库 SelectDB 版 实例中。背景信息 Stream Load 是属于同步接口的导入方式，用户通过发送HTTP请求将本地文件或数据流导入到 云数据库 SelectDB 版 实例中。Stream load执行并返回导入结果，...
自定义Stream宏节点大小
您可以通过 stream-node-max-bytes 参数修改Stream中每个宏节点（Macro Node）能够占用的最大内存，或者通过 stream-node-max-entries 参数指定每个宏节点中可存储条目的最大数量。前提条件 实例的引擎版本为Redis 5.0或以上。实例的架构为...
自定义Stream宏节点大小
您可以通过 stream-node-max-bytes 参数修改Stream中每个宏节点（Macro Node）能够占用的最大内存，或者通过 stream-node-max-entries 参数指定每个宏节点中可存储条目的最大数量。前提条件 实例为 内存型 或 持久内存型。实例的架构为标准...
Tablestore Stream配置同步任务
Tablestore Stream插件主要用于导出Tablestore增量数据，本文将为您介绍如何通过Tablestore Stream配置同步任务。背景信息 Tablestore Stream插件与全量导出插件不同，增量导出插件仅支持多版本模式，且不支持指定列。增量数据可以看作操作...
Quick BI中SQL自定义数据集预览报错“RST_STREAM ...
问题描述 Quick BI中SQL自定义数据集预览时报错“null:INTERNAL:RST_STREAM closed stream.HTTP/2 error code: PROTOCOL_ERROR”。问题原因 对应的代码中是将ds设置为SQL参数，如下：FROM dwd_log_xcx_http_req_di WHERE ${to_date(ds,'...
新建Spark Stream类型的公共节点
Spark Stream节点是流式节点，运行于Spark云计算资源之上，支持对RDS MySQL、Table Store、Hive、Kafka、Hbase、Phoenix、AnalyticDB MySQL、AnalyticDB_PostgreSQL和DataHub等类型的数据进行处理。本文介绍如何新建Spark Stream类型的公共...
新建Spark Stream类型的公共节点
Spark Stream节点是流式节点，运行于Spark云计算资源之上，支持对RDS MySQL、Table Store、Hive、Kafka、Hbase、Phoenix、AnalyticDB MySQL、AnalyticDB_PostgreSQL和DataHub等类型的数据进行处理。本文介绍如何新建Spark Stream类型的公共...
新建Flink Vvp Stream类型的公共节点
Flink Vvp Stream节点是流式节点，运行于Flink云计算资源之上，支持对ApsaraDB for RDS、Table Store、Hive、Kafka、Hbase、Phoenix、AnalyticDB MySQL和DataHub Service等类型的数据进行处理。本文介绍如何新建Flink Vvp Stream类型的公共...
Quick BI中数据集预览报错"RST_STREAM closed stream....
问题描述 自定义SQL数据集查询可以查到数据，保存数据集正常，数据集预览报错"RST_STREAM closed stream.HTTP/2 error code: PROTOCOL_ERROR"。问题原因 新建计算字段语法存在问题。解决方案 修改计算字段的语法。适用于 Quick BI
新建Flink Vvr Stream类型的公共节点
Flink Vvr Stream节点是流式节点，运行于Flink云计算资源之上，支持对RDS MySQL、Table Store、Hive、Kafka、Hbase、Phoenix、AnalyticDB MySQL和DataHub等类型的数据进行处理。本文介绍如何新建Flink Vvr Stream类型的公共节点。背景信息 ...
TimeStream管理Elasticsearch时序数据快速入门
{"time_streams":{"test_stream":{"name":"test_stream","data_stream_name":"test_stream","time_stream_config":{"labels_fields":{"includes":["labels.*"],"excludes":[]},"metrics_fields":{"includes":["metrics.*"],"excludes":[]},...
TimeStream集成InfluxDB写协议接口
示例 请求示例 curl-i-user"user:password""http://xxx:9200/_time_stream/influx/write?db=test_stream" -d "testInflux,label1=label_value1 metric1=0.5"返回示例 HTTP/1.1 204 No Content 写入成功时，Response的body为空，http code为...
RST_STREAM closed stream....
问题描述 Quick BI通过SQL新建数据集报错“INTERNAL:RST_STREAM closed stream.HTTP/2 error code: PROTOCOL_ERROR”。问题原因 数据溢出，存在0/0的情况。解决方案 需要修改SQL，排查除数为零字段。适用于 Quick BI 说明：本文适用于公共...
INTERNAL:RST_STREAM closed stream....
问题描述 sql创建数据集报错："INTERNAL:RST_STREAM closed stream.HTTP/2 error code: PROTOCOL_ERROR"。问题原因 没有设置分区字段的过滤条件导致全表扫描报错的。解决方案 在数据集中，对分区的字段设置过滤条件即可。适用于 Quick BI
如何在CentOS Stream 8和CentOS 8中安装中文支持
本文介绍如何在CentOS Stream 8和CentOS 8中安装中文支持。CentOS 8操作系统版本结束了生命周期（EOL），按照社区规则，CentOS 8的源地址内容已移除。当您在CentOS 8系统内继续使用默认配置的源地址时会发生报错。建议您先切换CentOS 8的源...
视频直播创建直播录制...stream does not exist”错误
阿里云视频直播调用CreateLiveStreamRecordIndexFiles接口创建直播录制索引文件时，提示“Speicified stream does not exist”错误的原因是直播流不存在，请您确认直播流是否正确。详情请参见 创建直播录制索引文件。适用于 视频直播
使用通道服务消费...stream data is already trimmed or...
现象 使用通道服务消费数据时出现如下错误：[ErrorCode]:OTSTunnelServerUnavailable,[Message]:OTSTrimmedDataAccess Requested stream data is already trimmed or does not exist.原因 长时间未拉取数据，Stream日志过期。说明 Stream...
使用CDN后访问HTML页面返回...stream”导致变为下载页面
问题原因 请求在不通过CDN时，直接指定源站访问，发现源站响应的Response Headers未响应Content-Type，因此CDN会带上 Content-Type:application/octet-stream。解决方案 目前CDN响应Content-Type的策略如下：源站如果有响应Content-Type，...
Tablestore Stream数据源
DataWorks数据集成支持使用Tablestore Stream Reader读取Tablestore的增量数据，本文为您介绍DataWorks的Tablestore Stream数据读取能力。数据同步前准备：Tablestore Stream环境准备 使用Tablestore Stream插件前，您必须确保Tablestore表...
TimeStream集成Prometheus接口
配置前后缀关键字的示例如下：PUT_time_stream/{name} {"time_stream":{"labels_fields":"@labels.*_l","metrics_fields":"@metrics.*_m","label_prefix":"@labels.","label_suffix":"_l","metric_prefix":"@metrics.","metric_suffix":"_m...
新建Flink Vvp Stream类型的公共节点
Flink Vvp Stream节点是流式节点，运行于Flink云计算资源之上，支持对ApsaraDB for RDS、Table Store、Hive、Kafka、Hbase、Phoenix、AnalyticDB MySQL和DataHub Service等类型的数据进行处理。本文介绍如何新建Flink Vvp Stream类型的公共...
新建Flink Vvr Stream类型的公共节点
Flink Vvr Stream节点是流式节点，运行于Flink云计算资源之上，支持对RDS MySQL、Table Store、Hive、Kafka、Hbase、Phoenix、AnalyticDB MySQL和DataHub等类型的数据进行处理。本文介绍如何新建Flink Vvr Stream类型的公共节点。背景信息 ...
基于TimeStream对接Prometheus+Grafana实现可观测性
在 控制台 中，执行 PUT_time_stream/prom_index 命令，创建名称为 prom_index 的TimeStream索引。步骤二：下载并启动node_exporter node_exporter用于收集各种与硬件和内核相关的指标，并提供给Prometheus进行读取，详细信息请参见 node_...
Timestream模型限制
本文主要为您介绍Timestream模型的使用限制。限制项 说明 Name长度 最大值：100Byte Tag个数 最大值：12 Tag名字和值的总长度 最大值：500Byte Tag名 字符中不能包含等号（=）Attribute名“h”、“n”、“s”、“t”为保留字段$...
- 产品推荐
- 这些文档可能帮助您