检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
统各自的客户端配置文件,可实现一次认证登录后访问调用多集群的HBase服务。 以下代码在hbase-example样例工程的“com.huawei.bigdata.hbase.examples”包的“TestMultipleLogin”类中。 代码认证 List<String>
string, company string); INSERT INTO TABLE info values(001,'jack','huawei'); SELECT * FROM info; beeline 调用Spark的JDBCServer执行Spark SQL,可以实现对
例) bin/spark-submit --master yarn --deploy-mode client --class com.huawei.bigdata.spark.examples.hbasecontext.JavaHBaseBulkGetExample SparkOnHbaseJavaExample
keytab方式下,若用户修改了keytab文件名,如修改为“huawei.keytab”,则需要在命令中增加第二个参数进行说明,提交命令示例(拓扑名为hdfs-test): storm jar /opt/jartarget/source.jar com.huawei.storm.example.hdfs
OME/HBase/hbase”,执行以下命令运行Jar包。 hbase com.huawei.bigdata.hbase.examples.TestMain 其中,hbase com.huawei.bigdata.hbase.examples.TestMain为举例,具体以实际样例代码为准。
例) bin/spark-submit --master yarn --deploy-mode client --class com.huawei.bigdata.spark.examples.hbasecontext.JavaHBaseMapPartitionExample S
例) bin/spark-submit --master yarn --deploy-mode client --class com.huawei.bigdata.spark.examples.hbasecontext.JavaHBaseBulkPutExample SparkOnHbaseJavaExample-1
HNAME>' 例如,注册名称为“example”的UDF的命令为: CREATE FUNCTION example AS 'com.huawei.bigdata.iotdb.UDTFExample' 父主题: 在IoTDBServer节点调测UDF应用
本例使用multiSplit进行多点分割将HBase表按照“A~D”、“D~F”、“F~H”、“H~Z”分为四个Region。 代码样例 以下代码片段在com.huawei.bigdata.hbase.examples包的“HBaseExample”类的testMultiSplit方法中 public void
t”到“row_stop”的范围,字段“f3:age”的值为“25”,rowkey的前两个字符为“mi”的行数。 hbase com.huawei.hadoop.hbase.tools.bulkload.RowCounter -Dcounter.rowkey.start="row_start"
10.0/bin”,执行命令:storm jar /opt/jartarget/storm-examples-1.0.jar com.huawei.storm.example.wordcount.WordCountTopology。 执行storm list命令,查看已经提交的应
下载工程后选择文件夹“presto-examples”。Windows下要求该文件夹的完整路径不包含空格。 单击“Finish”。 导入成功后,com.huawei.bigdata.presto.example包下的HCatalogExample类,为HCatalog接口样例代码。 设置Eclip
运行Consumer样例工程的命令如下。 java -cp /opt/client/lib/*:/opt/client/src/main/resources com.huawei.bigdata.kafka.example.Consumer 父主题: 调测Kafka应用
执行如下命令更新从“row_start”到“row_stop”的行,并且把输出结果定向到“/output/destdir/”。 hbase com.huawei.hadoop.hbase.tools.bulkload.UpdateData -Dupdate.rowkey.start="row_start"
Windows下要求该文件夹的完整路径不包含空格。 图1 导入样例工程到Eclipse中 单击“Finish”。 导入成功后,com.huawei.bigdata.hive.example包下的HCatalogExample类,为HCatalog接口样例代码 设置Eclipse的文本文件编码格式,解决乱码显示问题。
om.huawei.mrs.dt.MRSDelegationTokenProvider和com.huawei.mrs.dt.GuardianDTProvider。 com.huawei.mrs.dt.MRSDelegationTokenProvider和com.huawei.mrs
在HDFS样例工程代码中,不同的样例工程,使用的认证代码不同,包括基本安全认证和带ZooKeeper认证。 基本安全认证: com.huawei.bigdata.hdfs.examples包的HdfsExample类样例程序不需要访问HBase或ZooKeeper,所以使用基本的安全认证代码即可。示例代码如下:
ntConfig/Flume/FlumeClient/flume/plugins.s/plugin.sh plugins = com.huawei.flume.services.FlumePreTransmitService flume.check.default.interval
HNAME>' 例如,注册名称为“example”的UDF的命令为: CREATE FUNCTION example AS 'com.huawei.bigdata.iotdb.UDTFExample' 父主题: 在IoTDBServer节点调测UDF应用
--keytab /opt/FIclient/user.keytab --principal sparkuser --class com.huawei.spark.examples.SparkOnMultiHbase /opt/example/SparkOnMultiHbase-1.0