MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
MethodgetLag
()
external/storm-kafka-monitor/src/main/java/org/apache/storm/kafka/monitor/KafkaOffsetLagResult.java:57
MethodgetLateTupleStream
()
storm-client/src/jvm/org/apache/storm/streams/windowing/BaseWindow.java:27
MethodgetLaunchTime
Get the timestamp of when this topology was launched.
storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:594
MethodgetLayerResources
(ImageManifest manifest)
external/storm-hdfs-oci/src/main/java/org/apache/storm/container/oci/HdfsManifestToResourcesPlugin.java:83
MethodgetLayers
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:87
MethodgetLeader
(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:260
MethodgetLeader
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:1309
MethodgetLeader
(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3203
MethodgetLeader
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:5325
MethodgetLeader
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:8910
MethodgetLeader
(Runnable callback)
storm-client/src/jvm/org/apache/storm/cluster/StormClusterStateImpl.java:476
MethodgetLeader
Get leader info from state store, which was written when a master gains leadership. <p>Caution: it can not be used for fencing and is only for inform
storm-client/src/jvm/org/apache/storm/cluster/IStormClusterState.java:168
MethodgetLeader
(self)
storm-client/src/py/storm/Nimbus.py:337
MethodgetLeader
(self)
storm-client/src/py/storm/Nimbus.py:1761
MethodgetLeader
()
storm-server/src/main/java/org/apache/storm/LocalCluster.java:994
MethodgetLeader
()
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4943
MethodgetLeader
()
storm-server/src/main/java/org/apache/storm/zookeeper/LeaderElectorImp.java:106
MethodgetLeader
()
storm-core/src/jvm/org/apache/storm/testing/MockLeaderElector.java:64
MethodgetLeader_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:43299
MethodgetLeader_call
(org.apache.storm.thrift.async.AsyncMethodCallback<NimbusSummary> resultHandler, org.apache.storm.thrift.async
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3212
MethodgetLeader_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:43578
MethodgetLeafWeight
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:974
MethodgetLeafWeight
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1028
MethodgetLeftStream
()
storm-client/src/jvm/org/apache/storm/streams/processors/JoinProcessor.java:78
MethodgetLimit
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:850
MethodgetLimit
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1081
MethodgetLimit
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1144
MethodgetLinux
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:180
MethodgetList
()
storm-client/src/jvm/org/apache/storm/container/cgroup/core/DevicesCore.java:62
MethodgetLoad
(Collection<Integer> tasks)
storm-client/src/jvm/org/apache/storm/messaging/local/Context.java:186
MethodgetLoad
(Collection<Integer> tasks)
storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java:185
MethodgetLoad
(Collection<Integer> tasks)
storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java:519
MethodgetLoad
Get load. @return the load that is a combination of sub loads.
storm-client/src/jvm/org/apache/storm/grouping/Load.java:64
MethodgetLocalAssignmentForStorm
(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<Assignment> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:59
MethodgetLocalAssignmentForStorm
(java.lang.String id)
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:111
MethodgetLocalAssignmentForStorm
(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<Assignment> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:220
MethodgetLocalAssignmentForStorm
()
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:348
MethodgetLocalAssignmentForStorm
()
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:518
MethodgetLocalAssignmentForStorm
Get local assignment for a storm Parameters: - id
storm-client/src/py/storm/Supervisor.py:51
MethodgetLocalAssignmentForStorm
Get local assignment for a storm Parameters: - id
storm-client/src/py/storm/Supervisor.py:113
MethodgetLocalAssignmentForStorm
(String id)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Supervisor.java:425
MethodgetLocalAssignmentForStorm_args
()
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:1515
MethodgetLocalAssignmentForStorm_call
(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<Assignment> resultHandler, org.apache.
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:230
MethodgetLocalAssignmentForStorm_result
()
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:1905
MethodgetLocalCluster
Run with a local cluster. @deprecated use ``` try (LocalCluster cluster = new LocalCluster.Builder()....build()) { ... } ``` @param
storm-server/src/main/java/org/apache/storm/Testing.java:215
MethodgetLocalVersion
()
storm-server/src/test/java/org/apache/storm/localizer/LocallyCachedBlobTest.java:99
MethodgetLogConfig
(java.lang.String name, org.apache.storm.thrift.async.AsyncMethodCallback<LogConfig> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:204
MethodgetLogConfig
(java.lang.String name)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:551
MethodgetLogConfig
(java.lang.String name, org.apache.storm.thrift.async.AsyncMethodCallback<LogConfig> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:2188
MethodgetLogConfig
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:4279
MethodgetLogConfig
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:6755
MethodgetLogConfig
Parameters: - name
storm-client/src/py/storm/Nimbus.py:115
MethodgetLogConfig
Parameters: - name
storm-client/src/py/storm/Nimbus.py:807
MethodgetLogConfig
(String name)
storm-server/src/main/java/org/apache/storm/LocalCluster.java:863
MethodgetLogConfig
(String topoId)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:3635
MethodgetLogConfig_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:18517
MethodgetLogConfig_call
(java.lang.String name, org.apache.storm.thrift.async.AsyncMethodCallback<LogConfig> resultHandler, org.apache
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:2198
MethodgetLogConfig_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:18893
MethodgetLogDate
()
integration-test/src/test/java/org/apache/storm/st/wrapper/DecoratedLogLine.java:63
MethodgetLogDirs
(Set<Path> logDirs, Predicate<String> predicate)
storm-webapp/src/test/java/org/apache/storm/daemon/logviewer/utils/LogCleanerTest.java:238
MethodgetLogHandler_customHandler
If a log handler is correctly configured, it will be returned.
storm-client/test/jvm/org/apache/storm/utils/ShellUtilsTest.java:81
MethodgetLogHandler_notAShellLogHandler
If a log handler is not an instance of {@link ShellLogHandler}, a {@link RuntimeException} will be thrown with {@link ClassCastException} as the cause
storm-client/test/jvm/org/apache/storm/utils/ShellUtilsTest.java:69
MethodgetLogHandler_notConfigured
If a log handler is not configured, {@link DefaultShellLogHandler} will be returned.
storm-client/test/jvm/org/apache/storm/utils/ShellUtilsTest.java:45
MethodgetLogHandler_notFound
If a log handler cannot be found, a {@link RuntimeException} will be thrown with {@link ClassNotFoundException} as the cause.
storm-client/test/jvm/org/apache/storm/utils/ShellUtilsTest.java:55
MethodgetLogHandler_nullConf
A null config will throw IllegalArgumentException.
storm-client/test/jvm/org/apache/storm/utils/ShellUtilsTest.java:36
MethodgetLoginContextName
()
storm-client/src/jvm/org/apache/storm/messaging/netty/Login.java:291
MethodgetLong
(int i)
storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java:124
MethodgetLong
(int i)
storm-client/src/jvm/org/apache/storm/trident/tuple/TridentTupleView.java:110
MethodgetLong
(final int i)
external/storm-redis/src/test/java/org/apache/storm/redis/util/StubTuple.java:80
MethodgetLongByField
(String field)
storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java:174
MethodgetLongByField
(String field)
storm-client/src/jvm/org/apache/storm/trident/tuple/TridentTupleView.java:160
MethodgetLongByField
(final String field)
external/storm-redis/src/test/java/org/apache/storm/redis/util/StubTuple.java:130
MethodgetMajor
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:811
MethodgetMajor
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1016
MethodgetMajor
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1049
MethodgetManagedSpoutIds
()
storm-client/src/jvm/org/apache/storm/trident/topology/MasterBatchCoordinator.java:67
MethodgetManifestFromImageTag
(String imageTag)
external/storm-hdfs-oci/src/main/java/org/apache/storm/container/oci/LocalOrHdfsImageTagToManifestPlugin.java:229
MethodgetMaskedPaths
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:610
MethodgetMasterDeclarer
()
storm-client/src/jvm/org/apache/storm/coordination/BatchSubtopologyBuilder.java:53
MethodgetMaxWithSwapUsage
()
storm-client/src/jvm/org/apache/storm/container/cgroup/core/MemoryCore.java:64
MethodgetMechanismName
()
storm-client/src/jvm/org/apache/storm/security/auth/plain/SaslPlainServer.java:37
MethodgetMechanismNames
(Map<String, ?> props)
storm-client/src/jvm/org/apache/storm/security/auth/plain/SaslPlainServer.java:148
MethodgetMediaType
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:113
MethodgetMediaType
()
storm-server/src/main/java/org/apache/storm/container/oci/ImageManifest.java:101
MethodgetMemBwSchema
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:1197
MethodgetMemPressure
()
storm-client/src/jvm/org/apache/storm/container/cgroup/core/CpusetCore.java:154
MethodgetMemory
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:755
MethodgetMemoryReservationMb
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/BasicContainer.java:790
MethodgetMemoryResourceRequest
(ISchedulingState cluster)
storm-server/src/main/java/org/apache/storm/scheduler/resource/User.java:126
MethodgetMemoryUsage
(String user, String workerId, int port)
storm-server/src/test/java/org/apache/storm/daemon/supervisor/ContainerTest.java:279
MethodgetMemoryUsage
(String user, String workerId, int port)
storm-server/src/main/java/org/apache/storm/container/DefaultResourceIsolationManager.java:73
MethodgetMemoryUsage
(String user, String workerId, int port)
storm-server/src/main/java/org/apache/storm/container/oci/RuncLibContainerManager.java:486
MethodgetMemoryUsage
(String user, String workerId, int port)
storm-server/src/main/java/org/apache/storm/container/docker/DockerManager.java:206
MethodgetMemoryUsage
(String user, String workerId, int port)
storm-server/src/main/java/org/apache/storm/container/cgroup/CgroupManager.java:329
MethodgetMems
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:933
MethodgetMessage
()
storm-client/src/jvm/org/apache/storm/utils/WrappedIllegalStateException.java:28
MethodgetMessage
()
storm-client/src/jvm/org/apache/storm/utils/WrappedKeyAlreadyExistsException.java:31
MethodgetMessage
()
storm-client/src/jvm/org/apache/storm/utils/WrappedAuthorizationException.java:31
MethodgetMessage
()
storm-client/src/jvm/org/apache/storm/utils/WrappedHBExecutionException.java:32
MethodgetMessage
()
storm-client/src/jvm/org/apache/storm/utils/WrappedKeyNotFoundException.java:31
← previousnext →18,601–18,700 of 27,770, ranked by callers