检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
LoggerFactory; import java.util.Properties; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Future; import java.util.concurrent
2019-10-08 第二十三次正式发布： 优化Java和Python SDK。 2019-07-08 第二十次正式发布： 小文件功能下线，删除“创建源数据类型是FILE的通道”。 2019-07-03 第十九次正式发布： Java SDK不兼容原生Kafka客户端，删除“连接Kafka
LoggerFactory; import java.util.Properties; import java.util.concurrent.CountDownLatch; import java.util.concurrent.Future; import java.util.concurrent
v2.*; import com.huaweicloud.sdk.dis.v2.model.*; import java.util.List; import java.util.ArrayList; public class BatchDeleteTagsSolution {
v2.*; import com.huaweicloud.sdk.dis.v2.model.*; import java.util.List; import java.util.ArrayList; public class ListResourcesByTagsSolution
v2.*; import com.huaweicloud.sdk.dis.v2.model.*; import java.util.List; import java.util.ArrayList; public class BatchCreateTagsSolution {
v2.*; import com.huaweicloud.sdk.dis.v2.model.*; import java.util.List; import java.util.ArrayList; public class SendRecordsSolution {
失败。 显示类似如下信息，表示Agent启动成功。 Success to start DIS Agent [xxxxx]. 如果启动出现java变量找不到的情况，执行source /etc/profile后重新启动Agent。 Windows服务器上启动DIS Agent 进入DIS
样例工程为准备DIS应用开发环境中下载的“huaweicloud-sdk-dis-java-X.X.X.zip ”压缩包“\dis-sdk-demo\src\main\java\com\bigdata\dis\sdk\demo”路径下的“ProducerDemo.java”文件。 根据实际情况更改“AK”、“SK”和“ProjectId”的值。
配置为true或者false，默认值是false。 sort_columns：指定索引列，多级索引列用“，”分隔。 sort_scope：加载时，数据排序的范围。目前支持如下几种： local_sort：默认值，表示在一个node下做数据排序； no_sort：即不排序，在需要快
Insight，简称DLI）。 服务维护 负责服务的安装、升级。 负责服务的配置、巡检、日志收集与分析、运行监控。 负责服务工单处理。 用户SDK 提供Java接口，供用户上传与下载数据。 提供数据加密功能。 关键能力 无限扩展：DIS数据通道的吞吐量每小时可从数MB扩展到数TB，PUT记录每秒钟可从数千次扩展到数百万。
应用程序：一个DIS应用程序是读取和处理来自DIS数据通道的使用者。您可以使用客户端库（SDK）构建DIS应用程序。 客户端库：SDK是一个适用于Java的客户端库，帮助用户轻松构建DIS应用程序，用以读取和处理来自DIS数据通道的数据。 Project：用于将OpenStack的资源（计
IOT分析应用 通过在车载设备中集成IoTDA，并配置数据转发到DIS，实时上传车辆状态、监控数据，采用云上数据分析系统进行实时分析、检测，动态掌握设备状况，实现汽车故障提前感知。 图4 场景示例图
在左侧文本框中输入JSON或者CSV格式的源数据样例，也可单击导入源数据样例。例如： 导入源数据样例时，仅支持导入“.txt”,“.json”,“.csv”和“.java”的文件格式。 左侧文本框中单击，可在右侧文本框中根据源数据样例生成Avro schema。例如： 右侧文本框中单击，可修改已生成的Avro
值）。 响应参数 无 请求示例 删除App DELETE https://{Endpoint}/v2/{project_id}/apps/{app_name} 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6
删除转储任务 DELETE https://{Endpoint}/v2/{project_id}/streams/{stream_name}/transfer-tasks/{task_name} 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多
响应参数 无 请求示例 删除指定通道 DELETE https://{Endpoint}/v2/{project_id}/streams/{stream_name} 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5
commit_checkpoint_stream_names Array of strings 关联通道列表。 请求示例 查询App详情 GET https://{Endpoint}/v2/{project_id}/apps/{app_name} 响应示例 状态码： 200 正常返回 {
响应参数 无 请求示例 删除Checkpoint DELETE https://{Endpoint}/v2/{project_id}/checkpoints 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 1 2 3 4 5 6
无 请求示例 创建消费App POST https://{Endpoint}/v2/{project_id}/apps { "app_name" : "newapp" } 响应示例 无 SDK代码示例 SDK代码示例如下。 Java Python Go 更多 创建消费App
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
