Spark_Streaming
练习例子1。 package com.haiyang import java.nio.charset.Charset import org.apache.flume.api.RpcClientFactory import org.apache.flume.event.EventBuilder //flume 数据发送 productor端口 主要用于发送产生的Event object FlumeMsgSender { val client =RpcClientFactory.getDefaultInstance("master",33333) //客户端通过RPC协议工厂实现默认的主节点 以及端口 def sendEvent(msg:String)={ //发送event的Body val event =EventBuilder.withBody(msg,Charset.forName("UTF-8")) //追加event client.append(event) } def main(args: Array[String]): Unit = { //产生时间并发送 (1 to 10...
