• 大小: 32.26M
    文件类型: .rar
    金币: 1
    下载: 0 次
    发布日期: 2023-06-23
  • 语言: Java
  • 标签: STORM  Words  Word  ORM  

资源简介


资源截图

代码片段和文件信息

package com.mzz.storm;

import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileWriter;
import java.io.IOException;
import java.io.PrintWriter;
import java.io.Writer;
import java.net.InetAddress;
import java.net.UnknownHostException;

import org.apache.storm.topology.BasicOutputCollector;
import org.apache.storm.topology.OutputFieldsDeclarer;
import org.apache.storm.topology.base.baseBasicBolt;
import org.apache.storm.tuple.Tuple;

public class PrintWordBolt extends baseBasicBolt {

/**
 * 
 */
private static final long serialVersionUID = 1L;
private File file=new File(“/usr/mzz/words.txt“);
Writer output = null;

@Override
public void execute(Tuple tuple BasicOutputCollector colector) {
String word=tuple.getStringByField(“word“);

 属性            大小     日期    时间   名称
----------- ---------  ---------- -----  ----

     文件       2033  2020-03-23 14:30  HELLO\.classpath

     文件        381  2020-03-23 14:26  HELLO\.project

     文件        598  2020-03-23 14:26  HELLO\.settings\org.eclipse.jdt.core.prefs

     文件       2204  2020-03-31 18:40  HELLO\bin\com\mzz\storm\PrintWordBolt.class

     文件       2092  2020-03-31 18:19  HELLO\bin\com\mzz\storm\RandomWordsSpout.class

     文件       2301  2020-03-31 18:41  HELLO\bin\com\mzz\storm\TopMain.class

     文件      65084  2020-03-30 20:39  HELLO\hs_err_pid4560.log

     文件      57051  2020-03-07 11:20  HELLO\lib\arcsoft-sdk-face-2.2.0.1.jar

     文件      53231  2020-03-13 09:58  HELLO\lib\asm-5.0.3.jar

     文件     935929  2020-03-12 20:47  HELLO\lib\bridj-0.7.0.jar

     文件    3837631  2020-03-13 09:58  HELLO\lib\clojure-1.7.0.jar

     文件      85842  2020-03-13 09:58  HELLO\lib\disruptor-3.3.11.jar

     文件     407253  2020-03-12 19:06  HELLO\lib\javacv-1.5.jar

     文件      57635  2020-03-23 13:03  HELLO\lib\junit-3.8.1-sources.jar

     文件     121070  2020-03-23 13:03  HELLO\lib\junit-3.8.1.jar

     文件     285211  2020-03-13 09:58  HELLO\lib\kryo-3.0.3.jar

     文件     228154  2020-03-13 09:58  HELLO\lib\log4j-api-2.8.2.jar

     文件    1407853  2020-03-13 09:58  HELLO\lib\log4j-core-2.8.2.jar

     文件      20647  2020-03-13 09:58  HELLO\lib\log4j-over-slf4j-1.6.6.jar

     文件      23124  2020-03-13 09:58  HELLO\lib\log4j-slf4j-impl-2.8.2.jar

     文件     111908  2020-03-13 09:58  HELLO\lib\metrics-core-3.1.0.jar

     文件      20638  2020-03-13 09:58  HELLO\lib\metrics-graphite-3.1.0.jar

     文件       5711  2020-03-13 09:58  HELLO\lib\minlog-1.3.0.jar

     文件    1452708  2020-03-23 13:13  HELLO\lib\mysql-connector-java-8.0.17-sources.jar

     文件    2321813  2020-03-23 13:13  HELLO\lib\mysql-connector-java-8.0.17.jar

     文件      41755  2020-03-13 09:58  HELLO\lib\objenesis-2.1.jar

     文件      20738  2020-03-13 09:58  HELLO\lib\reflectasm-1.10.1.jar

     文件       5647  2020-03-13 09:58  HELLO\lib\ring-cors-0.1.5.jar

     文件     105112  2020-03-13 09:58  HELLO\lib\servlet-api-2.5.jar

     文件      26083  2020-03-12 20:47  HELLO\lib\slf4j-api-1.7.2.jar

............此处省略21个文件信息

评论

共有 条评论