rce/mongo/* 通过控制台提交作业请参考《 数据湖探索 用户指南》中的“选择依赖资源参数说明”表说明 通过API提交作业请参考《 数据湖 探索API参考》>《创建批处理作业》中“表2-请求参数说明”关于“modules”参数的说明。 完整示例代码 1 2 3 4 5 6

查看更多 →

return femaleInfo; } }); // 注册表。 DataFrame schemaFemaleInfo = sqlContext.createDataFrame(femaleInfoJavaRDD

查看更多 →

Java样例代码 功能介绍 在Spark应用中，通过使用Spark调用Hive接口来操作hive表，然后把Hive表的数据经过分析后写到HBase表。 代码样例 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.spark.examples.SparkHivetoHbase

查看更多 →

Java样例代码 功能介绍 在Spark应用中，通过使用Streaming调用kafka接口来获取数据,然后把数据经过分析后，找到对应的HBase表记录，再写到HBase表。 代码样例 下面代码片段仅为演示，具体代码参见：com.huawei.bigdata.spark.examples

查看更多 →

.appName("SecurityKafkaWordCount") .getOrCreate(); //创建表示来自kafka的输入行流的DataSet。 Dataset<String> lines = spark .readStream()

查看更多 →

java.sql.DatabaseMetaData java.sql.DatabaseMetaData是数据库对象定义接口。 表1 对java.sql.DatabaseMetaData的支持情况 方法名 返回值类型 支持JDBC4 allProceduresAreCallable()

查看更多 →

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

查看更多 →

java.sql.CallableStatement java.sql.CallableStatement是存储过程执行接口。 表1 对java.sql.CallableStatement的支持情况 方法名 返回值类型 支持JDBC 4 getArray(int parameterIndex)

查看更多 →

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

查看更多 →

'[operation]'); action表明操作动作，值可以为： ls表示查看数据库中jar包，会对各节点的文件进行MD5值一致性检查。 addjar表示将OBS 服务器 中的jar包部署到数据库中。 rmjar表示将数据库中的jar包删除。 operation表明操作字符串，格式为： obs

查看更多 →

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

查看更多 →

java.sql.DatabaseMetaData java.sql.DatabaseMetaData是数据库对象定义接口。 表1 对java.sql.DatabaseMetaData的支持情况 方法名 返回值类型 支持JDBC 4 getTables(String catalog

查看更多 →

也可以根据业务自行定制重试策略。 Session会话。 正常情况下，session和keyspace是不绑定的，所以在查询的时候是需要指定表的keyspace的，如下所示： Session session = cluster.connect(); session.execute("select

查看更多 →

使用SDK（Java） Java开发环境配置 SDK获取和安装 SDK调用示例

查看更多 →

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

查看更多 →

import java.security.InvalidKeyException; import java.security.NoSuchAlgorithmException; import java.security.SecureRandom; import java.util.HashMap;

查看更多 →

java.sql.CallableStatement java.sql.CallableStatement是存储过程执行接口。 表1 对java.sql.CallableStatement的支持情况 方法名 返回值类型 支持JDBC 4 getArray(int parameterIndex)

查看更多 →

ource/css/* 通过控制台提交作业请参考《数据湖探索用户指南》中的“选择依赖资源参数说明”表说明 通过API提交作业请参考《数据湖探索API参考》>《创建批处理作业》中“表2-请求参数说明”关于“modules”参数的说明。 完整示例代码 Maven依赖 <dependency>

查看更多 →

'[operation]'); action表明操作动作，值可以为： ls表示查看数据库中jar包，会对各节点的文件进行MD5值一致性检查。 addjar表示将OBS服务器中的jar包部署到数据库中。 rmjar表示将数据库中的jar包删除。 operation表明操作字符串，格式为： obs

查看更多 →

java.sql.CallableStatement java.sql.CallableStatement是存储过程执行接口。 表1 对java.sql.CallableStatement的支持情况 方法名 返回值类型 支持JDBC 4 registerOutParameter(int

查看更多 →