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

Applies this function to the given arguments. @param arg1 the first argument @param arg2 the second argument @return the result

storm-client/src/jvm/org/apache/storm/streams/operations/Reducer.java:28

↓ 12 callersMethodbuildResponsePageNotFound

Build a Response object representing page not found.

storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/utils/LogviewerResponseBuilder.java:109

↓ 12 callersMethodbuildWithNimbusHostPort

(String host, Integer port)

storm-client/src/jvm/org/apache/storm/utils/NimbusClient.java:73

↓ 12 callersMethodcheckExecutorDistribution

(Map<NodeInfo, List<List<Long>>> slotExecutors, List<Integer> distribution)

storm-server/src/test/java/org/apache/storm/daemon/nimbus/NimbusClojurePortTest.java:1137

↓ 12 callersMethodcheckFileExists

(String path)

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

↓ 12 callersMethodcompareTo

(sendSupervisorAssignments_args other)

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

↓ 12 callersMethodconnect

This method establish a client side connection to a remote server implementation should return a new connection every call. @param stormId topo

storm-client/src/jvm/org/apache/storm/messaging/IContext.java:74

↓ 12 callersMethodcount

Counts the number of values in this stream. This does a global count of values across all partitions. <p> If the stream is windowed, the counts are em

storm-client/src/jvm/org/apache/storm/streams/Stream.java:229

↓ 12 callersMethodcreateGrasClusterConfig

(Class strategyClass, double compPcore, double compOnHeap, double compOffHeap,

storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestGenericResourceAwareStrategy.java:86

↓ 12 callersMethoddeltaSecs

(int timeInSeconds)

storm-client/src/jvm/org/apache/storm/utils/Time.java:157

↓ 12 callersMethodemitAndAckMessage

(KafkaSpoutMessageId msgId)

external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/internal/OffsetManagerTest.java:167

↓ 12 callersMethodemitDirect

(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple)

storm-client/src/jvm/org/apache/storm/task/IOutputCollector.java:25

↓ 12 callersMethodempty

()

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

↓ 12 callersMethodexitProcess

(int val, String msg)

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

↓ 12 callersMethodfail

(Tuple input)

storm-client/src/jvm/org/apache/storm/task/IOutputCollector.java:29

↓ 12 callersMethodfindByThriftId

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

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

↓ 12 callersMethodfindNextCommitOffset

An offset can only be committed when all emitted records with lower offset have been acked. This guarantees that all offsets smaller than the committe

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/OffsetManager.java:101

↓ 12 callersMethodfloor

(ZonedDateTime dateTime, int sec)

integration-test/src/main/java/org/apache/storm/st/utils/TimeUtil.java:47

↓ 12 callersMethodflush

()

storm-client/src/jvm/org/apache/storm/trident/planner/TupleReceiver.java:22

↓ 12 callersMethodget

(String key)

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

↓ 12 callersMethodgetAvailableCpuResources

Gets the available cpu resources for this node. @return the available cpu for this node

storm-server/src/main/java/org/apache/storm/scheduler/resource/RasNode.java:512

↓ 12 callersMethodgetAvailableMemoryResources

Gets the available memory resources for this node. @return the available memory for this node

storm-server/src/main/java/org/apache/storm/scheduler/resource/RasNode.java:459

↓ 12 callersMethodgetBinaryTreeMap

()

external/storm-redis/src/test/java/org/apache/storm/redis/state/RedisKeyValueStateIteratorTest.java:207

↓ 12 callersMethodgetCommitPosition

()

external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/ProgressTracker.java:50

↓ 12 callersMethodgetDependencies

()

storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedBlob.java:323

↓ 12 callersMethodgetFields

Gets the names of the fields in this tuple.

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

↓ 12 callersMethodgetGroups

Get all various group memberships of a given user. Returns EMPTY list in case of non-existing user. @param user User's name @return group memberships

storm-client/src/jvm/org/apache/storm/security/auth/IGroupMappingServiceProvider.java:34

↓ 12 callersMethodgetHooks

()

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

↓ 12 callersMethodgetHostName

map from node id to supervisor details.

storm-server/src/main/java/org/apache/storm/scheduler/INimbus.java:38

↓ 12 callersMethodgetId

()

storm-client/src/jvm/org/apache/storm/trident/spout/IBatchID.java:18

↓ 12 callersMethodgetId

()

storm-server/src/main/java/org/apache/storm/scheduler/SupervisorDetails.java:109

↓ 12 callersMethodgetInputStream

()

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

↓ 12 callersMethodgetLockFile

()

external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/DirLock.java:127

↓ 12 callersMethodgetMax

()

storm-server/src/main/java/org/apache/storm/metricstore/Metric.java:161

↓ 12 callersMethodgetMessageId

(TopicPartition tp, long offset)

external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java:286

↓ 12 callersMethodgetMin

()

storm-server/src/main/java/org/apache/storm/metricstore/Metric.java:153

↓ 12 callersMethodgetOptions

()

storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:237

↓ 12 callersMethodgetResource

Fetches the worker-level data for the given name. The corresponding data needs to be first set in an implementation of {@link IWorkerHook#start(Map, W

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

↓ 12 callersMethodgetSubject

(String name)

external/storm-hdfs-blobstore/src/test/java/org/apache/storm/hdfs/blobstore/BlobStoreTest.java:273

↓ 12 callersMethodgetValueByField

(String field)

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

↓ 12 callersMethodget_num_executors

()

storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:421

↓ 12 callersMethodget_settable

()

storm-client/src/jvm/org/apache/storm/generated/ReadableBlobMeta.java:155

↓ 12 callersMethodget_spout

()

storm-client/src/jvm/org/apache/storm/generated/ExecutorSpecificStats.java:287

↓ 12 callersMethodheartbeat

(String fileOffset)

external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/FileLock.java:230

↓ 12 callersMethodincrementCount

(T obj, int slot)

examples/storm-starter/src/jvm/org/apache/storm/starter/tools/SlotBasedCounter.java:41

↓ 12 callersMethodinit

(Cluster cluster, Map<String, Node> nodeIdToNode)

storm-server/src/main/java/org/apache/storm/scheduler/multitenant/FreePool.java:33

↓ 12 callersMethodinitState

This method is invoked by the framework with the previously saved state of the component. This is invoked after prepare but before the component start

storm-client/src/jvm/org/apache/storm/topology/IStatefulComponent.java:30

↓ 12 callersMethodisValidConf

(Map<String, Object> topoConfIn)

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

↓ 12 callersMethodisZkAuthenticationConfiguredStormServer

Is the cluster configured to interact with ZooKeeper in a secure way? This only works when called from within Nimbus or a Supervisor process. @param

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

↓ 12 callersMethodis_set_acked

Returns true if field acked is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java:306

↓ 12 callersMethodis_set_acl

Returns true if field acl is set (has been assigned a value) and false otherwise

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

↓ 12 callersMethodis_set_assigned_cpu

Returns true if field assigned_cpu is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1128

↓ 12 callersMethodis_set_assigned_cpu

Returns true if field assigned_cpu is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:646

↓ 12 callersMethodis_set_assigned_cpu

Returns true if field assigned_cpu is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:775

↓ 12 callersMethodis_set_assigned_cpu

Returns true if field assigned_cpu is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:788

↓ 12 callersMethodis_set_assigned_memoffheap

Returns true if field assigned_memoffheap is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1106

↓ 12 callersMethodis_set_assigned_memoffheap

Returns true if field assigned_memoffheap is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:624

↓ 12 callersMethodis_set_assigned_memoffheap

Returns true if field assigned_memoffheap is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:753

↓ 12 callersMethodis_set_assigned_memoffheap

Returns true if field assigned_memoffheap is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:766

↓ 12 callersMethodis_set_assigned_memonheap

Returns true if field assigned_memonheap is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1084

↓ 12 callersMethodis_set_assigned_memonheap

Returns true if field assigned_memonheap is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:602

↓ 12 callersMethodis_set_assigned_memonheap

Returns true if field assigned_memonheap is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:731

↓ 12 callersMethodis_set_assigned_memonheap

Returns true if field assigned_memonheap is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:744

↓ 12 callersMethodis_set_assigned_off_heap_memory

Returns true if field assigned_off_heap_memory is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:719

↓ 12 callersMethodis_set_assigned_on_heap_memory

Returns true if field assigned_on_heap_memory is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:697

↓ 12 callersMethodis_set_assigned_regular_off_heap_memory

Returns true if field assigned_regular_off_heap_memory is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1282

↓ 12 callersMethodis_set_assigned_regular_on_heap_memory

Returns true if field assigned_regular_on_heap_memory is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1238

↓ 12 callersMethodis_set_assigned_shared_off_heap_memory

Returns true if field assigned_shared_off_heap_memory is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1304

↓ 12 callersMethodis_set_assigned_shared_on_heap_memory

Returns true if field assigned_shared_on_heap_memory is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1260

↓ 12 callersMethodis_set_blacklisted

Returns true if field blacklisted is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:569

↓ 12 callersMethodis_set_capacity

Returns true if field capacity is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java:248

↓ 12 callersMethodis_set_complete_latency_ms

Returns true if field complete_latency_ms is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/SpoutAggregateStats.java:149

↓ 12 callersMethodis_set_cpu

Returns true if field cpu is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/WorkerResources.java:265

↓ 12 callersMethodis_set_cpu_usage

Returns true if field cpu_usage is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:455

↓ 12 callersMethodis_set_data_size

Returns true if field data_size is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/BeginDownloadResult.java:227

↓ 12 callersMethodis_set_emitted

Returns true if field emitted is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java:262

↓ 12 callersMethodis_set_enable

Returns true if field enable is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/DebugOptions.java:160

↓ 12 callersMethodis_set_eventlog_port

Returns true if field eventlog_port is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java:739

↓ 12 callersMethodis_set_execute_latency_ms

Returns true if field execute_latency_ms is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java:182

↓ 12 callersMethodis_set_executed

Returns true if field executed is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java:226

↓ 12 callersMethodis_set_failed

Returns true if field failed is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java:328

↓ 12 callersMethodis_set_fragmented_cpu

Returns true if field fragmented_cpu is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:547

↓ 12 callersMethodis_set_fragmented_mem

Returns true if field fragmented_mem is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:525

↓ 12 callersMethodis_set_info

Returns true if field info is set (has been assigned a value) and false otherwise

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

↓ 12 callersMethodis_set_is_include_sys

Returns true if field is_include_sys is set (has been assigned a value) and false otherwise

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

↓ 12 callersMethodis_set_memory_usage

Returns true if field memory_usage is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:433

↓ 12 callersMethodis_set_message_id

Returns true if field message_id is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/HBMessage.java:242

↓ 12 callersMethodis_set_num_executors

Returns true if field num_executors is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:696

↓ 12 callersMethodis_set_num_executors

Returns true if field num_executors is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java:218

↓ 12 callersMethodis_set_num_executors

Returns true if field num_executors is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java:486

↓ 12 callersMethodis_set_num_tasks

Returns true if field num_tasks is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:652

↓ 12 callersMethodis_set_num_tasks

Returns true if field num_tasks is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java:240

↓ 12 callersMethodis_set_num_tasks

Returns true if field num_tasks is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java:508

↓ 12 callersMethodis_set_num_workers

Returns true if field num_workers is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:674

↓ 12 callersMethodis_set_off_heap_node

Returns true if field off_heap_node is set (has been assigned a value) and false otherwise

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

↓ 12 callersMethodis_set_off_heap_worker

Returns true if field off_heap_worker is set (has been assigned a value) and false otherwise

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

↓ 12 callersMethodis_set_on_heap

Returns true if field on_heap is set (has been assigned a value) and false otherwise

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

↓ 12 callersMethodis_set_port

Returns true if field port is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:365

↓ 12 callersMethodis_set_port

Returns true if field port is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/ErrorInfo.java:262

↓ 12 callersMethodis_set_process_latency_ms

Returns true if field process_latency_ms is set (has been assigned a value) and false otherwise

storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java:204

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