Package backtype.storm.spout

Examples of backtype.storm.spout.SpoutOutputCollector

41
42
43
44
45
46
47
48
49
50
51
    @Test
    public void testFailure() throws JMSException, Exception{
        JmsSpout spout = new JmsSpout();
        JmsProvider mockProvider = new MockJmsProvider();
        MockSpoutOutputCollector mockCollector = new MockSpoutOutputCollector();
        SpoutOutputCollector collector = new SpoutOutputCollector(mockCollector);
        spout.setJmsProvider(new MockJmsProvider());
        spout.setJmsTupleProducer(new MockTupleProducer());
        spout.setJmsAcknowledgeMode(Session.CLIENT_ACKNOWLEDGE);
        spout.setRecoveryPeriod(10); // Rapid recovery for testing.
        spout.open(new HashMap<String,String>(), null, collector);
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
        exeQueue, report_error);

    try {
      WorkerClassLoader.switchThreadContext();
      this.spout.open(storm_conf, userTopologyCtx,
          new SpoutOutputCollector(output_collector));
    } catch (Throwable e) {
      error = e;
      LOG.error("spout open error ", e);
      report_error.report(e);
    } finally {
View Full Code Here
83
84
85
86
87
88
89
90
91
92
93
                fail(txid);
            }
           
            _collector.reset(collector);
            if(!prepared) {
                _spout.open(_conf, _context, new SpoutOutputCollector(_collector));
                prepared = true;
            }
            for(int i=0; i<_maxBatchSize; i++) {
                _spout.nextTuple();
                if(_collector.numEmitted < i) {
View Full Code Here
36
37
38
39
40
41
42
43
44
45
46
        _coordStream = TridentBoltExecutor.COORD_STREAM(batchGroup);
    }
   
    @Override
    public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
        _delegate.open(conf, context, new SpoutOutputCollector(new StreamOverrideCollector(collector)));
        _outputTasks = new ArrayList<Integer>();
        for(String component: Utils.get(context.getThisTargets(),
                                        _coordStream,
                                        new HashMap<String, Grouping>()).keySet()) {
            _outputTasks.addAll(context.getComponentTasks(component));
View Full Code Here
56
57
58
59
60
61
62
  }

  public void open(Map conf, TopologyContext context,
      SpoutOutputCollector collector) {
    _tracker = new SpoutTrackOutputCollector(collector);
    _delegate.open(conf, context, new SpoutOutputCollector(_tracker));
  }
View Full Code Here
TOP

Related Classes of backtype.storm.spout.SpoutOutputCollector

  • backtype.storm.contrib.jms.spout.JmsSpoutTest
  • backtype.storm.testing.SpoutTracker
  • com.alibaba.jstorm.task.execute.spout.SpoutExecutors
  • com.alipay.bluewhale.core.task.executer.SpoutExecutors
  • com.mapr.ProtoSpoutTest
  • com.streamreduce.storm.spouts.ConnectionSpoutIT
  • com.streamreduce.storm.spouts.EventSpoutIT
  • storm.trident.spout.RichSpoutBatchExecutor$RichSpoutEmitter
  • storm.trident.spout.RichSpoutBatchTriggerer
    • Copyright © 2018 www.massapicom. 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.