MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
MethodgetTopologyErrors
getTopologyErrors. @param errorInfoList errorInfoList @param topologyId topologyId @param config config @return getTopologyErrors
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:1524
MethodgetTopologyFields
()
storm-client/src/jvm/org/apache/storm/Thrift.java:67
MethodgetTopologyHistory
(java.lang.String user, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:284
MethodgetTopologyHistory
(java.lang.String user)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:1671
MethodgetTopologyHistory
(java.lang.String user, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3647
MethodgetTopologyHistory
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:5790
MethodgetTopologyHistory
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:9863
MethodgetTopologyHistory
Parameters: - user
storm-client/src/py/storm/Nimbus.py:441
MethodgetTopologyHistory
Parameters: - user
storm-client/src/py/storm/Nimbus.py:2205
MethodgetTopologyHistory
(String user)
storm-server/src/main/java/org/apache/storm/LocalCluster.java:1031
MethodgetTopologyHistory_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:55517
MethodgetTopologyHistory_call
(java.lang.String user, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyHistoryInfo> resultHandler,
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3657
MethodgetTopologyHistory_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:55900
MethodgetTopologyId
()
storm-client/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java:366
MethodgetTopologyId
()
storm-server/src/main/java/org/apache/storm/scheduler/IsolationScheduler.java:391
MethodgetTopologyId
()
storm-server/src/main/java/org/apache/storm/scheduler/SchedulerAssignmentImpl.java:203
MethodgetTopologyId
()
storm-server/src/main/java/org/apache/storm/metricstore/FilterOptions.java:35
MethodgetTopologyInfo
Get the state of a topology. @param id the id of the topology (not the name) @return the state of a topology @throws TException on any error from nim
storm-client/src/jvm/org/apache/storm/ILocalCluster.java:155
MethodgetTopologyInfo
(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:266
MethodgetTopologyInfo
(java.lang.String id)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:1392
MethodgetTopologyInfo
(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3305
MethodgetTopologyInfo
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:5439
MethodgetTopologyInfo
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:9143
MethodgetTopologyInfo
Parameters: - id
storm-client/src/py/storm/Nimbus.py:356
MethodgetTopologyInfo
Parameters: - id
storm-client/src/py/storm/Nimbus.py:1859
MethodgetTopologyInfo
(String id)
storm-server/src/main/java/org/apache/storm/LocalCluster.java:591
MethodgetTopologyInfoByName
Get the state of a topology. @param name the name of the topology (not the id) @return the state of a topology @throws TException on any error from n
storm-client/src/jvm/org/apache/storm/ILocalCluster.java:164
MethodgetTopologyInfoByName
(java.lang.String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:264
MethodgetTopologyInfoByName
(java.lang.String name)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:1362
MethodgetTopologyInfoByName
(java.lang.String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3270
MethodgetTopologyInfoByName
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:5400
MethodgetTopologyInfoByName
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:9063
MethodgetTopologyInfoByName
Parameters: - name
storm-client/src/py/storm/Nimbus.py:348
MethodgetTopologyInfoByName
Parameters: - name
storm-client/src/py/storm/Nimbus.py:1823
MethodgetTopologyInfoByName
(String name)
storm-server/src/main/java/org/apache/storm/LocalCluster.java:596
MethodgetTopologyInfoByName
(String name)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4243
MethodgetTopologyInfoByNameWithOpts
Get the state of a topology. @param name the name of the topology (not the id) @param options This is GetInfoOptions to choose Error(s) in on Topolog
storm-client/src/jvm/org/apache/storm/ILocalCluster.java:184
MethodgetTopologyInfoByNameWithOpts
(java.lang.String name, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:268
MethodgetTopologyInfoByNameWithOpts
(java.lang.String name, GetInfoOptions options)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:1422
MethodgetTopologyInfoByNameWithOpts
(java.lang.String name, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3340
MethodgetTopologyInfoByNameWithOpts
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:5478
MethodgetTopologyInfoByNameWithOpts
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:9223
MethodgetTopologyInfoByNameWithOpts
Parameters: - name - options
storm-client/src/py/storm/Nimbus.py:364
MethodgetTopologyInfoByNameWithOpts
Parameters: - name - options
storm-client/src/py/storm/Nimbus.py:1895
MethodgetTopologyInfoByNameWithOpts
(String name, GetInfoOptions options)
storm-server/src/main/java/org/apache/storm/LocalCluster.java:606
MethodgetTopologyInfoByNameWithOpts
(String name, GetInfoOptions options)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4266
MethodgetTopologyInfoByNameWithOpts_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:46854
MethodgetTopologyInfoByNameWithOpts_call
(java.lang.String name, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3351
MethodgetTopologyInfoByNameWithOpts_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:47346
MethodgetTopologyInfoByName_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:44911
MethodgetTopologyInfoByName_call
(java.lang.String name, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler, org.apa
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3280
MethodgetTopologyInfoByName_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:45301
MethodgetTopologyInfoWithOpts
Get the state of a topology. @param id the id of the topology (not the name) @param options This is to choose number of Error(s) in TopologyInfo. @re
storm-client/src/jvm/org/apache/storm/ILocalCluster.java:174
MethodgetTopologyInfoWithOpts
(java.lang.String id, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo>
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:270
MethodgetTopologyInfoWithOpts
(java.lang.String id, GetInfoOptions options)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:1453
MethodgetTopologyInfoWithOpts
(java.lang.String id, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo>
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3378
MethodgetTopologyInfoWithOpts
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:5517
MethodgetTopologyInfoWithOpts
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:9303
MethodgetTopologyInfoWithOpts
Parameters: - id - options
storm-client/src/py/storm/Nimbus.py:373
MethodgetTopologyInfoWithOpts
Parameters: - id - options
storm-client/src/py/storm/Nimbus.py:1933
MethodgetTopologyInfoWithOpts
(String id, GetInfoOptions options)
storm-server/src/main/java/org/apache/storm/LocalCluster.java:601
MethodgetTopologyInfoWithOpts
(String topoId, GetInfoOptions options)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4281
MethodgetTopologyInfoWithOpts_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:47931
MethodgetTopologyInfoWithOpts_call
(java.lang.String id, GetInfoOptions options, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo>
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3389
MethodgetTopologyInfoWithOpts_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:48423
MethodgetTopologyInfo_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:45879
MethodgetTopologyInfo_call
(java.lang.String id, org.apache.storm.thrift.async.AsyncMethodCallback<TopologyInfo> resultHandler, org.apach
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3315
MethodgetTopologyInfo_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:46269
MethodgetTopologyKafkaSpout
(KafkaSpoutConfig<String, String> spoutConfig)
examples/storm-kafka-client-examples/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutTopologyMainWildcardTopics.java:42
MethodgetTopologyLag
/api/v1/topology/:id/lag -> lag.
storm-webapp/src/main/java/org/apache/storm/daemon/ui/resources/StormApiResource.java:348
MethodgetTopologyLogconfig
/api/v1/topology/:id/logconfig -> logconfig.
storm-webapp/src/main/java/org/apache/storm/daemon/ui/resources/StormApiResource.java:437
MethodgetTopologyMetrics
/api/v1/topology/:id/metrics -> metrics.
storm-webapp/src/main/java/org/apache/storm/daemon/ui/resources/StormApiResource.java:325
MethodgetTopologyPageInfo
(java.lang.String id, java.lang.String window, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMeth
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:272
MethodgetTopologyPageInfo
(java.lang.String id, java.lang.String window, boolean is_include_sys)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:1484
MethodgetTopologyPageInfo
(java.lang.String id, java.lang.String window, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMeth
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3416
MethodgetTopologyPageInfo
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:5556
MethodgetTopologyPageInfo
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:9383
MethodgetTopologyPageInfo
Parameters: - id - window - is_include_sys
storm-client/src/py/storm/Nimbus.py:382
MethodgetTopologyPageInfo
Parameters: - id - window - is_include_sys
storm-client/src/py/storm/Nimbus.py:1971
MethodgetTopologyPageInfo
(String id, String window, boolean isIncludeSys)
storm-server/src/main/java/org/apache/storm/LocalCluster.java:1004
MethodgetTopologyPageInfo
(String topoId, String window, boolean includeSys)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4382
MethodgetTopologyPageInfo_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:49017
MethodgetTopologyPageInfo_call
(java.lang.String id, java.lang.String window, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMeth
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3428
MethodgetTopologyPageInfo_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:49594
MethodgetTopologyProfilingDumpJstack
/api/v1/topology/:id/profiling/dumpjstack/:host-port -> dump jstack.
storm-webapp/src/main/java/org/apache/storm/daemon/ui/resources/StormApiResource.java:654
MethodgetTopologyProfilingDumpProfile
/api/v1/topology/:id/profiling/dumpprofile/:host-port -> dump profile.
storm-webapp/src/main/java/org/apache/storm/daemon/ui/resources/StormApiResource.java:636
MethodgetTopologyProfilingDumpheap
/api/v1/topology/:id/profiling/dumpheap/:host-port -> dump heap.
storm-webapp/src/main/java/org/apache/storm/daemon/ui/resources/StormApiResource.java:694
MethodgetTopologyProfilingRestartWorker
/api/v1/topology/:id/profiling/restartworker/:host-port -> restart worker.
storm-webapp/src/main/java/org/apache/storm/daemon/ui/resources/StormApiResource.java:674
MethodgetTopologyProfilingStart
/api/v1/topology/:id/profiling/start/:host-port/:timeout -> profiling start.
storm-webapp/src/main/java/org/apache/storm/daemon/ui/resources/StormApiResource.java:599
MethodgetTopologyProfilingStop
/api/v1/topology/:id/profiling/stop/:host-port -> profiling stop.
storm-webapp/src/main/java/org/apache/storm/daemon/ui/resources/StormApiResource.java:618
MethodgetTopologyResourcesMap
Get the amount of resources used by topologies. Used for displaying resource information on the UI. @return a map that contains multiple topologies a
storm-server/src/main/java/org/apache/storm/scheduler/ISchedulingState.java:312
MethodgetTopologySummaries
()
storm-client/src/jvm/org/apache/storm/ILocalCluster.java:142
MethodgetTopologySummaries
(org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<TopologySummary>> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:254
MethodgetTopologySummaries
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:1223
MethodgetTopologySummaries
(org.apache.storm.thrift.async.AsyncMethodCallback<java.util.List<TopologySummary>> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3101
MethodgetTopologySummaries
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:5210
MethodgetTopologySummaries
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:8674
MethodgetTopologySummaries
(self)
storm-client/src/py/storm/Nimbus.py:318
MethodgetTopologySummaries
(self)
storm-client/src/py/storm/Nimbus.py:1661
MethodgetTopologySummaries
()
storm-server/src/main/java/org/apache/storm/LocalCluster.java:576
← previousnext →20,001–20,100 of 27,770, ranked by callers