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
TridentMultiReducerContext
(List<TridentTuple.Factory> factories)
storm-client/src/jvm/org/apache/storm/trident/operation/TridentMultiReducerContext.java:24
Method
TridentOperationContext
(TopologyContext topoContext, TridentTuple.Factory factory)
storm-client/src/jvm/org/apache/storm/trident/operation/TridentOperationContext.java:36
Method
TridentSpoutCoordinator
(String id, ITridentSpout<Object> spout)
storm-client/src/jvm/org/apache/storm/trident/spout/TridentSpoutCoordinator.java:43
Method
TridentSpoutExecutor
(String txStateId, String streamName, ITridentSpout<Object> spout)
storm-client/src/jvm/org/apache/storm/trident/spout/TridentSpoutExecutor.java:47
Method
TridentState
(TridentTopology topology, Node node)
storm-client/src/jvm/org/apache/storm/trident/TridentState.java:24
Method
TridentTopology
()
storm-client/src/jvm/org/apache/storm/trident/TridentTopology.java:104
Method
TridentTupleView
(List delegates, ValuePointer[] index, Map<String, ValuePointer> fieldIndex)
storm-client/src/jvm/org/apache/storm/trident/tuple/TridentTupleView.java:36
Method
TriggerInfo
(String windowTaskId, int triggerId)
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowTridentProcessor.java:250
Method
TriggerResult
(int id, List<List<Object>> result)
storm-client/src/jvm/org/apache/storm/trident/windowing/AbstractTridentWindowManager.java:185
Method
TumblingCountWindow
(int windowLength)
storm-client/src/jvm/org/apache/storm/trident/windowing/config/TumblingCountWindow.java:23
Method
TumblingCountWindowStrategy
(WindowConfig tumblingCountWindow)
storm-client/src/jvm/org/apache/storm/trident/windowing/strategy/TumblingCountWindowStrategy.java:28
Method
TumblingDurationWindow
(int windowLength)
storm-client/src/jvm/org/apache/storm/trident/windowing/config/TumblingDurationWindow.java:24
Method
TumblingDurationWindowStrategy
(WindowConfig tumblingDurationWindow)
storm-client/src/jvm/org/apache/storm/trident/windowing/strategy/TumblingDurationWindowStrategy.java:28
Method
TumblingTimeCorrectness
(int tumbleSec)
integration-test/src/main/java/org/apache/storm/st/topology/window/TumblingTimeCorrectness.java:46
Method
TumblingWindowCorrectness
(final int tumbleSize)
integration-test/src/main/java/org/apache/storm/st/topology/window/TumblingWindowCorrectness.java:46
Method
TumblingWindows
(L windowLength)
storm-client/src/jvm/org/apache/storm/streams/windowing/TumblingWindows.java:28
Function
Tuple
(id, component, stream, task, values)
storm-multilang/javascript/src/main/resources/resources/storm.js:246
Method
Tuple10
Constructs a new tuple. @param value1 the first element @param value2 the second element @param value3 the third element @param value4 the fourth
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple10.java:56
Method
Tuple3
Constructs a new tuple. @param value1 the first element @param value2 the second element @param value3 the third element
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple3.java:34
Method
Tuple4
Constructs a new tuple. @param value1 the first element @param value2 the second element @param value3 the third element @param value4 the fourth ele
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple4.java:37
Method
Tuple5
Constructs a new tuple. @param value1 the first element @param value2 the second element @param value3 the third element @param value4 the fourth ele
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple5.java:40
Method
Tuple6
Constructs a new tuple. @param value1 the first element @param value2 the second element @param value3 the third element @param value4 the fourth ele
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple6.java:44
Method
Tuple7
Constructs a new tuple. @param value1 the first element @param value2 the second element @param value3 the third element @param value4 the fourth ele
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple7.java:46
Method
Tuple8
Constructs a new tuple. @param value1 the first element @param value2 the second element @param value3 the third element @param value4 the fourth ele
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple8.java:49
Method
Tuple9
Constructs a new tuple. @param value1 the first element @param value2 the second element @param value3 the third element @param value4 the fourth
storm-client/src/jvm/org/apache/storm/streams/tuple/Tuple9.java:52
Method
TupleCaptureBolt
()
storm-client/src/jvm/org/apache/storm/testing/TupleCaptureBolt.java:40
Method
TupleFieldTimestampExtractor
(String fieldName)
storm-client/src/jvm/org/apache/storm/topology/TupleFieldTimestampExtractor.java:24
Method
TupleImpl
(Tuple t)
storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java:31
Method
TupleSerializer
(KryoTupleSerializer tupleSerializer, KryoTupleDeserializer tupleDeserializer)
storm-client/src/jvm/org/apache/storm/state/DefaultStateSerializer.java:107
Method
TupleUtils
()
storm-client/src/jvm/org/apache/storm/utils/TupleUtils.java:27
Method
TupleValueMappers
()
storm-client/src/jvm/org/apache/storm/streams/operations/mappers/TupleValueMappers.java:30
Method
TupleWindowImpl
(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples)
storm-client/src/jvm/org/apache/storm/windowing/TupleWindowImpl.java:28
Method
TupleWindowIterImpl
(Supplier<Iterator<Tuple>> tuplesIt, Supplier<Iterator<Tuple>> newTuplesIt,
storm-client/src/jvm/org/apache/storm/windowing/TupleWindowIterImpl.java:32
Method
TxIdState
(long txid, Map<K, V> state)
storm-client/src/jvm/org/apache/storm/state/InMemoryKeyValueState.java:106
Method
TxnRecord
(long txnId, String dataFilePath, long offset)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/HdfsState.java:545
Method
UniqueIdGen
()
storm-client/src/jvm/org/apache/storm/streams/UniqueIdGen.java:21
Method
Units
(long byteCount)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/rotation/FileSizeRotationPolicy.java:77
Method
Units
(long byteCount)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/rotation/FileSizeRotationPolicy.java:73
Method
UpdateStateByKeyProcessor
(StateUpdater<V, R> stateUpdater)
storm-client/src/jvm/org/apache/storm/streams/processors/UpdateStateByKeyProcessor.java:23
Method
UptimeComputer
()
storm-client/src/jvm/org/apache/storm/utils/Utils.java:1854
Method
UrlBuilder
()
storm-webapp/src/main/java/org/apache/storm/daemon/utils/UrlBuilder.java:31
Method
User
(String name)
storm-client/src/jvm/org/apache/storm/security/auth/sasl/SaslTransportPlugin.java:159
Method
User
(int uid, int gid, int[] additionalGids)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:438
Method
User
(String userId)
storm-server/src/main/java/org/apache/storm/scheduler/resource/User.java:43
Method
UserSpout
()
examples/storm-jdbc-examples/src/main/java/org/apache/storm/jdbc/spout/UserSpout.java:42
Method
UtilsInstaller
(Utils instance)
storm-core/test/jvm/org/apache/storm/utils/staticmocking/UtilsInstaller.java:28
Method
Validator
(Map<String, Object> params)
storm-client/src/jvm/org/apache/storm/validation/ConfigValidation.java:257
Method
ValueMapper
Constructs a new {@link ValueMapper} that extracts the value at index 'i' from a tuple. @param index the index
storm-client/src/jvm/org/apache/storm/streams/operations/mappers/ValueMapper.java:30
Method
ValuePointer
(int delegateIndex, int index, String field)
storm-client/src/jvm/org/apache/storm/trident/tuple/ValuePointer.java:25
Method
Values
()
storm-client/src/jvm/org/apache/storm/tuple/Values.java:21
Method
ValuesMapper
Constructs a new {@link ValuesMapper} that extracts value from a {@link Tuple} at specified indices. @param indices the indices
storm-client/src/jvm/org/apache/storm/streams/operations/mappers/ValuesMapper.java:29
Method
Vehicle
(String name, int maxSpeed, double efficiency)
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentMinMaxOfDevicesTopology.java:159
Method
Vehicle
(String name, int maxSpeed, double efficiency)
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentMinMaxOfVehiclesTopology.java:137
Method
VersionInfoImpl
(String component)
storm-client/src/jvm/org/apache/storm/utils/VersionInfo.java:50
Method
VersionedData
(int version, D data)
storm-client/src/jvm/org/apache/storm/cluster/VersionedData.java:19
Method
VersionedStore
Creates a store at the given path. @param path The path for the store @param createRootDir option to create the path directory
storm-client/src/jvm/org/apache/storm/utils/VersionedStore.java:34
Method
WaitStrategyPark
()
storm-client/src/jvm/org/apache/storm/policy/WaitStrategyPark.java:29
Method
WaterMarkEvent
(long ts)
storm-client/src/jvm/org/apache/storm/windowing/WaterMarkEvent.java:19
Method
WaterMarkEventGenerator
Creates a new WatermarkEventGenerator. @param windowManager The window manager this generator will submit watermark events to @param intervalMs Th
storm-client/src/jvm/org/apache/storm/windowing/WaterMarkEventGenerator.java:54
Method
WatermarkCountEvictionPolicy
(int count)
storm-client/src/jvm/org/apache/storm/windowing/WatermarkCountEvictionPolicy.java:30
Method
WatermarkCountTriggerPolicy
(int count, TriggerHandler handler, EvictionPolicy<T, ?> evictionPolicy
storm-client/src/jvm/org/apache/storm/windowing/WatermarkCountTriggerPolicy.java:30
Method
WatermarkTimeEvictionPolicy
Constructs a WatermarkTimeEvictionPolicy that evicts events older than the given window length in millis. @param windowLength the window length in mi
storm-client/src/jvm/org/apache/storm/windowing/WatermarkTimeEvictionPolicy.java:26
Method
WatermarkTimeTriggerPolicy
(long slidingIntervalMs, TriggerHandler handler, EvictionPolicy<T, ?> evictionPolicy,
storm-client/src/jvm/org/apache/storm/windowing/WatermarkTimeTriggerPolicy.java:31
Method
WeightDevice
(long major, long minor, int weight, int leafWeight)
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1005
Method
WhitelistWordFilterMapper
()
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WhitelistWordCount.java:125
Method
WindowKryoSerializer
(Map<String, Object> topoConf)
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowKryoSerializer.java:32
Method
WindowManager
(WindowLifecycleListener<T> lifecycleListener)
storm-client/src/jvm/org/apache/storm/windowing/WindowManager.java:61
Method
WindowNode
(Window<?, ?> windowParams, String outputStream, Fields outputFields)
storm-client/src/jvm/org/apache/storm/streams/WindowNode.java:25
Method
WindowPartition
(long id)
storm-client/src/jvm/org/apache/storm/windowing/persistence/WindowState.java:347
Method
WindowPartitionLock
()
storm-client/src/jvm/org/apache/storm/windowing/persistence/WindowState.java:323
Method
WindowState
(KeyValueState<Long, WindowPartition<T>> windowPartitionsState, KeyValueState<String, D
storm-client/src/jvm/org/apache/storm/windowing/persistence/WindowState.java:61
Method
WindowState
()
storm-client/src/jvm/org/apache/storm/topology/StatefulWindowedBoltExecutor.java:293
Method
WindowTridentProcessor
(WindowConfig windowConfig, String uniqueWindowId, WindowsStoreFactory windowStoreFactory,
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowTridentProcessor.java:64
Method
WindowedBoltExecutor
(IWindowedBolt bolt)
storm-client/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java:81
Method
WindowedOutputCollector
(IOutputCollector delegate)
storm-client/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java:394
Method
WindowedProcessorBolt
(String id, Graph<Node, Edge> graph, List<ProcessorNode> nodes,
storm-client/src/jvm/org/apache/storm/streams/WindowedProcessorBolt.java:42
Method
WindowedTimeThrottler
(Number windowMillis, Number maxAmt)
storm-client/src/jvm/org/apache/storm/utils/WindowedTimeThrottler.java:21
Method
WindowsState
()
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowsState.java:28
Method
WindowsStateFactory
()
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowsStateFactory.java:25
Method
WindowsStateUpdater
(WindowsStoreFactory windowStoreFactory)
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowsStateUpdater.java:36
Method
WithAcl
(List<AccessControl> acl, T data)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/TopoCache.java:232
Method
WordCountRedisLookupMapper
()
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/LookupWordCount.java:129
Method
WordCountStoreMapper
()
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/PersistentWordCount.java:82
Method
WordCountStoreMapper
()
examples/storm-starter/src/jvm/org/apache/storm/starter/streams/WordCountToBolt.java:76
Method
WordGenSpout
(String file)
examples/storm-perf/src/main/java/org/apache/storm/perf/spout/WordGenSpout.java:49
Method
WordSpout
()
examples/storm-redis-examples/src/main/java/org/apache/storm/redis/topology/WordSpout.java:37
Method
Worker
TODO: should worker even take the topologyId as input? this should be deducible from cluster state (by searching through assignments) what about if th
storm-client/src/jvm/org/apache/storm/daemon/worker/Worker.java:113
Method
WorkerCpuMetric
()
storm-client/src/jvm/org/apache/storm/metric/SystemBolt.java:87
Method
WorkerLogs
Constructor. @param stormConf storm configuration @param logRootDir the log root directory @param metricsRegistry The logviewer metrics registry
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/utils/WorkerLogs.java:80
Method
WorkerMetricList
()
storm-client/src/jvm/org/apache/storm/generated/WorkerMetricList.java:111
Method
WorkerMetricPoint
()
storm-client/src/jvm/org/apache/storm/generated/WorkerMetricPoint.java:148
Method
WorkerMetrics
()
storm-client/src/jvm/org/apache/storm/generated/WorkerMetrics.java:133
Method
WorkerResources
()
storm-client/src/jvm/org/apache/storm/generated/WorkerResources.java:163
Method
WorkerSlot
(String nodeId, Number port)
storm-client/src/jvm/org/apache/storm/scheduler/WorkerSlot.java:22
Method
WorkerState
(Map<String, Object> conf, IContext mqContext, String topologyId, String a
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java:159
Method
WorkerSummary
()
storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:229
Method
WorkerToken
()
storm-client/src/jvm/org/apache/storm/generated/WorkerToken.java:128
Method
WorkerTokenAuthorizer
Constructor. @param conf the daemon config for the server. @param connectionType the type of connection we are authorizing.
storm-client/src/jvm/org/apache/storm/security/auth/workertoken/WorkerTokenAuthorizer.java:56
Method
WorkerTokenClientCallbackHandler
Constructor. @param token the token to use to authenticate. This was probably retrieved by calling findWorkerTokenInSubject.
storm-client/src/jvm/org/apache/storm/security/auth/workertoken/WorkerTokenClientCallbackHandler.java:36
Method
WorkerTokenInfo
()
storm-client/src/jvm/org/apache/storm/generated/WorkerTokenInfo.java:134
← previous
next →
12,701–12,800 of 27,770, ranked by callers