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
Processor
(I iface)
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:295
Method
Processor
(I iface)
storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java:156
Method
Processor
(I iface)
storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java:349
Method
ProcessorBolt
(String id, Graph<Node, Edge> graph, List<ProcessorNode> nodes)
storm-client/src/jvm/org/apache/storm/streams/ProcessorBolt.java:31
Method
ProcessorBoltDelegate
(String id, Graph<Node, Edge> graph, List<ProcessorNode> nodes)
storm-client/src/jvm/org/apache/storm/streams/ProcessorBoltDelegate.java:60
Method
ProcessorContext
(Object batchId, Object[] state)
storm-client/src/jvm/org/apache/storm/trident/planner/ProcessorContext.java:20
Method
ProcessorNode
(String streamId, String name, Fields allOutputFields, Fields selfOutFields, TridentProcessor processor)
storm-client/src/jvm/org/apache/storm/trident/planner/ProcessorNode.java:23
Method
ProcessorNode
(Processor<?> processor, String outputStream, Fields outputFields, boolean preservesKey)
storm-client/src/jvm/org/apache/storm/streams/ProcessorNode.java:33
Method
Prod
(MpscArrayQueue<Object> queue)
examples/storm-perf/src/main/java/org/apache/storm/perf/toolstest/Prod.java:26
Method
Prod2
(MpscArrayQueue<Object> q1, MpscArrayQueue<Object> q2)
examples/storm-perf/src/main/java/org/apache/storm/perf/toolstest/Prod2.java:30
Method
Producer
(JCQueue queue)
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Producer.java:26
Method
Producer2
(JCQueue q1, JCQueue q2)
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Producer2.java:30
Method
ProfileAction
(int value)
storm-client/src/jvm/org/apache/storm/generated/ProfileAction.java:38
Method
ProfileRequest
()
storm-client/src/jvm/org/apache/storm/generated/ProfileRequest.java:131
Method
ProjectedProcessor
(Fields projectFields)
storm-client/src/jvm/org/apache/storm/trident/planner/processor/ProjectedProcessor.java:31
Method
ProjectionFactory
(Factory parent, Fields projectFields)
storm-client/src/jvm/org/apache/storm/trident/tuple/TridentTupleView.java:204
Method
PrometheusReporterClient
Creates a new {@link PrometheusReporterClient} instance. @param registry the {@link MetricRegistry} containing the metrics this r
external/storm-metrics-prometheus/src/main/java/org/apache/storm/metrics/prometheus/PrometheusReporterClient.java:55
Method
PythonShellMetricsBolt
(String[] args)
storm-client/src/jvm/org/apache/storm/testing/PythonShellMetricsBolt.java:32
Method
PythonShellMetricsSpout
(String[] command)
storm-client/src/jvm/org/apache/storm/testing/PythonShellMetricsSpout.java:33
Method
QueueEntry
(Long endTimeMs, Runnable func, String id)
storm-client/src/jvm/org/apache/storm/StormTimer.java:188
Method
RLimits
(String type, long soft, long hard)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:366
Method
RandomNumberGeneratorSpout
(Fields fields, int batchSize, int maxNumber)
examples/storm-starter/src/jvm/org/apache/storm/starter/spout/RandomNumberGeneratorSpout.java:36
Method
RandomSentence
()
examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopologyNode.java:73
Function
RandomSentenceSpout
(sentences)
flux/flux-wrappers/src/main/resources/resources/randomsentence.js:36
Function
RandomSentenceSpout
(sentences)
examples/storm-starter/multilang/resources/randomsentence.js:36
Method
RankableObjectWithFields
(Object obj, long count, Object... otherFields)
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/RankableObjectWithFields.java:35
Method
Rankings
()
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/Rankings.java:29
Method
RasNode
Create a new node. @param nodeId the id of the node. @param sup the supervisor this is for. @param cluster the cluster this is a part of. @param worke
storm-server/src/main/java/org/apache/storm/scheduler/resource/RasNode.java:68
Method
RasNodes
(Cluster cluster)
storm-server/src/main/java/org/apache/storm/scheduler/resource/RasNodes.java:40
Method
RateCounter
(StormMetricRegistry metricRegistry, String metricName, String topologyId, String componentId,
storm-client/src/jvm/org/apache/storm/metrics2/RateCounter.java:29
Method
RateTracker
Constructor. @param validTimeWindowInMils events that happened before validTimeWindowInMils are not considered when reporting the rate. @param numBuc
storm-client/src/jvm/org/apache/storm/metric/internal/RateTracker.java:41
Method
Rdma
(int hcaHandles, int hcaObjects)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1154
Method
ReadClusterState
(Supervisor supervisor)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/ReadClusterState.java:74
Method
ReadOnlyZookeeper
(String connectionString, int timeout, Watcher watcher)
storm-core/src/jvm/org/apache/storm/shade/org/apache/zookeeper/ZkCli.java:102
Method
ReadableBlobMeta
()
storm-client/src/jvm/org/apache/storm/generated/ReadableBlobMeta.java:119
Method
RebalanceOptions
()
storm-client/src/jvm/org/apache/storm/generated/RebalanceOptions.java:155
Method
Record
(char type, Device device, int accesses)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/DevicesCore.java:72
Method
RedisClusterContainer
Constructor. @param jedisCluster JedisCluster instance
external/storm-redis/src/main/java/org/apache/storm/redis/common/container/RedisClusterContainer.java:38
Method
RedisClusterMapState
Constructor. @param jedisCluster JedisCluster @param options options of State @param serializer Serializer @param keyFactory KeyFactory
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterMapState.java:59
Method
RedisClusterState
Constructor. @param jedisCluster JedisCluster
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterState.java:36
Method
RedisClusterStateQuerier
Constructor. @param lookupMapper mapper for querying
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterStateQuerier.java:31
Method
RedisClusterStateUpdater
Constructor. @param storeMapper mapper for storing
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterStateUpdater.java:31
Method
RedisCommandsAdapterJedis
(Jedis resource)
external/storm-redis/src/main/java/org/apache/storm/redis/common/adapter/RedisCommandsAdapterJedis.java:35
Method
RedisCommandsAdapterJedisCluster
(JedisCluster jedisCluster)
external/storm-redis/src/main/java/org/apache/storm/redis/common/adapter/RedisCommandsAdapterJedisCluster.java:36
Method
RedisContainer
Constructor. @param jedisPool JedisPool which actually manages Jedis instances
external/storm-redis/src/main/java/org/apache/storm/redis/common/container/RedisContainer.java:39
Method
RedisDataTypeDescription
Constructor. @param dataType data type
external/storm-redis/src/main/java/org/apache/storm/redis/common/mapper/RedisDataTypeDescription.java:28
Method
RedisFilterBolt
Constructor for single Redis environment (JedisPool). @param config configuration for initializing JedisPool @param filterMapper mapper containing whi
external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisFilterBolt.java:52
Method
RedisKeyValueState
(String namespace)
external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueState.java:63
Method
RedisKeyValueStateIterator
Constructor. @param namespace The namespace of State @param container The instance of RedisCommandsInstanceContainer @param pendingPrepareIterator Th
external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueStateIterator.java:52
Method
RedisLookupBolt
Constructor for single Redis environment (JedisPool). @param config configuration for initializing JedisPool @param lookupMapper mapper containing whi
external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisLookupBolt.java:40
Method
RedisMapState
Constructor. @param jedisPool JedisPool @param options options of State @param serializer Serializer @param keyFactory KeyFactory
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java:57
Method
RedisState
Constructor. @param jedisPool JedisPool
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisState.java:34
Method
RedisStateQuerier
Constructor. @param lookupMapper mapper for querying
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisStateQuerier.java:30
Method
RedisStateUpdater
Constructor. @param storeMapper mapper for storing
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisStateUpdater.java:32
Method
RedisStoreBolt
Constructor for single Redis environment (JedisPool). @param config configuration for initializing JedisPool @param storeMapper mapper containing whic
external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisStoreBolt.java:38
Method
ReduceByKeyProcessor
(Reducer<V> reducer)
storm-client/src/jvm/org/apache/storm/streams/processors/ReduceByKeyProcessor.java:24
Method
ReduceProcessor
(Reducer<T> reducer)
storm-client/src/jvm/org/apache/storm/streams/processors/ReduceProcessor.java:21
Method
ReducedMetric
(IReducer reducer)
storm-client/src/jvm/org/apache/storm/metric/api/ReducedMetric.java:19
Method
ReducedShellMetric
(IReducer reducer)
storm-client/src/jvm/org/apache/storm/metric/api/rpc/ReducedShellMetric.java:20
Method
ReducerAggStateUpdater
(ReducerAggregator agg)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/ReducerAggStateUpdater.java:29
Method
ReducerAggregatorImpl
(ReducerAggregator agg)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/ReducerAggregatorImpl.java:26
Method
ReducerValueUpdater
(ReducerAggregator agg, List<TridentTuple> tuples)
storm-client/src/jvm/org/apache/storm/trident/state/ReducerValueUpdater.java:23
Method
RefCountedTuple
(Tuple tuple)
storm-client/src/jvm/org/apache/storm/streams/RefCountedTuple.java:26
Method
ReflectionUtilsInstaller
(ReflectionUtils instance)
storm-core/test/jvm/org/apache/storm/utils/staticmocking/ReflectionUtilsInstaller.java:28
Method
ReloadableSslContextFactory
()
storm-webapp/src/main/java/org/apache/storm/daemon/common/ReloadableSslContextFactory.java:36
Method
ReloadableX509KeyManager
(String keystorePath, String keystorePassword)
storm-client/src/jvm/org/apache/storm/security/auth/tls/ReloadableX509KeyManager.java:50
Method
ReloadableX509TrustManager
(String trustStorePath, String trustStorePassword)
storm-client/src/jvm/org/apache/storm/security/auth/tls/ReloadableX509TrustManager.java:37
Method
RemoveMetricFilter
(Set<Metric> toRemove)
storm-client/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java:473
Method
RenameException
(Path oldFile, Path newFile)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java:824
Method
ReplaceUpdater
(T t)
storm-client/src/jvm/org/apache/storm/trident/state/map/OpaqueMap.java:109
Method
ReportError
(Map<String, Object> topoConf, IStormClusterState stormClusterState, String stormId, String componentId,
storm-client/src/jvm/org/apache/storm/executor/error/ReportError.java:42
Method
ReportErrorAndDie
(IReportError reportError, Runnable suicideFn)
storm-client/src/jvm/org/apache/storm/executor/error/ReportErrorAndDie.java:24
Method
ReportWorkerHeartbeats
(Map<String, Object> conf, Supervisor supervisor)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/timer/ReportWorkerHeartbeats.java:40
Method
ReportedFailedException
()
storm-client/src/jvm/org/apache/storm/topology/ReportedFailedException.java:16
Method
ReqContext
()
storm-client/src/jvm/org/apache/storm/security/auth/ReqContext.java:48
Method
ReqContextFilter
(IHttpCredentialsPlugin httpCredsHandler)
storm-webapp/src/main/java/org/apache/storm/daemon/drpc/webapp/ReqContextFilter.java:42
Method
ResourceAuthorizer
Constuctor. @param stormConf storm configuration
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/utils/ResourceAuthorizer.java:59
Method
ResourceInitializingWorkerHook
(Map<String, String> resourceMap)
storm-core/test/jvm/org/apache/storm/integration/TopologyIntegrationTest.java:853
Method
ResourceMetrics
(StormMetricsRegistry metricsRegistry)
storm-server/src/main/java/org/apache/storm/scheduler/resource/normalization/ResourceMetrics.java:26
Method
ResourceNameNormalizer
Creates a new resource name normalizer.
storm-server/src/main/java/org/apache/storm/scheduler/resource/normalization/ResourceNameNormalizer.java:36
Method
Resources
(List<Device> device, Memory memory, Cpu cpu,
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:732
Method
ResultRecord
(Tuple tuple, boolean generateOutputFields)
storm-client/src/jvm/org/apache/storm/bolt/JoinBolt.java:556
Method
RetVal
(T v, boolean c)
storm-client/src/jvm/org/apache/storm/trident/state/map/CachedBatchReadsMap.java:65
Method
RetrySchedule
(KafkaSpoutMessageId msgId, long nextRetryTimeNanos)
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java:76
Method
RichShellBolt
(String[] command, Map<String, StreamInfo> outputs)
storm-clojure/src/main/java/org/apache/storm/clojure/RichShellBolt.java:32
Method
RichShellSpout
(String[] command, Map<String, StreamInfo> outputs)
storm-clojure/src/main/java/org/apache/storm/clojure/RichShellSpout.java:32
Method
RichSpoutBatchExecutor
(IRichSpout spout)
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchExecutor.java:34
Method
RichSpoutBatchId
(long id)
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchId.java:18
Method
RichSpoutBatchTriggerer
(IRichSpout delegate, String streamName, String batchGroup)
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchTriggerer.java:47
Method
RichSpoutEmitter
(Map<String, Object> conf, TopologyContext context)
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchExecutor.java:132
Method
RocksDbKey
Constructor for a RocksDB key for a metadata string. @param type type of metadata string @param metadataStringId the string Id for the string (stor
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbKey.java:68
Method
RocksDbMetricsWriter
Constructor for the RocksDbMetricsWriter. @param store The RocksDB store @param queue The queue to receive metrics for insertion
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbMetricsWriter.java:71
Method
RocksDbValue
Constructor from raw data. @param value the raw bytes representing the key
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbValue.java:57
Method
RollingCountBolt
()
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/RollingCountBolt.java:67
Method
RollingTopWords
()
examples/storm-starter/src/jvm/org/apache/storm/starter/RollingTopWords.java:36
Method
RootFactory
(Fields inputFields)
storm-client/src/jvm/org/apache/storm/trident/tuple/TridentTupleView.java:328
Method
RotatingMap
(int numBuckets, ExpiredCallback<K, V> callback)
storm-client/src/jvm/org/apache/storm/utils/RotatingMap.java:38
Method
RotatingTransactionalState
(TransactionalState state, String subdir)
storm-client/src/jvm/org/apache/storm/trident/topology/state/RotatingTransactionalState.java:30
Method
RoundRobinResourceAwareStrategy
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/RoundRobinResourceAwareStrategy.java:39
Method
RoundRobinSlotScheduler
Create a new scheduler for a given topology. @param td the topology to schedule @param slotsToUse the number of slots to use for the executors left to
storm-server/src/main/java/org/apache/storm/scheduler/multitenant/NodePool.java:197
← previous
next →
12,301–12,400 of 27,770, ranked by callers