MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
↓ 4 callersMethodgetMetricsReporterLocale
(Map<String, Object> daemonConf)
storm-server/src/main/java/org/apache/storm/daemon/metrics/MetricsUtils.java:96
↓ 4 callersMethodgetName
(long rotation, long timeStamp)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/SimpleFileNameFormat.java:33
↓ 4 callersMethodgetNeedsSchedulingExecutorToComponents
( TopologyDetails topology)
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:371
↓ 4 callersMethodgetNextAvailableRequest
(DRPCInvocationsClient invoke, String func)
storm-webapp/src/test/java/org/apache/storm/daemon/drpc/DRPCServerTest.java:59
↓ 4 callersMethodgetNimbodesWithLatestSequenceNumberOfBlob
(CuratorFramework zkClient, String key)
storm-server/src/main/java/org/apache/storm/blobstore/BlobStoreUtils.java:80
↓ 4 callersMethodgetNodeAndSlotCountIfSlotsWereTaken
(int slotsNeeded)
storm-server/src/main/java/org/apache/storm/scheduler/multitenant/IsolatedPool.java:352
↓ 4 callersMethodgetNodeAndSlotCountIfSlotsWereTaken
(int slotsNeeded)
storm-server/src/main/java/org/apache/storm/scheduler/multitenant/FreePool.java:93
↓ 4 callersMethodgetNodeAndSlotCountIfSlotsWereTaken
(int slotsNeeded)
storm-server/src/main/java/org/apache/storm/scheduler/multitenant/DefaultPool.java:88
↓ 4 callersMethodgetNodes
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/RasNodes.java:143
↓ 4 callersMethodgetNodes
Returns nodes. @return list of node information
external/storm-redis/src/main/java/org/apache/storm/redis/common/config/JedisClusterConfig.java:78
↓ 4 callersMethodgetNthUncommittedOffsetAfterCommittedOffset
Gets the offset of the nth emitted message after the committed offset. Example: If the committed offset is 0 and offsets 1, 2, 8, 10 have been emitted
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java:82
↓ 4 callersMethodgetNumTasks
()
flux/flux-core/src/main/java/org/apache/storm/flux/model/VertexDef.java:42
↓ 4 callersMethodgetObject
()
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/Rankable.java:17
↓ 4 callersMethodgetOffHeapMemoryLoad
()
flux/flux-core/src/main/java/org/apache/storm/flux/model/VertexDef.java:58
↓ 4 callersMethodgetOutput
Get the output of the shell command.
storm-client/src/jvm/org/apache/storm/utils/ShellUtils.java:445
↓ 4 callersMethodgetOutputFields
()
storm-client/src/jvm/org/apache/storm/trident/spout/IBatchSpout.java:31
↓ 4 callersMethodgetOutputStream
Get an output stream to write to a given file. @param file the file to write to @return an OutputStream for that file @throws IOException on any err
storm-client/src/jvm/org/apache/storm/daemon/supervisor/IAdvancedFSOps.java:205
↓ 4 callersMethodgetParallelism
()
flux/flux-core/src/main/java/org/apache/storm/flux/model/VertexDef.java:34
↓ 4 callersMethodgetParent
()
storm-client/src/jvm/org/apache/storm/container/cgroup/CgroupCommon.java:153
↓ 4 callersMethodgetParentStreams
(Node parent)
storm-client/src/jvm/org/apache/storm/streams/Node.java:126
↓ 4 callersMethodgetPath
()
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/SimpleFileNameFormat.java:46
↓ 4 callersMethodgetPhysicalUsageLimit
()
storm-client/src/jvm/org/apache/storm/container/cgroup/core/MemoryCore.java:68
↓ 4 callersMethodgetPrefix
Get a zeroed key of the specified type. @param type the desired type @return a key of the desired type
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbKey.java:93
↓ 4 callersMethodgetQueue
(int port)
storm-client/src/jvm/org/apache/storm/utils/InprocMessaging.java:87
↓ 4 callersMethodgetRackIdToHosts
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/NodeSorterHostProximity.java:120
↓ 4 callersMethodgetRequestedCpu
()
storm-server/src/main/java/org/apache/storm/daemon/nimbus/TopologyResources.java:194
↓ 4 callersMethodgetResourceAt
(int index)
storm-server/src/main/java/org/apache/storm/scheduler/resource/normalization/NormalizedResources.java:197
↓ 4 callersMethodgetResourcesForTopology
(String topoId, StormBase base)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:2420
↓ 4 callersMethodgetRollingAverageGauge
(String metricName, String streamId)
storm-client/src/jvm/org/apache/storm/metrics2/TaskMetrics.java:137
↓ 4 callersMethodgetRunningProcessIds
Get running processes for all or specified user. @param user Null for all users, otherwise specify the user. e.g. "root" @return List of ProcessIds f
storm-server/src/test/java/org/apache/storm/utils/ServerUtilsTest.java:106
↓ 4 callersMethodgetSerializer
(Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/utils/ShellProcess.java:95
↓ 4 callersMethodgetServiceId
Get the ID of the service. This is used internally if multiple local DRPC clusters are in use at one time.
storm-client/src/jvm/org/apache/storm/ILocalDRPC.java:24
↓ 4 callersMethodgetSizeOnDisk
Get the amount of disk space that is used by this blob. If the blob is uncompressed it should be the sum of the space used by all of the uncompressed
storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedBlob.java:180
↓ 4 callersMethodgetStartTime
()
storm-core/src/jvm/org/apache/storm/utils/Monitor.java:215
↓ 4 callersMethodgetStatDisplayMapLong
getStatDisplayMapLong. @param windowToTransferred windowToTransferred @return getStatDisplayMapLong
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:1191
↓ 4 callersMethodgetStats
()
storm-client/src/jvm/org/apache/storm/executor/Executor.java:660
↓ 4 callersMethodgetStr
(Map map, Object key)
examples/storm-perf/src/main/java/org/apache/storm/perf/KafkaClientHdfsTopo.java:121
↓ 4 callersMethodgetStreams
()
flux/flux-core/src/main/java/org/apache/storm/flux/model/TopologyDef.java:122
↓ 4 callersMethodgetSubSystems
get a list of available subsystems.
storm-client/src/jvm/org/apache/storm/container/cgroup/CgroupOperation.java:33
↓ 4 callersMethodgetSupervisorById
(String nodeId)
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:864
↓ 4 callersMethodgetSupervisorPageInfo
(java.lang.String id, java.lang.String host, boolean is_include_sys)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:130
↓ 4 callersMethodgetTGT
(Subject subject)
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/AutoTGT.java:49
↓ 4 callersMethodgetThisTargets
Gets information about who is consuming the outputs of this component, and how. @return Map from stream id to component id to the Grouping used.
storm-client/src/jvm/org/apache/storm/task/TopologyContext.java:247
↓ 4 callersMethodgetTimeCounts
Get time counts. @return a map of time window to count. Keys are "600" for last 10 mins "10800" for the last 3 hours "86400" for the last day ":al
storm-client/src/jvm/org/apache/storm/metric/internal/CountStat.java:138
↓ 4 callersMethodgetTimeData
()
integration-test/src/main/java/org/apache/storm/st/topology/window/data/TimeDataWindow.java:46
↓ 4 callersMethodgetTimeLatAvg
Get time latency average. @return a map of time window to average latency. Keys are "600" for last 10 mins "10800" for the last 3 hours "86400" for th
storm-client/src/jvm/org/apache/storm/metric/internal/LatencyStat.java:206
↓ 4 callersMethodgetTopicFilter
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/CommonKafkaSpoutConfig.java:240
↓ 4 callersMethodgetTopologyContext
()
storm-client/test/jvm/org/apache/storm/topology/WindowedBoltExecutorTest.java:80
↓ 4 callersMethodgetTopologyHistory
(java.lang.String user)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:150
↓ 4 callersMethodgetTopologyId
Get the unique string Id for a metric's topologyId.
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbKey.java:184
↓ 4 callersMethodgetTopologySummary
(java.lang.String id)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:114
↓ 4 callersMethodgetTotalCpuResources
Gets the total cpu resources for this node. @return the total cpu for this node
storm-server/src/main/java/org/apache/storm/scheduler/resource/RasNode.java:521
↓ 4 callersMethodgetTotalMemReqTask
Gets the total memory requirement for a task. @param exec the executor the inquiry is concerning. @return Double the total memory requirement for thi
storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:332
↓ 4 callersMethodgetTotalMemoryResources
Gets the total memory resources for this node. @return the total memory for this node
storm-server/src/main/java/org/apache/storm/scheduler/resource/RasNode.java:499
↓ 4 callersMethodgetTotalRequestedGenericResources
()
storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:502
↓ 4 callersMethodgetTrackedId
If the cluster is tracked get the id for the tracked cluster. This is intended for internal testing only. @return the id of the tracked cluster
storm-client/src/jvm/org/apache/storm/ILocalCluster.java:213
↓ 4 callersMethodgetTuple
()
storm-client/src/jvm/org/apache/storm/tuple/AddressedTuple.java:40
↓ 4 callersMethodgetTxid
()
storm-client/src/jvm/org/apache/storm/spout/CheckPointState.java:48
↓ 4 callersMethodgetUsedCpu
()
storm-server/src/main/java/org/apache/storm/scheduler/SupervisorResources.java:59
↓ 4 callersMethodgetUsedMem
()
storm-server/src/main/java/org/apache/storm/scheduler/SupervisorResources.java:55
↓ 4 callersMethodgetVal
()
storm-client/src/jvm/org/apache/storm/trident/state/TransactionalValue.java:26
↓ 4 callersMethodgetValueAndReset
Returns serialized byte count traffic metrics. @return Map of metric counts, or null if disabled
storm-client/src/jvm/org/apache/storm/messaging/DeserializingConnectionCallback.java:79
↓ 4 callersMethodgetVersion
()
storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedBlob.java:423
↓ 4 callersMethodgetWindowLength
Returns the length of the window.
storm-client/src/jvm/org/apache/storm/trident/windowing/config/WindowConfig.java:26
↓ 4 callersMethodgetWorkerLogLink
Get log link to supervisor log. @param host supervisor host name @param config storm config @return log link.
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:905
↓ 4 callersMethodgetZookeeperKeySet
()
storm-server/src/main/java/org/apache/storm/blobstore/LocalFsBlobStoreSynchronizer.java:70
↓ 4 callersMethodget_capacity
()
storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java:234
↓ 4 callersFunctionget_classpath
(extrajars, daemon=True, client=False)
bin/storm.py:108
↓ 4 callersMethodget_errors
()
storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:511
↓ 4 callersMethodget_exec_stats
()
storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java:637
↓ 4 callersMethodget_exec_summary
()
storm-client/src/jvm/org/apache/storm/generated/ExecutorAggregateStats.java:144
↓ 4 callersMethodget_executor_stats
()
storm-client/src/jvm/org/apache/storm/generated/ClusterWorkerHeartbeat.java:231
↓ 4 callersMethodget_fields
()
storm-client/src/jvm/org/apache/storm/generated/Grouping.java:563
↓ 4 callersMethodget_host
()
storm-client/src/jvm/org/apache/storm/generated/ExecutorSummary.java:255
↓ 4 callersMethodget_hostname
()
storm-client/src/jvm/org/apache/storm/generated/WorkerMetrics.java:227
↓ 4 callersMethodget_num_workers
()
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:660
↓ 4 callersMethodget_off_heap_node
()
storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java:243
↓ 4 callersMethodget_off_heap_worker
()
storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java:221
↓ 4 callersMethodget_on_heap
()
storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java:199
↓ 4 callersMethodget_owner
()
storm-client/src/jvm/org/apache/storm/generated/LocalAssignment.java:303
↓ 4 callersMethodget_port
()
storm-client/src/jvm/org/apache/storm/generated/NimbusSummary.java:232
↓ 4 callersMethodget_port
()
storm-client/src/jvm/org/apache/storm/generated/ExecutorSummary.java:279
↓ 4 callersMethodget_principal
()
storm-client/src/jvm/org/apache/storm/generated/StormBase.java:532
↓ 4 callersMethodget_replication_count
()
storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:642
↓ 4 callersMethodget_reset_log_level_timeout_epoch
()
storm-client/src/jvm/org/apache/storm/generated/LogLevel.java:268
↓ 4 callersMethodget_secretVersion
()
storm-client/src/jvm/org/apache/storm/generated/WorkerTokenInfo.java:230
↓ 4 callersMethodget_spout_object
()
storm-client/src/jvm/org/apache/storm/generated/SpoutSpec.java:152
↓ 4 callersMethodget_storm_version
()
storm-client/src/jvm/org/apache/storm/generated/StormTopology.java:545
↓ 4 callersMethodget_time_secs
()
storm-client/src/jvm/org/apache/storm/generated/LSWorkerHeartbeat.java:187
↓ 4 callersMethodget_topo_history
()
storm-client/src/jvm/org/apache/storm/generated/LSTopoHistoryList.java:160
↓ 4 callersMethodget_topologyId
()
storm-client/src/jvm/org/apache/storm/generated/WorkerTokenInfo.java:206
↓ 4 callersMethodget_topology_stats
()
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:822
↓ 4 callersMethodget_worker_hb_children
Get a list of paths of all the child nodes which exist immediately under path. This is similar to get_children, but must be used for any nodes @param
storm-client/src/jvm/org/apache/storm/cluster/IStateStorage.java:180
↓ 4 callersMethodget_worker_hooks
()
storm-client/src/jvm/org/apache/storm/generated/StormTopology.java:441
↓ 4 callersMethodgrouping
(GlobalStreamId id, Grouping grouping)
storm-client/src/jvm/org/apache/storm/topology/InputDeclarer.java:120
↓ 4 callersMethodgroupingType
(Grouping grouping)
storm-client/src/jvm/org/apache/storm/Thrift.java:157
↓ 4 callersMethodgzip
(byte[] data)
storm-client/src/jvm/org/apache/storm/utils/Utils.java:933
↓ 4 callersMethodhandleDataPoints
(ClusterInfo clusterInfo, Collection<DataPoint> dataPoints)
storm-server/src/main/java/org/apache/storm/metric/api/IClusterMetricsConsumer.java:20
↓ 4 callersMethodhashCode
()
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/RankableObjectWithFields.java:108
↓ 4 callersMethodhdel
(byte[] key, byte[]... fields)
external/storm-redis/src/main/java/org/apache/storm/redis/common/commands/RedisCommands.java:57
← previousnext →2,801–2,900 of 27,770, ranked by callers