Functions — github.com/apache/storm

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363

↓ 6 callersMethodbuildObject

(ObjectDef def, ExecutionContext context)

flux/flux-core/src/main/java/org/apache/storm/flux/FluxBuilder.java:352

↓ 6 callersMethodcanAdd

(TopologyDetails td)

storm-server/src/main/java/org/apache/storm/scheduler/multitenant/IsolatedPool.java:65

↓ 6 callersMethodcancel

Cancel all of the writes associated with this stream and close it.

storm-client/src/jvm/org/apache/storm/blobstore/AtomicOutputStream.java:25

↓ 6 callersMethodcancel

()

storm-server/src/main/java/org/apache/storm/blobstore/LocalFsBlobStoreFile.java:134

↓ 6 callersMethodcheckWorkerStats

(boolean includeSys, boolean userAuthorized, String filterSupervisor)

storm-core/test/jvm/org/apache/storm/stats/TestStatsUtil.java:202

↓ 6 callersMethodchooseTask

(int[] assignedTasks)

storm-client/src/jvm/org/apache/storm/grouping/PartialKeyGrouping.java:147

↓ 6 callersMethodcleanUp

()

storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/StringMetadataCache.java:94

↓ 6 callersMethodcommit

(Long txId)

external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/HdfsState.java:167

↓ 6 callersMethodcomparableAggregateStream

(String inputFieldName, Aggregator<T> aggregator)

storm-client/src/jvm/org/apache/storm/trident/Stream.java:590

↓ 6 callersMethodconvertExecutor

Convert a List<Long> executor to java List<Integer>.

storm-client/src/jvm/org/apache/storm/stats/ClientStatsUtil.java:47

↓ 6 callersMethodcoordStream

(String batch)

storm-client/src/jvm/org/apache/storm/trident/topology/TridentBoltExecutor.java:70

↓ 6 callersMethodcreate

(TridentTupleView parent, List<Object> selfVals)

storm-client/src/jvm/org/apache/storm/trident/tuple/TridentTupleView.java:302

↓ 6 callersMethodcreateHandlerTraversalTests

(Path rootPath)

storm-webapp/src/test/java/org/apache/storm/daemon/logviewer/handler/LogviewerProfileHandlerTest.java:144

↓ 6 callersMethodcreateKafkaSpoutConfigBuilder

(int port)

external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/trident/config/builder/SingleTopicKafkaTridentSpoutConfiguration.java:32

↓ 6 callersMethodcreateMetricKey

Creates a metric key with the desired properties. @return the generated key

storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbKey.java:121

↓ 6 callersMethodcreateNode

(CuratorFramework zk, String path, byte[] data, CreateMode mode, List<ACL> acls)

storm-client/src/jvm/org/apache/storm/zookeeper/ClientZookeeper.java:94

↓ 6 callersMethodcreateRoundRobinClusterConfig

(double compPcore, double compOnHeap, double compOffHeap, Map

storm-server/src/test/java/org/apache/storm/scheduler/resource/TestUtilsForResourceAwareScheduler.java:122

↓ 6 callersMethodcreateSession

Create a session. @param conn the connection @return the session @throws JMSException the JMS exception in case of error

external/storm-jms/src/main/java/org/apache/storm/jms/spout/JmsSpout.java:417

↓ 6 callersMethodcreateSymlink

Create a symbolic link pointing at target. @param link the link to create @param target where it should point to @throws IOException on any error.

storm-client/src/jvm/org/apache/storm/daemon/supervisor/IAdvancedFSOps.java:243

↓ 6 callersMethoddeleteKey

Delete a key from the blob store. @param key the key to delete @throws IOException on any error

external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsBlobStoreImpl.java:247

↓ 6 callersMethoddestroy

()

storm-client/src/jvm/org/apache/storm/utils/ShellProcess.java:113

↓ 6 callersMethodemit

Returns the task ids that received the tuples.

storm-client/src/jvm/org/apache/storm/spout/ISpoutOutputCollector.java:27

↓ 6 callersMethodequals

(Object o)

storm-client/src/jvm/org/apache/storm/spout/CheckPointState.java:104

↓ 6 callersMethodequals

(Object o)

storm-client/src/jvm/org/apache/storm/trident/planner/Node.java:41

↓ 6 callersMethodequals

(java.lang.Object that)

storm-client/src/jvm/org/apache/storm/generated/NodeInfo.java:270

↓ 6 callersMethodequals

(Object o)

storm-core/test/jvm/org/apache/storm/integration/TopologyIntegrationTest.java:836

↓ 6 callersMethodexec

()

storm-server/src/main/java/org/apache/storm/Testing.java:704

↓ 6 callersMethodfailure

(SchedulingStatus status, String errorMessage)

storm-server/src/main/java/org/apache/storm/scheduler/resource/SchedulingResult.java:40

↓ 6 callersMethodfinishFileUpload

(java.lang.String location)

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:102

↓ 6 callersMethodfirst

()

storm-clojure/src/main/java/org/apache/storm/clojure/ClojureTuple.java:132

↓ 6 callersMethodforTopic

Configure a translator for a given topic with tuples to be emitted to the default stream. @param topic the topic this should be used for @param func e

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/ByTopicRecordTranslator.java:84

↓ 6 callersMethodgenerateJoinedString

(Set<String> activeTopologyIds)

storm-server/src/main/java/org/apache/storm/nimbus/LeaderListenerCallback.java:167

↓ 6 callersMethodget

(Long batchTxid)

storm-client/src/jvm/org/apache/storm/trident/state/OpaqueValue.java:44

↓ 6 callersMethodgetAliveExecutors

Get all of the alive executors for a given topology. @param topoId the id of the topology we are looking for. @param allExecutors all of th

storm-server/src/main/java/org/apache/storm/daemon/nimbus/HeartbeatCache.java:209

↓ 6 callersMethodgetAllEmittedAggregate

Compute the total amount of all messages emitted in all streams per second. @return the sum of all messages emitted per second.

examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadCompConf.java:161

↓ 6 callersMethodgetAllVersions

Sorted from most recent to oldest.

storm-client/src/jvm/org/apache/storm/utils/VersionedStore.java:142

↓ 6 callersMethodgetAssignedNonSharedMemOffHeap

()

storm-server/src/main/java/org/apache/storm/daemon/nimbus/TopologyResources.java:262

↓ 6 callersMethodgetAssignedNonSharedMemOnHeap

()

storm-server/src/main/java/org/apache/storm/daemon/nimbus/TopologyResources.java:254

↓ 6 callersMethodgetAssignedSharedMemOffHeap

()

storm-server/src/main/java/org/apache/storm/daemon/nimbus/TopologyResources.java:246

↓ 6 callersMethodgetAssignedSharedMemOnHeap

()

storm-server/src/main/java/org/apache/storm/daemon/nimbus/TopologyResources.java:222

↓ 6 callersMethodgetAssignment

Get assignment as {@link Assignment} for a storm. @param stormId storm runtime id @return assignment

storm-client/src/jvm/org/apache/storm/assignments/ILocalAssignmentsBackend.java:54

↓ 6 callersMethodgetAssignmentId

The id used in assignments. This combined with confirmAssigned decides what this supervisor is responsible for. The combination of this and getSupervi

storm-server/src/main/java/org/apache/storm/scheduler/ISupervisor.java:35

↓ 6 callersMethodgetAvailableTaskIds

(int numTasks)

storm-client/test/jvm/org/apache/storm/grouping/LoadAwareShuffleGroupingTest.java:330

↓ 6 callersMethodgetByName

Get a topology given a topology name. Nimbus prevents multiple topologies from having the same name, so this assumes it is true. @param topologyName

storm-server/src/main/java/org/apache/storm/scheduler/Topologies.java:99

↓ 6 callersMethodgetClassName

()

flux/flux-core/src/main/java/org/apache/storm/flux/model/ObjectDef.java:39

↓ 6 callersMethodgetComponent

()

storm-client/src/jvm/org/apache/storm/coordination/BatchSubtopologyBuilder.java:134

↓ 6 callersMethodgetComponentId

()

storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbKey.java:197

↓ 6 callersMethodgetCurrentSymlinkPath

()

storm-server/src/main/java/org/apache/storm/localizer/LocalizedResource.java:219

↓ 6 callersMethodgetData

()

storm-client/src/jvm/org/apache/storm/testing/MockedSources.java:59

↓ 6 callersMethodgetEndOffsets

(Set<TopicPartition> topicPartitions, Supplier<Admin> adminSupplier)

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/metrics2/KafkaOffsetUtil.java:58

↓ 6 callersMethodgetEstimatedWorkerCountForRasTopo

(Map<String, Object> topoConf, StormTopology topology)

storm-server/src/main/java/org/apache/storm/utils/ServerUtils.java:688

↓ 6 callersMethodgetExtractionDir

()

storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java:362

↓ 6 callersMethodgetFieldDesc

(_Fields setField)

storm-client/src/jvm/org/apache/storm/generated/HBMessageData.java:405

↓ 6 callersMethodgetFieldDesc

(_Fields setField)

storm-client/src/jvm/org/apache/storm/generated/JavaObjectArg.java:399

↓ 6 callersMethodgetFieldName

()

storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:741

↓ 6 callersMethodgetInstance

()

storm-client/src/jvm/org/apache/storm/streams/UniqueIdGen.java:24

↓ 6 callersMethodgetJaasConf

(Map<String, Object> topoConf)

storm-client/src/jvm/org/apache/storm/security/auth/ClientAuthUtils.java:64

↓ 6 callersMethodgetKeyDir

(String key)

storm-server/src/main/java/org/apache/storm/blobstore/FileBlobStoreImpl.java:127

↓ 6 callersMethodgetLatencyAtPercentile

(double percential, TimeUnit unit)

examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java:188

↓ 6 callersMethodgetLockDirPath

()

external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java:225

↓ 6 callersMethodgetLongName

Returns the full metric name to be used for registering with the metrics registry. @return The full metric name.

storm-client/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java:448

↓ 6 callersMethodgetMetricsRateUnit

(Map<String, Object> daemonConf)

storm-server/src/main/java/org/apache/storm/daemon/metrics/MetricsUtils.java:88

↓ 6 callersMethodgetName

()

flux/flux-core/src/main/java/org/apache/storm/flux/model/TopologyDef.java:59

↓ 6 callersMethodgetName

()

storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:95

↓ 6 callersMethodgetNetworkTopography

Get the network topography (rackId -> nodes in the rack).

storm-server/src/main/java/org/apache/storm/scheduler/ISchedulingState.java:286

↓ 6 callersMethodgetNextHighest

()

storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/priority/DefaultSchedulingPriorityStrategy.java:84

↓ 6 callersMethodgetNimbusConf

()

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:106

↓ 6 callersMethodgetNumBacktrack

()

storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/SchedulingSearcherState.java:157

↓ 6 callersMethodgetOnHeapMemoryLoad

()

flux/flux-core/src/main/java/org/apache/storm/flux/model/VertexDef.java:50

↓ 6 callersMethodgetOnHeapMemoryMb

()

storm-server/src/main/java/org/apache/storm/scheduler/resource/normalization/NormalizedResourceRequest.java:219

↓ 6 callersMethodgetOutputStream

()

storm-client/src/jvm/org/apache/storm/blobstore/BlobStoreFile.java:51

↓ 6 callersMethodgetPhysicalUsage

()

storm-client/src/jvm/org/apache/storm/container/cgroup/core/MemoryCore.java:52

↓ 6 callersMethodgetProcessInfoString

()

storm-client/src/jvm/org/apache/storm/utils/ShellProcess.java:199

↓ 6 callersMethodgetProperties

()

flux/flux-core/src/main/java/org/apache/storm/flux/model/ObjectDef.java:85

↓ 6 callersMethodgetReceivers

()

storm-client/src/jvm/org/apache/storm/trident/planner/processor/TridentContext.java:55

↓ 6 callersMethodgetRemoteUser

()

storm-webapp/src/main/java/org/apache/storm/daemon/ui/TestingFilter.java:56

↓ 6 callersMethodgetResourceMetrics

()

storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:1110

↓ 6 callersMethodgetShortName

Returns the short metric name (without dimensions). @return The short metric name.

storm-client/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java:456

↓ 6 callersMethodgetSizeWithNoReferences

()

storm-server/src/main/java/org/apache/storm/localizer/LocalizedResourceRetentionSet.java:56

↓ 6 callersMethodgetSleepTimeMs

(int retryCount, long elapsedTimeMs)

storm-client/src/jvm/org/apache/storm/utils/StormBoundedExponentialBackoffRetry.java:54

↓ 6 callersMethodgetSpout

()

storm-core/test/jvm/org/apache/storm/integration/AckTrackingFeeder.java:38

↓ 6 callersMethodgetStreamId

()

storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbKey.java:213

↓ 6 callersMethodgetTaskMetrics

()

storm-client/src/jvm/org/apache/storm/metrics2/MetricRegistryProvider.java:22

↓ 6 callersMethodgetThisStreams

Gets the set of streams declared for the component of this task.

storm-client/src/jvm/org/apache/storm/task/TopologyContext.java:192

↓ 6 callersMethodgetTimeUnitForConfig

(Map<String, Object> reporterConf, String configName)

storm-client/src/jvm/org/apache/storm/daemon/metrics/ClientMetricsUtils.java:44

↓ 6 callersMethodgetTombstoneValue

Get the tombstone value (deletion mark). @return the tomestone value (VENCODEDT type)

storm-client/src/jvm/org/apache/storm/state/StateEncoder.java:56

↓ 6 callersMethodgetTopicPartition

()

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutTopicPartition.java:39

↓ 6 callersMethodgetTopoConf

()

storm-client/src/jvm/org/apache/storm/executor/Executor.java:652

↓ 6 callersMethodgetTopologyConf

(String id)

storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4787

↓ 6 callersMethodgetUniqueStreamId

()

storm-client/src/jvm/org/apache/storm/trident/TridentTopology.java:960

↓ 6 callersMethodgetUserPrincipal

()

storm-webapp/src/main/java/org/apache/storm/daemon/ui/TestingFilter.java:61

↓ 6 callersMethodgetUserTopology

Returns the user specified topology as submitted originally. Compare {@link #getTopology(String id)}. @param id

storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:148

↓ 6 callersMethodgetUserTopology

(String id)

storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4823

↓ 6 callersMethodgetValue

()

storm-client/src/jvm/org/apache/storm/metrics2/RollingAverageGauge.java:21

↓ 6 callersMethodgetValueAndReset

Get value and reset. @return an object that will be sent to {@link IMetricsConsumer#handleDataPoints(org.apache.storm.metric.api.IMetricsConsumer

storm-client/src/jvm/org/apache/storm/metric/api/IMetric.java:33

↓ 6 callersMethodgetValues

()

storm-client/src/jvm/org/apache/storm/trident/tuple/TridentTupleView.java:60

↓ 6 callersMethodgetViewUrl

()

integration-test/src/test/java/org/apache/storm/st/wrapper/TopoWrap.java:274

↓ 6 callersMethodgetWindowLength

The length of the window. @return the window length

storm-client/src/jvm/org/apache/storm/streams/windowing/Window.java:32

↓ 6 callersMethodget_acked

()

storm-client/src/jvm/org/apache/storm/generated/BoltStats.java:337

↓ 6 callersMethodget_acked

()

storm-client/src/jvm/org/apache/storm/generated/SpoutStats.java:224

← previous next →1,801–1,900 of 27,770, ranked by callers