MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
↓ 12 callersMethodis_set_replication_count
Returns true if field replication_count is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:908
↓ 12 callersMethodis_set_replication_count
Returns true if field replication_count is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:643
↓ 12 callersMethodis_set_replication_count
Returns true if field replication_count is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:656
↓ 12 callersMethodis_set_replication_factor
Returns true if field replication_factor is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SettableBlobMeta.java:212
↓ 12 callersMethodis_set_requested_cpu
Returns true if field requested_cpu is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1062
↓ 12 callersMethodis_set_requested_cpu
Returns true if field requested_cpu is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:580
↓ 12 callersMethodis_set_requested_cpu
Returns true if field requested_cpu is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:709
↓ 12 callersMethodis_set_requested_cpu
Returns true if field requested_cpu is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:722
↓ 12 callersMethodis_set_requested_cpu
Returns true if field requested_cpu is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:675
↓ 12 callersMethodis_set_requested_memoffheap
Returns true if field requested_memoffheap is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1040
↓ 12 callersMethodis_set_requested_memoffheap
Returns true if field requested_memoffheap is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:558
↓ 12 callersMethodis_set_requested_memoffheap
Returns true if field requested_memoffheap is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:687
↓ 12 callersMethodis_set_requested_memoffheap
Returns true if field requested_memoffheap is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:700
↓ 12 callersMethodis_set_requested_memonheap
Returns true if field requested_memonheap is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1018
↓ 12 callersMethodis_set_requested_memonheap
Returns true if field requested_memonheap is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:536
↓ 12 callersMethodis_set_requested_memonheap
Returns true if field requested_memonheap is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:665
↓ 12 callersMethodis_set_requested_memonheap
Returns true if field requested_memonheap is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:678
↓ 12 callersMethodis_set_requested_off_heap_memory
Returns true if field requested_off_heap_memory is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:631
↓ 12 callersMethodis_set_requested_on_heap_memory
Returns true if field requested_on_heap_memory is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:609
↓ 12 callersMethodis_set_requested_regular_off_heap_memory
Returns true if field requested_regular_off_heap_memory is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1194
↓ 12 callersMethodis_set_requested_regular_on_heap_memory
Returns true if field requested_regular_on_heap_memory is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1150
↓ 12 callersMethodis_set_requested_shared_off_heap_memory
Returns true if field requested_shared_off_heap_memory is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1216
↓ 12 callersMethodis_set_requested_shared_on_heap_memory
Returns true if field requested_shared_on_heap_memory is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1172
↓ 12 callersMethodis_set_requested_total_memory
Returns true if field requested_total_memory is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:653
↓ 12 callersMethodis_set_reset_log_level_timeout_secs
Returns true if field reset_log_level_timeout_secs is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/LogLevel.java:260
↓ 12 callersMethodis_set_server_port
Returns true if field server_port is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java:534
↓ 12 callersMethodis_set_serviceType
Returns true if field serviceType is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerToken.java:191
↓ 12 callersMethodis_set_shared_mem_on_heap
Returns true if field shared_mem_on_heap is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerResources.java:287
↓ 12 callersMethodis_set_signature
Returns true if field signature is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerToken.java:255
↓ 12 callersMethodis_set_success
Returns true if field success is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:1960
↓ 12 callersMethodis_set_success
Returns true if field success is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java:939
↓ 12 callersMethodis_set_success
Returns true if field success is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java:2208
↓ 12 callersMethodis_set_time_secs
Returns true if field time_secs is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:492
↓ 12 callersMethodis_set_time_stamp
Returns true if field time_stamp is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ProfileRequest.java:240
↓ 12 callersMethodis_set_tlsPort
Returns true if field tlsPort is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/NimbusSummary.java:336
↓ 12 callersMethodis_set_topologyId
Returns true if field topologyId is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerTokenInfo.java:220
↓ 12 callersMethodis_set_total_executors
Returns true if field total_executors is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:389
↓ 12 callersMethodis_set_total_tasks
Returns true if field total_tasks is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:587
↓ 12 callersMethodis_set_total_topologies
Returns true if field total_topologies is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:367
↓ 12 callersMethodis_set_total_workers
Returns true if field total_workers is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:411
↓ 12 callersMethodis_set_transferred
Returns true if field transferred is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/CommonAggregateStats.java:284
↓ 12 callersMethodis_set_type
Returns true if field type is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/HBMessage.java:194
↓ 12 callersMethodis_set_uptime_secs
Returns true if field uptime_secs is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:606
↓ 12 callersMethodis_set_uptime_secs
Returns true if field uptime_secs is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:514
↓ 12 callersMethodis_set_uptime_secs
Returns true if field uptime_secs is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java:453
↓ 12 callersMethodis_set_used_cpu
Returns true if field used_cpu is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:503
↓ 12 callersMethodis_set_used_mem
Returns true if field used_mem is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:481
↓ 12 callersMethodis_set_userName
Returns true if field userName is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerTokenInfo.java:196
↓ 12 callersMethodis_set_wait_secs
Returns true if field wait_secs is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/RebalanceOptions.java:223
↓ 12 callersMethoditerator
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/NodeSorter.java:516
↓ 12 callersMethodll
()
storm-client/test/jvm/org/apache/storm/daemon/worker/LogConfigManagerTest.java:43
↓ 12 callersMethodlookupMetadataString
(KeyType type, String s, Map<String, Integer> lookupCache)
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbStore.java:256
↓ 12 callersMethodmkExecutorInfoList
(int... executors)
storm-server/src/test/java/org/apache/storm/daemon/supervisor/SlotTest.java:86
↓ 12 callersMethodmultiPut
(List<List<Object>> keys, List<T> vals)
storm-client/src/jvm/org/apache/storm/trident/state/map/MapState.java:21
↓ 12 callersMethodpartitionByKey
()
storm-client/src/jvm/org/apache/storm/streams/PairStream.java:407
↓ 12 callersMethodprocess
{@inheritDoc}
external/storm-redis/src/main/java/org/apache/storm/redis/bolt/RedisFilterBolt.java:85
↓ 12 callersMethodprocessLauncherAndWait
(Map<String, Object> conf, String user, List<String> args, final
storm-client/src/jvm/org/apache/storm/daemon/supervisor/ClientSupervisorUtils.java:63
↓ 12 callersMethodrelease
Release lock by deleting file. @throws IOException if lock file could not be deleted
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/FileLock.java:255
↓ 12 callersMethodremoveSupervisorFromSupervisors
(Map<String, SupervisorDetails> supervisorDetailsMap, String supervisor)
storm-server/src/test/java/org/apache/storm/scheduler/blacklist/TestUtilsForBlacklistScheduler.java:64
↓ 12 callersMethodrename
(byte[] oldkey, byte[] newkey)
external/storm-redis/src/main/java/org/apache/storm/redis/common/commands/RedisCommands.java:42
↓ 12 callersMethodreverseMap
<code>"{:a 1 :b 1 :c 2} -> {1 [:a :b] 2 :c}"</code>. <p>Example usage in java: <code>Map&lt;Integer, String&gt; tasks; Map&lt;String, List&lt;Integer
storm-client/src/jvm/org/apache/storm/utils/Utils.java:774
↓ 12 callersMethodsetData
(String api, String artifact, String data)
storm-server/src/test/java/org/apache/storm/scheduler/utils/ArtifactoryConfigLoaderTest.java:216
↓ 12 callersMethodsetFirstPollOffsetStrategy
Sets the offset used by the Kafka spout in the first poll to Kafka broker upon process start. Please refer to to the documentation in {@link FirstPoll
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/CommonKafkaSpoutConfig.java:170
↓ 12 callersMethodset_num_err_choice
@see NumErrorsChoice
storm-client/src/jvm/org/apache/storm/generated/GetInfoOptions.java:150
↓ 12 callersMethodslotAssignments
Reverse map: NodeInfo -> List<List<Long>> (slot -> executors).
storm-server/src/test/java/org/apache/storm/daemon/nimbus/NimbusClojurePortTest.java:1092
↓ 12 callersMethodtoString
Returns a default formatted string with fields separated by ",". @return a default formatted string with fields separated by ","
storm-client/src/jvm/org/apache/storm/metric/IEventLogger.java:80
↓ 12 callersMethodtoString
()
external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsBlobStoreFile.java:179
↓ 12 callersMethodtrackedWait
Simulated time wait for a tracked topology. This is intended for internal testing.
storm-server/src/main/java/org/apache/storm/Testing.java:534
↓ 12 callersMethodurlFormat
url formatter for log links. @param fmt string format @param args hostname and other arguments. @return string formatter
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:200
↓ 12 callersMethoduserResourcePool
(TestUserResources... resources)
storm-server/src/test/java/org/apache/storm/scheduler/resource/TestUtilsForResourceAwareScheduler.java:102
↓ 12 callersMethodwithState
Transition to the given state. Notice that it's possible to transition to the same state. @param state The state to transition into @return New dynami
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:1351
↓ 11 callersMethod__setattr__
(self, *args)
storm-client/src/py/storm/ttypes.py:1750
↓ 11 callersMethodaddAggLevel
Add an aggregation level to search for.
storm-server/src/main/java/org/apache/storm/metricstore/FilterOptions.java:116
↓ 11 callersMethodaddConfigurations
add in several configs to the component. @param conf the configs to add @return this for chaining.
storm-client/src/jvm/org/apache/storm/topology/ComponentConfigurationDeclarer.java:24
↓ 11 callersMethodaddNode
(Node parent, Node child, int parallelism)
storm-client/src/jvm/org/apache/storm/streams/Stream.java:376
↓ 11 callersMethodassertValidTopologyForModification
Check if the given topology is allowed for modification right now. If not throw an IllegalArgumentException else go on. @param topologyId the id of t
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:300
↓ 11 callersMethodbasicConf
()
storm-core/test/jvm/org/apache/storm/messaging/netty/NettyTest.java:114
↓ 11 callersMethodbind
This method establishes a server side connection. @param stormId topology ID @param port port # @param cb The callback to deliver received messag
storm-client/src/jvm/org/apache/storm/messaging/IContext.java:62
↓ 11 callersMethodclose
()
storm-client/src/jvm/org/apache/storm/metric/IEventLogger.java:35
↓ 11 callersFunctionconfvalue
(name, storm_config_opts, extrapaths, overriding_conf_file=None, daemon=True)
bin/storm.py:91
↓ 11 callersMethodconsume
Non blocking. Returns immediately if Q is empty. Returns number of elements consumed from Q.
storm-client/src/jvm/org/apache/storm/utils/JCQueue.java:79
↓ 11 callersMethodcountFreeSlotsAlive
(Collection<Node> nodes)
storm-server/src/main/java/org/apache/storm/scheduler/multitenant/Node.java:76
↓ 11 callersMethodcreateClusterConfig
(double compPcore, double compOnHeap, double compOffHeap, Map<Str
storm-server/src/test/java/org/apache/storm/scheduler/resource/TestUtilsForResourceAwareScheduler.java:138
↓ 11 callersMethoddisconnect
()
storm-client/src/jvm/org/apache/storm/cluster/IStormClusterState.java:240
↓ 11 callersMethoddoRequiredTopoFilesExist
Sanity check if everything the topology needs is there for it to run. @param conf the config of the supervisor @param topologyId the ID of the
storm-client/src/jvm/org/apache/storm/daemon/supervisor/AdvancedFSOps.java:210
↓ 11 callersMethodfetchRequest
(java.lang.String functionName)
storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java:34
↓ 11 callersMethodgetAssignedMemOffHeap
()
storm-server/src/main/java/org/apache/storm/daemon/nimbus/TopologyResources.java:206
↓ 11 callersMethodgetAssignedMemOnHeap
()
storm-server/src/main/java/org/apache/storm/daemon/nimbus/TopologyResources.java:198
↓ 11 callersMethodgetAvailableResourcesOverall
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/ObjectResourcesSummary.java:70
↓ 11 callersMethodgetCommonConfigs
()
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestHdfsSpout.java:634
↓ 11 callersMethodgetComponentCommon
(Object component)
storm-client/src/jvm/org/apache/storm/daemon/StormCommon.java:298
↓ 11 callersMethodgetComponentConfiguration
()
storm-client/src/jvm/org/apache/storm/trident/spout/IBatchSpout.java:29
↓ 11 callersMethodgetComponentId
()
storm-client/src/jvm/org/apache/storm/executor/Executor.java:644
↓ 11 callersMethodgetCount
()
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/Rankable.java:19
↓ 11 callersMethodgetCount
(T obj, int slot)
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/SlotBasedCounter.java:50
↓ 11 callersMethodgetField
(HdfsSpout spout, String fieldName)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestHdfsSpout.java:79
↓ 11 callersMethodgetFreeSlots
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/RasNode.java:147
↓ 11 callersMethodgetLong
Returns the Long at position i in the tuple. @throws ClassCastException If that field is not a Long @throws IndexOutOfBoundsException - if the
storm-client/src/jvm/org/apache/storm/tuple/ITuple.java:75
↓ 11 callersMethodgetMajor
()
storm-client/src/jvm/org/apache/storm/utils/SimpleVersion.java:43
↓ 11 callersMethodgetMessageId
Gets the message id that associated with this tuple.
storm-client/src/jvm/org/apache/storm/tuple/Tuple.java:53
← previousnext →901–1,000 of 27,770, ranked by callers