Package org.apache.hadoop.chukwa.extraction.demux.processor.reducer

Examples of org.apache.hadoop.chukwa.extraction.demux.processor.reducer.ReduceProcessor.process()

142
143
144
145
146
147
148
149
150
151
152
        String defaultProcessor = Demux.jobConf.get(
            "chukwa.demux.reducer.default.processor", null);
        ReduceProcessor processor = ReduceProcessorFactory.getProcessor(
            key.getReduceType(), defaultProcessor);

        processor.process(key, values, chukwaOutputCollector, reporter);

        if (log.isDebugEnabled()) {
          duration = System.currentTimeMillis() - duration;
          log.debug("Demux:Reduce, dataType:" + key.getReduceType()
              + " duration:" + duration);
View Full Code Here
154
155
156
157
158
159
160
161
162
163
164
        else
          processClass = processClass_tmps[1];

        ReduceProcessor processor = ReduceProcessorFactory.getProcessor(processClass);
        System.out.println(processor.getClass().getName());
        processor.process(key, values, chukwaOutputCollector, reporter);

        if (log.isDebugEnabled()) {
          duration = System.currentTimeMillis() - duration;
          log.debug("Demux:Reduce, dataType:" + key.getReduceType()
                  + " duration:" + duration);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.