MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
↓ 5 callersMethodgetModTime
()
storm-client/src/jvm/org/apache/storm/blobstore/BlobStoreFile.java:43
↓ 5 callersMethodgetName
()
storm-client/src/jvm/org/apache/storm/security/auth/SingleUserPrincipal.java:33
↓ 5 callersMethodgetNegativeResourceEventsMeter
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/normalization/ResourceMetrics.java:30
↓ 5 callersMethodgetNimbusBlobStore
(Map<String, Object> conf, NimbusInfo nimbusInfo, ILeaderElector leaderElector)
storm-server/src/main/java/org/apache/storm/utils/ServerUtils.java:140
↓ 5 callersMethodgetNumaMap
Return supervisor numa configuration. @param stormConf stormConf @return getNumaMap
storm-server/src/main/java/org/apache/storm/daemon/supervisor/SupervisorUtils.java:182
↓ 5 callersMethodgetOrderedPartitions
Sorts the partition info to produce an ordered list of partition. @param allPartitionInfo The partition info for all partitions being processed by al
storm-client/src/jvm/org/apache/storm/trident/spout/IOpaquePartitionedTridentSpout.java:94
↓ 5 callersMethodgetOutgoingTasks
(Integer outTaskId, String stream, List<Object> values)
storm-client/src/jvm/org/apache/storm/daemon/Task.java:113
↓ 5 callersMethodgetOwnerResourceSummaries
(java.lang.String owner)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:152
↓ 5 callersMethodgetOwnerResourceSummaries
(String owner)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4973
↓ 5 callersMethodgetPartitionsForThisTask
Filter the list of all partitions handled by this set of spouts to get only the partitions assigned to this task. @param allPartitionsSorted all of th
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/subscription/ManualPartitioner.java:43
↓ 5 callersMethodgetPath
()
storm-client/src/jvm/org/apache/storm/testing/TmpPath.java:42
↓ 5 callersMethodgetPort
()
storm-client/src/jvm/org/apache/storm/nimbus/NimbusInfo.java:99
↓ 5 callersMethodgetProcessingGuarantee
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java:350
↓ 5 callersMethodgetRequestedMemOffHeap
()
storm-server/src/main/java/org/apache/storm/daemon/nimbus/TopologyResources.java:190
↓ 5 callersMethodgetRequestedMemOnHeap
()
storm-server/src/main/java/org/apache/storm/daemon/nimbus/TopologyResources.java:186
↓ 5 callersMethodgetResponse
getResponse. @param ex ex @param responseStatus responseStatus @return getResponse
storm-webapp/src/main/java/org/apache/storm/daemon/ui/exceptionmappers/ExceptionMapperUtils.java:39
↓ 5 callersMethodgetSequenceNumber
()
storm-server/src/main/java/org/apache/storm/blobstore/BlobKeySequenceInfo.java:27
↓ 5 callersMethodgetServer
Create a server associated with a given port, service handler, and purpose. @param processor service handler @return server
storm-client/src/jvm/org/apache/storm/security/auth/ITransportPlugin.java:41
↓ 5 callersMethodgetServerSocket
(int port, int clientTimeout, InetAddress ifAddress, ThriftCon
storm-client/src/jvm/org/apache/storm/security/auth/tls/ReloadableTsslTransportFactory.java:40
↓ 5 callersMethodgetService
(String id)
storm-client/src/jvm/org/apache/storm/utils/ServiceRegistry.java:31
↓ 5 callersMethodgetSpouts
Returns all spout definitions. @return spout definitions.
flux/flux-core/src/main/java/org/apache/storm/flux/model/TopologyDef.java:84
↓ 5 callersMethodgetStartTimeMillis
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/SchedulingSearcherState.java:145
↓ 5 callersMethodgetStoredBlobMeta
(String key)
storm-server/src/main/java/org/apache/storm/blobstore/LocalFsBlobStore.java:251
↓ 5 callersMethodgetSupervisorAssignments
Get assigned assignments for a specific supervisor @param node
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:159
↓ 5 callersMethodgetTaskIds
()
storm-client/src/jvm/org/apache/storm/executor/Executor.java:640
↓ 5 callersMethodgetThisComponentId
()
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestHdfsSpout.java:780
↓ 5 callersMethodgetThriftServerPort
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java:267
↓ 5 callersMethodgetTopicPartition
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutMessageId.java:79
↓ 5 callersMethodgetToplogyId
()
storm-server/src/main/java/org/apache/storm/localizer/PortAndAssignment.java:21
↓ 5 callersMethodgetTopologyHeartbeatTimeoutSecs
(Map<String, Object> topoConf)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:2692
↓ 5 callersMethodgetTopologyHistory
(String user)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4841
↓ 5 callersMethodgetTopologyOpResponse
getTopologyOpResponse. @param id id @param op op @return getTopologyOpResponse
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:2178
↓ 5 callersMethodgetTotalCpu
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/normalization/NormalizedResourceOffer.java:158
↓ 5 callersMethodgetTotalCpuReqTask
Get the total CPU requirement for executor. @return generic resource mapping requirement for the executor
storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:419
↓ 5 callersMethodgetTotalMemory
Get the total Memory on this supervisor in MB.
storm-server/src/main/java/org/apache/storm/scheduler/SupervisorDetails.java:145
↓ 5 callersMethodgetTotalResourcesOverall
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/ObjectResourcesSummary.java:74
↓ 5 callersMethodgetTranslator
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/CommonKafkaSpoutConfig.java:248
↓ 5 callersMethodgetType
get the type of key. @return the type of key
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbKey.java:167
↓ 5 callersMethodgetUsedSlots
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/RasNode.java:159
↓ 5 callersMethodgetUserArchives
()
storm-server/src/test/java/org/apache/storm/localizer/AsyncLocalizerTest.java:1022
↓ 5 callersMethodgetUserId
Get the userId for a user name. This works on Posix systems by using "id -u" command. Throw IllegalArgumentException on Windows. @param user username
storm-server/src/main/java/org/apache/storm/utils/ServerUtils.java:1096
↓ 5 callersMethodgetUserName
(jakarta.servlet.http.HttpServletRequest req)
storm-server/src/main/java/org/apache/storm/security/auth/DefaultHttpCredentialsPlugin.java:37
↓ 5 callersMethodgetWindowStrategy
Gives the type of windowing. It can be any of {@code Type} values.
storm-client/src/jvm/org/apache/storm/trident/windowing/config/WindowConfig.java:36
↓ 5 callersMethodget_complete_latency_ms
()
storm-client/src/jvm/org/apache/storm/generated/SpoutAggregateStats.java:135
↓ 5 callersMethodget_component_executors
()
storm-client/src/jvm/org/apache/storm/generated/StormBase.java:371
↓ 5 callersMethodget_component_type
@see ComponentType
storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java:396
↓ 5 callersMethodget_dependency_artifacts
()
storm-client/src/jvm/org/apache/storm/generated/StormTopology.java:521
↓ 5 callersMethodget_execute_latency_ms
()
storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java:168
↓ 5 callersMethodget_executed
()
storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java:212
↓ 5 callersMethodget_executor_start_time_secs
()
storm-client/src/jvm/org/apache/storm/generated/Assignment.java:376
↓ 5 callersMethodget_expirationTimeMillis
()
storm-client/src/jvm/org/apache/storm/generated/PrivateWorkerKey.java:224
↓ 5 callersMethodget_expirationTimeMillis
()
storm-client/src/jvm/org/apache/storm/generated/WorkerTokenInfo.java:252
↓ 5 callersMethodget_host
()
storm-client/src/jvm/org/apache/storm/generated/NimbusSummary.java:208
↓ 5 callersMethodget_info
()
storm-client/src/jvm/org/apache/storm/generated/WorkerToken.java:201
↓ 5 callersMethodget_nimbuses
()
storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java:276
↓ 5 callersMethodget_process_latency_ms
()
storm-client/src/jvm/org/apache/storm/generated/BoltAggregateStats.java:190
↓ 5 callersMethodget_pulse
()
storm-client/src/jvm/org/apache/storm/generated/HBMessageData.java:455
↓ 5 callersMethodget_requested_cpu
()
storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:708
↓ 5 callersMethodget_requested_memonheap
()
storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:664
↓ 5 callersMethodget_reset_log_level
()
storm-client/src/jvm/org/apache/storm/generated/LogLevel.java:290
↓ 5 callersMethodget_reset_log_level_timeout_secs
()
storm-client/src/jvm/org/apache/storm/generated/LogLevel.java:246
↓ 5 callersMethodget_resources_map
()
storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java:806
↓ 5 callersMethodget_serviceType
@see WorkerTokenServiceType
storm-client/src/jvm/org/apache/storm/generated/WorkerToken.java:173
↓ 5 callersMethodget_shared_memory
()
storm-client/src/jvm/org/apache/storm/generated/StormTopology.java:639
↓ 5 callersMethodget_time_stamp
()
storm-client/src/jvm/org/apache/storm/generated/LSTopoHistory.java:209
↓ 5 callersMethodget_type
@see ComponentType
storm-client/src/jvm/org/apache/storm/generated/ComponentAggregateStats.java:174
↓ 5 callersMethodget_uptime_secs
()
storm-client/src/jvm/org/apache/storm/generated/ExecutorSummary.java:301
↓ 5 callersMethodget_used_cpu
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:489
↓ 5 callersMethodget_used_mem
()
storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:467
↓ 5 callersMethodget_userName
()
storm-client/src/jvm/org/apache/storm/generated/WorkerTokenInfo.java:182
↓ 5 callersMethodget_wait_secs
()
storm-client/src/jvm/org/apache/storm/generated/KillOptions.java:135
↓ 5 callersMethodget_worker_hb
Get the heartbeat from the node at path @param path The path to look under @param watch Whether or not to set a watch on the path. Watched paths emi
storm-client/src/jvm/org/apache/storm/cluster/IStateStorage.java:169
↓ 5 callersMethodget_worker_resources
()
storm-client/src/jvm/org/apache/storm/generated/Assignment.java:411
↓ 5 callersMethodglobal
()
storm-client/src/jvm/org/apache/storm/streams/Stream.java:427
↓ 5 callersMethodhasNext
()
storm-client/src/jvm/org/apache/storm/windowing/persistence/WindowState.java:112
↓ 5 callersMethodhasNext
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/NodeSorterHostProximity.java:520
↓ 5 callersFunctionhdfs_rm
(file_path, error_on_file_not_found=False, print_stdout=False, print_stderr=True, raise_on_error=True)
bin/docker-to-squash.py:171
↓ 5 callersFunctionhdfs_setrep
(replication, file_path, print_stdout=False, print_stderr=True, raise_on_error=True)
bin/docker-to-squash.py:203
↓ 5 callersMethodhexists
(String key, String field)
external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisCommandsContainer.java:33
↓ 5 callersMethodhget
(byte[] key, byte[] field)
external/storm-redis/src/main/java/org/apache/storm/redis/common/commands/RedisCommands.java:47
↓ 5 callersMethodincrement
(boolean syncSeen, long newBytePosition)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/SequenceFileReader.java:195
↓ 5 callersMethodindexToFieldsList
(ValuePointer[] index)
storm-client/src/jvm/org/apache/storm/trident/tuple/TridentTupleView.java:42
↓ 5 callersMethodinitLocalFs
()
storm-server/src/test/java/org/apache/storm/blobstore/LocalFsBlobStoreTest.java:86
↓ 5 callersMethodisActive
()
storm-client/src/jvm/org/apache/storm/StormTimer.java:263
↓ 5 callersMethodisAuthorized
(String operation, String topoId)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:2828
↓ 5 callersMethodisFailed
(Object id)
storm-client/src/jvm/org/apache/storm/testing/AckFailMapTracker.java:33
↓ 5 callersMethodisPrimitiveNumber
(Class clazz)
flux/flux-core/src/main/java/org/apache/storm/flux/FluxBuilder.java:736
↓ 5 callersMethodisResourceManaged
Return true if resources are being managed. The {@link DefaultResourceIsolationManager} will have it return false since it doesn't really manage resou
storm-server/src/main/java/org/apache/storm/container/ResourceIsolationInterface.java:138
↓ 5 callersMethodisTmp
()
storm-server/src/main/java/org/apache/storm/blobstore/LocalFsBlobStoreFile.java:73
↓ 5 callersMethodisTopologyNameAllowed
(java.lang.String name)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:118
↓ 5 callersMethodisTupleTs
()
storm-client/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java:248
↓ 5 callersMethodisValid
()
storm-client/src/jvm/org/apache/storm/windowing/StatefulWindowManager.java:155
↓ 5 callersMethodis_enable
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:19393
↓ 5 callersMethodis_set_access
Returns true if field access is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/AccessControl.java:241
↓ 5 callersMethodis_set_direct
Returns true if field direct is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java:211
↓ 5 callersMethodis_set_error_time_secs
Returns true if field error_time_secs is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ErrorInfo.java:216
↓ 5 callersMethodis_set_isLeader
Returns true if field isLeader is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/NimbusSummary.java:290
↓ 5 callersMethodis_set_metricValue
Returns true if field metricValue is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerMetricPoint.java:268
↓ 5 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/TopologySummary.java:457
↓ 5 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/TopologySummary.java:435
← previousnext →2,301–2,400 of 27,770, ranked by callers