【文件属性】：
文件名称：spark-structured-streaming-hbase-writer
文件大小：13KB
文件格式：ZIP
更新时间：2021-05-08 21:50:16
scala sbt hbase spark-streaming Scala
如何使用该库：//进行中
例如 ：
运行nc -lk 9999
创建火花会话：
val spark = SparkSession
.builder
.master("local[*]")
.appName("StructuredStreamingApp")
.getOrCreate()
读取流
val lines = spark.readStream
.format("socket")
.option("host", "localhost")
.option("port", 9999)
.load()
写入hbase
val query = lines
.writeStream
.foreach(new HBaseForeachWriter[WhatEverYourDataType] {
【文件预览】：
spark-structured-streaming-hbase-writer-master
----.gitignore(76B)
----build.sbt(1KB)
----src()
--------test()
--------main()
----scripts()
--------docker_setup.sh(647B)
----ReadMe.md(2KB)
----version.sbt(39B)
----project()
--------assembly.sbt(57B)
--------plugins.sbt(168B)
--------build.properties(19B)