• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java RotatingTransactionalState类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中backtype.storm.transactional.state.RotatingTransactionalState的典型用法代码示例。如果您正苦于以下问题:Java RotatingTransactionalState类的具体用法?Java RotatingTransactionalState怎么用?Java RotatingTransactionalState使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



RotatingTransactionalState类属于backtype.storm.transactional.state包,在下文中一共展示了RotatingTransactionalState类的14个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: open

import backtype.storm.transactional.state.RotatingTransactionalState; //导入依赖的package包/类
@Override
public void open(Map conf, TopologyContext context,
		SpoutOutputCollector collector) {
	_rand = new Random(Utils.secureRandomLong());
	_state = TransactionalState.newCoordinatorState(conf,
			(String) conf.get(Config.TOPOLOGY_TRANSACTIONAL_ID),
			_spout.getComponentConfiguration());
	_coordinatorState = new RotatingTransactionalState(_state, META_DIR,
			true);
	_collector = collector;
	_coordinator = _spout.getCoordinator(conf, context);
	_currTransaction = getStoredCurrTransaction(_state);
	Object active = conf.get(Config.TOPOLOGY_MAX_SPOUT_PENDING);
	if (active == null) {
		_maxTransactionActive = 1;
	} else {
		_maxTransactionActive = Utils.getInt(active);
	}
	_initializer = new StateInitializer();
}
 
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:21,代码来源:TransactionalSpoutCoordinator.java


示例2: Emitter

import backtype.storm.transactional.state.RotatingTransactionalState; //导入依赖的package包/类
public Emitter(Map conf, TopologyContext context) {
	_emitter = _spout.getEmitter(conf, context);
	_index = context.getThisTaskIndex();
	_numTasks = context.getComponentTasks(context.getThisComponentId())
			.size();
	_state = TransactionalState.newUserState(conf,
			(String) conf.get(Config.TOPOLOGY_TRANSACTIONAL_ID),
			getComponentConfiguration());
	List<String> existingPartitions = _state.list("");
	for (String p : existingPartitions) {
		int partition = Integer.parseInt(p);
		if ((partition - _index) % _numTasks == 0) {
			_partitionStates.put(partition,
					new RotatingTransactionalState(_state, p));
		}
	}
}
 
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:18,代码来源:OpaquePartitionedTransactionalSpoutExecutor.java


示例3: open

import backtype.storm.transactional.state.RotatingTransactionalState; //导入依赖的package包/类
@Override
public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
    _rand = new Random(Utils.secureRandomLong());
    _state = TransactionalState.newCoordinatorState(conf, (String) conf.get(Config.TOPOLOGY_TRANSACTIONAL_ID), _spout.getComponentConfiguration());
    _coordinatorState = new RotatingTransactionalState(_state, META_DIR, true);
    _collector = collector;
    _coordinator = _spout.getCoordinator(conf, context);
    _currTransaction = getStoredCurrTransaction(_state);
    Object active = conf.get(Config.TOPOLOGY_MAX_SPOUT_PENDING);
    if (active == null) {
        _maxTransactionActive = 1;
    } else {
        _maxTransactionActive = Utils.getInt(active);
    }
    _initializer = new StateInitializer();
}
 
开发者ID:kkllwww007,项目名称:jstrom,代码行数:17,代码来源:TransactionalSpoutCoordinator.java


示例4: emitBatch

import backtype.storm.transactional.state.RotatingTransactionalState; //导入依赖的package包/类
@Override
public void emitBatch(final TransactionAttempt tx, final Integer partitions, final BatchOutputCollector collector) {
    for (int i = _index; i < partitions; i += _numTasks) {
        if (!_partitionStates.containsKey(i)) {
            _partitionStates.put(i, new RotatingTransactionalState(_state, "" + i));
        }
        RotatingTransactionalState state = _partitionStates.get(i);
        final int partition = i;
        Object meta = state.getStateOrCreate(tx.getTransactionId(), new RotatingTransactionalState.StateInitializer() {
            @Override
            public Object init(BigInteger txid, Object lastState) {
                return _emitter.emitPartitionBatchNew(tx, collector, partition, lastState);
            }
        });
        // it's null if one of:
        // a) a later transaction batch was emitted before this, so we should skip this batch
        // b) if didn't exist and was created (in which case the StateInitializer was invoked and
        // it was emitted
        if (meta != null) {
            _emitter.emitPartitionBatch(tx, collector, partition, meta);
        }
    }

}
 
开发者ID:kkllwww007,项目名称:jstrom,代码行数:25,代码来源:PartitionedTransactionalSpoutExecutor.java


示例5: open

import backtype.storm.transactional.state.RotatingTransactionalState; //导入依赖的package包/类
@Override
public void open(Map conf, TopologyContext context, SpoutOutputCollector collector) {
    _rand = new Random(Utils.secureRandomLong());
    _state = TransactionalState.newCoordinatorState(conf, (String) conf.get(Config.TOPOLOGY_TRANSACTIONAL_ID), _spout.getComponentConfiguration());
    _coordinatorState = new RotatingTransactionalState(_state, META_DIR, true);
    _collector = collector;
    _coordinator = _spout.getCoordinator(conf, context);
    _currTransaction = getStoredCurrTransaction(_state);
    Object active = conf.get(Config.TOPOLOGY_MAX_SPOUT_PENDING);
    if(active==null) {
        _maxTransactionActive = 1;
    } else {
        _maxTransactionActive = Utils.getInt(active);
    }
    _initializer = new StateInitializer();
}
 
开发者ID:metamx,项目名称:incubator-storm,代码行数:17,代码来源:TransactionalSpoutCoordinator.java


示例6: emitBatch

import backtype.storm.transactional.state.RotatingTransactionalState; //导入依赖的package包/类
@Override
public void emitBatch(final TransactionAttempt tx, final Integer partitions,
        final BatchOutputCollector collector) {
    for(int i=_index; i < partitions; i+=_numTasks) {
        if(!_partitionStates.containsKey(i)) {
            _partitionStates.put(i, new RotatingTransactionalState(_state, "" + i));
        }
        RotatingTransactionalState state = _partitionStates.get(i);
        final int partition = i;
        Object meta = state.getStateOrCreate(tx.getTransactionId(),
                new RotatingTransactionalState.StateInitializer() {
            @Override
            public Object init(BigInteger txid, Object lastState) {
                return _emitter.emitPartitionBatchNew(tx, collector, partition, lastState);
            }
        });
        // it's null if one of:
        //   a) a later transaction batch was emitted before this, so we should skip this batch
        //   b) if didn't exist and was created (in which case the StateInitializer was invoked and 
        //      it was emitted
        if(meta!=null) {
            _emitter.emitPartitionBatch(tx, collector, partition, meta);
        }
    }
    
}
 
开发者ID:metamx,项目名称:incubator-storm,代码行数:27,代码来源:PartitionedTransactionalSpoutExecutor.java


示例7: emitBatch

import backtype.storm.transactional.state.RotatingTransactionalState; //导入依赖的package包/类
@Override
public void emitBatch(final TransactionAttempt tx,
		final Integer partitions, final BatchOutputCollector collector) {
	for (int i = _index; i < partitions; i += _numTasks) {
		if (!_partitionStates.containsKey(i)) {
			_partitionStates.put(i, new RotatingTransactionalState(
					_state, "" + i));
		}
		RotatingTransactionalState state = _partitionStates.get(i);
		final int partition = i;
		Object meta = state.getStateOrCreate(tx.getTransactionId(),
				new RotatingTransactionalState.StateInitializer() {
					@Override
					public Object init(BigInteger txid, Object lastState) {
						return _emitter.emitPartitionBatchNew(tx,
								collector, partition, lastState);
					}
				});
		// it's null if one of:
		// a) a later transaction batch was emitted before this, so we
		// should skip this batch
		// b) if didn't exist and was created (in which case the
		// StateInitializer was invoked and
		// it was emitted
		if (meta != null) {
			_emitter.emitPartitionBatch(tx, collector, partition, meta);
		}
	}

}
 
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:31,代码来源:PartitionedTransactionalSpoutExecutor.java


示例8: Emitter

import backtype.storm.transactional.state.RotatingTransactionalState; //导入依赖的package包/类
public Emitter(Map conf, TopologyContext context) {
    _emitter = _spout.getEmitter(conf, context);
    _index = context.getThisTaskIndex();
    _numTasks = context.getComponentTasks(context.getThisComponentId()).size();
    _state = TransactionalState.newUserState(conf, (String) conf.get(Config.TOPOLOGY_TRANSACTIONAL_ID), getComponentConfiguration());
    List<String> existingPartitions = _state.list("");
    for (String p : existingPartitions) {
        int partition = Integer.parseInt(p);
        if ((partition - _index) % _numTasks == 0) {
            _partitionStates.put(partition, new RotatingTransactionalState(_state, p));
        }
    }
}
 
开发者ID:kkllwww007,项目名称:jstrom,代码行数:14,代码来源:OpaquePartitionedTransactionalSpoutExecutor.java


示例9: Emitter

import backtype.storm.transactional.state.RotatingTransactionalState; //导入依赖的package包/类
public Emitter(Map conf, TopologyContext context) {
    _emitter = _spout.getEmitter(conf, context);
    _index = context.getThisTaskIndex();
    _numTasks = context.getComponentTasks(context.getThisComponentId()).size();
    _state = TransactionalState.newUserState(conf, (String) conf.get(Config.TOPOLOGY_TRANSACTIONAL_ID), getComponentConfiguration()); 
    List<String> existingPartitions = _state.list("");
    for(String p: existingPartitions) {
        int partition = Integer.parseInt(p);
        if((partition - _index) % _numTasks == 0) {
            _partitionStates.put(partition, new RotatingTransactionalState(_state, p));
        }
    }
}
 
开发者ID:metamx,项目名称:incubator-storm,代码行数:14,代码来源:OpaquePartitionedTransactionalSpoutExecutor.java


示例10: Emitter

import backtype.storm.transactional.state.RotatingTransactionalState; //导入依赖的package包/类
public Emitter(Map conf, TopologyContext context) {
    _emitter = _spout.getEmitter(conf, context);
    _index = context.getThisTaskIndex();
    _numTasks = context.getComponentTasks(context.getThisComponentId()).size();
    _state = TransactionalState.newUserState(
            conf, (String) conf.get(Config.TOPOLOGY_TRANSACTIONAL_ID), getComponentConfiguration());
    List<String> existingPartitions = _state.list("");
    for (String p : existingPartitions) {
        int partition = Integer.parseInt(p);
        if ((partition - _index) % _numTasks == 0) {
            _partitionStates.put(partition, new RotatingTransactionalState(_state, p));
        }
    }
}
 
开发者ID:alibaba,项目名称:jstorm,代码行数:15,代码来源:OpaquePartitionedTransactionalSpoutExecutor.java


示例11: cleanupBefore

import backtype.storm.transactional.state.RotatingTransactionalState; //导入依赖的package包/类
@Override
public void cleanupBefore(BigInteger txid) {
	for (RotatingTransactionalState state : _partitionStates.values()) {
		state.cleanupBefore(txid);
	}
}
 
开发者ID:zhangjunfang,项目名称:jstorm-0.9.6.3-,代码行数:7,代码来源:OpaquePartitionedTransactionalSpoutExecutor.java


示例12: cleanupBefore

import backtype.storm.transactional.state.RotatingTransactionalState; //导入依赖的package包/类
@Override
public void cleanupBefore(BigInteger txid) {
    for (RotatingTransactionalState state : _partitionStates.values()) {
        state.cleanupBefore(txid);
    }
}
 
开发者ID:kkllwww007,项目名称:jstrom,代码行数:7,代码来源:OpaquePartitionedTransactionalSpoutExecutor.java


示例13: cleanupBefore

import backtype.storm.transactional.state.RotatingTransactionalState; //导入依赖的package包/类
@Override
public void cleanupBefore(BigInteger txid) {
    for(RotatingTransactionalState state: _partitionStates.values()) {
        state.cleanupBefore(txid);
    }            
}
 
开发者ID:metamx,项目名称:incubator-storm,代码行数:7,代码来源:OpaquePartitionedTransactionalSpoutExecutor.java


示例14: cleanupBefore

import backtype.storm.transactional.state.RotatingTransactionalState; //导入依赖的package包/类
@Override
public void cleanupBefore(BigInteger txid) {
    for(RotatingTransactionalState state: _partitionStates.values()) {
        state.cleanupBefore(txid);
    }
}
 
开发者ID:metamx,项目名称:incubator-storm,代码行数:7,代码来源:PartitionedTransactionalSpoutExecutor.java



注:本文中的backtype.storm.transactional.state.RotatingTransactionalState类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java UnmarshallerFactory类代码示例发布时间:2022-05-23
下一篇:
Java StrRegEx类代码示例发布时间:2022-05-23
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap