MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

MethodSpoutFailInfo
(Object messageId, int spoutTaskId, Long failLatencyMs)
storm-client/src/jvm/org/apache/storm/hooks/info/SpoutFailInfo.java:25
MethodSpoutGetter
(String id)
storm-client/src/jvm/org/apache/storm/topology/TopologyBuilder.java:642
MethodSpoutHeartbeatTimerTask
(ShellSpout spout)
storm-client/src/jvm/org/apache/storm/spout/ShellSpout.java:285
MethodSpoutNode
(String streamId, Fields allOutputFields, String txid, Object spout, SpoutType type)
storm-client/src/jvm/org/apache/storm/trident/planner/SpoutNode.java:23
MethodSpoutNode
(IRichSpout spout)
storm-client/src/jvm/org/apache/storm/streams/SpoutNode.java:24
MethodSpoutOutputCollector
(ISpoutOutputCollector delegate)
storm-client/src/jvm/org/apache/storm/spout/SpoutOutputCollector.java:28
MethodSpoutOutputCollectorImpl
(ISpout spout, SpoutExecutor executor, Task taskData, MutableLong emittedC
storm-client/src/jvm/org/apache/storm/executor/spout/SpoutOutputCollectorImpl.java:51
MethodSpoutSpec
()
storm-client/src/jvm/org/apache/storm/generated/SpoutSpec.java:117
MethodSpoutStats
()
storm-client/src/jvm/org/apache/storm/generated/SpoutStats.java:136
MethodSpoutTrackOutputCollector
(SpoutOutputCollector collector)
storm-client/src/jvm/org/apache/storm/testing/SpoutTracker.java:78
MethodSpoutTracker
(IRichSpout delegate, String trackId)
storm-client/src/jvm/org/apache/storm/testing/SpoutTracker.java:33
MethodSpringJmsProvider
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
MethodSslConf
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
MethodStat
(String output)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/MemoryCore.java:152
MethodStat
(List<String> statStr)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/CpuCore.java:89
MethodStateMetric
(IStatefulObject obj)
storm-client/src/jvm/org/apache/storm/metric/api/StateMetric.java:18
MethodStateQueryProcessor
(String stateId, Fields inputFields, QueryFunction function)
storm-client/src/jvm/org/apache/storm/trident/planner/processor/StateQueryProcessor.java:40
MethodStateQueryProcessor
(StreamState<K, V> streamState)
storm-client/src/jvm/org/apache/storm/streams/processors/StateQueryProcessor.java:23
MethodStateSpec
(StateFactory stateFactory)
storm-client/src/jvm/org/apache/storm/trident/state/StateSpec.java:22
MethodStateSpoutSpec
()
storm-client/src/jvm/org/apache/storm/generated/StateSpoutSpec.java:117
MethodStatefulBoltExecutor
(IStatefulBolt<T> bolt)
storm-client/src/jvm/org/apache/storm/topology/StatefulBoltExecutor.java:49
MethodStatefulProcessorBolt
(String boltId, Graph<Node, Edge> graph, List<ProcessorNode> nodes)
storm-client/src/jvm/org/apache/storm/streams/StatefulProcessorBolt.java:38
MethodStatefulSumBolt
(String name)
examples/storm-starter/src/jvm/org/apache/storm/starter/StatefulTopology.java:91
MethodStatefulWindowManager
(WindowLifecycleListener<T> lifecycleListener)
storm-client/src/jvm/org/apache/storm/windowing/StatefulWindowManager.java:32
MethodStatefulWindowedBoltExecutor
(IStatefulWindowedBolt<T> bolt)
storm-client/src/jvm/org/apache/storm/topology/StatefulWindowedBoltExecutor.java:49
MethodStaticSingleKeyMapState
(Map map)
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentReach.java:92
MethodStaticState
(AsyncLocalizer localizer, long hbTimeoutMs, long firstHbTimeoutMs, long killSleepMs, long
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:1172
MethodStoreBasedTridentWindowManager
(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore, Aggregator aggregator,
storm-client/src/jvm/org/apache/storm/trident/windowing/StoreBasedTridentWindowManager.java:45
FunctionStorm
()
storm-multilang/javascript/src/main/resources/resources/storm.js:27
MethodStormApiResource
(StormMetricsRegistry metricsRegistry)
storm-webapp/src/main/java/org/apache/storm/daemon/ui/resources/StormApiResource.java:81
MethodStormBase
()
storm-client/src/jvm/org/apache/storm/generated/StormBase.java:196
MethodStormBoundedExponentialBackoffRetry
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
MethodStormClientHandler
(Client client, AtomicBoolean[] remoteBpStatus, Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/messaging/netty/StormClientHandler.java:33
MethodStormClientPipelineFactory
(Client client, AtomicBoolean[] remoteBpStatus, Map<String, Object> conf, SslCo
storm-client/src/jvm/org/apache/storm/messaging/netty/StormClientPipelineFactory.java:30
MethodStormCluster
()
integration-test/src/test/java/org/apache/storm/st/wrapper/StormCluster.java:48
MethodStormClusterStateImpl
(IStateStorage stateStorage, ILocalAssignmentsBackend assignmentsassignmentsBackend,
storm-client/src/jvm/org/apache/storm/cluster/StormClusterStateImpl.java:76
MethodStormCommonInstaller
(StormCommon instance)
storm-server/src/main/java/org/apache/storm/utils/StormCommonInstaller.java:27
MethodStormServerHandler
(IServer server)
storm-client/src/jvm/org/apache/storm/messaging/netty/StormServerHandler.java:31
MethodStormServerPipelineFactory
(Map<String, Object> topoConf, Server server, SslContext sslContext)
storm-client/src/jvm/org/apache/storm/messaging/netty/StormServerPipelineFactory.java:31
MethodStormTimer
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
MethodStormTopology
()
storm-client/src/jvm/org/apache/storm/generated/StormTopology.java:188
MethodStream
(TridentTopology topology, String name, Node node)
storm-client/src/jvm/org/apache/storm/trident/Stream.java:103
MethodStream
(StreamBuilder streamBuilder, Node node)
storm-client/src/jvm/org/apache/storm/streams/Stream.java:69
MethodStreamBuilder
Creates a new {@link StreamBuilder}.
storm-client/src/jvm/org/apache/storm/streams/StreamBuilder.java:69
MethodStreamInfo
()
storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java:120
MethodStreamOverrideCollector
(SpoutOutputCollector collector)
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchTriggerer.java:137
MethodStreamRedirect
(InputStream in, OutputStream out)
flux/flux-core/src/test/java/org/apache/storm/flux/multilang/MultilangEnvironmentTest.java:55
MethodStreamState
(PairStream<K, V> stream)
storm-client/src/jvm/org/apache/storm/streams/StreamState.java:26
MethodStreamUtil
()
storm-webapp/src/main/java/org/apache/storm/daemon/utils/StreamUtil.java:28
MethodStringGenSpout
(int strLen)
examples/storm-perf/src/main/java/org/apache/storm/perf/spout/StringGenSpout.java:47
MethodStringMetadata
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
MethodStringMetadataCache
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
MethodStringValidator
()
storm-client/src/jvm/org/apache/storm/validation/ConfigValidation.java:345
MethodStubTuple
(final Map<String, Object> values)
external/storm-redis/src/test/java/org/apache/storm/redis/util/StubTuple.java:36
MethodSubSystem
(SubSystemType type, int hierarchyId, int cgroupNum, boolean enable)
storm-client/src/jvm/org/apache/storm/container/cgroup/SubSystem.java:29
MethodSubjectCompat
()
storm-client/src/jvm/org/apache/storm/security/auth/SubjectCompat.java:44
MethodSubmitOptions
()
storm-client/src/jvm/org/apache/storm/generated/SubmitOptions.java:122
MethodSubmitterHookException
()
storm-client/src/jvm/org/apache/storm/hooks/SubmitterHookException.java:27
MethodSubstringSearchResult
(List<Map<String, Object>> matches, Integer newByteOffset, byte[] newBeforeBytes)
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogSearchHandler.java:808
MethodSubtopologyBolt
(DefaultDirectedGraph<Node, IndexedEdge> graph, Set<Node> nodes, Map<Node, String> batchGroups)
storm-client/src/jvm/org/apache/storm/trident/planner/SubtopologyBolt.java:56
MethodSupervisor
(ISupervisor iSupervisor, StormMetricsRegistry metricsRegistry)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java:128
MethodSupervisorAssignments
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorAssignments.java:113
MethodSupervisorClient
(Map conf, ThriftConnectionType type, String host, Integer port, String asUser)
storm-client/src/jvm/org/apache/storm/utils/SupervisorClient.java:82
MethodSupervisorDetails
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
MethodSupervisorDistribution
(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
MethodSupervisorHealthCheck
(Supervisor supervisor)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/timer/SupervisorHealthCheck.java:31
MethodSupervisorHeartbeat
(Map<String, Object> conf, Supervisor supervisor)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/timer/SupervisorHeartbeat.java:47
MethodSupervisorInfo
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java:184
MethodSupervisorInfo
(String srcSupervisorHost, String srcSupervisorId, long timestamp)
storm-server/src/main/java/org/apache/storm/metric/api/IClusterMetricsConsumer.java:43
MethodSupervisorPageInfo
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorPageInfo.java:120
MethodSupervisorResources
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
MethodSupervisorSummary
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:208
MethodSupervisorWorkerHeartbeat
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeat.java:127
MethodSupervisorWorkerHeartbeats
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeats.java:118
MethodSynchronizeAssignments
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
MethodSyscall
(List<String> names, String action, List<SeccompArg> args)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1241
MethodTBackoffConnect
(int retryTimes, int retryInterval, int retryIntervalCeiling, boolean retryForever)
storm-client/src/jvm/org/apache/storm/security/auth/TBackoffConnect.java:29
MethodTEST_CLUSTER_NAME
(String clusterName)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestLargeCluster.java:85
MethodTTlsWrapProcessor
(TProcessor wrapped, boolean clientAuthRequired)
storm-client/src/jvm/org/apache/storm/security/auth/tls/TlsTransportPlugin.java:135
MethodTUGIAssumingTransportFactory
(TTransportFactory wrapped, Subject subject)
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/KerberosSaslTransportPlugin.java:250
MethodTUGIWrapProcessor
(TProcessor wrapped)
storm-client/src/jvm/org/apache/storm/security/auth/sasl/SaslTransportPlugin.java:122
MethodTask
(Executor executor, Integer taskId)
storm-client/src/jvm/org/apache/storm/daemon/Task.java:75
MethodTaskBundle
(IBolt task, int componentId)
storm-core/src/jvm/org/apache/storm/planner/TaskBundle.java:23
MethodTaskInfo
()
storm-client/src/jvm/org/apache/storm/metric/api/IMetricsConsumer.java:37
MethodTaskMessage
(int task, byte[] message)
storm-client/src/jvm/org/apache/storm/messaging/TaskMessage.java:21
MethodTaskMetricDimensions
(int taskId, String componentId, String streamId, StormMetricRegistry metricRegistry)
storm-client/src/jvm/org/apache/storm/metrics2/TaskMetricDimensions.java:27
MethodTaskMetrics
(WorkerTopologyContext context, String componentId, Integer taskid, StormMetricRegistry
storm-client/src/jvm/org/apache/storm/metrics2/TaskMetrics.java:45
MethodTaskStream
()
storm-client/src/jvm/org/apache/storm/topology/StatefulWindowedBoltExecutor.java:340
MethodTestAcceptedStrings
()
storm-client/test/jvm/org/apache/storm/TestConfigValidate.java:716
MethodTestAutoSSL
(String newDir)
storm-client/test/jvm/org/apache/storm/security/auth/AutoSSLTest.java:124
MethodTestBadSlot
(boolean blacklistOnBadSlot)
storm-server/src/test/java/org/apache/storm/scheduler/blacklist/TestBlacklistScheduler.java:232
MethodTestBadSupervisor
()
storm-server/src/test/java/org/apache/storm/scheduler/blacklist/TestBlacklistScheduler.java:199
MethodTestBolt
(TestEnum te)
flux/flux-core/src/test/java/org/apache/storm/flux/test/TestBolt.java:73
MethodTestClass
(String field)
flux/flux-core/src/test/java/org/apache/storm/flux/test/TestBolt.java:43
MethodTestConfBolt
()
storm-client/src/jvm/org/apache/storm/testing/TestConfBolt.java:29
MethodTestConstraintSolverStrategy
()
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestConstraintSolverStrategy.java:83
MethodTestDNSToSwitchMapping
(Map<String, SupervisorDetails> ... racks)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestDefaultResourceAwareStrategy.java:117
MethodTestDNSToSwitchMapping
(Map<String, SupervisorDetails>... racks)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestRoundRobinNodeSorterHostIsolation.java:79
MethodTestDNSToSwitchMapping
(Map<String, SupervisorDetails>... racks)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/TestNodeSorterHostProximity.java:94
MethodTestDNSToSwitchMapping
(Map<String, SupervisorDetails>... racks)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/TestRoundRobinNodeSorterHostProximity.java:98
← previousnext →12,501–12,600 of 27,770, ranked by callers