本文使用的MapReduce样例程序的代码已上传至: https://github.com/BCEBIGDATA/bmr-sample-java ,您可通过GitHub克隆代码至本地设计自己的程序。 编译程序生成jar包,具体可参考编译Maven项目。 上传编译生成的jar包到对象存储BOS(具体操作详见 对象存储BOS入门指南 )。
1.2 作业程序 1.2.1 查询tsdb的通用作业程序 Main class: package com.baidu.cloud.bmr.spark; import org.apache.spark.SparkConf; import org.apache.spark.api.java.JavaSparkContext; import org.apache.spark.sql.Dataset; import
Step(作业) 概述 作业是和集群相关联的资源,对作业的操作需要指定相关集群的ID。 添加steps BMR支持多种类型的作业,不同类型的作业有不同的配置项。如下代码可向指定的hadoop类型的集群添加Custom Jar、Streaming、Hive、Pig作业。 添加作业可以通过配置AddStepsRequest对象的clientToken属性来保证创建请求的幂等性。
ProducerConfig ; import java . time . Duration ; import java . util . Collections ; import java . util .
支持通过Python SDK、Go SDK、Java SDK和Node.js SDK调用,调用流程请查看 SDK安装及使用流程 。 SDK调用 调用示例 指定支持预置服务的模型 使用 model 字段,指定平台支持预置服务的模型,调用示例如下。
JSONObject ; import java . io . BufferedReader ; import java . io . InputStreamReader ; import java . net . HttpURLConnection ; import java . net . URL ; import java . util .
操作方式 您可以通过 Console 控制台、 SDK 和 API 查看 Bucket 列表,具体如下: 通过控制台查看 Bucket 列表: 登录 对象存储 BOS 管理控制台 。 您可以在控制台页面左侧“存储管理”查看拥有的 Bucket。
背景信息 升级检查操作入口,在 百度智能云 Elasticsearch 控制台- 集群详情 ,单击版本升级。版本升级操作步骤详见 版本升级 。 本文的命令都可在Kibana控制台上执行,关于如何登录Kibana控制台,请参见 Kibana使用指南 。 注意: 需特别留意本文中需要人工检查的部分(无法自动检查),并在升级前完成代码兼容性改造,避免升级后造成集群无法正常访问。
JSONObject ; import java . io . BufferedReader ; import java . io . InputStreamReader ; import java . net . HttpURLConnection ; import java . net . URL ; import java . util .
和crypto-config的路径 下载fabric-sdk-java所需依赖,使用maven可以自动下载相关依赖 编写链码调用程序,可参考(demo/java-sdk/src/main/java/com/fabric/example/main.go) 3、NodeJs sdk 根据实际应用,修改sdk_config.yaml和crypto-config路径 下载fabric-sdk-nodejs所需依赖