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
↓ 1 callers
Method
zkLeaderElectorImpl
(Map<String, Object> conf, CuratorFramework zk, BlobStore blobStore,
storm-server/src/main/java/org/apache/storm/zookeeper/Zookeeper.java:125
Method
AbstractDNSToSwitchMapping
Create an unconfigured instance.
storm-client/src/jvm/org/apache/storm/networktopography/AbstractDNSToSwitchMapping.java:33
Method
AbstractFileReader
(FileSystem fs, Path file)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/AbstractFileReader.java:23
Method
AbstractHDFSWriter
(FileRotationPolicy policy, Path path)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/AbstractHDFSWriter.java:29
Method
AbstractHDFSWriterMock
(FileRotationPolicy policy, Path path)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/TestWritersMap.java:58
Method
AbstractJdbcBolt
Constructor. <p/> @param connectionProviderParam database connection provider
external/storm-jdbc/src/main/java/org/apache/storm/jdbc/bolt/AbstractJdbcBolt.java:59
Method
AbstractRankerBolt
()
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/AbstractRankerBolt.java:45
Method
AbstractRedisBolt
Constructor for single Redis environment (JedisPool). @param config configuration for initializing JedisPool
external/storm-redis/src/main/java/org/apache/storm/redis/bolt/AbstractRedisBolt.java:57
Method
AbstractRedisStateQuerier
Constructor. @param lookupMapper mapper for querying
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/AbstractRedisStateQuerier.java:43
Method
AbstractRedisStateUpdater
Constructor. @param storeMapper mapper for storing
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/AbstractRedisStateUpdater.java:44
Method
AbstractTridentWindowManager
(WindowConfig windowConfig, String windowTaskId, WindowsStore windowStore,
storm-client/src/jvm/org/apache/storm/trident/windowing/AbstractTridentWindowManager.java:52
Method
AccessControl
()
storm-client/src/jvm/org/apache/storm/generated/AccessControl.java:131
Method
AccessControlType
(int value)
storm-client/src/jvm/org/apache/storm/generated/AccessControlType.java:34
Method
AccumulatedTuplesCollector
(BatchOutputCollector delegateCollector)
storm-client/src/jvm/org/apache/storm/trident/windowing/AbstractTridentWindowManager.java:160
Method
AckFailMapTracker
()
storm-client/src/jvm/org/apache/storm/testing/AckFailMapTracker.java:24
Method
AckTracker
()
storm-client/src/jvm/org/apache/storm/testing/AckTracker.java:25
Method
AckTrackingFeeder
(String... fields)
storm-core/test/jvm/org/apache/storm/integration/AckTrackingFeeder.java:32
Method
AckTrackingOutputCollector
(OutputCollector delegate)
storm-client/src/jvm/org/apache/storm/topology/StatefulBoltExecutor.java:172
Method
Acker
(JCQueue ackerInQ, JCQueue spoutInQ)
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Acker.java:30
Method
AckingProducer
(JCQueue ackerInQ, JCQueue spoutInQ)
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/AckingProducer.java:30
Method
AclFunctionEntry
(Collection<String> clientUsers, String invocationUser)
storm-client/src/jvm/org/apache/storm/security/auth/authorizer/DRPCSimpleACLAuthorizer.java:161
Method
AddIdCollector
(String stream, BatchOutputCollector c)
storm-client/src/jvm/org/apache/storm/trident/spout/TridentSpoutExecutor.java:113
Method
AddressedTuple
(int dest, Tuple tuple)
storm-client/src/jvm/org/apache/storm/tuple/AddressedTuple.java:29
Method
AdvancedFSOps
(Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/daemon/supervisor/AdvancedFSOps.java:51
Method
AdvancedRunAsUserFSOps
(Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/daemon/supervisor/AdvancedFSOps.java:372
Method
AdvancedWindowsFSOps
(Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/daemon/supervisor/AdvancedFSOps.java:433
Method
AetherUtils
()
storm-submit-tools/src/main/java/org/apache/storm/submit/dependency/AetherUtils.java:37
Method
AggBolt
(int branches)
storm-core/test/jvm/org/apache/storm/integration/AggBolt.java:36
Method
AggLevel
(int value)
storm-server/src/main/java/org/apache/storm/metricstore/AggLevel.java:25
Method
AggSpec
(Fields inFields, Aggregator agg, Fields outFields)
storm-client/src/jvm/org/apache/storm/trident/fluent/ChainedAggregatorDeclarer.java:189
Method
AggregateByKeyProcessor
(CombinerAggregator<V, A, R> aggregator)
storm-client/src/jvm/org/apache/storm/streams/processors/AggregateByKeyProcessor.java:25
Method
AggregateProcessor
(Fields inputFields, Aggregator agg)
storm-client/src/jvm/org/apache/storm/trident/planner/processor/AggregateProcessor.java:35
Method
AggregateProcessor
(CombinerAggregator<T, A, R> aggregator)
storm-client/src/jvm/org/apache/storm/streams/processors/AggregateProcessor.java:22
Method
AlreadyAliveException
()
storm-client/src/jvm/org/apache/storm/generated/AlreadyAliveException.java:110
Method
AnchoringOutputCollector
(IOutputCollector delegate)
storm-client/src/jvm/org/apache/storm/topology/BaseStatefulBoltExecutor.java:147
Method
AppendCollector
(TridentContext context)
storm-client/src/jvm/org/apache/storm/trident/planner/processor/AppendCollector.java:31
Method
Arg
(String name, Parse parse, Assoc assoc)
storm-core/src/jvm/org/apache/storm/command/CLI.java:243
Method
ArtifactoryConfigLoader
(Map<String, Object> conf)
storm-server/src/main/java/org/apache/storm/scheduler/utils/ArtifactoryConfigLoader.java:73
Method
ArtifactoryConfigLoaderMock
(Map<String, Object> conf)
storm-server/src/test/java/org/apache/storm/scheduler/utils/ArtifactoryConfigLoaderTest.java:212
Method
AssignableMetric
(Object value)
storm-client/src/jvm/org/apache/storm/metric/api/AssignableMetric.java:18
Method
AssignableShellMetric
(Object value)
storm-client/src/jvm/org/apache/storm/metric/api/rpc/AssignableShellMetric.java:18
Method
Assignment
()
storm-client/src/jvm/org/apache/storm/generated/Assignment.java:165
Method
AssignmentInfo
(WorkerSlot workerSlot, String topologyId, Set<ExecutorDetails> executors)
storm-server/src/main/java/org/apache/storm/scheduler/IsolationScheduler.java:381
Method
Assoc
(K key, V value)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:5230
Method
AsyncClient
(org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.async.TAsyncClient
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:1866
Method
AsyncClient
(org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.async.TAsyncClient
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:180
Method
AsyncClient
(org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.async.TAsyncClient
storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java:110
Method
AsyncClient
(org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.async.TAsyncClient
storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java:192
Method
AsyncLocalizer
(Map<String, Object> conf, AdvancedFSOps ops, String baseDir, StormMetricsRegistry metricsRegistry)
storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java:108
Method
AsyncProcessor
(I iface)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:6051
Method
AsyncProcessor
(I iface)
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:427
Method
AsyncProcessor
(I iface)
storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java:212
Method
AsyncProcessor
(I iface)
storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java:517
Method
AuthenticationTestSubject
(Subject subject)
external/storm-hdfs-blobstore/src/test/java/org/apache/storm/hdfs/blobstore/BlobStoreTest.java:292
Method
AuthorizationException
()
storm-client/src/jvm/org/apache/storm/generated/AuthorizationException.java:110
Method
AutoCloseableBlobStoreContainer
(HdfsBlobStore blobStore)
external/storm-hdfs-blobstore/src/test/java/org/apache/storm/hdfs/blobstore/BlobStoreTest.java:161
Method
AutoCloseableHdfsSpout
(HdfsSpout spout)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestHdfsSpout.java:698
Method
AutoHBaseCommand
()
external/storm-autocreds/src/main/java/org/apache/storm/hbase/security/AutoHBaseCommand.java:37
Method
AutoHDFSCommand
()
external/storm-autocreds/src/main/java/org/apache/storm/hdfs/security/AutoHDFSCommand.java:39
Method
Averages
(double global, double window)
examples/storm-starter/src/jvm/org/apache/storm/starter/PersistentWindowingTopology.java:115
Method
AvroGenericRecordHDFSWriter
(FileRotationPolicy policy, Path path, FSDataOutputStream stream, Schema schema)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/AvroGenericRecordHDFSWriter.java:39
Method
BackPressureStatus
()
storm-client/src/jvm/org/apache/storm/messaging/netty/BackPressureStatus.java:41
Method
BackPressureStatusEncoder
(KryoValuesSerializer ser)
storm-client/src/jvm/org/apache/storm/messaging/netty/BackPressureStatusEncoder.java:28
Method
BackPressureTracker
(String workerId, Map<Integer, JCQueue> localTasksToQueues, StormMetricRegistry
storm-client/src/jvm/org/apache/storm/daemon/worker/BackPressureTracker.java:43
Method
BackpressureState
(JCQueue queue, Integer taskId, String componentId, StormMetricRegistry metricRegistry)
storm-client/src/jvm/org/apache/storm/daemon/worker/BackPressureTracker.java:121
Method
Base64ToBinaryStateMigrationUtil
(JedisPoolConfig poolConfig)
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/tools/Base64ToBinaryStateMigrationUtil.java:54
Method
BaseBinaryStateIterator
Constructor. @param pendingPrepareIterator The iterator of pendingPrepare @param pendingCommitIterator The iterator of pendingCommit
storm-client/src/jvm/org/apache/storm/state/BaseBinaryStateIterator.java:32
Method
BaseResourceAwareStrategy
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/BaseResourceAwareStrategy.java:111
Method
BaseStateIterator
Constructor. @param pendingPrepareIterator The iterator of pendingPrepare @param pendingCommitIterator The iterator of pendingCommit @param initialP
storm-client/src/jvm/org/apache/storm/state/BaseStateIterator.java:43
Method
BaseStatefulBoltExecutor
()
storm-client/src/jvm/org/apache/storm/topology/BaseStatefulBoltExecutor.java:44
Method
BaseWindowConfig
(int windowLength, int slideLength)
storm-client/src/jvm/org/apache/storm/trident/windowing/config/BaseWindowConfig.java:19
Method
BaseWindowStrategy
(WindowConfig windowConfig)
storm-client/src/jvm/org/apache/storm/trident/windowing/strategy/BaseWindowStrategy.java:20
Method
BaseWindowedBolt
()
storm-client/src/jvm/org/apache/storm/topology/base/BaseWindowedBolt.java:35
Function
BasicBolt
* Base class for storm bolt. * To create a bolt implement 'process' method. * You may also implement initialize method too
storm-multilang/javascript/src/main/resources/resources/storm.js:267
Method
BasicBoltExecutor
(IBasicBolt bolt)
storm-client/src/jvm/org/apache/storm/topology/BasicBoltExecutor.java:28
Method
BasicContainer
Create a new BasicContainer. @param type the type of container being made. @param conf the supervisor config
storm-server/src/main/java/org/apache/storm/daemon/supervisor/BasicContainer.java:98
Method
BasicContainerLauncher
(Map<String, Object> conf, String supervisorId, int supervisorPort, Resource
storm-server/src/main/java/org/apache/storm/daemon/supervisor/BasicContainerLauncher.java:34
Method
BasicLoadAwareCustomStreamGrouping
(CustomStreamGrouping customStreamGrouping)
storm-client/src/jvm/org/apache/storm/daemon/GrouperFactory.java:130
Method
BasicMetricsCollector
(String topoName, Map<String, Object> topoConfig)
examples/storm-perf/src/main/java/org/apache/storm/perf/utils/BasicMetricsCollector.java:70
Method
BasicOutputCollector
(OutputCollector out)
storm-client/src/jvm/org/apache/storm/topology/BasicOutputCollector.java:26
Method
BatchBoltExecutor
(IBatchBolt bolt)
storm-client/src/jvm/org/apache/storm/coordination/BatchBoltExecutor.java:38
Method
BatchHelper
(int batchSize, OutputCollector collector)
storm-client/src/jvm/org/apache/storm/utils/BatchHelper.java:31
Method
BatchInfo
(String batchGroup, IBatchID batchId, Object state)
storm-client/src/jvm/org/apache/storm/trident/topology/BatchInfo.java:23
Method
BatchInserter
(JCQueue queue, int batchSz)
storm-client/src/jvm/org/apache/storm/utils/JCQueue.java:331
Method
BatchOutputCollectorImpl
(OutputCollector collector)
storm-client/src/jvm/org/apache/storm/coordination/BatchOutputCollectorImpl.java:22
Method
BatchSpoutExecutor
(IBatchSpout spout)
storm-client/src/jvm/org/apache/storm/trident/spout/BatchSpoutExecutor.java:24
Method
BatchSubtopologyBuilder
(String masterBoltId, IBasicBolt masterBolt, Number boltParallelism)
storm-client/src/jvm/org/apache/storm/coordination/BatchSubtopologyBuilder.java:43
Method
BeanListReference
()
flux/flux-core/src/main/java/org/apache/storm/flux/model/BeanListReference.java:29
Method
BeanReference
()
flux/flux-core/src/main/java/org/apache/storm/flux/model/BeanReference.java:27
Method
BeginDownloadResult
()
storm-client/src/jvm/org/apache/storm/generated/BeginDownloadResult.java:128
Method
BlacklistScheduler
(IScheduler underlyingScheduler)
storm-server/src/main/java/org/apache/storm/scheduler/blacklist/BlacklistScheduler.java:64
Method
BlkioCore
(String dir)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/BlkioCore.java:48
Method
Blob
()
storm-server/src/main/java/org/apache/storm/container/oci/ImageManifest.java:88
Method
BlobChanging
(LocalAssignment assignment, LocallyCachedBlob blob, GoodToGo.GoodToGoLatch latch)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:1467
Method
BlobStoreAclHandler
(Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/blobstore/BlobStoreAclHandler.java:56
Method
BlobStoreFileInputStream
(BlobStoreFile part)
storm-client/src/jvm/org/apache/storm/blobstore/BlobStore.java:440
Method
BlobStoreFileOutputStream
(BlobStoreFile part)
storm-client/src/jvm/org/apache/storm/blobstore/BlobStore.java:391
Method
BlockIo
(int weight, int leafWeight, List<WeightDevice> weightDevices, List<Throttl
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:952
Method
BlockingOutstandingRequest
(String function, DRPCRequest req)
storm-server/src/main/java/org/apache/storm/daemon/drpc/BlockingOutstandingRequest.java:33
Method
BlowfishTupleSerializer
(Kryo unused, Map<String, Object> topoConf)
storm-client/src/jvm/org/apache/storm/security/serialization/BlowfishTupleSerializer.java:51
← previous
next →
11,501–11,600 of 27,770, ranked by callers