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
EmitInfo
(List<Object> values, String stream, int taskId, Collection<Integer> outTasks)
storm-client/src/jvm/org/apache/storm/hooks/info/EmitInfo.java:26
Method
EmittedTuple
(final String streamId, final List<Object> tuple, final Collection<Tuple> anchors)
external/storm-redis/src/test/java/org/apache/storm/redis/util/outputcollector/EmittedTuple.java:30
Method
Emitter
(String txStateId, Map<String, Object> conf, TopologyContext context)
storm-client/src/jvm/org/apache/storm/trident/spout/OpaquePartitionedTridentSpoutExecutor.java:116
Method
Emitter
(String txStateId, Map<String, Object> conf, TopologyContext context)
storm-client/src/jvm/org/apache/storm/trident/spout/PartitionedTridentSpoutExecutor.java:120
Method
EmitterPartitionState
(RotatingTransactionalState s, ISpoutPartition p)
storm-client/src/jvm/org/apache/storm/trident/spout/OpaquePartitionedTridentSpoutExecutor.java:66
Method
EmitterPartitionState
(RotatingTransactionalState s, ISpoutPartition p)
storm-client/src/jvm/org/apache/storm/trident/spout/PartitionedTridentSpoutExecutor.java:67
Method
EmittingProcessorContext
(ProcessorNode processorNode, OutputCollector collector, String outputStreamId)
storm-client/src/jvm/org/apache/storm/streams/processors/EmittingProcessorContext.java:48
Method
Entry
(String key, Object value)
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowsStore.java:54
Method
ErrorInfo
()
storm-client/src/jvm/org/apache/storm/generated/ErrorInfo.java:135
Method
EventImpl
(T event, long ts)
storm-client/src/jvm/org/apache/storm/windowing/EventImpl.java:19
Method
EventInfo
(long ts, String component, int task, Object messageId, List<Object> values)
storm-client/src/jvm/org/apache/storm/metric/IEventLogger.java:47
Method
EventManagerImp
(boolean isDaemon)
storm-server/src/main/java/org/apache/storm/event/EventManagerImp.java:35
Method
EventManagerPushCallback
(Runnable cb, EventManager eventManager)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/EventManagerPushCallback.java:23
Method
ExecAndProcessLatencyEngine
()
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/ExecAndProcessLatencyEngine.java:45
Method
ExecSorterByConnectionCount
(TopologyDetails topologyDetails)
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/ExecSorterByConnectionCount.java:39
Method
ExecSorterByConstraintSeverity
(Cluster cluster, TopologyDetails topologyDetails)
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/ExecSorterByConstraintSeverity.java:35
Method
ExecSorterByProximity
(TopologyDetails topologyDetails)
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/ExecSorterByProximity.java:45
Method
ExecutionContext
(TopologyDef topologyDef, Config config)
flux/flux-core/src/main/java/org/apache/storm/flux/model/ExecutionContext.java:49
Method
Executor
(WorkerState workerData, List<Long> executorId, Map<String, String> credentials, String type)
storm-client/src/jvm/org/apache/storm/executor/Executor.java:135
Method
ExecutorAggregateStats
()
storm-client/src/jvm/org/apache/storm/generated/ExecutorAggregateStats.java:118
Method
ExecutorBeat
(int timeSecs, int uptime, ExecutorStats stats)
storm-client/src/jvm/org/apache/storm/cluster/ExecutorBeat.java:22
Method
ExecutorCache
(Map<String, Object> newBeat)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/HeartbeatCache.java:53
Method
ExecutorDetails
(int startTask, int endTask)
storm-server/src/main/java/org/apache/storm/scheduler/ExecutorDetails.java:28
Method
ExecutorInfo
()
storm-client/src/jvm/org/apache/storm/generated/ExecutorInfo.java:120
Method
ExecutorShutdown
(Executor executor, List<Utils.SmartThread> threads, ArrayList<Task> taskDatas, JCQueue recvQueue)
storm-client/src/jvm/org/apache/storm/executor/ExecutorShutdown.java:44
Method
ExecutorSpecificStats
()
storm-client/src/jvm/org/apache/storm/generated/ExecutorSpecificStats.java:109
Method
ExecutorStats
()
storm-client/src/jvm/org/apache/storm/generated/ExecutorStats.java:141
Method
ExecutorSummary
()
storm-client/src/jvm/org/apache/storm/generated/ExecutorSummary.java:149
Method
ExecutorTransfer
(WorkerState workerData, Map<String, Object> topoConf)
storm-client/src/jvm/org/apache/storm/executor/ExecutorTransfer.java:43
Method
ExecutorURL
(String componentId, String host, int logViewerPort, int executorPort, String topoId)
integration-test/src/test/java/org/apache/storm/st/wrapper/TopoWrap.java:257
Method
ExitCodeException
(int exitCode, String message)
storm-client/src/jvm/org/apache/storm/utils/ShellUtils.java:360
Method
ExtendedThreadPoolExecutor
(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit,
storm-client/src/jvm/org/apache/storm/utils/ExtendedThreadPoolExecutor.java:32
Method
FIFOSimulatedUser
(User other, ISchedulingState cluster)
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/priority/FIFOSchedulingPriorityStrategy.java:34
Method
Factory
(int... sizes)
storm-client/src/jvm/org/apache/storm/trident/tuple/ComboList.java:44
Method
Factory
(int maxSize)
storm-client/src/jvm/org/apache/storm/trident/testing/LRUMemoryMapState.java:97
Method
Factory
()
storm-client/src/jvm/org/apache/storm/trident/testing/MemoryMapState.java:115
Method
Factory
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:302
Method
Factory
(org.apache.storm.thrift.async.TAsyncClientManager clientManager, org.apache.storm.thrift.protocol.TProtocolFa
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:1856
Method
Factory
()
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:67
Method
Factory
(org.apache.storm.thrift.async.TAsyncClientManager clientManager, org.apache.storm.thrift.protocol.TProtocolFa
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:170
Method
Factory
()
storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java:44
Method
Factory
(org.apache.storm.thrift.async.TAsyncClientManager clientManager, org.apache.storm.thrift.protocol.TProtocolFa
storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java:100
Method
Factory
()
storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java:56
Method
Factory
(org.apache.storm.thrift.async.TAsyncClientManager clientManager, org.apache.storm.thrift.protocol.TProtocolFa
storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java:182
Method
Factory
(Map map)
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentReach.java:109
Method
Factory
()
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/DebugMemoryMapState.java:64
Method
Factory
Constructor. @param jedisPoolConfig configuration for JedisPool @param type StateType @param options options of State
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java:326
Method
Factory
Constructor. @param config configuration of JedisPool
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisState.java:87
Method
Factory
Constructor. @param jedisClusterConfig configuration for JedisCluster @param type StateType @param options options of State
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterMapState.java:299
Method
Factory
Constructor. @param config configuration of JedisCluster
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterState.java:89
Method
FailedException
()
storm-client/src/jvm/org/apache/storm/topology/FailedException.java:16
Method
FastRandomSentenceSpout
Constructor. @param ratePerSecond the rate to emite tuples at.
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/ThroughputVsLatency.java:74
Method
FeederBatchSpout
(List<String> fields)
storm-client/src/jvm/org/apache/storm/trident/testing/FeederBatchSpout.java:38
Method
FeederCommitterBatchSpout
(List<String> fields)
storm-client/src/jvm/org/apache/storm/trident/testing/FeederCommitterBatchSpout.java:29
Method
FeederCoordinator
(int numPartitions)
storm-client/src/jvm/org/apache/storm/trident/testing/FeederBatchSpout.java:119
Method
FeederEmitter
(int index)
storm-client/src/jvm/org/apache/storm/trident/testing/FeederBatchSpout.java:89
Method
FeederSpout
(List<String> outFields)
storm-client/src/jvm/org/apache/storm/testing/FeederSpout.java:34
Method
FieldIndexTopicSelector
Creates a new FieldIndexTopicSelector. @param fieldIndex The index of the field containing the topic name @param defaultTopicName The default topic na
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/selector/FieldIndexTopicSelector.java:41
Method
FieldNameBasedTupleToKafkaMapper
(String keyFieldName, String msgFieldName)
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/trident/mapper/FieldNameBasedTupleToKafkaMapper.java:28
Method
FieldNameBasedTupleToKafkaMapper
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/mapper/FieldNameBasedTupleToKafkaMapper.java:30
Method
FieldNameTopicSelector
(String fieldName, String defaultTopicName)
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/selector/FieldNameTopicSelector.java:36
Method
FieldSelector
(String fieldDescriptor)
storm-client/src/jvm/org/apache/storm/bolt/JoinBolt.java:490
Method
Fields
(String... fields)
storm-client/src/jvm/org/apache/storm/tuple/Fields.java:31
Method
FieldsGrouper
(Fields outFields, Grouping thriftGrouping)
storm-client/src/jvm/org/apache/storm/daemon/GrouperFactory.java:157
Method
FileBlobStoreImpl
(File path, Map<String, Object> conf)
storm-server/src/main/java/org/apache/storm/blobstore/FileBlobStoreImpl.java:48
Method
FileConfigLoader
(Map<String, Object> conf)
storm-server/src/main/java/org/apache/storm/scheduler/utils/FileConfigLoader.java:32
Method
FileDeletionThread
(int thdNum, FileSystem fs, Path file)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestHdfsSemantics.java:181
Method
FileLock
(FileSystem fs, Path lockFile, FSDataOutputStream lockFileStream, String spoutId)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/FileLock.java:45
Method
FileLockingThread
(int thdNum, FileSystem fs, Path fileToLock, Path locksDir, String spoutId)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestFileLock.java:342
Method
FileNotAvailableException
(String fileName)
storm-client/src/jvm/org/apache/storm/dependency/FileNotAvailableException.java:16
Method
FileReadSpout
(String file)
examples/storm-perf/src/main/java/org/apache/storm/perf/spout/FileReadSpout.java:48
Method
FileReader
(String file)
examples/storm-perf/src/main/java/org/apache/storm/perf/spout/FileReadSpout.java:115
Method
FileReporter
(Map<String, MetricExtractor> allExtractors)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java:331
Method
FileSizeRotationPolicy
(float count, Units units)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/rotation/FileSizeRotationPolicy.java:36
Method
FileSizeRotationPolicy
(float count, Units units)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/rotation/FileSizeRotationPolicy.java:37
Method
FileWatcher
(final Path watchedFile, Callback callback)
storm-client/src/jvm/org/apache/storm/daemon/common/FileWatcher.java:43
Method
FilterByMetricName
(List<String> whitelistPattern, List<String> blacklistPattern)
storm-client/src/jvm/org/apache/storm/metric/filter/FilterByMetricName.java:31
Method
FilterConfiguration
FilterConfiguration. @param filterClass filterClass @param filterParams filterParams
storm-webapp/src/main/java/org/apache/storm/daemon/ui/FilterConfiguration.java:27
Method
FilterExecutor
(Filter filter)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/FilterExecutor.java:27
Method
FilterOptions
()
storm-server/src/main/java/org/apache/storm/metricstore/FilterOptions.java:32
Method
FilterProcessor
(Predicate<T> predicate)
storm-client/src/jvm/org/apache/storm/streams/processors/FilterProcessor.java:20
Method
FirstN
(int n, String sortField)
storm-client/src/jvm/org/apache/storm/trident/operation/builtin/FirstN.java:33
Method
FirstNAgg
(int n)
storm-client/src/jvm/org/apache/storm/trident/operation/builtin/FirstN.java:56
Method
FirstNSortedAgg
(int n, String sortField, boolean reverse)
storm-client/src/jvm/org/apache/storm/trident/operation/builtin/FirstN.java:89
Method
FixedAvroSerializer
()
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/avro/FixedAvroSerializer.java:37
Method
FixedBatchSpout
(Fields fields, int maxBatchSize, List<Object>... outputs)
storm-client/src/jvm/org/apache/storm/trident/testing/FixedBatchSpout.java:35
Method
FixedBatchSpout
(Fields fields, int maxBatchSize, List<Object>... outputs)
examples/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/trident/FixedBatchSpout.java:40
Method
FixedTuple
(List<Object> values)
storm-client/src/jvm/org/apache/storm/testing/FixedTuple.java:23
Method
FixedTupleSpout
(List tuples)
storm-client/src/jvm/org/apache/storm/testing/FixedTupleSpout.java:39
Method
FixedWidthReporter
(String path, Map<String, String> query, Map<String, MetricExtractor> extractorsMap)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java:593
Method
FlatMapFunctionExecutor
(FlatMapFunction function)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/FlatMapFunctionExecutor.java:28
Method
FlatMapProcessor
(FlatMapFunction<T, R> function)
storm-client/src/jvm/org/apache/storm/streams/processors/FlatMapProcessor.java:20
Method
FlatMapValuesProcessor
(FlatMapFunction<V, R> function)
storm-client/src/jvm/org/apache/storm/streams/processors/FlatMapValuesProcessor.java:21
Method
FluxParser
()
flux/flux-core/src/main/java/org/apache/storm/flux/parser/FluxParser.java:52
Method
FluxShellBolt
Create a ShellBolt with command line arguments. @param command Command line arguments for the bolt
flux/flux-wrappers/src/main/java/org/apache/storm/flux/wrappers/bolts/FluxShellBolt.java:44
Method
FluxShellSpout
Create a ShellSpout with command line arguments. @param command Command line arguments for the bolt
flux/flux-wrappers/src/main/java/org/apache/storm/flux/wrappers/spouts/FluxShellSpout.java:45
Method
ForEachProcessor
(Consumer<T> consumer)
storm-client/src/jvm/org/apache/storm/streams/processors/ForEachProcessor.java:20
Method
Forwarder
(JCQueue inq, JCQueue outq)
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Forwarder.java:30
Method
ForwardingProcessorContext
(ProcessorNode processorNode, Multimap<String, ProcessorNode> streamToChildren)
storm-client/src/jvm/org/apache/storm/streams/processors/ForwardingProcessorContext.java:32
Method
FreezerCore
(String dir)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/FreezerCore.java:25
← previous
next →
11,801–11,900 of 27,770, ranked by callers