每一行记录转成RDD里面的一个元素 JavaRDD<String> data = jsc.textFile(args[0]); //将每条记录的每列切割出来，生成一个Tuple JavaRDD<Tuple3<String,String,Integer>> person = data

查看更多 →

该参数必须设置 jssc.checkpoint("checkpoint"); // 组装Kafka的主题列表 HashSet<String> topicsSet = new HashSet<String>(Arrays.asList(topics

查看更多 →

forName("org.apache.hive.jdbc.HiveDriver").newInstance(); 获取JDBC连接，执行HQL，输出查询的列名和结果到控制台，关闭JDBC连接。 在网络拥塞的情况下，您还可以设置客户端与JD BCS erver连接的超时时间，可以避免客户端由于无限等待服务端的返回而挂起。使用方式如下：

查看更多 →

key.serializer 消息Key值序列化类 指定消息Key值序列化方式。 value.serializer 消息序列化类 指定所发送消息的序列化方式。 表2 Producer重要接口函数 返回值类型 接口函数 描述 java.util.concurrent.Future<RecordMetadata>

查看更多 →

Oozie Java接口介绍 Java API主要由org.apache.oozie.client.OozieClient提供。 表1 接口介绍 方法 说明 public String run(Properties conf) 运行job public void start(String

查看更多 →

java.sql.PreparedStatement java.sql.PreparedStatement是预处理语句接口。 表1 对java.sql.PreparedStatement的支持情况 方法名 返回值类型 支持JDBC 4 clearParameters() void

查看更多 →

aryKeys(String catalog, String schema, String table)方法用于获取分区表含全局索引的主键列，使用示例如下： PgDatabaseMetaData dbmd = (PgDatabaseMetaData)conn.getMetaData();

查看更多 →

java.sql.PreparedStatement java.sql.PreparedStatement是预处理语句接口。 表1 对java.sql.PreparedStatement的支持情况 方法名 返回值类型 支持JDBC4 clearParameters() void Yes

查看更多 →

aryKeys(String catalog, String schema, String table)接口用于获取分区表含全局索引的主键列，使用示例如下： PgDatabaseMetaData dbmd = (PgDatabaseMetaData)conn.getMetaData();

查看更多 →

java.sql.Statement java.sql.Statement是SQL语句接口。 表1 对java.sql.Statement的支持情况 方法名 返回值类型 支持JDBC 4 addBatch(String sql) void Yes clearBatch() void

查看更多 →

使用SDK（Java） Java开发环境配置 SDK获取和安装 媒资图像标签示例 名人识别示例 主体识别示例 翻拍识别示例 图像标签示例

查看更多 →

使用SDK（Java） JAVA开发环境配置 JAVA语言SDK获取和安装 添加数据示例 更新数据示例 检查数据示例 搜索数据示例 删除数据示例

查看更多 →

aryKeys(String catalog, String schema, String table)接口用于获取分区表含全局索引的主键列，使用示例如下： PgDatabaseMetaData dbmd = (PgDatabaseMetaData)conn.getMetaData();

查看更多 →

具体操作请参考初始化 DLI 客户端 Java SDK列表 表1 Java SDK列表 类型 说明 OBS授权 介绍将OBS桶的操作权限授权给DLI的Java SDK使用说明。 队列相关 介绍创建队列、获取默认队列、查询所有队列、删除队列的Java SDK使用说明。 资源相关 介绍上

查看更多 →

搭建Java Web环境 镜像部署Java Web环境 基于Tomcat构建Java web环境（CentOS 7.4） 基于Tomcat构建Java web环境（Huawei Cloud EulerOS 2.0） 父主题： 搭建环境

查看更多 →

java.sql.PreparedStatement java.sql.PreparedStatement是预处理语句接口。 表1 对java.sql.PreparedStatement的支持情况 方法名 返回值类型 支持JDBC 4 clearParameters() void

查看更多 →

Java SDK介绍 SDK配置 通用方法 利用合约发送交易 利用合约查询数据 其他查询 父主题： SDK介绍

查看更多 →

使用SDK（Java） 准备环境 配置样例工程 初始化DIS客户端 创建通道 添加转储任务 更新转储任务 删除转储任务 查询转储列表 查询转储详情 删除通道 查询通道列表 查询通道详情 下载流式数据 上传流式数据 获取数据游标 创建APP 删除APP 新增Checkpoint 查询Checkpoint

查看更多 →

JAVA版SDK SDK获取和安装 1. 安装Java开发环境。 访问Java官网，下载并说明安装Java开发环境。 华为云Java SDK支持Java JDK 1.8 及其以上版本。 2. 使用eclipse/IDEA创建工程。 3. 下载ModuleSDK，并在工程中导入jar包。

查看更多 →

开始监控JAVA应用 Java语言支持增强型探针、OpenTelemetry和Skywalking。 快速接入Agent 为JAVA应用手工安装Agent 为部署在CCE容器中的JAVA应用安装Agent 为CodeArts Deploy应用安装Agent 为Docker应用安装Agent

查看更多 →

java样例代码 开发说明 本样例只适用于 MRS 的OpenTSDB。 前提条件 在DLI管理控制台上已完成创建跨源连接并绑定队列。具体操作请参考《 数据湖探索 用户指南》。 认证用的password硬编码到代码中或者明文存储都有很大的安全风险，建议在配置文件或者环境变量中密文存放，使用时解密，确保安全。

查看更多 →