MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
↓ 3 callersMethodgetOrderedPartitions
Get the input partitions in sorted order.
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutEmitter.java:327
↓ 3 callersMethodgetOutStreamId
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/TridentContext.java:59
↓ 3 callersMethodgetOutputCollector
()
storm-client/test/jvm/org/apache/storm/topology/WindowedBoltExecutorTest.java:76
↓ 3 callersMethodgetOverflowCount
()
storm-client/src/jvm/org/apache/storm/utils/JCQueue.java:219
↓ 3 callersMethodgetParallelism
()
storm-client/src/jvm/org/apache/storm/Thrift.java:343
↓ 3 callersMethodgetParents
Assumes edge contains an index.
storm-client/src/jvm/org/apache/storm/trident/util/TridentUtils.java:78
↓ 3 callersMethodgetParents
()
storm-server/src/main/java/org/apache/storm/scheduler/Component.java:74
↓ 3 callersMethodgetPartitionRefreshPeriodMs
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/CommonKafkaSpoutConfig.java:260
↓ 3 callersMethodgetPartitionsForBatch
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutCoordinator.java:73
↓ 3 callersMethodgetPartitionsForTask
Get the partitions assigned to this task. @param taskId The id of this task @param numTasks The number of tasks for thi
storm-client/src/jvm/org/apache/storm/trident/spout/IOpaquePartitionedTridentSpout.java:105
↓ 3 callersMethodgetPartitionsForThisTask
(List<TopicPartition> allPartitionsSorted, TopologyContext context)
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/RoundRobinManualPartitioner.java:39
↓ 3 callersMethodgetPendingCount
()
storm-client/src/jvm/org/apache/storm/spout/ISpoutOutputCollector.java:31
↓ 3 callersMethodgetPort
()
storm-client/src/jvm/org/apache/storm/scheduler/WorkerSlot.java:37
↓ 3 callersMethodgetPort
()
storm-client/src/jvm/org/apache/storm/drpc/DRPCInvocationsClient.java:46
↓ 3 callersMethodgetPort
()
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbKey.java:209
↓ 3 callersMethodgetPort
()
storm-server/src/main/java/org/apache/storm/localizer/TimePortAndAssignment.java:37
↓ 3 callersMethodgetPreparableReporters
(Map<String, Object> daemonConf)
storm-server/src/main/java/org/apache/storm/daemon/metrics/MetricsUtils.java:40
↓ 3 callersMethodgetPrepareCallCount
()
storm-server/src/test/java/org/apache/storm/metric/ClusterMetricsConsumerExecutorTest.java:80
↓ 3 callersMethodgetPrev
()
storm-client/src/jvm/org/apache/storm/trident/state/OpaqueValue.java:62
↓ 3 callersMethodgetPriority
(Node node)
storm-client/src/jvm/org/apache/storm/streams/StreamBuilder.java:264
↓ 3 callersMethodgetPrivateWorkerKey
Get a private key used to validate a token is correct. This is expected to be called from a privileged daemon, and the ACLs should be set up to only a
storm-client/src/jvm/org/apache/storm/cluster/IStormClusterState.java:251
↓ 3 callersMethodgetProcessTerminationInfoString
()
storm-client/src/jvm/org/apache/storm/utils/ShellProcess.java:203
↓ 3 callersMethodgetPunctuationStream
(String stream)
storm-client/src/jvm/org/apache/storm/streams/StreamUtil.java:47
↓ 3 callersMethodgetQueueName
()
storm-client/src/jvm/org/apache/storm/utils/JCQueue.java:65
↓ 3 callersMethodgetQueueSize
(Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/security/auth/ThriftConnectionType.java:146
↓ 3 callersMethodgetRandomSentence
()
examples/storm-starter/src/jvm/org/apache/storm/starter/BlobStoreAPIWordCountTopology.java:93
↓ 3 callersMethodgetRankings
()
examples/storm-starter/src/jvm/org/apache/storm/starter/bolt/AbstractRankerBolt.java:66
↓ 3 callersMethodgetRateCounterUpdateIntervalSeconds
()
storm-client/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java:348
↓ 3 callersMethodgetRaw
get the raw value bytes
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbValue.java:120
↓ 3 callersMethodgetRecords
()
storm-client/src/jvm/org/apache/storm/bolt/JoinBolt.java:599
↓ 3 callersMethodgetRegisteredMetricByName
Get component's metric from registered metrics by name. Notice: Normally, one component can only register one metric name once. But now registerMetric
storm-client/src/jvm/org/apache/storm/task/TopologyContext.java:411
↓ 3 callersMethodgetRegistry
()
storm-client/src/jvm/org/apache/storm/metrics2/MetricRegistryProvider.java:20
↓ 3 callersMethodgetRemoteVersion
(ClientBlobStore store)
storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java:123
↓ 3 callersMethodgetReportPeriod
(Map<String, Object> reporterConf)
storm-client/src/jvm/org/apache/storm/metrics2/reporters/ScheduledStormReporter.java:38
↓ 3 callersMethodgetReportPeriodUnit
(Map<String, Object> reporterConf)
storm-client/src/jvm/org/apache/storm/metrics2/reporters/ScheduledStormReporter.java:33
↓ 3 callersMethodgetRequestedNonSharedOffHeap
()
storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:465
↓ 3 callersMethodgetRequestedNonSharedOnHeap
()
storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:445
↓ 3 callersMethodgetRequestedSharedOffHeap
()
storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:476
↓ 3 callersMethodgetRequestedSharedOnHeap
()
storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:435
↓ 3 callersMethodgetScore
Get a score for the simulated user. This is used to sort the users, by their highest priority topology. The only requirement is that if the user is o
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/priority/DefaultSchedulingPriorityStrategy.java:104
↓ 3 callersMethodgetScore
Get a score for the simulated user. This is used to sort the users, by their highest priority topology. Only give user guarantees that will not excee
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/priority/GenericResourceAwareSchedulingPriorityStrategy.java:130
↓ 3 callersMethodgetServerKeyStorePath
(Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/security/auth/ThriftConnectionType.java:202
↓ 3 callersMethodgetShort
Returns the Short at position i in the tuple. @throws ClassCastException If that field is not a Short @throws IndexOutOfBoundsException - if t
storm-client/src/jvm/org/apache/storm/tuple/ITuple.java:91
↓ 3 callersMethodgetSignedPasswordFor
(byte[] user, WorkerTokenInfo deser)
storm-client/src/jvm/org/apache/storm/security/auth/workertoken/WorkerTokenAuthorizer.java:95
↓ 3 callersMethodgetSingleOutputStreamFields
(IComponent component)
storm-client/src/jvm/org/apache/storm/trident/util/TridentUtils.java:61
↓ 3 callersMethodgetSocketTimeOut
(Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/security/auth/ThriftConnectionType.java:167
↓ 3 callersMethodgetSourceComponent
()
storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java:229
↓ 3 callersMethodgetSpoutExecutors
()
integration-test/src/main/java/org/apache/storm/st/topology/TestableTopology.java:38
↓ 3 callersMethodgetSpoutStatsFromTopologySummaryResult
Given the results Map from UIHelper.getTopologySummary(), return the entry for the requested spoutId. @param result Map from UIHelper.getTopologySumm
storm-webapp/src/test/java/org/apache/storm/daemon/ui/UIHelpersTest.java:586
↓ 3 callersMethodgetSpoutsResources
(StormTopology topology, Map<String, Object> topologyConf)
storm-server/src/main/java/org/apache/storm/scheduler/resource/ResourceUtils.java:66
↓ 3 callersMethodgetSqlType
()
external/storm-jdbc/src/main/java/org/apache/storm/jdbc/common/Column.java:70
↓ 3 callersMethodgetStateConfig
(Map<String, Object> topoConf)
external/storm-redis/src/main/java/org/apache/storm/redis/state/RedisKeyValueStateProvider.java:47
↓ 3 callersFunctiongetStatic
(url, cb)
storm-webapp/src/main/webapp/js/script.js:342
↓ 3 callersMethodgetStatus
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/SchedulingResult.java:52
↓ 3 callersMethodgetStormConf
()
storm-client/src/jvm/org/apache/storm/utils/Utils.java:1880
↓ 3 callersMethodgetStreamForDirectory
Creates DirectoryStream for give directory. @param dir File instance representing specific directory @return DirectoryStream
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/utils/DirectoryCleaner.java:70
↓ 3 callersMethodgetStreamName
()
storm-client/src/jvm/org/apache/storm/bolt/JoinBolt.java:531
↓ 3 callersMethodgetSubSystem
(String str)
storm-client/src/jvm/org/apache/storm/container/cgroup/SubSystemType.java:24
↓ 3 callersMethodgetSubject
(String name)
storm-server/src/test/java/org/apache/storm/blobstore/LocalFsBlobStoreTest.java:137
↓ 3 callersMethodgetSupervisorById
Get a specific supervisor with the <code>nodeId</code>.
storm-server/src/main/java/org/apache/storm/scheduler/ISchedulingState.java:237
↓ 3 callersMethodgetSupervisorsResourcesMap
()
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:1039
↓ 3 callersMethodgetSysTime
(TimeUnit unit)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java:216
↓ 3 callersMethodgetTargets
Gets information about who is consuming the outputs of the specified component, and how. @return Map from stream id to component id to the Grouping u
storm-client/src/jvm/org/apache/storm/task/GeneralTopologyContext.java:146
↓ 3 callersMethodgetTargetsInScope
(LocalityScope scope)
storm-client/src/jvm/org/apache/storm/grouping/LoadAwareShuffleGrouping.java:134
↓ 3 callersMethodgetTask
()
storm-client/src/jvm/org/apache/storm/multilang/BoltMsg.java:56
↓ 3 callersMethodgetTaskToComponent
()
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java:333
↓ 3 callersMethodgetTaskToNodePort
Get a map from task Id to NodePort. @return a map from task To NodePort
storm-client/src/jvm/org/apache/storm/task/WorkerTopologyContext.java:113
↓ 3 callersMethodgetTempExtractionDir
(long version)
storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java:366
↓ 3 callersMethodgetTimestamp
()
storm-server/src/main/java/org/apache/storm/metricstore/Metric.java:177
↓ 3 callersMethodgetTimestampField
The name of the field in the tuple that contains the timestamp when the event occurred as a long value. This is used of event-time based processing. I
storm-client/src/jvm/org/apache/storm/streams/windowing/Window.java:48
↓ 3 callersMethodgetTlsPort
()
storm-client/src/jvm/org/apache/storm/nimbus/NimbusInfo.java:103
↓ 3 callersMethodgetTopic
(Tuple tuple)
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/selector/KafkaTopicSelector.java:25
↓ 3 callersMethodgetTopicPartitioner
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/CommonKafkaSpoutConfig.java:244
↓ 3 callersMethodgetTopoAcl
(String path, String topoId, Map<String, Id> topoToZkCreds, ACL superAcl, boolean fixUp, int perms)
storm-server/src/main/java/org/apache/storm/zookeeper/AclEnforcement.java:188
↓ 3 callersMethodgetTopoCode
(final String topologyId, String owner)
storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java:163
↓ 3 callersMethodgetTopoConf
(final String topologyId, String owner)
storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java:179
↓ 3 callersMethodgetTopoJar
(final String topologyId, String owner)
storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java:147
↓ 3 callersMethodgetTopology
(String id)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4805
↓ 3 callersMethodgetTopologyId
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutBatchMetadata.java:69
↓ 3 callersMethodgetTopologyInfoWithOptsImpl
(String topoId, GetInfoOptions options)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4297
↓ 3 callersMethodgetTopologyResourcesMap
()
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:1028
↓ 3 callersMethodgetTopologySummaryImpl
(String topoId, StormBase base)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:3123
↓ 3 callersMethodgetTotalMem
()
storm-server/src/main/java/org/apache/storm/scheduler/SupervisorResources.java:63
↓ 3 callersMethodgetTransferred
()
storm-client/src/jvm/org/apache/storm/stats/CommonStats.java:52
↓ 3 callersMethodgetTransport
(final TTransport trans)
storm-client/src/jvm/org/apache/storm/security/auth/kerberos/KerberosSaslTransportPlugin.java:260
↓ 3 callersMethodgetTransportPlugin
Construct a transport plugin per storm configuration.
storm-client/src/jvm/org/apache/storm/security/auth/ClientAuthUtils.java:478
↓ 3 callersMethodgetTruststoreLocation
()
storm-client/src/jvm/org/apache/storm/utils/CuratorUtils.java:194
↓ 3 callersMethodgetTruststorePassword
()
storm-client/src/jvm/org/apache/storm/utils/CuratorUtils.java:198
↓ 3 callersMethodgetTuple
(String streamId, final Fields fields, Values values, String srcComponent)
storm-client/test/jvm/org/apache/storm/topology/WindowedBoltExecutorTest.java:67
↓ 3 callersMethodgetTuple
(String stream, List values)
storm-client/src/jvm/org/apache/storm/daemon/Task.java:185
↓ 3 callersMethodgetTuples
()
storm-client/src/jvm/org/apache/storm/trident/state/ITupleCollection.java:20
↓ 3 callersMethodgetUnassignedAckers
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/SchedulingSearcherState.java:165
↓ 3 callersMethodgetUniqueSpoutName
()
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/TopologyLoadConf.java:208
↓ 3 callersMethodgetUniqueStreamName
()
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/TopologyLoadConf.java:212
↓ 3 callersMethodgetUptime
()
storm-client/src/jvm/org/apache/storm/cluster/ExecutorBeat.java:32
↓ 3 callersMethodgetUsedGenericResources
()
storm-server/src/main/java/org/apache/storm/scheduler/SupervisorResources.java:83
↓ 3 callersMethodgetUsedPorts
(SupervisorDetails supervisor)
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:402
↓ 3 callersMethodgetUsedSlots
()
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:869
↓ 3 callersMethodgetUsedSlots
Get all currently occupied slots.
storm-server/src/main/java/org/apache/storm/scheduler/ISchedulingState.java:182
↓ 3 callersMethodgetUser
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:333
← previousnext →3,501–3,600 of 27,770, ranked by callers