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
thriftifyCompPageData
( String topologyId, StormTopology topology, String compId, Map<String, Object> data)
storm-server/src/main/java/org/apache/storm/stats/StatsUtil.java:1984
↓ 1 callers
Method
thriftifyExecAggStats
(String compId, String compType, Map m)
storm-server/src/main/java/org/apache/storm/stats/StatsUtil.java:1923
↓ 1 callers
Method
thriftifyExecutorStats
Convert Executor stats to thrift data structure. @param stats the stats in the form of a map. @return teh thrift structure for the stats.
storm-server/src/main/java/org/apache/storm/stats/StatsUtil.java:2051
↓ 1 callers
Method
thriftifyRpcWorkerHb
Used for local test.
storm-server/src/main/java/org/apache/storm/stats/StatsUtil.java:1883
↓ 1 callers
Method
thriftifySpecificStats
(Map stats)
storm-server/src/main/java/org/apache/storm/stats/StatsUtil.java:2063
↓ 1 callers
Method
thriftifySpoutOutputStats
(Map id2outStats)
storm-server/src/main/java/org/apache/storm/stats/StatsUtil.java:1953
↓ 1 callers
Method
throughput
()
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/MyThread.java:29
↓ 1 callers
Method
throughput
()
examples/storm-perf/src/main/java/org/apache/storm/perf/toolstest/MyThd.java:30
↓ 1 callers
Method
timeoutId
(Object id)
storm-client/src/jvm/org/apache/storm/coordination/CoordinatedBolt.java:244
↓ 1 callers
Method
toDeliveryModeString
Return a friendly string for the given JMS acknowledge mode, or throw an IllegalArgumentException if the mode is not recognized. <p/> Possible values:
external/storm-jms/src/main/java/org/apache/storm/jms/trident/TridentJmsSpout.java:81
↓ 1 callers
Method
toDouble
(Map<String, Number> resources)
storm-server/src/test/java/org/apache/storm/scheduler/resource/TestUtilsForResourceAwareScheduler.java:94
↓ 1 callers
Method
toDouble
(Object obj)
external/storm-metrics-prometheus/src/main/java/org/apache/storm/metrics/prometheus/PrometheusReporterClient.java:98
↓ 1 callers
Method
toExecInfo
(List<Long> exec)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:1284
↓ 1 callers
Method
toGlobalStreamId
(List list)
storm-server/src/main/java/org/apache/storm/stats/StatsUtil.java:2096
↓ 1 callers
Method
toPairStream
()
storm-client/src/jvm/org/apache/storm/streams/StreamState.java:30
↓ 1 callers
Method
toPositive
A cheap way to deterministically convert a number to a positive value. When the input is positive, the original value is returned. When the input numb
storm-client/src/jvm/org/apache/storm/utils/Utils.java:1003
↓ 1 callers
Method
toSetterName
(String name)
flux/flux-core/src/main/java/org/apache/storm/flux/FluxBuilder.java:325
↓ 1 callers
Method
toStream
()
storm-client/src/jvm/org/apache/storm/trident/fluent/GroupedStream.java:151
↓ 1 callers
Method
toStream
()
storm-client/src/jvm/org/apache/storm/trident/fluent/IAggregatableStream.java:25
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/container/cgroup/CgroupCommon.java:251
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/spout/CheckPointState.java:129
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/KerberosSaslTransportPlugin.java:316
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/grouping/Load.java:71
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/trident/operation/impl/Result.java:18
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/trident/graph/Group.java:154
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/Credentials.java:361
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/SubmitOptions.java:359
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:2682
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/NotAliveException.java:275
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/AuthorizationException.java:275
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/KeyAlreadyExistsException.java:275
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/HBMessage.java:434
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/AlreadyAliveException.java:275
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/LogLevel.java:570
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/LSApprovedWorkers.java:289
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/InvalidTopologyException.java:275
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/HBPulse.java:360
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java:628
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/LSSupervisorAssignments.java:300
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/LocalStateData.java:300
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/IllegalStateException.java:275
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/HBExecutionException.java:275
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/Assignment.java:822
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/HBAuthorizationException.java:275
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/LSTopoHistoryList.java:296
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/KeyNotFoundException.java:275
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/LSSupervisorId.java:275
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/DRPCExecutionException.java:359
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java:485
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/state/InMemoryKeyValueState.java:93
↓ 1 callers
Method
toString
()
storm-client/src/jvm/org/apache/storm/coordination/CoordinatedBolt.java:262
↓ 1 callers
Method
toString
()
storm-server/src/main/java/org/apache/storm/container/oci/ImageManifest.java:69
↓ 1 callers
Method
toString
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/SchedulingResult.java:72
↓ 1 callers
Method
toString
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:60
↓ 1 callers
Method
toString
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/BasicContainer.java:878
↓ 1 callers
Method
toString
()
storm-server/src/main/java/org/apache/storm/localizer/LocalResource.java:47
↓ 1 callers
Method
toString
()
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/RankableObjectWithFields.java:117
↓ 1 callers
Method
toString
()
examples/storm-starter/src/jvm/org/apache/storm/starter/trident/TridentMinMaxOfDevicesTopology.java:144
↓ 1 callers
Method
toString
()
external/storm-redis/src/test/java/org/apache/storm/redis/util/outputcollector/EmittedTuple.java:48
↓ 1 callers
Method
toString
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutOpaque.java:73
↓ 1 callers
Method
toString
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutBatchMetadata.java:98
↓ 1 callers
Method
toString
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutEmitter.java:381
↓ 1 callers
Method
toString
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutCoordinator.java:90
↓ 1 callers
Method
toString
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java:227
↓ 1 callers
Method
toYamlString
Convert this into a YAML String. @return this as a YAML String.
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/TopologyLoadConf.java:147
↓ 1 callers
Function
toggleComponents
(elId)
storm-webapp/src/main/webapp/js/script.js:548
↓ 1 callers
Method
tokenizePath
(String path)
storm-client/src/jvm/org/apache/storm/cluster/StormClusterStateImpl.java:157
↓ 1 callers
Method
topologicalSortComponents
Sort components topologically. @param componentMap The map of component Id to Component Object. @return The sorted components
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/ExecSorterByProximity.java:91
↓ 1 callers
Method
topologyMachineDistributions
(List<TopologyDetails> isoTopologies)
storm-server/src/main/java/org/apache/storm/scheduler/IsolationScheduler.java:242
↓ 1 callers
Method
topologyUsingThisBlob
Returns the topologyId of the topology using this blob. @param state the cluster state @param topoCache the topology cache @param key the blob key @re
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:1012
↓ 1 callers
Method
topologyWorkerSpecs
(List<TopologyDetails> topologies)
storm-server/src/main/java/org/apache/storm/scheduler/IsolationScheduler.java:185
↓ 1 callers
Method
track
feed the event to the eviction and trigger policies for bookkeeping and optionally firing the trigger.
storm-client/src/jvm/org/apache/storm/windowing/WindowManager.java:183
↓ 1 callers
Method
trackAssignmentFailures
()
storm-server/src/main/java/org/apache/storm/scheduler/blacklist/BlacklistScheduler.java:165
↓ 1 callers
Method
trackMissedHeartbeats
(Map<String, SupervisorDetails> supervisors)
storm-server/src/main/java/org/apache/storm/scheduler/blacklist/BlacklistScheduler.java:139
↓ 1 callers
Method
transactional
Provides StateFactory for transactional. @param jedisPoolConfig configuration for JedisPool @return StateFactory
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisMapState.java:118
↓ 1 callers
Method
transactional
Provides StateFactory for transactional. @param jedisClusterConfig configuration for JedisCluster @return StateFactory
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/RedisClusterMapState.java:120
↓ 1 callers
Method
transfer
(ArrayList<AddressedTuple> tupleBatch)
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java:830
↓ 1 callers
Method
transformArtifactResultToArtifactToPaths
(List<ArtifactResult> artifactResults)
storm-submit-tools/src/main/java/org/apache/storm/submit/command/DependencyResolverMain.java:187
↓ 1 callers
Method
transition
(LoadMapping load)
storm-client/src/jvm/org/apache/storm/grouping/LoadAwareShuffleGrouping.java:147
↓ 1 callers
Method
transition
(Object argument, Nimbus nimbus, String topoId, StormBase base)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/TopologyStateTransition.java:22
↓ 1 callers
Method
trimHead
()
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/ProgressTracker.java:37
↓ 1 callers
Method
trimmed_title
(self)
dev-tools/github/__init__.py:48
↓ 1 callers
Method
tryFlush
Non blocking call. tries to flush as many as possible. Returns true if at least one from non-empty currentBatch was flushed or if currentBatch is empt
storm-client/src/jvm/org/apache/storm/utils/JCQueue.java:394
↓ 1 callers
Method
tryFlushPendingEmits
()
storm-client/src/jvm/org/apache/storm/executor/spout/SpoutExecutor.java:249
↓ 1 callers
Method
tryFlushPendingEmits
()
storm-client/src/jvm/org/apache/storm/executor/bolt/BoltExecutor.java:180
↓ 1 callers
Method
tryPublishDirect
Non-blocking call. Bypasses any batching that may be enabled on the recvQueue. Intended for sending flush/metrics tuples
storm-client/src/jvm/org/apache/storm/utils/JCQueue.java:194
↓ 1 callers
Method
tryReadAhead
Tries once to read ahead in the stream to fill the context and resets the stream to its position before the call.
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogSearchHandler.java:653
↓ 1 callers
Method
tryReadTopologyFromName
(final String topoName)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:2768
↓ 1 callers
Method
tryTransferLocal
Adds tuple to localQueue (if overflow is empty). If localQueue is full adds to pendingEmits instead. pendingEmits can be null. Returns false if unable
storm-client/src/jvm/org/apache/storm/executor/ExecutorTransfer.java:100
↓ 1 callers
Method
tuples
(Collection<RefCountedTuple> anchors)
storm-client/src/jvm/org/apache/storm/streams/processors/EmittingProcessorContext.java:129
↓ 1 callers
Method
umount
(String pathToDir)
storm-client/src/jvm/org/apache/storm/container/cgroup/SystemOperation.java:46
↓ 1 callers
Method
unJar
Unpack matching files from a jar. Entries inside the jar that do not match the given pattern will be skipped. @param jarFile the .jar file to unpack
storm-server/src/main/java/org/apache/storm/utils/ServerUtils.java:396
↓ 1 callers
Method
unTar
Given a Tar File as input it will untar the file in a the untar directory passed as the second parameter <p/> This utility will untar ".tar" files and
storm-server/src/main/java/org/apache/storm/utils/ServerUtils.java:422
↓ 1 callers
Method
unTarUsingJava
(File inFile, File untarDir, boolean gzipped, boolean symlinksDisabled)
storm-server/src/main/java/org/apache/storm/utils/ServerUtils.java:467
↓ 1 callers
Method
unTarUsingTar
(File inFile, File untarDir, boolean gzipped)
storm-server/src/main/java/org/apache/storm/utils/ServerUtils.java:437
↓ 1 callers
Method
unZip
Given a File input it will unzip the file in a the unzip directory passed as the second parameter. @param inFile The zip file as input @param toDir
storm-server/src/main/java/org/apache/storm/utils/ServerUtils.java:649
↓ 1 callers
Method
unauthorizedUserJson
Unauthorized user json. @param user User id. @return Unauthorized user json.
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:222
↓ 1 callers
Method
uncaughtException
(Thread t, Throwable e)
storm-client/src/jvm/org/apache/storm/utils/Utils.java:421
↓ 1 callers
Method
uniquedSubscriptions
(Set<PartitionNode> subscriptions)
storm-client/src/jvm/org/apache/storm/trident/TridentTopology.java:247
↓ 1 callers
Method
unpack
(File localrsrc, File dst, boolean symLinksDisabled)
storm-server/src/main/java/org/apache/storm/utils/ServerUtils.java:571
← previous
next →
10,301–10,400 of 27,770, ranked by callers