MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
↓ 2 callersMethodgetRequestedGenericResources
()
storm-server/src/main/java/org/apache/storm/daemon/nimbus/TopologyResources.java:274
↓ 2 callersMethodgetResourceAsBytes
Read the contents of the fully qualified resource path. @param resource to read. @return byte array of the fully read resource. @throws Exception upo
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestLargeCluster.java:158
↓ 2 callersMethodgetResourceAsBytes
Read the contents of the fully qualified resource path. @param resourcePath to read @return byte array read @throws Exception in called nnethods.
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestTopologyAnonymizerUtils.java:191
↓ 2 callersMethodgetResourceAsStream
InputStream to read the fully qualified resource path. @param resourcePath to read
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestTopologyAnonymizerUtils.java:152
↓ 2 callersMethodgetResourceFiles
Get the list of serialized topology ( code.ser) and configuration ( conf.ser) resource files in the path. The resources are sorted so that paired topo
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestLargeCluster.java:120
↓ 2 callersMethodgetResourceFiles
Get the list of serialized topology (ending with {@link #COMPRESSED_SERIALIZED_TOPOLOGY_FILENAME_ENDING} and configuration (ending with {@link #COMPRE
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestTopologyAnonymizerUtils.java:164
↓ 2 callersFunctiongetResourceGuaranteeRemainingFormat
(type, data)
storm-webapp/src/main/webapp/js/script.js:606
↓ 2 callersMethodgetResourceNameMapping
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/normalization/ResourceNameNormalizer.java:64
↓ 2 callersMethodgetResourceNamesToArrayIndex
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/normalization/ResourceMapArrayBridge.java:93
↓ 2 callersMethodgetResourcePath
()
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestLargeCluster.java:93
↓ 2 callersMethodgetRetryService
()
examples/storm-kafka-client-examples/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutTopologyMainNamedTopics.java:98
↓ 2 callersMethodgetRevision
Get the SCM revision number of the build. @return the SCM revision number of the build.
storm-client/src/jvm/org/apache/storm/utils/IVersionInfo.java:35
↓ 2 callersMethodgetRocksDbAbsoluteDir
(Map<String, Object> conf)
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbStore.java:150
↓ 2 callersMethodgetRootCgroups
()
storm-client/src/jvm/org/apache/storm/container/cgroup/Hierarchy.java:104
↓ 2 callersMethodgetRootId
()
storm-client/src/jvm/org/apache/storm/executor/TupleInfo.java:69
↓ 2 callersMethodgetSampleTime
()
examples/storm-perf/src/main/java/org/apache/storm/perf/utils/MetricsSample.java:170
↓ 2 callersMethodgetSaslMechanism
()
external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/NewKafkaSpoutOffsetQuery.java:59
↓ 2 callersMethodgetSaslProps
()
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslUtils.java:28
↓ 2 callersMethodgetSearchHandler
()
storm-webapp/src/test/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogSearchHandlerTest.java:866
↓ 2 callersMethodgetSecretKey
(Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslUtils.java:55
↓ 2 callersMethodgetSecurityProtocol
()
external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/NewKafkaSpoutOffsetQuery.java:55
↓ 2 callersMethodgetSelfOutputFields
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/TridentContext.java:47
↓ 2 callersMethodgetSerializer
Returns Serializer which is used for serializing tuple value and deserializing Redis value. @return serializer
external/storm-redis/src/main/java/org/apache/storm/redis/trident/state/AbstractRedisMapState.java:110
↓ 2 callersMethodgetServerKeyStorePassword
(Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/security/auth/ThriftConnectionType.java:206
↓ 2 callersMethodgetServerTrustStorePassword
(Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/security/auth/ThriftConnectionType.java:214
↓ 2 callersMethodgetServerTrustStorePath
(Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/security/auth/ThriftConnectionType.java:210
↓ 2 callersMethodgetSession
Returns the currently active session. @return The currently active session
external/storm-jms/src/main/java/org/apache/storm/jms/spout/JmsSpout.java:362
↓ 2 callersMethodgetSharedContext
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java:219
↓ 2 callersMethodgetSharedMemoryRequests
Gets the total memory resource list for a set of tasks that is part of a topology. @param executors all executors for a topology @return the set o
storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:346
↓ 2 callersMethodgetSize
()
storm-server/src/main/java/org/apache/storm/container/oci/OciResource.java:53
↓ 2 callersMethodgetSizeOnDisk
()
storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java:303
↓ 2 callersMethodgetSlidingInterval
Returns the sliding interval for time based windows. @return the sliding interval
storm-client/src/jvm/org/apache/storm/windowing/EvictionContext.java:40
↓ 2 callersMethodgetSlotsAvailableToScheduleOn
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/RasNode.java:143
↓ 2 callersMethodgetSlotsPorts
(Map<String, Object> supervisorConf)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/SupervisorUtils.java:94
↓ 2 callersMethodgetSortedNodesForHost
(String hostId)
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/NodeSorterHostProximity.java:596
↓ 2 callersMethodgetSortedRacks
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/INodeSorter.java:34
↓ 2 callersMethodgetSourceStreamId
()
storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java:239
↓ 2 callersMethodgetSpoutEmittedAggregate
Get the messages emitted per second in aggregate for all of the spouts in the topology. @return messages per second.
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/TopologyLoadConf.java:465
↓ 2 callersMethodgetSpoutName
()
integration-test/src/main/java/org/apache/storm/st/topology/TestableTopology.java:36
↓ 2 callersMethodgetSpoutName
()
integration-test/src/main/java/org/apache/storm/st/topology/window/SlidingWindowCorrectness.java:60
↓ 2 callersMethodgetSpoutName
()
integration-test/src/main/java/org/apache/storm/st/topology/window/TumblingWindowCorrectness.java:58
↓ 2 callersMethodgetSpoutName
()
integration-test/src/main/java/org/apache/storm/st/topology/window/SlidingTimeCorrectness.java:60
↓ 2 callersMethodgetSpoutName
()
integration-test/src/main/java/org/apache/storm/st/topology/window/TumblingTimeCorrectness.java:58
↓ 2 callersMethodgetSpoutTransferred
()
examples/storm-perf/src/main/java/org/apache/storm/perf/utils/MetricsSample.java:198
↓ 2 callersMethodgetSrcChecksum
Get the checksum of the source. @return the checksum of the source.
storm-client/src/jvm/org/apache/storm/utils/IVersionInfo.java:53
↓ 2 callersMethodgetSslConf
(Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/utils/CuratorUtils.java:158
↓ 2 callersMethodgetStartTask
()
storm-server/src/main/java/org/apache/storm/scheduler/ExecutorDetails.java:33
↓ 2 callersMethodgetStateStorage
()
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java:293
↓ 2 callersMethodgetStatefulProcessors
(List<ProcessorNode> nodes)
storm-client/src/jvm/org/apache/storm/streams/StatefulProcessorBolt.java:92
↓ 2 callersMethodgetStatesSearched
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/SchedulingSearcherState.java:149
↓ 2 callersMethodgetStats
()
storm-client/src/jvm/org/apache/storm/executor/spout/SpoutExecutor.java:92
↓ 2 callersMethodgetStats
()
storm-client/src/jvm/org/apache/storm/executor/bolt/BoltExecutor.java:89
↓ 2 callersMethodgetStormClusterState
()
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:1767
↓ 2 callersMethodgetStormTopology
()
integration-test/src/main/java/org/apache/storm/ExclamationTopology.java:119
↓ 2 callersMethodgetStormVersion
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java:247
↓ 2 callersMethodgetStreamId
()
flux/flux-core/src/main/java/org/apache/storm/flux/model/GroupingDef.java:63
↓ 2 callersMethodgetStreamId
()
storm-server/src/main/java/org/apache/storm/metricstore/Metric.java:216
↓ 2 callersMethodgetStreamSelector
(Tuple ti)
storm-client/src/jvm/org/apache/storm/bolt/JoinBolt.java:305
↓ 2 callersMethodgetStringMetadata
Gets StringMetadata associated with the key/value pair.
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbValue.java:106
↓ 2 callersMethodgetSummaries
()
integration-test/src/test/java/org/apache/storm/st/wrapper/StormCluster.java:63
↓ 2 callersMethodgetSuperUserAcl
Get the ACL for nimbus/supervisor. The Super User ACL. This assumes that security is enabled. @param conf the config to get the super User ACL from
storm-client/src/jvm/org/apache/storm/utils/Utils.java:601
↓ 2 callersMethodgetSupervisorToCpuUsage
(ISchedulingState cluster, Topologies topologies)
storm-server/src/test/java/org/apache/storm/scheduler/resource/TestUtilsForResourceAwareScheduler.java:591
↓ 2 callersMethodgetSupervisorToMemoryUsage
(ISchedulingState cluster, Topologies topologies)
storm-server/src/test/java/org/apache/storm/scheduler/resource/TestUtilsForResourceAwareScheduler.java:557
↓ 2 callersMethodgetSupervisors
()
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:917
↓ 2 callersMethodgetSupervisorsByHost
(String host)
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:874
↓ 2 callersMethodgetSupervisorsByHost
Get all the supervisors on the specified <code>host</code>. @param host hostname of the supervisor @return the <code>SupervisorDetails</code> object.
storm-server/src/main/java/org/apache/storm/scheduler/ISchedulingState.java:245
↓ 2 callersMethodgetSupervisorsMap
getSupervisorsMap. @param supervisors supervisors @param config config @return getSupervisorsMap
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:1078
↓ 2 callersMethodgetSvnUriInfo
(String str)
storm-buildtools/storm-maven-plugins/src/main/java/org/apache/storm/maven/plugin/versioninfo/VersionInfoMojo.java:148
↓ 2 callersMethodgetTarget
()
storm-client/src/jvm/org/apache/storm/streams/Edge.java:33
↓ 2 callersMethodgetTaskData
Fetches the task-level data for the given name. This data is shared amongst the task and its corresponding task hooks. @param name name of the task-
storm-client/src/jvm/org/apache/storm/task/TopologyContext.java:267
↓ 2 callersMethodgetTaskIdToBuckets
(String componentName, String metricName)
storm-core/test/jvm/org/apache/storm/metric/FakeMetricConsumer.java:32
↓ 2 callersMethodgetTasks
()
storm-client/src/jvm/org/apache/storm/container/cgroup/CgroupCommon.java:61
↓ 2 callersMethodgetTempFileName
(long version)
storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java:346
↓ 2 callersMethodgetTestDir
Get an uncreated directory for tests. We use this method to get rid of getTestDir() in GenericTestUtils in Hadoop code which uses assert from junit4.
external/storm-hdfs-blobstore/src/test/java/org/apache/storm/hdfs/testing/MiniDFSClusterExtension.java:79
↓ 2 callersMethodgetTestDir
Get an uncreated directory for tests. We use this method to get rid of getTestDir() in GenericTestUtils in Hadoop code which uses assert from junit4.
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/testing/MiniDFSClusterExtension.java:78
↓ 2 callersMethodgetTextFileContents
(FileSystem fs, Path txtFile)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestHdfsSpout.java:353
↓ 2 callersFunctiongetThemeOptions
()
storm-webapp/src/main/webapp/js/visualization.js:131
↓ 2 callersMethodgetTimeUnitForConfig
(Map<String, Object> daemonConf, String configName)
storm-server/src/main/java/org/apache/storm/daemon/metrics/MetricsUtils.java:104
↓ 2 callersMethodgetTimeWindow
()
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java:264
↓ 2 callersMethodgetTimestamp
()
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbKey.java:189
↓ 2 callersMethodgetTimestampExtractor
Return a {@link TimestampExtractor} for extracting timestamps from a tuple for event time based processing, or null for processing time. @return the
storm-client/src/jvm/org/apache/storm/topology/IWindowedBolt.java:44
↓ 2 callersMethodgetTimestampFieldName
()
integration-test/src/main/java/org/apache/storm/st/topology/window/data/TimeData.java:75
↓ 2 callersMethodgetTokenSeparatorRegex
Token separator regex used to parse Shell tool outputs.
storm-client/src/jvm/org/apache/storm/utils/ShellCommandRunner.java:64
↓ 2 callersMethodgetTopoCache
()
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:1803
↓ 2 callersMethodgetTopoLogsGroups
(Map<String, Object> topologyConf)
storm-server/src/main/java/org/apache/storm/utils/ServerConfigUtils.java:99
↓ 2 callersMethodgetTopoLogsUsers
(Map<String, Object> topologyConf)
storm-server/src/main/java/org/apache/storm/utils/ServerConfigUtils.java:89
↓ 2 callersMethodgetTopolgoyLogConfig
getTopolgoyLogConfig. @param logConfig logConfig @return getTopolgoyLogConfig
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:2155
↓ 2 callersMethodgetTopologiesMap
getTopologiesMap. @param id id @param topologies topologies @return getTopologiesMap
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:839
↓ 2 callersMethodgetTopologiesWithStatus
(final String expectedStatus)
integration-test/src/test/java/org/apache/storm/st/wrapper/StormCluster.java:77
↓ 2 callersMethodgetTopologyIds
Get the topology ids with cached heartbeats. @return the set of topology ids with cached heartbeats.
storm-server/src/main/java/org/apache/storm/daemon/nimbus/HeartbeatCache.java:132
↓ 2 callersMethodgetTopologyInfo
(String name, String asUser, Map<String, Object> topoConf)
storm-client/src/jvm/org/apache/storm/utils/Utils.java:1199
↓ 2 callersMethodgetTopologyInfo
(String id)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4227
↓ 2 callersMethodgetTopologyInfoByNameImpl
(String name, GetInfoOptions options)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4259
↓ 2 callersMethodgetTopologyKafkaSpout
(KafkaSpoutConfig<String, String> spoutConfig)
examples/storm-kafka-client-examples/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutTopologyMainNamedTopics.java:71
↓ 2 callersMethodgetTopologyPortWorkerLog
Return the path of the worker log with the format of topoId/port/worker.log. @param file worker log
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/utils/WorkerLogs.java:273
↓ 2 callersMethodgetTopologyProfileRequests
(String stormId)
storm-client/src/jvm/org/apache/storm/cluster/IStormClusterState.java:130
↓ 2 callersMethodgetTopologySource
()
flux/flux-core/src/main/java/org/apache/storm/flux/model/TopologyDef.java:289
↓ 2 callersMethodgetTopologySummariesImpl
()
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:3107
↓ 2 callersMethodgetTopologyTimeoutMillis
(Map<String, Object> topoConf)
storm-client/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java:86
↓ 2 callersMethodgetTotalAcked
()
examples/storm-perf/src/main/java/org/apache/storm/perf/utils/MetricsSample.java:182
← previousnext →4,901–5,000 of 27,770, ranked by callers