MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
↓ 5 callersMethodis_set_num_used_workers
Returns true if field num_used_workers is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:376
↓ 5 callersMethodis_set_num_workers
Returns true if field num_workers is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:479
↓ 5 callersMethodis_set_num_workers
Returns true if field num_workers is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:354
↓ 5 callersMethodis_set_num_workers
Returns true if field num_workers is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/StormBase.java:352
↓ 5 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/LSWorkerHeartbeat.java:287
↓ 5 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/WorkerMetrics.java:219
↓ 5 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/NimbusSummary.java:246
↓ 5 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/ExecutorSummary.java:293
↓ 5 callersMethodis_set_rate
Returns true if field rate is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ExecutorStats.java:321
↓ 5 callersMethodis_set_task_end
Returns true if field task_end is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ExecutorInfo.java:192
↓ 5 callersMethodis_set_task_start
Returns true if field task_start is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ExecutorInfo.java:170
↓ 5 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/ClusterWorkerHeartbeat.java:269
↓ 5 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/LSWorkerHeartbeat.java:201
↓ 5 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/SupervisorWorkerHeartbeat.java:251
↓ 5 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/SupervisorInfo.java:268
↓ 5 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/LSTopoHistory.java:223
↓ 5 callersMethodis_set_timestamp
Returns true if field timestamp is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/WorkerMetricPoint.java:246
↓ 5 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/TopologySummary.java:501
↓ 5 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/ClusterWorkerHeartbeat.java:291
↓ 5 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/TopologyInfo.java:428
↓ 5 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/NimbusSummary.java:268
↓ 5 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/SupervisorSummary.java:332
↓ 5 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/ExecutorSummary.java:315
↓ 5 callersMethodis_set_version
Returns true if field version is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/ReadableBlobMeta.java:193
↓ 5 callersMethodis_set_version
Returns true if field version is set (has been assigned a value) and false otherwise
storm-client/src/jvm/org/apache/storm/generated/BeginDownloadResult.java:181
↓ 5 callersMethodkeepOrUpdateAssignment
Keep a storm assignment to local state or update old assignment. @param stormId storm runtime id @param assignment assignment as thrift
storm-client/src/jvm/org/apache/storm/assignments/ILocalAssignmentsBackend.java:46
↓ 5 callersMethodkeepStormId
Keep a mapping storm-name -> storm-id to local state. @param stormName storm name @param stormId storm runtime id
storm-client/src/jvm/org/apache/storm/assignments/ILocalAssignmentsBackend.java:85
↓ 5 callersMethodkeyClass
Key class used by implementation (e.g. IntWritable.class, etc.).
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/SequenceFormat.java:31
↓ 5 callersMethodkeyStr
(String key)
storm-core/src/jvm/org/apache/storm/command/AdminCommands.java:165
↓ 5 callersMethodlistBlobStoreKeys
(BlobStore bs, Subject who)
external/storm-blobstore-migration/src/main/java/org/apache/storm/blobstore/MigratorMain.java:27
↓ 5 callersMethodlistBlobs
(java.lang.String session)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:90
↓ 5 callersMethodlistKeys
()
storm-server/src/main/java/org/apache/storm/blobstore/LocalFsBlobStore.java:400
↓ 5 callersMethodlogAccess
(Integer requestId, InetAddress remoteAddress, Principal principal, String op
storm-server/src/main/java/org/apache/storm/logging/ThriftAccessLogger.java:37
↓ 5 callersMethodmakeAvroBolt
(String nameNodeAddr, int countSync, float rotationSizeMB, String schemaAsString)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/AvroGenericRecordBoltTest.java:211
↓ 5 callersMethodmakeCluster
(Topologies topologies)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestConstraintSolverStrategy.java:198
↓ 5 callersMethodmakeContext
(Device device, Object data)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/BlkioCore.java:170
↓ 5 callersMethodmasterLocalDir
(Map<String, Object> conf)
storm-server/src/main/java/org/apache/storm/utils/ServerConfigUtils.java:57
↓ 5 callersMethodmkAssignment
(int startTimeSecs, int... executors)
storm-server/src/test/java/org/apache/storm/daemon/nimbus/HeartbeatCacheTest.java:181
↓ 5 callersMethodmkClient
(Map<String, Object> conf, List<String> servers, Object port, Stri
storm-client/src/jvm/org/apache/storm/zookeeper/ClientZookeeper.java:73
↓ 5 callersMethodmkNimbus
(Map<String, Object> conf, INimbus inimbus, BlobStore blobStore, ILeaderElector leaderElector,
storm-server/src/test/java/org/apache/storm/daemon/nimbus/NimbusClojurePortTest.java:1203
↓ 5 callersMethodmkPrincipal
(final String name)
storm-server/src/test/java/org/apache/storm/security/auth/AuthTest.java:69
↓ 5 callersMethodmockTickTuple
()
storm-client/test/jvm/org/apache/storm/utils/MockTupleHelpers.java:24
↓ 5 callersMethodneedsScheduling
(TopologyDetails topology)
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:359
↓ 5 callersMethodnewStaticState
(StateFactory factory)
storm-client/src/jvm/org/apache/storm/trident/TridentTopology.java:588
↓ 5 callersMethodnimbusPath
(String id)
storm-client/src/jvm/org/apache/storm/cluster/ClusterUtils.java:147
↓ 5 callersMethodnimbuses
()
storm-client/src/jvm/org/apache/storm/cluster/IStormClusterState.java:96
↓ 5 callersMethodnoneGrouping
()
storm-client/src/jvm/org/apache/storm/drpc/LinearDRPCInputDeclarer.java:37
↓ 5 callersMethodnormalizeNimbusHostPortSequenceNumberInfo
(String nimbusSeqNumberInfo)
storm-server/src/main/java/org/apache/storm/blobstore/BlobStoreUtils.java:71
↓ 5 callersMethodnumFails
()
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutMessageId.java:71
↓ 5 callersMethodopen
(Map<String, Object> conf, TopologyContext context)
storm-client/src/jvm/org/apache/storm/trident/spout/IBatchSpout.java:21
↓ 5 callersMethodpermit
(ReqContext context, String operation, Map<String, Object> topoConf)
storm-client/src/jvm/org/apache/storm/security/auth/authorizer/ImpersonationAuthorizer.java:61
↓ 5 callersMethodpfadd
(String key, String... elements)
external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisCommandsContainer.java:39
↓ 5 callersMethodpopulateSubject
Called to initially populate the subject on the worker side with credentials passed in. @param subject the subject to optionally put credentials
storm-client/src/jvm/org/apache/storm/security/auth/IAutoCredentials.java:38
↓ 5 callersMethodprepare
(Map<String, Object> topoConf, TopologyContext context)
storm-client/src/jvm/org/apache/storm/topology/IBasicBolt.java:20
↓ 5 callersMethodprepare
Prepare the Strategy for scheduling. @param config the cluster configuration
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/IStrategy.java:37
↓ 5 callersMethodprepare
(Map<String, Object> conf, String overrideBase, NimbusInfo nimbusInfo, ILeaderElector leaderElector)
storm-server/src/main/java/org/apache/storm/blobstore/LocalFsBlobStore.java:95
↓ 5 callersMethodprepare
(Map<String, Object> topoConf, TopologyContext context)
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/bolt/PreparableCallback.java:31
↓ 5 callersMethodprepare
(Map<String, Object> conf, TopologyContext topologyContext)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/SimpleFileNameFormat.java:51
↓ 5 callersMethodprepareDirectGrouping
()
storm-client/src/jvm/org/apache/storm/Thrift.java:99
↓ 5 callersMethodprettyPrint
Print value in a human readable format. @param value what to print. @return a human readable string
storm-core/src/jvm/org/apache/storm/command/AdminCommands.java:124
↓ 5 callersMethodprocessLauncher
(Map<String, Object> conf, String user, List<String> commandPrefix, List<String> args,
storm-client/src/jvm/org/apache/storm/daemon/supervisor/ClientSupervisorUtils.java:88
↓ 5 callersMethodprocessLogConfigChange
(LogConfig logConfig)
storm-client/src/jvm/org/apache/storm/daemon/worker/LogConfigManager.java:55
↓ 5 callersMethodput_to_bolts
(java.lang.String key, Bolt val)
storm-client/src/jvm/org/apache/storm/generated/StormTopology.java:359
↓ 5 callersMethodput_to_inputs
(GlobalStreamId key, Grouping val)
storm-client/src/jvm/org/apache/storm/generated/ComponentCommon.java:209
↓ 5 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/ProfileRequest.java:422
↓ 5 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/ExecutorStats.java:537
↓ 5 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/TopologyPageInfo.java:2672
↓ 5 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:1320
↓ 5 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/TopologySummary.java:1631
↓ 5 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/ErrorInfo.java:478
↓ 5 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/JavaObject.java:359
↓ 5 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/NodeInfo.java:356
↓ 5 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/DebugOptions.java:328
↓ 5 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/HBPulse.java:350
↓ 5 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/LocalAssignment.java:573
↓ 5 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:1140
↓ 5 callersMethodread
(self, iprot)
storm-client/src/py/storm/DistributedRPC.py:170
↓ 5 callersMethodread
(self, iprot)
storm-client/src/py/storm/ttypes.py:4567
↓ 5 callersMethodread
Get an input stream for reading a part. @param key the key of the part to read. @return the where to read the data from. @throws IOException on any er
storm-server/src/main/java/org/apache/storm/blobstore/FileBlobStoreImpl.java:92
↓ 5 callersMethodreadAssertEqualsWithAuth
(BlobStore store, Subject who, String key, int value)
external/storm-hdfs-blobstore/src/test/java/org/apache/storm/hdfs/blobstore/BlobStoreTest.java:142
↓ 5 callersFunctionreadMsg
reads lines and reconstructs newlines appropriately
storm-multilang/python/src/main/resources/resources/storm.py:34
↓ 5 callersMethodreadSupervisorTopologyImpl
(Map<String, Object> conf, String stormId, AdvancedFSOps ops)
storm-client/src/jvm/org/apache/storm/utils/ConfigUtils.java:439
↓ 5 callersMethodregisterCounter
(MetricNames metricNames, Counter counter, int taskId, String componentId,
storm-client/src/jvm/org/apache/storm/metrics2/StormMetricRegistry.java:236
↓ 5 callersMethodremoveNonGenericResources
(Map<String, Double> map)
storm-server/src/main/java/org/apache/storm/scheduler/resource/normalization/NormalizedResourceRequest.java:183
↓ 5 callersMethodremovePortFromSupervisors
(Map<String, SupervisorDetails> supervisorDetailsMap, String supervisor, int port)
storm-server/src/test/java/org/apache/storm/scheduler/blacklist/TestUtilsForBlacklistScheduler.java:71
↓ 5 callersMethodroundtrip
(List<Object> vals)
storm-core/test/jvm/org/apache/storm/serialization/SerializationTest.java:91
↓ 5 callersMethodrunDockerCommandWaitFor
Run docker command using {@link Config#SUPERVISOR_WORKER_LAUNCHER}. @param conf the storm conf @param dockerCommand the docker command
storm-server/src/main/java/org/apache/storm/container/docker/DockerManager.java:383
↓ 5 callersMethodsanitizeStreamName
Sanitizes streamName for use as an identifier in the visualization. Replaces all characters except A-Z, a-z, '.', '-', and '_' with '_'. If streamNa
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIHelpers.java:1771
↓ 5 callersMethodschedule
Schedules this {@link KafkaSpoutMessageId} if not yet scheduled, or updates retry time if it has already been scheduled. It may also indicate that the
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryService.java:37
↓ 5 callersMethodscheduleAsNeeded
(NodePool... lesserPools)
storm-server/src/main/java/org/apache/storm/scheduler/multitenant/IsolatedPool.java:81
↓ 5 callersMethodscheduleMs
Same as schedule with millisecond resolution. @param delayMs the number of milliseconds to delay before running the function @param func t
storm-client/src/jvm/org/apache/storm/StormTimer.java:80
↓ 5 callersMethodsendSyncCommand
(String command, Object msgId)
storm-client/src/jvm/org/apache/storm/spout/ShellSpout.java:140
↓ 5 callersMethodsentence
(String input)
examples/storm-starter/src/jvm/org/apache/storm/starter/AnchoredWordCount.java:81
↓ 5 callersMethodsentence
(String input)
examples/storm-starter/src/jvm/org/apache/storm/starter/spout/RandomSentenceSpout.java:56
↓ 5 callersMethodserialized_java
(java.nio.ByteBuffer value)
storm-client/src/jvm/org/apache/storm/generated/ComponentObject.java:131
↓ 5 callersMethodset
(T o)
storm-client/src/jvm/org/apache/storm/trident/state/snapshot/Snapshottable.java:22
↓ 5 callersMethodsetAssignment
(String stormId, Assignment info, Map<String, Object> topoConf)
storm-client/src/jvm/org/apache/storm/cluster/IStormClusterState.java:214
↓ 5 callersMethodsetCommonSpoutConfig
(KafkaSpoutConfig.Builder<String, String> config)
external/storm-kafka-client/src/test/java/org/apache/storm/kafka/spout/config/builder/SingleTopicKafkaSpoutConfiguration.java:46
↓ 5 callersMethodsetContext
(EvictionContext context)
storm-client/src/jvm/org/apache/storm/windowing/TimeEvictionPolicy.java:62
↓ 5 callersMethodsetData
(String path, Object obj)
storm-client/src/jvm/org/apache/storm/trident/topology/state/TransactionalState.java:114
← previousnext →2,401–2,500 of 27,770, ranked by callers