MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
↓ 14 callersMethodgetUserFiles
()
storm-server/src/test/java/org/apache/storm/localizer/AsyncLocalizerTest.java:1018
↓ 14 callersMethodgetVal
()
external/storm-jdbc/src/main/java/org/apache/storm/jdbc/common/Column.java:66
↓ 14 callersMethodgetVersion
Get the version number of the build. @return the version number of the build.
storm-client/src/jvm/org/apache/storm/utils/IVersionInfo.java:29
↓ 14 callersMethodget_common_stats
()
storm-client/src/jvm/org/apache/storm/generated/ComponentAggregateStats.java:202
↓ 14 callersMethodget_node_host
()
storm-client/src/jvm/org/apache/storm/generated/Assignment.java:306
↓ 14 callersMethodget_port_iterator
()
storm-client/src/jvm/org/apache/storm/generated/NodeInfo.java:182
↓ 14 callersMethodhasNext
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/sorter/NodeSorter.java:445
↓ 14 callersMethodis_set_debug_options
Returns true if field debug_options is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:884
↓ 14 callersMethodis_set_executor_node_port
Returns true if field executor_node_port is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/Assignment.java:355
↓ 14 callersMethodis_set_jdk_version
Returns true if field jdk_version is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/StormTopology.java:583
↓ 14 callersMethodis_set_mem_on_heap
Returns true if field mem_on_heap is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerResources.java:221
↓ 14 callersMethodis_set_meta
Returns true if field meta is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java:394
↓ 14 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/WorkerSummary.java:435
↓ 14 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/RebalanceOptions.java:278
↓ 14 callersMethodis_set_owner
Returns true if field owner is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/Assignment.java:484
↓ 14 callersMethodis_set_resources_map
Returns true if field resources_map is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java:510
↓ 14 callersMethodis_set_topoOwner
Returns true if field topoOwner is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/Credentials.java:203
↓ 14 callersMethodis_set_topology_conf_overrides
Returns true if field topology_conf_overrides is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/RebalanceOptions.java:337
↓ 14 callersMethodis_set_total_node_shared
Returns true if field total_node_shared is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/LocalAssignment.java:295
↓ 14 callersMethodis_set_total_shared_off_heap
Returns true if field total_shared_off_heap is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/Assignment.java:460
↓ 14 callersMethodis_set_used_ports
Returns true if field used_ports is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java:354
↓ 14 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/KillOptions.java:149
↓ 14 callersMethodis_set_worker_resources
Returns true if field worker_resources is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/Assignment.java:425
↓ 14 callersMethodis_set_worker_summaries
Returns true if field worker_summaries is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorPageInfo.java:224
↓ 14 callersMethodis_set_workers
Returns true if field workers is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:946
↓ 14 callersMethodmapToPair
Returns a stream of key-value pairs by applying a {@link PairFunction} on each value of this stream. @param function the mapping function to be appli
storm-client/src/jvm/org/apache/storm/streams/Stream.java:107
↓ 14 callersMethodmasterStormCodeKey
(String topologyId)
storm-client/src/jvm/org/apache/storm/utils/ConfigUtils.java:333
↓ 14 callersMethodmaybeDeserialize
(byte[] serialized, Class<T> clazz)
storm-client/src/jvm/org/apache/storm/cluster/ClusterUtils.java:249
↓ 14 callersMethodmessageWithRandId
(HBServerMessageType type, HBMessageData data)
storm-server/src/test/java/org/apache/storm/PacemakerTest.java:224
↓ 14 callersMethodmultiGet
(List<List<Object>> keys)
storm-client/src/jvm/org/apache/storm/trident/state/map/IBackingMap.java:19
↓ 14 callersMethodprepareCommit
Invoked by the framework to prepare a transaction for commit. It should be possible to commit the prepared state later. <p> The same txid can be prepa
storm-client/src/jvm/org/apache/storm/state/State.java:30
↓ 14 callersMethodprepareSpout
(int messageCount, FirstPollOffsetStrategy firstPollOffsetStrategy)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/KafkaSpoutReactivationTest.java:75
↓ 14 callersMethodput
(String key, TBase val)
storm-client/src/jvm/org/apache/storm/utils/LocalState.java:157
↓ 14 callersMethodregisterTimer
(String name)
storm-client/src/jvm/org/apache/storm/task/IMetricsContext.java:50
↓ 14 callersMethodreportError
Reports an error. The corresponding stack trace will be visible in the Storm UI. <p>Note that calling this method does not alter the processing of a
storm-client/src/jvm/org/apache/storm/trident/operation/TridentCollector.java:51
↓ 14 callersMethodrequestDownloadTopologyBlobs
Request that all of the blobs necessary for this topology be downloaded. Note that this adds references to blobs asynchronously in background threads
storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java:224
↓ 14 callersMethodschedule
(KafkaSpoutMessageId msgId)
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java:255
↓ 14 callersMethodsetLoggerLevel
(LoggerContext logContext, String loggerName, String newLevelStr)
storm-client/test/jvm/org/apache/storm/daemon/worker/LogConfigManagerTest.java:261
↓ 14 callersMethodsetOffsetCommitPeriodMs
Specifies the period, in milliseconds, the offset commit task is periodically called. Default is 15s. <p>This setting only has an effect if the confi
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java:160
↓ 14 callersMethodset_action
@see LogLevelAction
storm-client/src/jvm/org/apache/storm/generated/LogLevel.java:203
↓ 14 callersMethodset_target_log_level
(@org.apache.storm.thrift.annotation.Nullable java.lang.String target_log_level)
storm-client/src/jvm/org/apache/storm/generated/LogLevel.java:227
↓ 14 callersMethodsetupSpout
Creates, opens and activates a KafkaSpout using a mocked consumer. The TopicFilter and ManualPartitioner should be mock objects, since this method sho
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/SpoutWithMockedConsumerSetupHelper.java:69
↓ 14 callersMethodsingleGet
(MapState<Object> map, Object key)
storm-core/test/jvm/org/apache/storm/trident/StateTest.java:60
↓ 14 callersMethodstateQuery
(TridentState state, Fields inputFields, QueryFunction function, Fields functionFields)
storm-client/src/jvm/org/apache/storm/trident/Stream.java:340
↓ 14 callersMethodstatus
()
storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java:199
↓ 14 callersMethodsubmitTopology
(java.lang.String name, java.lang.String uploadedJarLocation, java.lang.String jsonConf, StormTopology topolog
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:32
↓ 14 callersMethodsubstringSearch
(Path file, String searchString)
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogSearchHandler.java:304
↓ 14 callersMethodtoString
()
storm-client/src/jvm/org/apache/storm/utils/SimpleVersion.java:78
↓ 14 callersMethodtoString
()
storm-server/src/main/java/org/apache/storm/container/oci/OciResource.java:65
↓ 14 callersMethodtryLock
returns lock on file or null if file is already locked. throws if unexpected problem
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/FileLock.java:67
↓ 14 callersMethodvalueStat
(MultiCountStat metric)
storm-client/src/jvm/org/apache/storm/stats/CommonStats.java:71
↓ 13 callersMethodaddBolt
(IBatchBolt bolt, Number parallelism)
storm-client/src/jvm/org/apache/storm/drpc/LinearDRPCTopologyBuilder.java:58
↓ 13 callersMethodaddResource
Add generic resource for this component.
storm-client/src/jvm/org/apache/storm/topology/ComponentConfigurationDeclarer.java:82
↓ 13 callersMethodall
(NullStruct value)
storm-client/src/jvm/org/apache/storm/generated/Grouping.java:174
↓ 13 callersMethodassertNumAcks
(int expectedNumAcks)
storm-core/test/jvm/org/apache/storm/integration/AckTrackingFeeder.java:54
↓ 13 callersMethodconstructLocalAssignment
(String topoId, String owner)
storm-server/src/test/java/org/apache/storm/localizer/AsyncLocalizerTest.java:329
↓ 13 callersMethodcreateBlob
(String key, SettableBlobMeta meta, Subject who)
external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsBlobStore.java:136
↓ 13 callersMethodcreateSubject
(String name)
storm-client/test/jvm/org/apache/storm/security/auth/authorizer/SimpleACLAuthorizerTest.java:354
↓ 13 callersMethoddeserialize
(ByteBuffer ser)
storm-client/src/jvm/org/apache/storm/spout/Scheme.java:22
↓ 13 callersMethodequals
(Object o)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/FileLock.java:299
↓ 13 callersMethodfindNMatches
Find the first N matches of target string in files. @param logs all candidate log files to search @param numMatches number of matches expected @param
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogSearchHandler.java:460
↓ 13 callersMethodflatMap
Returns a stream consisting of the results of replacing each value of this stream with the contents produced by applying the provided mapping function
storm-client/src/jvm/org/apache/storm/trident/Stream.java:460
↓ 13 callersMethodfromMap
Constructs a metadata object from a Map in the format produced by {@link #toMap() }. @param map The source map @return A new metadata object
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutBatchMetadata.java:79
↓ 13 callersMethodgenSupervisorsWithRacks
( int numRacks, int numSupersPerRack, int numPorts, int rackStart, int superInRackStart,
storm-server/src/test/java/org/apache/storm/scheduler/resource/TestUtilsForResourceAwareScheduler.java:209
↓ 13 callersMethodgetAssignments
Get all the assignments.
storm-server/src/main/java/org/apache/storm/scheduler/ISchedulingState.java:250
↓ 13 callersMethodgetDir
()
storm-client/src/jvm/org/apache/storm/container/cgroup/Hierarchy.java:100
↓ 13 callersMethodgetFileName
()
storm-server/src/main/java/org/apache/storm/localizer/LocallyCachedTopologyBlob.java:342
↓ 13 callersMethodgetMap
()
storm-clojure/src/main/java/org/apache/storm/clojure/ClojureTuple.java:71
↓ 13 callersMethodgetMetricsFromScan
(FilterOptions filter)
storm-server/src/test/java/org/apache/storm/metricstore/rocksdb/RocksDbStoreTest.java:157
↓ 13 callersMethodgetObjectResources
()
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/ObjectResourcesSummary.java:66
↓ 13 callersMethodgetProcessor
()
storm-client/src/jvm/org/apache/storm/streams/ProcessorNode.java:44
↓ 13 callersMethodgetStr
(Map map, Object key)
examples/storm-perf/src/main/java/org/apache/storm/perf/utils/Helper.java:43
↓ 13 callersMethodgetSubject
()
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:750
↓ 13 callersMethodgetThisSources
Gets the declared inputs to this component. @return A map from subscribed component/stream to the grouping subscribed with.
storm-client/src/jvm/org/apache/storm/task/TopologyContext.java:238
↓ 13 callersMethodgetThisWorkerPort
()
storm-client/src/jvm/org/apache/storm/task/WorkerTopologyContext.java:100
↓ 13 callersMethodgetTopology
(String name, Map<String, Object> config, int numSpout, int numBolt,
storm-server/src/test/java/org/apache/storm/scheduler/blacklist/TestUtilsForBlacklistScheduler.java:133
↓ 13 callersMethodgetValueAsList
Get the given config value as a List &lt;String&gt;, if possible. @param name - the config key @param conf - the config map @return - the config valu
storm-client/src/jvm/org/apache/storm/utils/ConfigUtils.java:420
↓ 13 callersMethodget_nodeInfo
()
storm-client/src/jvm/org/apache/storm/generated/ProfileRequest.java:170
↓ 13 callersMethodget_num_workers
()
storm-client/src/jvm/org/apache/storm/generated/StormBase.java:338
↓ 13 callersMethodget_output_fields
()
storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java:173
↓ 13 callersMethodget_parallelism_hint
()
storm-client/src/jvm/org/apache/storm/generated/ComponentCommon.java:275
↓ 13 callersMethodget_resources
()
storm-client/src/jvm/org/apache/storm/generated/WorkerResources.java:328
↓ 13 callersMethodhasPermissions
Validates if the user has at least the set of permissions mentioned in the mask. @param acl ACL for the key. @param mask mask holds the cumulative v
storm-client/src/jvm/org/apache/storm/blobstore/BlobStoreAclHandler.java:298
↓ 13 callersMethodindexOf
(Object o)
storm-client/src/jvm/org/apache/storm/utils/ListDelegate.java:126
↓ 13 callersMethodinit
(Object batchId, TridentCollector collector)
storm-client/src/jvm/org/apache/storm/trident/operation/Aggregator.java:18
↓ 13 callersMethodisSimulating
()
storm-client/src/jvm/org/apache/storm/utils/Time.java:38
↓ 13 callersMethodisTimerWaiting
is timer waiting. Used in timer simulation.
storm-client/src/jvm/org/apache/storm/StormTimer.java:179
↓ 13 callersMethodis_set_assigned_generic_resources
Returns true if field assigned_generic_resources is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:1372
↓ 13 callersMethodis_set_assigned_generic_resources
Returns true if field assigned_generic_resources is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:843
↓ 13 callersMethodis_set_assignment_id
Returns true if field assignment_id is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorInfo.java:314
↓ 13 callersMethodis_set_common_stats
Returns true if field common_stats is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ComponentAggregateStats.java:216
↓ 13 callersMethodis_set_component_debug
Returns true if field component_debug is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:560
↓ 13 callersMethodis_set_component_executors
Returns true if field component_executors is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/StormBase.java:385
↓ 13 callersMethodis_set_component_to_num_tasks
Returns true if field component_to_num_tasks is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:468
↓ 13 callersMethodis_set_component_to_shared_memory
Returns true if field component_to_shared_memory is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/StormTopology.java:618
↓ 13 callersMethodis_set_cpu_guarantee
Returns true if field cpu_guarantee is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:499
↓ 13 callersMethodis_set_cpu_guarantee_remaining
Returns true if field cpu_guarantee_remaining is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/OwnerResourceSummary.java:543
↓ 13 callersMethodis_set_creds
Returns true if field creds is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SubmitOptions.java:201
↓ 13 callersMethodis_set_errors
Returns true if field errors is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java:691
↓ 13 callersMethodis_set_eventlog_host
Returns true if field eventlog_host is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ComponentPageInfo.java:715
← previousnext →601–700 of 27,770, ranked by callers