MCPcopy Create free account
hub / github.com/apache/storm / commit

Method commit

storm-client/src/jvm/org/apache/storm/state/State.java:37–37  ·  view source on GitHub ↗

Commit a previously prepared transaction. It should be possible to retrieve a committed state later. @param txid the transaction id

(long txid)

Source from the content-addressed store, hash-verified

35 * @param txid the transaction id
36 */
37 void commit(long txid);
38
39 /**
40 * Persist the current state. This is used when the component manages the state.

Callers 15

loginModuleWithSubjAndTgtMethod · 0.65
testPrepareCommitRollbackMethod · 0.65
testCommitMethod · 0.65
testPrepareAndCommitMethod · 0.65
commitMethod · 0.65
loadCheckpointStateMethod · 0.65
saveTxStateMethod · 0.65
closeMethod · 0.65
testPrepareCommitRollbackMethod · 0.65
doAckMethod · 0.65
commitMethod · 0.65
testCommitMethod · 0.65

Implementers 6

RedisStateexternal/storm-redis/src/main/java/org
RedisClusterStateexternal/storm-redis/src/main/java/org
JmsStateexternal/storm-jms/src/main/java/org/a
TridentKafkaStateexternal/storm-kafka-client/src/main/j
JdbcStateexternal/storm-jdbc/src/main/java/org/
HdfsStateexternal/storm-hdfs/src/main/java/org/

Calls

no outgoing calls

Tested by 9

loginModuleWithSubjAndTgtMethod · 0.52
testPrepareCommitRollbackMethod · 0.52
testCommitMethod · 0.52
testPrepareAndCommitMethod · 0.52
testPrepareCommitRollbackMethod · 0.52
testCommitMethod · 0.52
testCommittedFlagSetOnCommitMethod · 0.52
testOpaqueMapMethod · 0.52
testTransactionalMapMethod · 0.52