删选专题

SparkStreaming 删选含有error的行

筛选流数据中所有含error的行 package com.streamingimport org.apache.spark.SparkConfimport org.apache.spark.streaming.Secondsimport org.apache.spark.streaming.StreamingContextobject PrintError {def main(args: