文件名称：spark-structured-streaming-hbase-writer
文件大小：13KB
文件格式：ZIP
更新时间：2024-05-28 15:36:56
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)