MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
Methodcount
()
storm-clojure/src/main/java/org/apache/storm/clojure/IndifferentAccessMap.java:56
Methodcreate
(Kryo kryo, Input input, Class<? extends ArrayList> type, int length)
storm-client/src/jvm/org/apache/storm/serialization/types/ArrayListSerializer.java:23
Methodcreate
(Kryo kryo, Input input, Class<? extends HashSet> type, int length)
storm-client/src/jvm/org/apache/storm/serialization/types/HashSetSerializer.java:23
Methodcreate
(Kryo kryo, Input input, Class<? extends HashMap> type, int length)
storm-client/src/jvm/org/apache/storm/serialization/types/HashMapSerializer.java:23
Methodcreate
(Kryo kryo, Input input, Class<? extends ListDelegate> type, int length)
storm-client/src/jvm/org/apache/storm/serialization/types/ListDelegateSerializer.java:23
Methodcreate
(Map<String, Object> topoConf)
storm-client/src/jvm/org/apache/storm/trident/windowing/InMemoryWindowsStoreFactory.java:29
Methodcreate
(List[] delegates)
storm-client/src/jvm/org/apache/storm/trident/tuple/ComboList.java:62
Methodcreate
(ILeaderElector elector)
storm-server/src/main/java/org/apache/storm/zookeeper/LeaderListenerCallbackFactory.java:62
Methodcreate
(String path, byte[] data, List<ACL> acl, CreateMode createMode)
storm-core/src/jvm/org/apache/storm/shade/org/apache/zookeeper/ZkCli.java:106
MethodcreateAdmin
(Map<String, Object> adminProps)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutAbstractTest.java:107
MethodcreateAdmin
(Map<String, Object> adminProps)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/SpoutWithMockedConsumerSetupHelper.java:95
MethodcreateAdmin
(Map<String, Object> adminProps)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutRebalanceTest.java:89
MethodcreateAdmin
(Map<String, Object> adminProps)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutEmitterPartitioningTest.java:75
MethodcreateAdmin
(Map<String, Object> adminProps)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutOpaqueCoordinatorTest.java:68
MethodcreateAdmin
(Map<String, Object> adminProps)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutEmitterEmitTest.java:112
MethodcreateArtifactsLink
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/LocalContainer.java:44
MethodcreateBaseDirectory
(FileSystem passedFs, String path)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/TestHdfsBolt.java:216
MethodcreateBlob
Client facing API to create a blob. @param key blob key name @param meta contains ACL information @return AtomicOutputStream returns an output strea
storm-client/src/jvm/org/apache/storm/blobstore/ClientBlobStore.java:162
MethodcreateBlobToExtend
(String key, SettableBlobMeta meta)
storm-client/test/jvm/org/apache/storm/blobstore/ClientBlobStoreTest.java:123
MethodcreateBlobToExtend
(String key, SettableBlobMeta meta)
storm-client/src/jvm/org/apache/storm/blobstore/NimbusBlobStore.java:53
MethodcreateBlobToExtend
(String key, SettableBlobMeta meta)
storm-client/src/jvm/org/apache/storm/blobstore/LocalModeClientBlobStore.java:45
MethodcreateBlobToExtend
(String key, SettableBlobMeta meta)
external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsClientBlobStore.java:59
MethodcreateBlobstoreLinks
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/LocalContainer.java:49
MethodcreateCgroup
(CgroupCommon cgroup)
storm-client/src/jvm/org/apache/storm/container/cgroup/CgroupCenter.java:180
MethodcreateClusterConfig
(double compPcore, double compOnHeap, double compOffHeap, Map<String, M
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestRoundRobinNodeSorterHostIsolation.java:68
MethodcreateConsumer
(Map<String, Object> consumerProps)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutAbstractTest.java:103
MethodcreateConsumer
(Map<String, Object> consumerProps)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/SpoutWithMockedConsumerSetupHelper.java:90
MethodcreateConsumer
(Map<String, Object> consumerProps)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutRebalanceTest.java:84
MethodcreateConsumer
(Map<String, Object> consumerProps)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutEmitterPartitioningTest.java:70
MethodcreateConsumer
(Map<String, Object> consumerProps)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutOpaqueCoordinatorTest.java:63
MethodcreateConsumer
(Map<String, Object> consumerProps)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutEmitterEmitTest.java:107
MethodcreateExclusion
()
storm-submit-tools/src/test/java/org/apache/storm/submit/dependency/AetherUtilsTest.java:59
MethodcreateIfSupported
Create a FileConfigLoader if the scheme of the URI is "file"; else return null. @param uri The URI which pointing to the config file location. @param
storm-server/src/main/java/org/apache/storm/scheduler/utils/FileConfigLoaderFactory.java:35
MethodcreateIfSupported
Create a ArtifactoryConfigLoader if the scheme of the URI is "artifactory+http" or "artifactory+https"; otherwise return null. @param uri The URI whic
storm-server/src/main/java/org/apache/storm/scheduler/utils/ArtifactoryConfigLoaderFactory.java:34
MethodcreateNewWorkerId
()
storm-server/src/test/java/org/apache/storm/daemon/supervisor/BasicContainerTest.java:692
MethodcreateOutputFile
()
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/HdfsState.java:403
MethodcreateOutputFile
()
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/HdfsState.java:507
MethodcreateSession
(final Connection conn)
external/storm-jms/src/main/java/org/apache/storm/jms/spout/JmsSpout.java:552
MethodcreateSpoutConfig
()
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutSingleTopicTest.java:52
MethodcreateSpoutConfig
()
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutNullTupleTest.java:38
MethodcreateSpoutConfig
()
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutTopologyDeployActivateDeactivateTest.java:36
MethodcreateStateInZookeeper
(String key)
storm-client/test/jvm/org/apache/storm/blobstore/ClientBlobStoreTest.java:190
MethodcreateStateInZookeeper
(java.lang.String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:240
MethodcreateStateInZookeeper
(java.lang.String key)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:1048
MethodcreateStateInZookeeper
(java.lang.String key, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:2859
MethodcreateStateInZookeeper
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:4955
MethodcreateStateInZookeeper
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:8149
MethodcreateStateInZookeeper
Creates state inside a zookeeper. Required for blobstore to write to zookeeper when Nimbus HA is turned on in order to maintain state consistency.
storm-client/src/jvm/org/apache/storm/blobstore/ClientBlobStore.java:150
MethodcreateStateInZookeeper
(String key)
storm-client/src/jvm/org/apache/storm/blobstore/LocalModeClientBlobStore.java:118
MethodcreateStateInZookeeper
Parameters: - key
storm-client/src/py/storm/Nimbus.py:276
MethodcreateStateInZookeeper
Parameters: - key
storm-client/src/py/storm/Nimbus.py:1447
MethodcreateStateInZookeeper
(String key)
storm-server/src/main/java/org/apache/storm/LocalCluster.java:961
MethodcreateStateInZookeeper
(String key)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4102
MethodcreateStateInZookeeper
(String key)
external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsClientBlobStore.java:120
MethodcreateStateInZookeeper_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:35201
MethodcreateStateInZookeeper_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:2869
MethodcreateStateInZookeeper_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:35569
MethodcreateSymlink
Create a symbolic link pointing at target. @param link the link to create @param target where it should point to @throws IOException on any error.
storm-client/src/jvm/org/apache/storm/daemon/supervisor/AdvancedFSOps.java:350
MethodcreateTempDir
()
storm-server/src/test/java/org/apache/storm/scheduler/utils/ArtifactoryConfigLoaderTest.java:38
Methodcreate_sequential
(String path, byte[] data, List<ACL> acls)
storm-client/src/jvm/org/apache/storm/cluster/ZKStateStorage.java:108
Methodcreate_sequential
(String path, byte[] data, List<ACL> acls)
storm-client/src/jvm/org/apache/storm/cluster/PaceMakerStateStorage.java:62
MethodcreatedZNodes
()
storm-client/test/jvm/org/apache/storm/cluster/StormClusterStateImplTest.java:55
Methodcredentials
(String stormId, Runnable callback)
storm-client/src/jvm/org/apache/storm/cluster/StormClusterStateImpl.java:829
MethodcredentialsChanged
(Credentials credentials)
storm-client/src/jvm/org/apache/storm/executor/ExecutorShutdown.java:61
MethodcurrentSubjectReturnsNullWhenNoneSet
()
storm-client/test/jvm/org/apache/storm/security/auth/SubjectCompatTest.java:26
Functioncygpath
(x)
bin/storm.py:52
MethoddaemonLog
Handles '/daemonlog' request.
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/webapp/LogviewerResource.java:151
Methoddays
Returns a {@link Duration} corresponding to the the given value in days. @param days the number of days @return the Duration
storm-client/src/jvm/org/apache/storm/topology/base/BaseWindowedBolt.java:331
Functiondeactivate
(args)
bin/storm.py:1139
Methoddeactivate
Deactivate a topology. @param topologyName the name of the topology to deactivate @throws TException on any error from nimbus
storm-client/src/jvm/org/apache/storm/ILocalCluster.java:98
Methoddeactivate
()
storm-client/src/jvm/org/apache/storm/spout/ShellSpout.java:246
Methoddeactivate
()
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchTriggerer.java:75
Methoddeactivate
()
storm-client/src/jvm/org/apache/storm/trident/topology/MasterBatchCoordinator.java:76
Methoddeactivate
(java.lang.String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:198
Methoddeactivate
(java.lang.String name)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:471
Methoddeactivate
(java.lang.String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:2074
Methoddeactivate
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:4166
Methoddeactivate
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:6522
Methoddeactivate
()
storm-client/src/jvm/org/apache/storm/topology/base/BaseRichSpout.java:30
Methoddeactivate
()
storm-client/src/jvm/org/apache/storm/testing/FixedTupleSpout.java:159
Methoddeactivate
Parameters: - name
storm-client/src/py/storm/Nimbus.py:89
Methoddeactivate
Parameters: - name
storm-client/src/py/storm/Nimbus.py:703
Methoddeactivate
(String topologyName)
storm-server/src/main/java/org/apache/storm/LocalCluster.java:541
Methoddeactivate
()
storm-clojure/src/main/java/org/apache/storm/clojure/ClojureSpout.java:149
Methoddeactivate
()
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordSpout.java:86
Methoddeactivate
()
examples/storm-jdbc-examples/src/main/java/org/apache/storm/jdbc/spout/UserSpout.java:91
Methoddeactivate
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java:642
Methoddeactivate_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:15836
Methoddeactivate_call
(java.lang.String name, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.stor
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:2084
Methoddeactivate_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:16219
Methoddebug
(java.lang.String name, java.lang.String component, boolean enable, double samplingPercentage, org.apache.stor
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:206
Methoddebug
(java.lang.String name, java.lang.String component, boolean enable, double samplingPercentage)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:575
Methoddebug
(java.lang.String name, java.lang.String component, boolean enable, double samplingPercentage, org.apache.stor
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:2223
Methoddebug
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:4312
Methoddebug
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:6827
Methoddebug
Enable/disable logging the tuples generated in topology via an internal EventLogger bolt. The component name is optional and if null
storm-client/src/py/storm/Nimbus.py:123
Methoddebug
Enable/disable logging the tuples generated in topology via an internal EventLogger bolt. The component name is optional and if null
storm-client/src/py/storm/Nimbus.py:839
Methoddebug
(String name, String component, boolean enable, double samplingPercentage)
storm-server/src/main/java/org/apache/storm/LocalCluster.java:869
Methoddebug_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:19297
Methoddebug_call
(java.lang.String name, java.lang.String component, boolean enable, double samplingPercentage, org.apache.stor
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:2236
← previousnext →15,301–15,400 of 27,770, ranked by callers