MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
MethodgetShort
(int i)
storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java:134
MethodgetShort
(int i)
storm-client/src/jvm/org/apache/storm/trident/tuple/TridentTupleView.java:120
MethodgetShort
(final int i)
external/storm-redis/src/test/java/org/apache/storm/redis/util/StubTuple.java:90
MethodgetShortByField
(String field)
storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java:184
MethodgetShortByField
(String field)
storm-client/src/jvm/org/apache/storm/trident/tuple/TridentTupleView.java:170
MethodgetShortByField
(final String field)
external/storm-redis/src/test/java/org/apache/storm/redis/util/StubTuple.java:140
MethodgetSimulatedUserFor
(User u, ISchedulingState cluster)
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/priority/FIFOSchedulingPriorityStrategy.java:27
MethodgetSingletons
()
storm-webapp/src/main/java/org/apache/storm/daemon/drpc/webapp/DRPCApplication.java:49
MethodgetSingletons
()
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/webapp/LogviewerApplication.java:79
MethodgetSize
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:660
MethodgetSize
()
storm-server/src/main/java/org/apache/storm/container/oci/ImageManifest.java:109
MethodgetSlidingCount
()
storm-client/src/jvm/org/apache/storm/windowing/DefaultEvictionContext.java:50
MethodgetSlidingInterval
()
storm-client/src/jvm/org/apache/storm/windowing/DefaultEvictionContext.java:55
MethodgetSlidingInterval
()
storm-client/src/jvm/org/apache/storm/streams/windowing/TumblingWindows.java:55
MethodgetSlidingInterval
{@inheritDoc}
storm-client/src/jvm/org/apache/storm/streams/windowing/SlidingWindows.java:85
MethodgetSlidingLength
()
storm-client/src/jvm/org/apache/storm/trident/windowing/config/BaseWindowConfig.java:29
MethodgetSoft
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:380
MethodgetSortedRacks
Racks are sorted by two criteria. <p>1) the number executors of the topology that needs to be scheduled is already on the rack in descending order. T
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/NodeSorter.java:582
MethodgetSource
()
storm-server/src/main/java/org/apache/storm/container/oci/OciContainerExecutorConfig.java:233
MethodgetSourceComponent
()
external/storm-redis/src/test/java/org/apache/storm/redis/util/StubTuple.java:175
MethodgetSourceGlobalStreamId
()
storm-client/test/jvm/org/apache/storm/topology/WindowedBoltExecutorTest.java:69
MethodgetSourceGlobalStreamId
()
storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java:224
MethodgetSourceGlobalStreamId
()
external/storm-redis/src/test/java/org/apache/storm/redis/util/StubTuple.java:170
MethodgetSourceStreamId
()
external/storm-redis/src/test/java/org/apache/storm/redis/util/StubTuple.java:185
MethodgetSourceTask
()
storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java:234
MethodgetSourceTask
()
external/storm-redis/src/test/java/org/apache/storm/redis/util/StubTuple.java:180
MethodgetSpoutDef
(String id)
flux/flux-core/src/main/java/org/apache/storm/flux/model/TopologyDef.java:197
MethodgetSpoutEmitted
()
examples/storm-perf/src/main/java/org/apache/storm/perf/utils/MetricsSample.java:194
MethodgetSpoutExecutors
()
integration-test/src/main/java/org/apache/storm/st/topology/window/SlidingWindowCorrectness.java:70
MethodgetSpoutExecutors
()
integration-test/src/main/java/org/apache/storm/st/topology/window/TumblingWindowCorrectness.java:68
MethodgetSpoutExecutors
()
integration-test/src/main/java/org/apache/storm/st/topology/window/SlidingTimeCorrectness.java:70
MethodgetSpoutExecutors
()
integration-test/src/main/java/org/apache/storm/st/topology/window/TumblingTimeCorrectness.java:68
MethodgetSpoutExecutors
()
examples/storm-perf/src/main/java/org/apache/storm/perf/utils/MetricsSample.java:218
MethodgetSrcChecksum
()
storm-client/src/jvm/org/apache/storm/utils/Utils.java:1603
MethodgetStartTimestamp
()
storm-client/src/jvm/org/apache/storm/windowing/TupleWindowIterImpl.java:70
MethodgetStartTimestamp
()
storm-client/src/jvm/org/apache/storm/windowing/TupleWindowImpl.java:56
MethodgetStartTimestamp
Returns the window start timestamp. Will return null if the window length is not based on time duration. @return the window start timestamp or null i
storm-client/src/jvm/org/apache/storm/windowing/Window.java:88
MethodgetStat
()
storm-client/src/jvm/org/apache/storm/container/cgroup/core/MemoryCore.java:46
MethodgetStatMapFromExecutorSummary
getStatMapFromExecutorSummary. @param executorSummary executorSummary @return getStatMapFromExecutorSummary
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:1802
MethodgetState
()
storm-client/src/jvm/org/apache/storm/windowing/TimeEvictionPolicy.java:87
MethodgetState
()
storm-client/src/jvm/org/apache/storm/windowing/WatermarkCountEvictionPolicy.java:100
MethodgetState
()
storm-client/src/jvm/org/apache/storm/windowing/WatermarkCountTriggerPolicy.java:76
MethodgetState
()
storm-client/src/jvm/org/apache/storm/windowing/CountEvictionPolicy.java:81
MethodgetState
()
storm-client/src/jvm/org/apache/storm/windowing/CountTriggerPolicy.java:62
MethodgetState
()
storm-client/src/jvm/org/apache/storm/windowing/TimeTriggerPolicy.java:132
MethodgetState
()
storm-client/src/jvm/org/apache/storm/windowing/WatermarkTimeTriggerPolicy.java:109
MethodgetState
Return runtime state to be checkpointed by the framework for restoring the eviction policy in case of failures. @return the state
storm-client/src/jvm/org/apache/storm/windowing/EvictionPolicy.java:61
MethodgetState
()
storm-client/src/jvm/org/apache/storm/windowing/WindowManager.java:303
MethodgetState
()
storm-client/src/jvm/org/apache/storm/container/cgroup/core/FreezerCore.java:34
MethodgetState
()
storm-client/src/jvm/org/apache/storm/spout/CheckPointState.java:52
MethodgetState
()
storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java:225
MethodgetState
()
storm-client/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java:222
MethodgetStats
()
storm-client/src/jvm/org/apache/storm/cluster/ExecutorBeat.java:36
MethodgetStormId
Gets the unique id assigned to this topology. The id is the storm name with a unique nonce appended to it. @return the storm id
storm-client/src/jvm/org/apache/storm/task/GeneralTopologyContext.java:67
MethodgetStormId
(String stormName)
storm-client/src/jvm/org/apache/storm/assignments/InMemoryAssignmentBackend.java:110
MethodgetStormId
()
storm-client/src/jvm/org/apache/storm/executor/Executor.java:656
MethodgetStream
()
storm-client/src/jvm/org/apache/storm/trident/topology/TridentTopologyBuilder.java:408
MethodgetStream
()
storm-client/src/jvm/org/apache/storm/multilang/BoltMsg.java:48
MethodgetStream
()
storm-client/src/jvm/org/apache/storm/streams/Stream.java:404
MethodgetStream
()
storm-client/src/jvm/org/apache/storm/executor/TupleInfo.java:47
MethodgetStream
()
storm-client/src/jvm/org/apache/storm/testing/MkTupleParam.java:24
MethodgetStream
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaTuple.java:50
MethodgetStreamBox
getStreamBox. @param visualization visualization @return getStreamBox
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:1912
MethodgetStreamId
()
storm-server/src/main/java/org/apache/storm/metricstore/FilterOptions.java:105
MethodgetStreams
()
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadCompConf.java:199
MethodgetString
(int i)
storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java:114
MethodgetString
(int i)
storm-client/src/jvm/org/apache/storm/trident/tuple/TridentTupleView.java:100
MethodgetString
(final int i)
external/storm-redis/src/test/java/org/apache/storm/redis/util/StubTuple.java:70
MethodgetStringByField
(String field)
storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java:164
MethodgetStringByField
(String field)
storm-client/src/jvm/org/apache/storm/trident/tuple/TridentTupleView.java:150
MethodgetStringByField
(final String field)
external/storm-redis/src/test/java/org/apache/storm/redis/util/StubTuple.java:120
MethodgetStructDesc
()
storm-client/src/jvm/org/apache/storm/generated/Grouping.java:546
MethodgetStructDesc
()
storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java:257
MethodgetStructDesc
()
storm-client/src/jvm/org/apache/storm/generated/HBMessageData.java:425
MethodgetStructDesc
()
storm-client/src/jvm/org/apache/storm/generated/ComponentObject.java:303
MethodgetStructDesc
()
storm-client/src/jvm/org/apache/storm/generated/JavaObjectArg.java:419
MethodgetStructDesc
()
storm-client/src/jvm/org/apache/storm/generated/ExecutorSpecificStats.java:257
MethodgetStructDesc
()
storm-client/src/jvm/org/apache/storm/generated/TopologyActionOptions.java:257
MethodgetSubSystems
get subsystems.
storm-client/src/jvm/org/apache/storm/container/cgroup/Hierarchy.java:43
MethodgetSupervisor
/api/v1/supervisor -> topo history.
storm-webapp/src/main/java/org/apache/storm/daemon/ui/resources/StormApiResource.java:237
MethodgetSupervisor
Get a specific Supervisor. This is intended mostly for internal testing. @param id the id of the supervisor
storm-server/src/main/java/org/apache/storm/LocalCluster.java:686
MethodgetSupervisorAssignments
(java.lang.String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:288
MethodgetSupervisorAssignments
(java.lang.String node)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:1725
MethodgetSupervisorAssignments
(java.lang.String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3717
MethodgetSupervisorAssignments
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:5864
MethodgetSupervisorAssignments
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:10015
MethodgetSupervisorAssignments
Get assigned assignments for a specific supervisor Parameters: - node
storm-client/src/py/storm/Nimbus.py:457
MethodgetSupervisorAssignments
Get assigned assignments for a specific supervisor Parameters: - node
storm-client/src/py/storm/Nimbus.py:2273
MethodgetSupervisorAssignments
(String node)
storm-server/src/main/java/org/apache/storm/LocalCluster.java:1043
MethodgetSupervisorAssignments
(String nodeId)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:5096
MethodgetSupervisorAssignments_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:57291
MethodgetSupervisorAssignments_call
(java.lang.String node, org.apache.storm.thrift.async.AsyncMethodCallback<SupervisorAssignments> resultHandler
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3727
MethodgetSupervisorAssignments_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:57674
MethodgetSupervisorId
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/StandaloneSupervisor.java:45
MethodgetSupervisorPageInfo
(java.lang.String id, java.lang.String host, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethod
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:274
MethodgetSupervisorPageInfo
(java.lang.String id, java.lang.String host, boolean is_include_sys)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:1516
MethodgetSupervisorPageInfo
(java.lang.String id, java.lang.String host, boolean is_include_sys, org.apache.storm.thrift.async.AsyncMethod
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:3457
MethodgetSupervisorPageInfo
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:5595
MethodgetSupervisorPageInfo
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:9463
MethodgetSupervisorPageInfo
Parameters: - id - host - is_include_sys
storm-client/src/py/storm/Nimbus.py:392
← previousnext →19,601–19,700 of 27,770, ranked by callers