MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
↓ 10 callersMethodis_set_msg
Returns true if field msg is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/HBAuthorizationException.java:153
↓ 10 callersMethodis_set_msg
Returns true if field msg is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/KeyNotFoundException.java:153
↓ 10 callersMethodis_set_msg
Returns true if field msg is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/DRPCExecutionException.java:169
↓ 10 callersMethodis_set_name
Returns true if field name is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ThriftSerializedObject.java:166
↓ 10 callersMethodis_set_name
Returns true if field name is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:411
↓ 10 callersMethodis_set_name
Returns true if field name is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:404
↓ 10 callersMethodis_set_name
Returns true if field name is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java:189
↓ 10 callersMethodis_set_node
Returns true if field node is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/NodeInfo.java:168
↓ 10 callersMethodis_set_nodeInfo
Returns true if field nodeInfo is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ProfileRequest.java:184
↓ 10 callersMethodis_set_output_fields
Returns true if field output_fields is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/StreamInfo.java:187
↓ 10 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/OwnerResourceSummary.java:343
↓ 10 callersMethodis_set_port
Returns true if field port is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/NodeInfo.java:208
↓ 10 callersMethodis_set_process_ms_avg
Returns true if field process_ms_avg is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/BoltStats.java:421
↓ 10 callersMethodis_set_request_id
Returns true if field request_id is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/DRPCRequest.java:190
↓ 10 callersMethodis_set_serialized_parts
Returns true if field serialized_parts is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/LocalStateData.java:178
↓ 10 callersMethodis_set_session
Returns true if field session is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/BeginDownloadResult.java:203
↓ 10 callersMethodis_set_session
Returns true if field session is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ListBlobsResult.java:208
↓ 10 callersMethodis_set_settable
Returns true if field settable is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ReadableBlobMeta.java:169
↓ 10 callersMethodis_set_specific
Returns true if field specific is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ExecutorStats.java:297
↓ 10 callersMethodis_set_spout_object
Returns true if field spout_object is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SpoutSpec.java:166
↓ 10 callersMethodis_set_spouts
Returns true if field spouts is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/StormTopology.java:345
↓ 10 callersMethodis_set_state_spout_object
Returns true if field state_spout_object is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/StateSpoutSpec.java:166
↓ 10 callersMethodis_set_state_spouts
Returns true if field state_spouts is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/StormTopology.java:415
↓ 10 callersMethodis_set_status
Returns true if field status is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:523
↓ 10 callersMethodis_set_status
Returns true if field status is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologyInfo.java:490
↓ 10 callersMethodis_set_status
Returns true if field status is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/StormBase.java:328
↓ 10 callersMethodis_set_storm_id
Returns true if field storm_id is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ClusterWorkerHeartbeat.java:210
↓ 10 callersMethodis_set_storm_id
Returns true if field storm_id is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeat.java:187
↓ 10 callersMethodis_set_streamId
Returns true if field streamId is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerMetricPoint.java:338
↓ 10 callersMethodis_set_streamId
Returns true if field streamId is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/GlobalStreamId.java:190
↓ 10 callersMethodis_set_streams
Returns true if field streams is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ComponentCommon.java:265
↓ 10 callersMethodis_set_supervisor_id
Returns true if field supervisor_id is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeats.java:171
↓ 10 callersMethodis_set_supervisor_id
Returns true if field supervisor_id is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:398
↓ 10 callersMethodis_set_supervisor_id
Returns true if field supervisor_id is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/LSSupervisorId.java:153
↓ 10 callersMethodis_set_supervisors
Returns true if field supervisors is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java:210
↓ 10 callersMethodis_set_topo_history
Returns true if field topo_history is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/LSTopoHistoryList.java:174
↓ 10 callersMethodis_set_topologies
Returns true if field topologies is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ClusterSummary.java:250
↓ 10 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/WorkerMetrics.java:195
↓ 10 callersMethodis_set_topology_id
Returns true if field topology_id is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/LSWorkerHeartbeat.java:223
↓ 10 callersMethodis_set_topology_id
Returns true if field topology_id is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/LocalAssignment.java:207
↓ 10 callersMethodis_set_topology_id
Returns true if field topology_id is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/LSTopoHistory.java:199
↓ 10 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/ExecutorStats.java:273
↓ 10 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/AccessControl.java:193
↓ 10 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/PrivateWorkerKey.java:214
↓ 10 callersMethodis_set_users
Returns true if field users is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/LSTopoHistory.java:261
↓ 10 callersMethodis_set_worker_heartbeats
Returns true if field worker_heartbeats is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeats.java:211
↓ 10 callersMethodlastError
(String stormId, String componentId)
storm-client/src/jvm/org/apache/storm/cluster/IStormClusterState.java:234
↓ 10 callersMethodlaunchContainer
Launch a container in a given slot. @param port the port to run this on @param assignment what to launch @param state the current state of the supervi
storm-server/src/main/java/org/apache/storm/daemon/supervisor/ContainerLauncher.java:87
↓ 10 callersFunctionloadFixture
(name)
storm-webapp/cypress/test-server.js:54
↓ 10 callersMethodlocalHostname
()
storm-client/src/jvm/org/apache/storm/utils/Utils.java:513
↓ 10 callersMethodlogsForPort
Get the filtered, authorized, sorted log files for a port.
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogSearchHandler.java:426
↓ 10 callersMethodmake
Factory to create a new AdvancedFSOps. @param conf the configuration of the process @return the appropriate instance of the class for this config and
storm-client/src/jvm/org/apache/storm/daemon/supervisor/AdvancedFSOps.java:61
↓ 10 callersMethodmasterStormConfKey
(String topologyId)
storm-client/src/jvm/org/apache/storm/utils/ConfigUtils.java:337
↓ 10 callersMethodnodesAvailable
()
storm-server/src/main/java/org/apache/storm/scheduler/multitenant/DefaultPool.java:72
↓ 10 callersMethodof
(K key, V value)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/common/HdfsUtils.java:81
↓ 10 callersMethodoutputFields
(List<String> fields)
storm-client/src/jvm/org/apache/storm/Thrift.java:79
↓ 10 callersMethodprepare
Called when the `Operation` is first initialized. @param conf the Storm configuration map @param context the operation context which provides info
storm-client/src/jvm/org/apache/storm/trident/operation/Operation.java:35
↓ 10 callersMethodprint
Print the values in this stream.
storm-client/src/jvm/org/apache/storm/streams/Stream.java:301
↓ 10 callersMethodpublish
(Object obj)
storm-client/src/jvm/org/apache/storm/utils/JCQueue.java:247
↓ 10 callersMethodrefreshLoad
(LoadMapping loadMapping)
storm-client/src/jvm/org/apache/storm/grouping/LoadAwareShuffleGrouping.java:109
↓ 10 callersMethodregisterMetric
Register metric. @deprecated in favor of metrics v2 (the non-deprecated methods on this class)
storm-client/src/jvm/org/apache/storm/task/IMetricsContext.java:33
↓ 10 callersMethodremove
Remove the resources in other from this. @param other the resources to be removed. @param resourceMetrics The resource related metrics @return true if
storm-server/src/main/java/org/apache/storm/scheduler/resource/normalization/NormalizedResourceOffer.java:90
↓ 10 callersMethodreportRate
Get report rate. @return the approximate average rate per second.
storm-client/src/jvm/org/apache/storm/metric/internal/RateTracker.java:86
↓ 10 callersMethodsearch
Handles '/search' (searching from specific worker or daemon log file) request.
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/webapp/LogviewerResource.java:283
↓ 10 callersMethodsetBlobMeta
(java.lang.String key, SettableBlobMeta meta)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:82
↓ 10 callersMethodsetCommitFrequencySec
(int commitFrequencySec)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java:176
↓ 10 callersMethodsetHost
Sets host. @param host host @return Builder itself
external/storm-redis/src/main/java/org/apache/storm/redis/common/config/JedisPoolConfig.java:118
↓ 10 callersMethodsetInstance
Provide an instance of this class for delegates to use. To mock out delegated methods, provide an instance of a subclass that overrides the implement
storm-client/src/jvm/org/apache/storm/utils/ConfigUtils.java:75
↓ 10 callersMethodsetProcessingGuarantee
Specifies which processing guarantee the spout should offer. Refer to the documentation for {@link ProcessingGuarantee}. @param processingGuarantee T
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutConfig.java:236
↓ 10 callersMethodset_options_isSet
(boolean value)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:16779
↓ 10 callersMethodset_session_isSet
(boolean value)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:32473
↓ 10 callersMethodset_settable
(@org.apache.storm.thrift.annotation.Nullable SettableBlobMeta settable)
storm-client/src/jvm/org/apache/storm/generated/ReadableBlobMeta.java:160
↓ 10 callersMethodset_status
@see TopologyStatus
storm-client/src/jvm/org/apache/storm/generated/StormBase.java:319
↓ 10 callersMethodsetupBlob
(String key, NimbusInfo nimbusInfo, Integer versionInfo)
storm-client/src/jvm/org/apache/storm/cluster/IStormClusterState.java:216
↓ 10 callersMethodshuffle
(NullStruct value)
storm-client/src/jvm/org/apache/storm/generated/Grouping.java:168
↓ 10 callersMethodslotsAvailable
()
storm-server/src/main/java/org/apache/storm/scheduler/multitenant/IsolatedPool.java:317
↓ 10 callersMethodslotsAvailable
()
storm-server/src/main/java/org/apache/storm/scheduler/multitenant/DefaultPool.java:83
↓ 10 callersMethodsubList
(int i, int i1)
storm-client/src/jvm/org/apache/storm/utils/ListDelegate.java:146
↓ 10 callersMethodsubmit
Submits the topology with the name taken from the configuration.
storm-client/src/jvm/org/apache/storm/topology/ConfigurableTopology.java:109
↓ 10 callersMethodtest
(T obj)
storm-client/src/jvm/org/apache/storm/utils/IPredicate.java:20
↓ 10 callersMethodtoString
()
storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java:304
↓ 10 callersMethodtoString
()
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/NormalDistStats.java:134
↓ 10 callersMethodtoString
()
external/storm-jdbc/src/main/java/org/apache/storm/jdbc/common/Column.java:103
↓ 10 callersMethodvalidate
Determines is this represents a valid Topology. @return true if valid
flux/flux-core/src/main/java/org/apache/storm/flux/model/TopologyDef.java:306
↓ 10 callersMethodverifyAllMessagesCommitted
(Consumer<K, V> consumerSpy, ArgumentCaptor<Map<TopicPartition, OffsetAndMetadata>> commitCapture, lon
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/SingleTopicKafkaUnitSetupHelper.java:62
↓ 10 callersMethodwithBlobStore
Use the following blobstore instead of the one in the config. This is intended mostly for internal testing with Mocks.
storm-server/src/main/java/org/apache/storm/LocalCluster.java:1206
↓ 10 callersMethodwithClusterState
Use the following clusterState instead of the one in the config. This is intended mostly for internal testing with Mocks.
storm-server/src/main/java/org/apache/storm/LocalCluster.java:1222
↓ 10 callersMethodwithFileNameFormat
(FileNameFormat fileNameFormat)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/HdfsBolt.java:51
↓ 10 callersMethodwithFsUrl
(String fsUrl)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/HdfsBolt.java:41
↓ 10 callersMethodwithTopoCache
Use the following topo cache instead of creating out own. This is intended mostly for internal testing with Mocks.
storm-server/src/main/java/org/apache/storm/LocalCluster.java:1214
↓ 10 callersMethodwithWindow
(Count windowLength, Count slidingInterval)
storm-client/src/jvm/org/apache/storm/bolt/JoinBolt.java:364
↓ 9 callersMethodaddResources
Add blobs to be checked if they can be deleted. @param blobs a map of blob name to the blob object. The blobs in this map will be deleted from the ma
storm-server/src/main/java/org/apache/storm/localizer/LocalizedResourceRetentionSet.java:65
↓ 9 callersMethodaddValue
(double value)
storm-client/src/jvm/org/apache/storm/metrics2/RollingAverageGauge.java:29
↓ 9 callersMethodareAllProcessesDead
Check whether all processes are dead. @return true if all of the processes are dead, else false @throws IOException on any error
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Killable.java:38
↓ 9 callersMethodassertAcked
(AckFailMapTracker tracker, Object... ids)
storm-server/src/test/java/org/apache/storm/AssertLoop.java:43
↓ 9 callersMethodassignments
(Runnable callback)
storm-client/src/jvm/org/apache/storm/cluster/IStormClusterState.java:36
↓ 9 callersMethodassignmentsInfo
Get all the topologies assignments mapping stormId -> Assignment from local backend. @return stormId -> Assignment mapping
storm-client/src/jvm/org/apache/storm/cluster/IStormClusterState.java:61
↓ 9 callersMethodboltId
(int index)
storm-client/src/jvm/org/apache/storm/drpc/LinearDRPCTopologyBuilder.java:54
↓ 9 callersMethodbuild
Builds a new {@link StormTopology} for the computation expressed via the stream api. @return the storm topology
storm-client/src/jvm/org/apache/storm/streams/StreamBuilder.java:156
↓ 9 callersMethodbuildSuccessJsonResponse
Build a Response object representing success response with JSON entity. @param entity entity object to represent it as JSON @param callback callbackP
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/utils/LogviewerResponseBuilder.java:66
← previousnext →1,201–1,300 of 27,770, ranked by callers