Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/storm
/ functions
Functions
27,770 in github.com/apache/storm
⨍
Functions
27,770
◇
Types & classes
4,363
Method
SpoutFailInfo
(Object messageId, int spoutTaskId, Long failLatencyMs)
storm-client/src/jvm/org/apache/storm/hooks/info/SpoutFailInfo.java:25
Method
SpoutGetter
(String id)
storm-client/src/jvm/org/apache/storm/topology/TopologyBuilder.java:642
Method
SpoutHeartbeatTimerTask
(ShellSpout spout)
storm-client/src/jvm/org/apache/storm/spout/ShellSpout.java:285
Method
SpoutNode
(String streamId, Fields allOutputFields, String txid, Object spout, SpoutType type)
storm-client/src/jvm/org/apache/storm/trident/planner/SpoutNode.java:23
Method
SpoutNode
(IRichSpout spout)
storm-client/src/jvm/org/apache/storm/streams/SpoutNode.java:24
Method
SpoutOutputCollector
(ISpoutOutputCollector delegate)
storm-client/src/jvm/org/apache/storm/spout/SpoutOutputCollector.java:28
Method
SpoutOutputCollectorImpl
(ISpout spout, SpoutExecutor executor, Task taskData, MutableLong emittedC
storm-client/src/jvm/org/apache/storm/executor/spout/SpoutOutputCollectorImpl.java:51
Method
SpoutSpec
()
storm-client/src/jvm/org/apache/storm/generated/SpoutSpec.java:117
Method
SpoutStats
()
storm-client/src/jvm/org/apache/storm/generated/SpoutStats.java:136
Method
SpoutTrackOutputCollector
(SpoutOutputCollector collector)
storm-client/src/jvm/org/apache/storm/testing/SpoutTracker.java:78
Method
SpoutTracker
(IRichSpout delegate, String trackId)
storm-client/src/jvm/org/apache/storm/testing/SpoutTracker.java:33
Method
SpringJmsProvider
Constructs a <code>SpringJmsProvider</code> object given the name of a classpath resource (the spring application context file), and the bean names of
examples/storm-jms-examples/src/main/java/org/apache/storm/jms/example/SpringJmsProvider.java:55
Method
SslConf
Configuration for the ZooKeeper connection when SSL/TLS is enabled. @param conf configuration map
storm-client/src/jvm/org/apache/storm/utils/CuratorUtils.java:178
Method
Stat
(String output)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/MemoryCore.java:152
Method
Stat
(List<String> statStr)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/CpuCore.java:89
Method
StateMetric
(IStatefulObject obj)
storm-client/src/jvm/org/apache/storm/metric/api/StateMetric.java:18
Method
StateQueryProcessor
(String stateId, Fields inputFields, QueryFunction function)
storm-client/src/jvm/org/apache/storm/trident/planner/processor/StateQueryProcessor.java:40
Method
StateQueryProcessor
(StreamState<K, V> streamState)
storm-client/src/jvm/org/apache/storm/streams/processors/StateQueryProcessor.java:23
Method
StateSpec
(StateFactory stateFactory)
storm-client/src/jvm/org/apache/storm/trident/state/StateSpec.java:22
Method
StateSpoutSpec
()
storm-client/src/jvm/org/apache/storm/generated/StateSpoutSpec.java:117
Method
StatefulBoltExecutor
(IStatefulBolt<T> bolt)
storm-client/src/jvm/org/apache/storm/topology/StatefulBoltExecutor.java:49
Method
StatefulProcessorBolt
(String boltId, Graph<Node, Edge> graph, List<ProcessorNode> nodes)
storm-client/src/jvm/org/apache/storm/streams/StatefulProcessorBolt.java:38
Method
StatefulSumBolt
(String name)
examples/storm-starter/src/jvm/org/apache/storm/starter/StatefulTopology.java:91
Method
StatefulWindowManager
(WindowLifecycleListener<T> lifecycleListener)
storm-client/src/jvm/org/apache/storm/windowing/StatefulWindowManager.java:32
Method
StatefulWindowedBoltExecutor
(IStatefulWindowedBolt<T> bolt)
storm-client/src/jvm/org/apache/storm/topology/StatefulWindowedBoltExecutor.java:49
Method
StaticSingleKeyMapState
(Map map)
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentReach.java:92
Method
StaticState
(AsyncLocalizer localizer, long hbTimeoutMs, long firstHbTimeoutMs, long killSleepMs, long
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:1172
Method
StoreBasedTridentWindowManager
(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator,
storm-client/src/jvm/org/apache/storm/trident/windowing/StoreBasedTridentWindowManager.java:45
Function
Storm
()
storm-multilang/javascript/src/main/resources/resources/storm.js:27
Method
StormApiResource
(StormMetricsRegistry metricsRegistry)
storm-webapp/src/main/java/org/apache/storm/daemon/ui/resources/StormApiResource.java:81
Method
StormBase
()
storm-client/src/jvm/org/apache/storm/generated/StormBase.java:196
Method
StormBoundedExponentialBackoffRetry
The class provides generic exponential-linear backoff retry strategy for storm. It calculates threshold for exponentially increasing sleeptime for ret
storm-client/src/jvm/org/apache/storm/utils/StormBoundedExponentialBackoffRetry.java:34
Method
StormClientHandler
(Client client, AtomicBoolean[] remoteBpStatus, Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/messaging/netty/StormClientHandler.java:33
Method
StormClientPipelineFactory
(Client client, AtomicBoolean[] remoteBpStatus, Map<String, Object> conf, SslCo
storm-client/src/jvm/org/apache/storm/messaging/netty/StormClientPipelineFactory.java:30
Method
StormCluster
()
integration-test/src/test/java/org/apache/storm/st/wrapper/StormCluster.java:48
Method
StormClusterStateImpl
(IStateStorage stateStorage, ILocalAssignmentsBackend assignmentsassignmentsBackend,
storm-client/src/jvm/org/apache/storm/cluster/StormClusterStateImpl.java:76
Method
StormCommonInstaller
(StormCommon instance)
storm-server/src/main/java/org/apache/storm/utils/StormCommonInstaller.java:27
Method
StormServerHandler
(IServer server)
storm-client/src/jvm/org/apache/storm/messaging/netty/StormServerHandler.java:31
Method
StormServerPipelineFactory
(Map<String, Object> topoConf, Server server, SslContext sslContext)
storm-client/src/jvm/org/apache/storm/messaging/netty/StormServerPipelineFactory.java:31
Method
StormTimer
Makes a Timer in the form of a StormTimerTask Object. @param name name of the timer @param onKill function to call when timer is killed unexpectedl
storm-client/src/jvm/org/apache/storm/StormTimer.java:39
Method
StormTopology
()
storm-client/src/jvm/org/apache/storm/generated/StormTopology.java:188
Method
Stream
(TridentTopology topology, String name, Node node)
storm-client/src/jvm/org/apache/storm/trident/Stream.java:103
Method
Stream
(StreamBuilder streamBuilder, Node node)
storm-client/src/jvm/org/apache/storm/streams/Stream.java:69
Method
StreamBuilder
Creates a new {@link StreamBuilder}.
storm-client/src/jvm/org/apache/storm/streams/StreamBuilder.java:69
Method
StreamInfo
()
storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java:120
Method
StreamOverrideCollector
(SpoutOutputCollector collector)
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchTriggerer.java:137
Method
StreamRedirect
(InputStream in, OutputStream out)
flux/flux-core/src/test/java/org/apache/storm/flux/multilang/MultilangEnvironmentTest.java:55
Method
StreamState
(PairStream<K, V> stream)
storm-client/src/jvm/org/apache/storm/streams/StreamState.java:26
Method
StreamUtil
()
storm-webapp/src/main/java/org/apache/storm/daemon/utils/StreamUtil.java:28
Method
StringGenSpout
(int strLen)
examples/storm-perf/src/main/java/org/apache/storm/perf/spout/StringGenSpout.java:47
Method
StringMetadata
Constructor for StringMetadata. @param metadataType the type of metadata string @param stringId the unique id for the metadata string @param
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/StringMetadata.java:32
Method
StringMetadataCache
Constructor to create a cache. @param dbWriter The rocks db writer instance the cache should use when evicting data @param capacity The cache size
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/StringMetadataCache.java:48
Method
StringValidator
()
storm-client/src/jvm/org/apache/storm/validation/ConfigValidation.java:345
Method
StubTuple
(final Map<String, Object> values)
external/storm-redis/src/test/java/org/apache/storm/redis/util/StubTuple.java:36
Method
SubSystem
(SubSystemType type, int hierarchyId, int cgroupNum, boolean enable)
storm-client/src/jvm/org/apache/storm/container/cgroup/SubSystem.java:29
Method
SubjectCompat
()
storm-client/src/jvm/org/apache/storm/security/auth/SubjectCompat.java:44
Method
SubmitOptions
()
storm-client/src/jvm/org/apache/storm/generated/SubmitOptions.java:122
Method
SubmitterHookException
()
storm-client/src/jvm/org/apache/storm/hooks/SubmitterHookException.java:27
Method
SubstringSearchResult
(List<Map<String, Object>> matches, Integer newByteOffset, byte[] newBeforeBytes)
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogSearchHandler.java:808
Method
SubtopologyBolt
(DefaultDirectedGraph<Node, IndexedEdge> graph, Set<Node> nodes, Map<Node, String> batchGroups)
storm-client/src/jvm/org/apache/storm/trident/planner/SubtopologyBolt.java:56
Method
Supervisor
(ISupervisor iSupervisor, StormMetricsRegistry metricsRegistry)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java:128
Method
SupervisorAssignments
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorAssignments.java:113
Method
SupervisorClient
(Map conf, ThriftConnectionType type, String host, Integer port, String asUser)
storm-client/src/jvm/org/apache/storm/utils/SupervisorClient.java:82
Method
SupervisorDetails
Create the details of a new supervisor. @param id the ID as reported by the supervisor. @param serverPort the thrift server for the supervisor. @param
storm-server/src/main/java/org/apache/storm/scheduler/SupervisorDetails.java:60
Method
SupervisorDistribution
(int supervisorCnt, String rackId, int slotCnt, int memoryMb, int cpuPercent)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestLargeCluster.java:462
Method
SupervisorHealthCheck
(Supervisor supervisor)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/timer/SupervisorHealthCheck.java:31
Method
SupervisorHeartbeat
(Map<String, Object> conf, Supervisor supervisor)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/timer/SupervisorHeartbeat.java:47
Method
SupervisorInfo
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java:184
Method
SupervisorInfo
(String srcSupervisorHost, String srcSupervisorId, long timestamp)
storm-server/src/main/java/org/apache/storm/metric/api/IClusterMetricsConsumer.java:43
Method
SupervisorPageInfo
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorPageInfo.java:120
Method
SupervisorResources
Constructor for a Supervisor's resources. @param totalMem the total mem on the supervisor @param totalCpu the total CPU on the supervisor @param tota
storm-server/src/main/java/org/apache/storm/scheduler/SupervisorResources.java:45
Method
SupervisorSummary
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:208
Method
SupervisorWorkerHeartbeat
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeat.java:127
Method
SupervisorWorkerHeartbeats
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeats.java:118
Method
SynchronizeAssignments
Constructor. @param supervisor {@link Supervisor} @param assignments {@link SupervisorAssignments} @param readClusterState {@link ReadClusterState}
storm-server/src/main/java/org/apache/storm/daemon/supervisor/timer/SynchronizeAssignments.java:53
Method
Syscall
(List<String> names, String action, List<SeccompArg> args)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1241
Method
TBackoffConnect
(int retryTimes, int retryInterval, int retryIntervalCeiling, boolean retryForever)
storm-client/src/jvm/org/apache/storm/security/auth/TBackoffConnect.java:29
Method
TEST_CLUSTER_NAME
(String clusterName)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestLargeCluster.java:85
Method
TTlsWrapProcessor
(TProcessor wrapped, boolean clientAuthRequired)
storm-client/src/jvm/org/apache/storm/security/auth/tls/TlsTransportPlugin.java:135
Method
TUGIAssumingTransportFactory
(TTransportFactory wrapped, Subject subject)
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/KerberosSaslTransportPlugin.java:250
Method
TUGIWrapProcessor
(TProcessor wrapped)
storm-client/src/jvm/org/apache/storm/security/auth/sasl/SaslTransportPlugin.java:122
Method
Task
(Executor executor, Integer taskId)
storm-client/src/jvm/org/apache/storm/daemon/Task.java:75
Method
TaskBundle
(IBolt task, int componentId)
storm-core/src/jvm/org/apache/storm/planner/TaskBundle.java:23
Method
TaskInfo
()
storm-client/src/jvm/org/apache/storm/metric/api/IMetricsConsumer.java:37
Method
TaskMessage
(int task, byte[] message)
storm-client/src/jvm/org/apache/storm/messaging/TaskMessage.java:21
Method
TaskMetricDimensions
(int taskId, String componentId, String streamId, StormMetricRegistry metricRegistry)
storm-client/src/jvm/org/apache/storm/metrics2/TaskMetricDimensions.java:27
Method
TaskMetrics
(WorkerTopologyContext context, String componentId, Integer taskid, StormMetricRegistry
storm-client/src/jvm/org/apache/storm/metrics2/TaskMetrics.java:45
Method
TaskStream
()
storm-client/src/jvm/org/apache/storm/topology/StatefulWindowedBoltExecutor.java:340
Method
TestAcceptedStrings
()
storm-client/test/jvm/org/apache/storm/TestConfigValidate.java:716
Method
TestAutoSSL
(String newDir)
storm-client/test/jvm/org/apache/storm/security/auth/AutoSSLTest.java:124
Method
TestBadSlot
(boolean blacklistOnBadSlot)
storm-server/src/test/java/org/apache/storm/scheduler/blacklist/TestBlacklistScheduler.java:232
Method
TestBadSupervisor
()
storm-server/src/test/java/org/apache/storm/scheduler/blacklist/TestBlacklistScheduler.java:199
Method
TestBolt
(TestEnum te)
flux/flux-core/src/test/java/org/apache/storm/flux/test/TestBolt.java:73
Method
TestClass
(String field)
flux/flux-core/src/test/java/org/apache/storm/flux/test/TestBolt.java:43
Method
TestConfBolt
()
storm-client/src/jvm/org/apache/storm/testing/TestConfBolt.java:29
Method
TestConstraintSolverStrategy
()
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestConstraintSolverStrategy.java:83
Method
TestDNSToSwitchMapping
(Map<String, SupervisorDetails> ... racks)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestDefaultResourceAwareStrategy.java:117
Method
TestDNSToSwitchMapping
(Map<String, SupervisorDetails>... racks)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestRoundRobinNodeSorterHostIsolation.java:79
Method
TestDNSToSwitchMapping
(Map<String, SupervisorDetails>... racks)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/TestNodeSorterHostProximity.java:94
Method
TestDNSToSwitchMapping
(Map<String, SupervisorDetails>... racks)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/TestRoundRobinNodeSorterHostProximity.java:98
← previous
next →
12,501–12,600 of 27,770, ranked by callers