本文整理汇总了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；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论