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

Method get

storm-client/src/jvm/org/apache/storm/utils/LocalState.java:142–155  ·  view source on GitHub ↗
(String key)

Source from the content-addressed store, hash-verified

140 }
141
142 public TBase get(String key) {
143 try {
144 TDeserializer td = new TDeserializer();
145 Map<String, ThriftSerializedObject> partial = partialSnapshot(td);
146 ThriftSerializedObject tso = partial.get(key);
147 TBase ret = null;
148 if (tso != null) {
149 ret = deserialize(tso, td);
150 }
151 return ret;
152 } catch (TTransportException e) {
153 throw new RuntimeException(e);
154 }
155 }
156
157 public void put(String key, TBase val) {
158 put(key, val, true);

Callers 10

getTopoHistoryListMethod · 0.95
filterOldTopologiesMethod · 0.95
addTopologyHistoryMethod · 0.95
getSupervisorIdMethod · 0.95
getApprovedWorkersMethod · 0.95
getWorkerHeartBeatMethod · 0.95
testLocalStateMethod · 0.95
testEmptyStateMethod · 0.95
testAllNulStateMethod · 0.95

Calls 3

partialSnapshotMethod · 0.95
deserializeMethod · 0.95
getMethod · 0.65

Tested by 3

testLocalStateMethod · 0.76
testEmptyStateMethod · 0.76
testAllNulStateMethod · 0.76