文件名称：HBase-SparkStreaming:从HBase表读取并写入HBase表的简单Spark Streaming项目
文件大小：620KB
文件格式：ZIP
更新时间：2024-06-01 18:32:54
Scala
HBase-SparkStreaming 从HBase表读取并写入HBase表的简单Spark Streaming项目 #Prereqs运行 创建一个要写入的hbase表：a）启动hbase shell $ hbase shell b）创建表create'/ user / chanumolu / sensor'，{NAME =>'data'}，{NAME =>'alert'}，{ NAME =>'stats'} ＃执行： 第1步：MVN全新安装 步骤2：启动流媒体应用程序 $ {SPARK_HOME} / bin / spark-submit --driver-class-path $ {HBASE_CLASSPATH} --class示例。HBaseSensorStreamhbasesparkstreamingapp-1.0.jar 步骤3：将流数据文件复制到流目录cp sens
【文件预览】：
HBase-SparkStreaming-master
----README.md(1KB)
----pom.xml(5KB)
----src()
--------main()
----scripts()
--------create_join_view.hql(237B)
--------create_ext_table.hql(497B)
--------create_pump_table.hql(270B)
--------create_maint_table.hql(224B)
----data()
--------sensordata.csv(2.28MB)
--------sensormaint.csv(4KB)
--------sensorvendor.csv(622B)