检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
在Windows环境调测程序请参考在Windows中调测程序。 在Linux环境调测程序请参考在Linux调测程序。 父主题： 调测Kafka应用
情况 应用场景 MRS离线处理集群，可对海量数据进行分析和处理，形成结果数据，供下一步数据应用使用。 离线处理对处理时间要求不高，但是所处理数据量较大，占用计算存储资源较多，通常通过Hive/SparkSQL引擎或者MapReduce/Spark2x实现。 本实践基于华为云Map
2 streams 2 is 2 running 1 test 3 end 1 父主题： 调测Kafka应用
流程文件名 start 流程开始节点 end 流程结束节点 action 实现具体业务动作的节点（可以是多个） 样例代码 <workflow-app xmlns="uri:oozie:workflow:1.0" name="data_load"> <start to="copyData"/>
2"> <action> <workflow> <app-path>${workflowAppUri}</app-path> <configuration> <property>
修改HBase表 功能简介 HBase通过org.apache.hadoop.hbase.client.Admin的modifyTable方法修改表信息。 代码样例 以下代码片段在com.huawei.bigdata.hbase.examples包的“HBaseSample”类的testModifyTable方法中
创建Phoenix表 功能简介 Phoenix依赖HBase作为其后备存储，支持标准SQL和JDBC API的强大功能，使得SQL用户可以访问HBase集群。 代码样例 以下代码片段在com.huawei.bigdata.hbase.examples包的“PhoenixSampl
//设置文件压缩方式，HBase默认提供了GZ和SNAPPY两种压缩算法 //其中GZ的压缩率高，但压缩和解压性能低，适用于冷数据 //SNAPPY压缩率低，但压缩解压性能高，适用于热数据 //建议默认开启SNAPPY压缩 hcd.setCompressionType(Compression
2"> <action> <workflow> <app-path>${workflowAppUri}</app-path> <configuration> <property>
Flink引入了第三方软件包RocksDB的缺陷问题导致该现象的发生。建议用户将checkpoint设置为FsStateBackend方式。 用户需要在应用代码中将checkpoint设置为FsStateBackend。例如： env.setStateBackend(new FsStateB
执行如下命令。 storm list 如果可以正常打印出storm集群正在运行的任务信息，则说明客户端安装成功。 父主题： 准备Storm应用开发环境
在Linux环境中调测Hive JDBC样例程序 Hive JDBC应用程序支持在安装Hive客户端的Linux环境中运行。在程序代码完成开发后，您可以上传Jar包至准备好的Linux运行环境中运行。 前提条件 已安装Hive客户端。 当客户端所在主机不是集群中的节点时，需要在客
+ clusterName; util.exeSql(createDbSql); } 父主题： 开发ClickHouse应用
collector.putInt(row.getTime(), -row.getInt(0)); } } 父主题： 开发IoTDB应用
collector.putInt(row.getTime(), -row.getInt(0)); } } 父主题： 开发IoTDB应用
SparkStreaming批量写入HBase表 场景说明 用户可以在Spark应用程序中使用HBaseContext的方式去操作HBase，使用streamBulkPut接口将流数据写入Hbase表中。 数据规划 在客户端执行hbase shell进入HBase命令行。 在HB
camelcase | +------------------+ Returned 4 row(s) in 0.54s 父主题： 开发Impala应用
camelcase | +------------------+ Returned 4 row(s) in 0.54s 父主题： 开发Impala应用
获取结果并输出 for result in cursor.fetchall(): print(result) 父主题： 开发Hive应用
Start Action 功能描述 流程任务的执行入口，每个流程任务有且仅有一个该节点。 参数解释 Start Action节点中包含的各参数及其含义，请参见表1。 表1 参数含义 参数 含义 to 后继action节点的名称 样例代码 <start to="mr-dataLoad"/>
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
