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

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/LSTopoHistoryList.java:53

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/KeyNotFoundException.java:53

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/ListBlobsResult.java:56

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeat.java:59

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/WorkerToken.java:63

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java:56

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/WorkerMetricList.java:53

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/WorkerTokenInfo.java:62

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/SupervisorAssignments.java:53

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/LSSupervisorId.java:53

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/DRPCExecutionException.java:60

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java:80

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/HBRecords.java:53

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/StormBase.java:91

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/ExecutorSummary.java:68

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/StormTopology.java:80

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java:62

↓ 2 callersMethodfindByThriftId

Find the _Fields constant that matches fieldId, or null if its not found.

storm-client/src/jvm/org/apache/storm/generated/SpoutSpec.java:56

↓ 2 callersMethodfindByValue

Find a the enum type by its integer value, as defined in the Thrift IDL. @return null if the value is not found.

storm-client/src/jvm/org/apache/storm/generated/TopologyInitialStatus.java:50

↓ 2 callersMethodfindCompatibleMethod

(List<Object> args, Class target, String methodName)

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

↓ 2 callersMethodfindComponentCycles

Find and return components cycles in the topology graph when starting from spout. Return a list of cycles. Each cycle may consist of one or more compo

storm-client/src/jvm/org/apache/storm/utils/Utils.java:2000

↓ 2 callersMethodfindResources

(String name)

storm-client/src/jvm/org/apache/storm/utils/Utils.java:160

↓ 2 callersMethodfindWorkerToken

Find a worker token in a given subject with a given token type. @param subject what to look in. @param type the type of token to look for. @return

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

↓ 2 callersMethodfindWorkerTokenInSubject

Look in the current subject for a WorkerToken. This should really only happen when we are in a worker, because the tokens will not be placed in anyth

storm-client/src/jvm/org/apache/storm/security/auth/workertoken/WorkerTokenClientCallbackHandler.java:48

↓ 2 callersMethodfinish

(String stream)

storm-client/src/jvm/org/apache/storm/streams/processors/ForwardingProcessorContext.java:72

↓ 2 callersMethodfinishBatch

(TrackedBatch tracked, Tuple finishTuple)

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

↓ 2 callersMethodfleshOutStreamBatchIds

(boolean includeCommitStream)

storm-client/src/jvm/org/apache/storm/trident/topology/TridentTopologyBuilder.java:102

↓ 2 callersMethodflush

Flush any buffered tuples (when batching is enabled).

storm-client/src/jvm/org/apache/storm/trident/operation/TridentCollector.java:41

↓ 2 callersMethodflushPending

()

storm-client/src/jvm/org/apache/storm/messaging/local/Context.java:159

↓ 2 callersMethodformatName

(String name, TimeUnit targetUnit)

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

↓ 2 callersMethodforwardValues

()

storm-client/src/jvm/org/apache/storm/streams/processors/CoGroupByKeyProcessor.java:58

↓ 2 callersMethodfree

Frees a single slot in this node. @param ws the slot to free @param cluster the cluster to update

storm-server/src/main/java/org/apache/storm/scheduler/multitenant/Node.java:267

↓ 2 callersMethodfrom

Construct a new instance based on the provided {@link Tuple}. <p/> This method expects the object to be ranked in the first field (index 0) of the pro

examples/storm-starter/src/jvm/org/apache/storm/starter/tools/RankableObjectWithFields.java:59

↓ 2 callersMethodfromConf

Parse the LoadCompConf from a config Map. @param conf the map holding the config for a LoadCompConf. @return the parsed object.

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

↓ 2 callersMethodfromJson

(String jsonStr)

integration-test/src/main/java/org/apache/storm/st/topology/window/data/FromJson.java:21

↓ 2 callersMethodfromTuple

(Tuple input)

storm-client/src/jvm/org/apache/storm/topology/StatefulWindowedBoltExecutor.java:348

↓ 2 callersMethodfullCleanup

(long age)

external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsBlobStore.java:404

↓ 2 callersMethodgenerateDependencyBlobKey

(String key)

storm-client/src/jvm/org/apache/storm/dependency/DependencyBlobStoreUtils.java:29

↓ 2 callersMethodgenerateTestTuple

(GenericRecord record)

external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/AvroGenericRecordBoltTest.java:113

↓ 2 callersMethodgenerateTestTuple

(Long key, String value)

external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/TestSequenceFileBolt.java:153

↓ 2 callersMethodgenerateTestTuple

(Object id, Object msg, Object city, Object state)

external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/TestHdfsBolt.java:240

↓ 2 callersMethodget

(String key)

storm-client/src/jvm/org/apache/storm/trident/windowing/InMemoryWindowsStore.java:49

↓ 2 callersMethodgetAcked

()

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

↓ 2 callersMethodgetAckedPerSec

()

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

↓ 2 callersMethodgetAckedTuples

()

external/storm-redis/src/test/java/org/apache/storm/redis/util/outputcollector/StubOutputCollector.java:84

↓ 2 callersMethodgetAliveAssignedWorkerSlotExecutors

(Cluster cluster, String topologyId)

storm-server/src/main/java/org/apache/storm/scheduler/EvenScheduler.java:94

↓ 2 callersMethodgetAliveIds

Retrieve the set of alive worker IDs. @param nowSecs current time in seconds

storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/utils/WorkerLogs.java:202

↓ 2 callersMethodgetAllAssignmentsFromNumaSupervisors

( Nimbus.Iface nimbus, String node )

storm-server/src/main/java/org/apache/storm/daemon/supervisor/timer/SynchronizeAssignments.java:89

↓ 2 callersMethodgetAllGroups

()

storm-client/src/jvm/org/apache/storm/trident/graph/GraphGrouper.java:36

↓ 2 callersMethodgetAllKeys

()

storm-client/src/jvm/org/apache/storm/trident/windowing/WindowsStore.java:35

↓ 2 callersMethodgetAllNimbuses

Get list of current nimbus addresses. @return list of current nimbus addresses, includes leader.

storm-client/src/jvm/org/apache/storm/nimbus/ILeaderElector.java:70

↓ 2 callersMethodgetAllSubscribedPartitions

(Consumer<?, ?> consumer)

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/NamedTopicFilter.java:54

↓ 2 callersMethodgetAllTimeEmittedCount

(final String componentId)

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

↓ 2 callersMethodgetAllowed

(AccessControl ac, Set<String> users)

storm-client/src/jvm/org/apache/storm/blobstore/BlobStoreAclHandler.java:339

↓ 2 callersMethodgetAllowedImages

(Map<String, Object> conf, boolean validationEnforced)

storm-server/src/main/java/org/apache/storm/container/oci/OciUtils.java:121

↓ 2 callersMethodgetAlternativeVersionsMap

Get a mapping of the configured supported versions of storm to their actual versions. @param conf what to read the configuration out of. @return the m

storm-client/src/jvm/org/apache/storm/utils/Utils.java:1572

↓ 2 callersMethodgetAnchors

()

external/storm-redis/src/test/java/org/apache/storm/redis/util/outputcollector/EmittedTuple.java:44

↓ 2 callersMethodgetAnchorsToIds

()

storm-client/src/jvm/org/apache/storm/tuple/MessageId.java:61

↓ 2 callersMethodgetAnnotations

()

storm-server/src/main/java/org/apache/storm/container/oci/ImageManifest.java:65

↓ 2 callersMethodgetApproximateResources

Get approximate resources for given topology executors. ignores shared memory. @param execs the executors the inquiry is concerning. @return the appr

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

↓ 2 callersMethodgetAssignablePorts

(SupervisorDetails supervisor)

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

↓ 2 callersMethodgetAssignableSlots

Return all non-blacklisted slots on this supervisor. @param supervisor the supervisor @return the non-blacklisted slots

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

↓ 2 callersMethodgetAssignedGenericResources

()

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

↓ 2 callersMethodgetAssignedNumWorkers

Get the number of workers assigned to a topology. @param topology the topology this is for @return the number of workers assigned to this topology.

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

↓ 2 callersMethodgetAssignmentId

()

storm-client/src/jvm/org/apache/storm/task/WorkerTopologyContext.java:104

↓ 2 callersMethodgetAutoCredentials

()

storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java:683

↓ 2 callersMethodgetAvailablePorts

Return the available ports of this supervisor.

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

↓ 2 callersMethodgetBackend

(Map<String, Object> conf)

storm-client/src/jvm/org/apache/storm/assignments/LocalAssignmentsBackendFactory.java:26

↓ 2 callersMethodgetBatchBolt

(Object id)

storm-client/src/jvm/org/apache/storm/coordination/BatchBoltExecutor.java:90

↓ 2 callersMethodgetBlob

Gets the InputStream to read the blob details. @param key Key for the blob @param who Is the subject having the read privilege for the blob @return I

storm-client/src/jvm/org/apache/storm/blobstore/BlobStore.java:221

↓ 2 callersMethodgetBlob

Client facing API to read a blob. @param key blob key name @return an InputStream to read the metadata for a blob

storm-client/src/jvm/org/apache/storm/blobstore/ClientBlobStore.java:112

↓ 2 callersMethodgetBlob

(String key, Subject who)

external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsBlobStore.java:283

↓ 2 callersMethodgetBlobMeta

Gets the current version of metadata for a blob to be viewed by the user or downloaded by the supervisor. @param key Key for the blob @param who Is t

storm-client/src/jvm/org/apache/storm/blobstore/BlobStore.java:189

↓ 2 callersMethodgetBlobStoreSubtree

()

storm-server/src/main/java/org/apache/storm/blobstore/BlobStoreUtils.java:47

↓ 2 callersMethodgetBolt

()

storm-client/src/jvm/org/apache/storm/Thrift.java:331

↓ 2 callersMethodgetBoltExecutors

()

integration-test/src/main/java/org/apache/storm/st/topology/TestableTopology.java:34

↓ 2 callersMethodgetBoltLoad

Get bolt load. @return the load as reported by the bolt.

storm-client/src/jvm/org/apache/storm/grouping/Load.java:48

↓ 2 callersMethodgetBoltName

()

integration-test/src/main/java/org/apache/storm/st/topology/TestableTopology.java:32

↓ 2 callersMethodgetBoltSubscriptionStreams

(String id)

storm-client/src/jvm/org/apache/storm/trident/topology/TridentTopologyBuilder.java:283

↓ 2 callersMethodgetBoolean

Returns the Boolean at position i in the tuple. @throws ClassCastException If that field is not a Boolean @throws IndexOutOfBoundsException -

storm-client/src/jvm/org/apache/storm/tuple/ITuple.java:83

↓ 2 callersMethodgetBoundAckers

()

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

↓ 2 callersMethodgetBranch

Get the SCM branch of the build. @return the SCM branch of the build.

storm-client/src/jvm/org/apache/storm/utils/IVersionInfo.java:41

↓ 2 callersMethodgetByKeyOr0

(Map<String, Object> m, String k)

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

↓ 2 callersMethodgetCgroupStormHierarchyDir

(Map<String, Object> conf)

storm-server/src/main/java/org/apache/storm/DaemonConfig.java:1348

↓ 2 callersMethodgetChannelSaslClient

(Channel channel)

storm-client/src/jvm/org/apache/storm/messaging/netty/KerberosSaslClientHandler.java:86

↓ 2 callersMethodgetChannelSaslNettyClient

(Channel channel)

storm-client/src/jvm/org/apache/storm/messaging/netty/SaslStormClientHandler.java:79

↓ 2 callersMethodgetChildren

()

storm-client/src/jvm/org/apache/storm/container/cgroup/CgroupCommon.java:157

↓ 2 callersMethodgetClientCertPath

(Map<String, Object> conf)

storm-client/src/jvm/org/apache/storm/security/auth/ThriftConnectionType.java:238

↓ 2 callersMethodgetClientKeyPath

(Map<String, Object> conf)

storm-client/src/jvm/org/apache/storm/security/auth/ThriftConnectionType.java:234

↓ 2 callersMethodgetClientKeyStorePassword

(Map<String, Object> conf)

storm-client/src/jvm/org/apache/storm/security/auth/ThriftConnectionType.java:222

↓ 2 callersMethodgetClientTrustStorePassword

(Map<String, Object> conf)

storm-client/src/jvm/org/apache/storm/security/auth/ThriftConnectionType.java:230

↓ 2 callersMethodgetClusterInfo

()

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

↓ 2 callersMethodgetClusterTotalCpuResource

Get the total amount of CPU resources in cluster.

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

↓ 2 callersMethodgetClusterTotalGenericResources

Get the total amount of generic resources (excluding CPU and memory) in cluster.

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

↓ 2 callersMethodgetClusterTotalMemoryResource

Get the total amount of memory resources in cluster.

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

↓ 2 callersMethodgetCommaSeparatedList

(List list)

storm-buildtools/storm-maven-plugins/src/main/java/org/apache/storm/maven/plugin/versioninfo/VersionInfoMojo.java:69

↓ 2 callersMethodgetCommandWithArguments

Get the full command. @return the full command

storm-server/src/main/java/org/apache/storm/container/docker/DockerRmCommand.java:40

↓ 2 callersMethodgetCommonAggStatsMap

getCommonAggStatsMap. @param commonAggregateStats commonAggregateStats @return getCommonAggStatsMap

storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:1204

↓ 2 callersMethodgetCompleted

()

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

↓ 2 callersMethodgetComponentCommon

(String id, IComponent component)

storm-client/src/jvm/org/apache/storm/topology/TopologyBuilder.java:545

← previous next →4,601–4,700 of 27,770, ranked by callers