MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/HBAuthorizationException.java:129
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/TopologyStats.java:178
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/LSTopoHistoryList.java:134
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/KeyNotFoundException.java:129
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/ListBlobsResult.java:143
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeat.java:160
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/WorkerToken.java:157
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java:146
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/WorkerMetricList.java:134
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/WorkerTokenInfo.java:167
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorAssignments.java:139
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/LSSupervisorId.java:129
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/DRPCExecutionException.java:144
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java:232
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/HBRecords.java:134
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/StormBase.java:260
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/ExecutorSummary.java:190
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java:159
MethoddeepCopy
()
storm-client/src/jvm/org/apache/storm/generated/SpoutSpec.java:141
MethoddeepSearch
Handles '/deepSearch' request.
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/webapp/LogviewerResource.java:315
MethoddefaultConstructorShouldSetPositiveTopN
()
examples/storm-starter/test/jvm/org/apache/storm/starter/tools/RankingsTest.java:129
MethoddefaultYamlTest
()
storm-client/test/jvm/org/apache/storm/TestConfigValidate.java:182
MethoddefensiveCopyRankingsData
()
examples/storm-starter/test/jvm/org/apache/storm/starter/tools/RankingsTest.java:73
Methoddel
(byte[] key)
external/storm-redis/src/main/java/org/apache/storm/redis/common/adapter/RedisCommandsAdapterJedis.java:79
Methoddel
(byte[] key)
external/storm-redis/src/main/java/org/apache/storm/redis/common/adapter/RedisCommandsAdapterJedisCluster.java:80
Methoddelay
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/Timer.java:53
Methoddelete
()
storm-client/src/jvm/org/apache/storm/container/cgroup/CgroupCommon.java:182
Methoddelete
(String path)
storm-client/src/jvm/org/apache/storm/trident/topology/state/TransactionalState.java:136
Methoddelete
(K key)
storm-client/src/jvm/org/apache/storm/state/InMemoryKeyValueState.java:47
Methoddelete
(final String key)
external/storm-redis/src/test/java/org/apache/storm/redis/util/JedisTestHelper.java:38
Methoddelete
(K key)
external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java:166
Methoddelete
(String path, int version)
storm-core/src/jvm/org/apache/storm/shade/org/apache/zookeeper/ZkCli.java:116
MethoddeleteBlob
(String key)
storm-client/test/jvm/org/apache/storm/blobstore/ClientBlobStoreTest.java:153
MethoddeleteBlob
(java.lang.String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:232
MethoddeleteBlob
(java.lang.String key)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:933
MethoddeleteBlob
(java.lang.String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:2715
MethoddeleteBlob
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:4801
MethoddeleteBlob
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:7832
MethoddeleteBlob
(String key)
storm-client/src/jvm/org/apache/storm/blobstore/NimbusBlobStore.java:119
MethoddeleteBlob
Client facing API to delete a blob. @param key blob key name
storm-client/src/jvm/org/apache/storm/blobstore/ClientBlobStore.java:104
MethoddeleteBlob
(String key)
storm-client/src/jvm/org/apache/storm/blobstore/LocalModeClientBlobStore.java:76
MethoddeleteBlob
Parameters: - key
storm-client/src/py/storm/Nimbus.py:243
MethoddeleteBlob
Parameters: - key
storm-client/src/py/storm/Nimbus.py:1305
MethoddeleteBlob
(String key)
storm-server/src/main/java/org/apache/storm/LocalCluster.java:937
MethoddeleteBlob
(String key)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4003
MethoddeleteBlob
(String key, Subject who)
external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsBlobStore.java:266
MethoddeleteBlob
(String key)
external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsClientBlobStore.java:88
MethoddeleteBlob_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:31461
MethoddeleteBlob_call
(java.lang.String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.storm
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:2725
MethoddeleteBlob_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:31851
MethoddeleteCgroup
(CgroupCommon cgroup)
storm-client/src/jvm/org/apache/storm/container/cgroup/CgroupCenter.java:206
MethoddeleteIfExists
Delete a file or a directory and all of the children. If it exists. @param path what to delete @param user who to delete it as if doing it
storm-client/src/jvm/org/apache/storm/daemon/supervisor/AdvancedFSOps.java:152
MethoddeleteIfExists
(File path, String user, String logPrefix)
storm-client/src/jvm/org/apache/storm/daemon/supervisor/AdvancedFSOps.java:386
MethoddeleteStormId
(String stormName)
storm-client/src/jvm/org/apache/storm/assignments/InMemoryAssignmentBackend.java:127
MethoddeleteTopologyProfileRequests
(String stormId, ProfileRequest profileRequest)
storm-client/src/jvm/org/apache/storm/cluster/StormClusterStateImpl.java:388
Methoddelete_node
(String path)
storm-client/src/jvm/org/apache/storm/cluster/PaceMakerStateStorage.java:72
Methoddelete_node_blobstore
(String path, String nimbusHostPortInfo)
storm-client/src/jvm/org/apache/storm/cluster/ZKStateStorage.java:91
Methoddelete_node_blobstore
(String path, String nimbusHostPortInfo)
storm-client/src/jvm/org/apache/storm/cluster/PaceMakerStateStorage.java:277
Methoddelete_worker_hb
(String path)
storm-client/src/jvm/org/apache/storm/cluster/ZKStateStorage.java:214
Methoddelete_worker_hb
(String path)
storm-client/src/jvm/org/apache/storm/cluster/PaceMakerStateStorage.java:225
MethoddeltaSecsConvertsToSecondsTest
()
storm-client/test/jvm/org/apache/storm/utils/TimeTest.java:77
MethoddeltaSecsTruncatesFractionalSecondsTest
()
storm-client/test/jvm/org/apache/storm/utils/TimeTest.java:86
MethoddescribeMismatchSafely
(T item, Description mismatchDescription)
storm-client/test/jvm/org/apache/storm/utils/PredicateMatcher.java:45
MethoddescribeTo
(Description description)
storm-client/test/jvm/org/apache/storm/utils/ThrowableNestedCauseMatcher.java:41
MethoddescribeTo
(Description description)
storm-client/test/jvm/org/apache/storm/utils/PredicateMatcher.java:40
Methoddeserialize
(ByteBuffer ser)
storm-client/src/jvm/org/apache/storm/spout/RawScheme.java:27
Methoddeserialize
(final ByteBuffer ser)
storm-client/src/jvm/org/apache/storm/spout/SchemeAsMultiScheme.java:27
Methoddeserialize
(ByteBuffer ser)
storm-client/src/jvm/org/apache/storm/spout/MultiScheme.java:21
Methoddeserialize
(ByteBuffer ser)
storm-client/src/jvm/org/apache/storm/spout/RawMultiScheme.java:29
Methoddeserialize
(byte[] bytes, Class<T> clazz)
storm-client/src/jvm/org/apache/storm/serialization/ThriftSerializationDelegate.java:36
Methoddeserialize
(byte[] bytes, Class<T> clazz)
storm-client/src/jvm/org/apache/storm/serialization/GzipSerializationDelegate.java:48
Methoddeserialize
(byte[] bytes, Class<T> clazz)
storm-client/src/jvm/org/apache/storm/serialization/GzipThriftSerializationDelegate.java:47
Methoddeserialize
(byte[] bytes, Class<T> clazz)
storm-client/src/jvm/org/apache/storm/serialization/GzipBridgeThriftSerializationDelegate.java:42
Methoddeserialize
(byte[] bytes, Class<T> clazz)
storm-client/src/jvm/org/apache/storm/serialization/SerializationDelegate.java:29
Methoddeserialize
(ByteBuffer packet)
storm-client/src/jvm/org/apache/storm/messaging/TaskMessage.java:41
Methoddeserialize
Returns an Object which is created using Kryo deserialization of given byte array instance. @param buff byte array to be deserialized into an Object
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowKryoSerializer.java:65
Methoddeserialize
(byte[] b)
storm-client/src/jvm/org/apache/storm/trident/state/JSONNonTransactionalSerializer.java:28
Methoddeserialize
(byte[] b)
storm-client/src/jvm/org/apache/storm/trident/state/Serializer.java:21
Methoddeserialize
(byte[] b)
storm-client/src/jvm/org/apache/storm/trident/state/JSONOpaqueSerializer.java:33
Methoddeserialize
(byte[] b)
storm-client/src/jvm/org/apache/storm/trident/state/JSONTransactionalSerializer.java:31
Methoddestination
()
examples/storm-jms-examples/src/main/java/org/apache/storm/jms/example/SpringJmsProvider.java:66
Methoddestroy
()
storm-webapp/src/main/java/org/apache/storm/daemon/drpc/webapp/ReqContextFilter.java:86
Methoddestroy
()
storm-webapp/src/main/java/org/apache/storm/daemon/ui/TestingFilter.java:70
Methoddestroy
()
storm-webapp/src/main/java/org/apache/storm/daemon/ui/filters/HeaderResponseServletFilter.java:65
Methoddestroy
()
storm-server/src/main/java/org/apache/storm/logging/filters/AccessLoggingFilter.java:51
Functiondev_zookeeper
(args)
bin/storm.py:1384
MethoddidMainProcessExit
()
storm-server/src/test/java/org/apache/storm/daemon/supervisor/ContainerTest.java:240
MethoddidMainProcessExit
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/LocalContainer.java:88
MethoddidMainProcessExit
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/BasicContainer.java:259
MethoddigestAuthTest
()
storm-server/src/test/java/org/apache/storm/security/auth/AuthTest.java:259
MethoddirectGrouping
(final String component)
storm-client/src/jvm/org/apache/storm/trident/topology/TridentTopologyBuilder.java:647
MethoddirectGrouping
(String componentId)
storm-client/src/jvm/org/apache/storm/topology/TopologyBuilder.java:715
MethoddirectGrouping
()
storm-client/src/jvm/org/apache/storm/drpc/LinearDRPCTopologyBuilder.java:333
MethoddirectGrouping
(final String component)
storm-client/src/jvm/org/apache/storm/coordination/BatchSubtopologyBuilder.java:349
MethoddisableDetach
Disable detach. @return the self
storm-server/src/main/java/org/apache/storm/container/docker/DockerRunCommand.java:254
Methoddisconnect
()
storm-client/src/jvm/org/apache/storm/cluster/StormClusterStateImpl.java:839
MethoddisplayByteArray
Test Utility Method Display Byte Array.
storm-client/src/jvm/org/apache/storm/utils/WritableUtils.java:229
Methoddispose
()
storm-client/src/jvm/org/apache/storm/security/auth/plain/SaslPlainServer.java:122
MethoddoAck
(final Message msg)
external/storm-jms/src/main/java/org/apache/storm/jms/spout/JmsSpout.java:515
MethoddoAck
(final Message msg)
external/storm-jms/src/main/java/org/apache/storm/jms/spout/JmsSpout.java:533
← previousnext →15,801–15,900 of 27,770, ranked by callers