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
SaslClientCallbackHandler
Set private members using topology token.
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslNettyClient.java:99
Method
SaslDigestCallbackHandler
(String topologyName, byte[] token)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslNettyServer.java:91
Method
SaslMessageToken
Constructor used for reflection only.
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslMessageToken.java:35
Method
SaslNettyClient
Create a SaslNettyClient for authentication with servers.
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslNettyClient.java:45
Method
SaslNettyServer
(String topologyName, byte[] token)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslNettyServer.java:36
Method
SaslPlainServer
(CallbackHandler callback)
storm-client/src/jvm/org/apache/storm/security/auth/plain/SaslPlainServer.java:33
Method
SaslStormClientHandler
(ISaslClient client)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormClientHandler.java:35
Method
SaslStormServerAuthorizeHandler
Constructor.
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormServerAuthorizeHandler.java:31
Method
SaslStormServerHandler
(ISaslServer server)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormServerHandler.java:33
Method
ScheduleRunnable
(int runnableNum)
storm-client/test/jvm/org/apache/storm/TestStormTimer.java:117
Method
SchedulerAssignmentImpl
Create a new assignment. @param topologyId the id of the topology the assignment is for. @param executorToSlot the execut
storm-server/src/main/java/org/apache/storm/scheduler/SchedulerAssignmentImpl.java:57
Method
SchedulerConfigCache
(Map<String, Object> conf, Reloadable<T> reloader)
storm-server/src/main/java/org/apache/storm/scheduler/utils/SchedulerConfigCache.java:39
Method
SchedulingResult
(SchedulingStatus status, String message, String errorMessage)
storm-server/src/main/java/org/apache/storm/scheduler/resource/SchedulingResult.java:34
Method
SchedulingSearcherState
(Map<WorkerSlot, Map<String, Integer>> workerCompAssignmentCnts, Map<RasNo
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/SchedulingSearcherState.java:87
Method
SchemeAsMultiScheme
(Scheme scheme)
storm-client/src/jvm/org/apache/storm/spout/SchemeAsMultiScheme.java:23
Method
ScopedTopologySet
Constructor. @param client the client used to kill the topologies when this exist.
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/ScopedTopologySet.java:50
Method
Seccomp
(String defaultAction, List<String> architectures, List<Syscall> syscalls)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1213
Method
SeccompArg
(int index, long value, long valueTwo, String op)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1270
Method
SecurityProvider
()
storm-client/src/jvm/org/apache/storm/security/auth/plain/SaslPlainServer.java:133
Method
SentWithTime
(String streamName, Values keyValue, long time, HistogramMetric histogram)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadSpout.java:58
Method
SepValReporter
(String separator, String path, Map<String, String> query, Map<String, MetricExtractor> extractorsMap)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java:655
Method
Seq
(List<String> fields, List<Object> values, int count)
storm-clojure/src/main/java/org/apache/storm/clojure/ClojureTuple.java:117
Method
SequenceFileBolt
()
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/SequenceFileBolt.java:46
Method
SequenceFileReader
(FileSystem fs, Path file, Map<String, Object> conf)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/SequenceFileReader.java:43
Method
SequenceFileWriter
(FileRotationPolicy policy, Path path, SequenceFile.Writer writer, SequenceFormat format)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/SequenceFileWriter.java:31
Method
Server
Starts Netty at the given port. @param topoConf The topology config @param port The port to start Netty at @param cb The callback to deliver incoming
storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java:78
Method
ServerCallbackHandler
(Map<String, Object> topoConf, boolean impersonationAllowed)
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/ServerCallbackHandler.java:39
Method
ServerConfigUtilsInstaller
(ServerConfigUtils instance)
storm-core/test/jvm/org/apache/storm/utils/staticmocking/ServerConfigUtilsInstaller.java:28
Method
SettableBlobMeta
()
storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java:121
Method
SharedMemory
()
storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java:136
Method
SharedOffHeapWithinNode
Create a new request for a shared memory region off heap between workers on a node. @param amount the number of MB to share @param name the name of
storm-client/src/jvm/org/apache/storm/topology/SharedOffHeapWithinNode.java:30
Method
SharedOffHeapWithinWorker
Create a new request for a shared memory region off heap within a worker. @param amount the number of MB to share @param name the name of the share
storm-client/src/jvm/org/apache/storm/topology/SharedOffHeapWithinWorker.java:28
Method
SharedOnHeap
Create a new request for a shared memory region on heap. @param amount the number of MB to share on heap @param name the name of the shared region
storm-client/src/jvm/org/apache/storm/topology/SharedOnHeap.java:30
Method
ShellBasedGroupsMapping
()
storm-client/src/jvm/org/apache/storm/security/auth/ShellBasedGroupsMapping.java:42
Method
ShellBolt
(ShellComponent component)
storm-client/src/jvm/org/apache/storm/task/ShellBolt.java:99
Method
ShellBoltMessageQueue
(int boltMsgCapacity)
storm-client/src/jvm/org/apache/storm/utils/ShellBoltMessageQueue.java:35
Method
ShellCommandExecutor
(String[] execString)
storm-client/src/jvm/org/apache/storm/utils/ShellUtils.java:383
Method
ShellComponent
()
storm-client/src/jvm/org/apache/storm/generated/ShellComponent.java:117
Method
ShellProcess
(String[] command)
storm-client/src/jvm/org/apache/storm/utils/ShellProcess.java:43
Method
ShellSpout
(ShellComponent component)
storm-client/src/jvm/org/apache/storm/spout/ShellSpout.java:63
Method
ShellTimeoutTimerTask
(ShellUtils shell)
storm-client/src/jvm/org/apache/storm/utils/ShellUtils.java:478
Method
ShellUtils
()
storm-client/src/jvm/org/apache/storm/utils/ShellUtils.java:69
Method
SimpleACLNimbusUserAuthTest
()
storm-client/test/jvm/org/apache/storm/security/auth/authorizer/SimpleACLAuthorizerTest.java:198
Method
SimpleACLTopologyReadOnlyGroupAuthTest
()
storm-client/test/jvm/org/apache/storm/security/auth/authorizer/SimpleACLAuthorizerTest.java:331
Method
SimpleACLTopologyReadOnlyUserAuthTest
()
storm-client/test/jvm/org/apache/storm/security/auth/authorizer/SimpleACLAuthorizerTest.java:224
Method
SimpleACLUserAuthTest
()
storm-client/test/jvm/org/apache/storm/security/auth/authorizer/SimpleACLAuthorizerTest.java:36
Method
SimpleGauge
(T value)
storm-client/src/jvm/org/apache/storm/metrics2/SimpleGauge.java:20
Method
SimpleJdbcLookupMapper
(Fields outputFields, List<Column> queryColumns)
external/storm-jdbc/src/main/java/org/apache/storm/jdbc/mapper/SimpleJdbcLookupMapper.java:28
Method
SimpleJdbcMapper
(String tableName, ConnectionProvider connectionProvider)
external/storm-jdbc/src/main/java/org/apache/storm/jdbc/mapper/SimpleJdbcMapper.java:31
Method
SimpleRecordTranslator
(Func<ConsumerRecord<K, V>, List<Object>> func, Fields fields)
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/SimpleRecordTranslator.java:32
Method
SimpleSaslClientCallbackHandler
Constructor. @param username the username to use. @param password the password to use.
storm-client/src/jvm/org/apache/storm/security/auth/sasl/SimpleSaslClientCallbackHandler.java:36
Method
SimpleSaslServerCallbackHandler
Constructor with different password providers. @param impersonationAllowed true if impersonation is allowed else false. @param providers w
storm-client/src/jvm/org/apache/storm/security/auth/sasl/SimpleSaslServerCallbackHandler.java:45
Method
SimpleTopology
()
flux/flux-core/src/test/java/org/apache/storm/flux/test/SimpleTopology.java:34
Method
SimpleTopologySource
()
flux/flux-core/src/test/java/org/apache/storm/flux/test/SimpleTopologySource.java:31
Method
SimpleTopologyWithConfigParam
()
flux/flux-core/src/test/java/org/apache/storm/flux/test/SimpleTopologyWithConfigParam.java:33
Method
SimpleTypeValidator
(Map<String, Object> params)
storm-client/src/jvm/org/apache/storm/validation/ConfigValidation.java:287
Method
SimpleVersion
(String version)
storm-client/src/jvm/org/apache/storm/utils/SimpleVersion.java:26
Method
SimpleWindowPartitionCache
(long maximumSize, RemovalListener<K, V> removalListener, CacheLoader<K, V> cacheLoader)
storm-client/src/jvm/org/apache/storm/windowing/persistence/SimpleWindowPartitionCache.java:40
Method
SimpleWrapProcessor
(TProcessor wrapped)
storm-client/src/jvm/org/apache/storm/security/auth/SimpleTransportPlugin.java:125
Method
SimulatedTime
()
storm-client/src/jvm/org/apache/storm/utils/Time.java:203
Method
SimulatedUser
(User other, ISchedulingState cluster)
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/priority/DefaultSchedulingPriorityStrategy.java:69
Method
SimulatedUserComparator
(double cpuAvail, double memAvail)
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/priority/DefaultSchedulingPriorityStrategy.java:128
Method
SingleEmitAggregator
(Aggregator agg, BatchToPartition batchToPartition)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/SingleEmitAggregator.java:30
Method
SingleEmitState
(Object batchId)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/SingleEmitAggregator.java:83
Method
SingleJoinBolt
(Fields outFields)
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/SingleJoinBolt.java:43
Method
SingleThreadedConsumer
(KryoTupleDeserializer deserializer, int numMessages)
storm-client/test/jvm/org/apache/storm/executor/ExecutorTransferMultiThreadingTest.java:170
Method
SingleTopologyCluster
Create a new cluster that only allows modifications to a single topology. @param other the current cluster to base this off of @param topologyId
storm-server/src/main/java/org/apache/storm/scheduler/SingleTopologyCluster.java:33
Method
SingleUserPrincipal
(String userName)
storm-client/src/jvm/org/apache/storm/security/auth/SingleUserPrincipal.java:24
Method
SinkNode
(IComponent bolt)
storm-client/src/jvm/org/apache/storm/streams/SinkNode.java:26
Method
SkewedRollingTopWords
()
examples/storm-starter/src/jvm/org/apache/storm/starter/SkewedRollingTopWords.java:39
Method
SlidingCountWindow
(int windowLength, int slideLength)
storm-client/src/jvm/org/apache/storm/trident/windowing/config/SlidingCountWindow.java:24
Method
SlidingCountWindowStrategy
(WindowConfig slidingCountWindow)
storm-client/src/jvm/org/apache/storm/trident/windowing/strategy/SlidingCountWindowStrategy.java:28
Method
SlidingDurationWindow
(int windowLength, int slideLength)
storm-client/src/jvm/org/apache/storm/trident/windowing/config/SlidingDurationWindow.java:25
Method
SlidingDurationWindowStrategy
(WindowConfig slidingDurationWindow)
storm-client/src/jvm/org/apache/storm/trident/windowing/strategy/SlidingDurationWindowStrategy.java:28
Method
SlidingTimeCorrectness
(int windowSec, int slideSec)
integration-test/src/main/java/org/apache/storm/st/topology/window/SlidingTimeCorrectness.java:47
Method
SlidingWindowCorrectness
(int windowSize, int slideSize)
integration-test/src/main/java/org/apache/storm/st/topology/window/SlidingWindowCorrectness.java:47
Method
SlidingWindowCounter
(int windowLengthInSlots)
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/SlidingWindowCounter.java:73
Method
SlidingWindows
(L windowLength, I slidingInterval)
storm-client/src/jvm/org/apache/storm/streams/windowing/SlidingWindows.java:29
Method
Slot
(AsyncLocalizer localizer, Map<String, Object> conf, ContainerLauncher containerLauncher, Stri
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:79
Method
SlotBasedCounter
(int numSlots)
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/SlotBasedCounter.java:34
Method
SlotMetrics
(StormMetricsRegistry metricsRegistry)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/SlotMetrics.java:36
Method
SlowExecutorPattern
(double maxSlownessMs, int count)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/SlowExecutorPattern.java:74
Method
SmartThread
(Runnable r)
storm-client/src/jvm/org/apache/storm/utils/Utils.java:1842
Method
SnapshottableMap
(MapState<T> delegate, List<Object> snapshotKey)
storm-client/src/jvm/org/apache/storm/trident/state/map/SnapshottableMap.java:25
Method
SourceArgs
(boolean singleCount)
storm-client/src/jvm/org/apache/storm/coordination/CoordinatedBolt.java:250
Method
SpecificAggregateStats
()
storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java:109
Method
SplitSentence
()
examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopology.java:63
Method
SplitSentence
()
examples/storm-starter/src/jvm/org/apache/storm/starter/BlobStoreAPIWordCountTopology.java:249
Method
SplitSentence
()
examples/storm-starter/src/jvm/org/apache/storm/starter/WordCountTopologyNode.java:56
Method
SplitSentence
(SlowExecutorPattern slowness)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/ThroughputVsLatency.java:94
Function
SplitSentenceBolt
()
examples/storm-starter/multilang/resources/asyncSplitsentence.js:28
Function
SplitSentenceBolt
()
examples/storm-starter/multilang/resources/splitsentence.js:26
Function
Spout
* Base class for storm spout. * To create a spout implement the following methods: nextTuple, ack and fail (nextTuple - mandatory, ack and fail * ca
storm-multilang/javascript/src/main/resources/resources/storm.js:348
Method
SpoutAckInfo
(Object messageId, int spoutTaskId, Long completeLatencyMs)
storm-client/src/jvm/org/apache/storm/hooks/info/SpoutAckInfo.java:25
Method
SpoutAggregateStats
()
storm-client/src/jvm/org/apache/storm/generated/SpoutAggregateStats.java:113
Method
SpoutComponent
(Object spout, String streamName, Integer parallelism, String batchGroupId)
storm-client/src/jvm/org/apache/storm/trident/topology/TridentTopologyBuilder.java:308
Method
SpoutDeclarerImpl
(SpoutComponent component)
storm-client/src/jvm/org/apache/storm/trident/topology/TridentTopologyBuilder.java:359
Method
SpoutDetails
(IRichSpout spout, Integer parallelism, Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/Thrift.java:298
Method
SpoutExecutor
(final WorkerState workerData, final List<Long> executorId, Map<String, String> credentials)
storm-client/src/jvm/org/apache/storm/executor/spout/SpoutExecutor.java:71
Method
SpoutExecutorStats
(int rate, int numStatBuckets)
storm-client/src/jvm/org/apache/storm/stats/SpoutExecutorStats.java:24
← previous
next →
12,401–12,500 of 27,770, ranked by callers