我正在使用星火2.1和卡夫卡0.08.xx做一个星火流工作。这是一个文本过滤作业,大部分文本将在处理过程中被过滤掉。我以两种不同的方式实现:
val messages = KafkaUtils.createDirectStream val jsonMsg = messages.map(_._2) val filteredMsg = jsonMsg.filter(x=>x.contains(TEXT1) & x.contains(TEXT2) & x.contains(TEXT3))
me
假设我有一个函数,它接受一些数据作为输入,并生成一个图: plot = produce_plot(data) return plotdata_categories = divide_in_category(data)
for d in data_categories: f(data, color=user_option.color, format=&