MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

↓ 2 callersMethodwrite
(org.apache.storm.thrift.protocol.TProtocol oprot)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:59935
↓ 2 callersMethodwrite
(org.apache.storm.thrift.protocol.TProtocol oprot)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:60579
↓ 2 callersMethodwrite
(org.apache.storm.thrift.protocol.TProtocol oprot)
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:917
↓ 2 callersMethodwrite
(org.apache.storm.thrift.protocol.TProtocol oprot)
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:1675
↓ 2 callersMethodwrite
(org.apache.storm.thrift.protocol.TProtocol oprot)
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:2643
↓ 2 callersMethodwrite
(org.apache.storm.thrift.protocol.TProtocol oprot)
storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java:623
↓ 2 callersMethodwrite
(org.apache.storm.thrift.protocol.TProtocol oprot)
storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java:1152
↓ 2 callersMethodwrite
(org.apache.storm.thrift.protocol.TProtocol oprot)
storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java:1936
↓ 2 callersMethodwrite
(org.apache.storm.thrift.protocol.TProtocol oprot)
storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java:2798
↓ 2 callersMethodwrite
(org.apache.storm.thrift.protocol.TProtocol oprot)
storm-client/src/jvm/org/apache/storm/generated/DistributedRPCInvocations.java:3624
↓ 2 callersMethodwrite
(self, oprot)
storm-client/src/py/storm/ttypes.py:6206
↓ 2 callersMethodwriteCompressedResource
(String newResourceName, byte[] compressedBytes)
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestTopologyAnonymizerUtils.java:301
↓ 2 callersMethodwriteMessage
(Channel channel, MessageBatch batch)
storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java:352
↓ 2 callersMethodwriteMetadata
(String key, SettableBlobMeta meta)
external/storm-hdfs-blobstore/src/main/java/org/apache/storm/hdfs/blobstore/HdfsBlobStore.java:380
↓ 2 callersMethodwriteMetadataToDisk
(String key, StringMetadata val)
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/StringMetadataCache.java:152
↓ 2 callersMethodwriteSpoutMsg
This method sends a spout message to a non-JVM spout process. @param msg spout message
storm-client/src/jvm/org/apache/storm/multilang/ISerializer.java:66
↓ 2 callersMethodwriteToFile
(File file, Set<String> content)
examples/storm-starter/src/jvm/org/apache/storm/starter/BlobStoreAPIWordCountTopology.java:162
↓ 2 callersMethodzipFileSize
Given a zip File input it will return its size Only works for zip files whose uncompressed size is less than 4 GB, otherwise returns the size module 2
storm-server/src/main/java/org/apache/storm/utils/ServerUtils.java:662
↓ 1 callersMethod__init__
(self, jira_repo=None, github_repo=None)
dev-tools/report/report_builder.py:18
↓ 1 callersMethod_assert
(o1, o2, o3)
dev-tools/report/formatter.py:29
↓ 1 callersMethod_build_format_tuples
(self, fields_tuple, row_tuple, min_width_tuple)
dev-tools/report/formatter.py:47
↓ 1 callersMethod_find_sizes
(fields_tuple, row_tuple, min_width_tuple)
dev-tools/report/formatter.py:37
↓ 1 callersMethod_idx_1st_comment_with_vote
(self)
dev-tools/report/report.py:145
↓ 1 callersMethod_jira_issue
(self, jira_id)
dev-tools/report/report.py:163
↓ 1 callersMethod_min_width_tuple
(self)
dev-tools/report/report.py:69
↓ 1 callersMethod_min_width_tuple
(self)
dev-tools/report/report.py:108
↓ 1 callersMethod_print_github_reports
(self)
dev-tools/report/report.py:248
↓ 1 callersMethod_print_jira_github_combined_reports
(self)
dev-tools/report/report.py:252
↓ 1 callersMethod_print_jira_reports
(self)
dev-tools/report/report.py:244
↓ 1 callersMethodabsoluteHealthCheckDir
(Map<String, Object> conf)
storm-server/src/main/java/org/apache/storm/utils/ServerConfigUtils.java:124
↓ 1 callersMethodabsoluteStormBlobStoreDir
(Map<String, Object> conf)
storm-client/src/jvm/org/apache/storm/utils/ConfigUtils.java:254
↓ 1 callersMethodaccept
(T t, U u)
storm-server/src/test/java/org/apache/storm/security/auth/AuthTest.java:641
↓ 1 callersMethodacceptTupleAction
(int taskId, TupleImpl tuple)
storm-client/src/jvm/org/apache/storm/executor/Executor.java:295
↓ 1 callersMethodaccessToString
(int access)
storm-client/src/jvm/org/apache/storm/blobstore/BlobStoreAclHandler.java:134
↓ 1 callersFunctionack
(tup)
storm-multilang/python/src/main/resources/resources/storm.py:145
↓ 1 callersMethodack
(long batchId)
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchExecutor.java:184
↓ 1 callersMethodack
(List<Tuple> tuples)
storm-client/src/jvm/org/apache/storm/topology/StatefulBoltExecutor.java:148
↓ 1 callersMethodack
(RefCountedTuple tuple)
storm-client/src/jvm/org/apache/storm/streams/ProcessorBoltDelegate.java:235
↓ 1 callersMethodack
(self, id)
storm-multilang/python/src/main/resources/resources/storm.py:271
↓ 1 callersMethodackRetriableOffsetsIfCompactedAway
(Map<TopicPartition, Long> earliestRetriableOffsets, Consu
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpout.java:390
↓ 1 callersMethodackerInputs
(StormTopology topology)
storm-client/src/jvm/org/apache/storm/daemon/StormCommon.java:230
↓ 1 callersMethodacquireNewPort
()
storm-client/src/jvm/org/apache/storm/utils/InprocMessaging.java:30
↓ 1 callersMethodactivate
(self)
storm-multilang/python/src/main/resources/resources/storm.py:265
↓ 1 callersMethodactivateSpouts
()
storm-client/src/jvm/org/apache/storm/executor/spout/SpoutExecutor.java:262
↓ 1 callersMethodactivateWorkerWhenAllConnectionsReady
we will wait all connections to be ready and then activate the spout/bolt when the worker bootup.
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java:539
↓ 1 callersMethodactiveKeys
()
storm-client/src/jvm/org/apache/storm/cluster/IStormClusterState.java:218
↓ 1 callersMethodactiveStorms
()
storm-client/src/jvm/org/apache/storm/cluster/StormClusterStateImpl.java:309
↓ 1 callersMethodadd
(TaskMessage msg)
storm-client/src/jvm/org/apache/storm/messaging/netty/MessageBatch.java:31
↓ 1 callersMethodadd
(WorkerResources wr)
storm-server/src/main/java/org/apache/storm/scheduler/SupervisorResources.java:87
↓ 1 callersMethodadd
(ObjectResourcesItem other)
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/ObjectResourcesItem.java:75
↓ 1 callersMethodadd
Add the values in other to this and return a combined resources object. @param other the other resources to add to this @return the combined resources
storm-server/src/main/java/org/apache/storm/daemon/nimbus/TopologyResources.java:283
↓ 1 callersMethodadd
Add other to this. @param other meaurements to add in.
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java:169
↓ 1 callersMethodadd
(InputStream inputStream)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadBolt.java:55
↓ 1 callersMethodaddAcker
(Map<String, Object> conf, StormTopology topology)
storm-client/src/jvm/org/apache/storm/daemon/StormCommon.java:255
↓ 1 callersMethodaddAllBolts
Adds a list of bolt definitions. Optionally overriding existing definitions if one with the same ID already exists. @param bolts bolt definitions @par
flux/flux-core/src/main/java/org/apache/storm/flux/model/TopologyDef.java:215
↓ 1 callersMethodaddAllComponents
Adds a list of component definitions. Optionally overriding existing definitions if one with the same ID already exists. @param components component d
flux/flux-core/src/main/java/org/apache/storm/flux/model/TopologyDef.java:249
↓ 1 callersMethodaddAllReadOnlyMountLocations
Add all readonly locations. @param paths the locations @return the self
storm-server/src/main/java/org/apache/storm/container/docker/DockerRunCommand.java:165
↓ 1 callersMethodaddAllReadWriteMountLocations
Add all the rw bind mount locations. @param paths the locations @return the self
storm-server/src/main/java/org/apache/storm/container/docker/DockerRunCommand.java:112
↓ 1 callersMethodaddAllSpouts
Adds a list of spout definitions. Optionally overriding existing definitions if one with the same ID already exists. @param spouts spout definitions @
flux/flux-core/src/main/java/org/apache/storm/flux/model/TopologyDef.java:232
↓ 1 callersMethodaddAllStreams
Adds a list of stream definitions. Optionally overriding existing definitions if one with the same ID already exists. @param streams stream definition
flux/flux-core/src/main/java/org/apache/storm/flux/model/TopologyDef.java:266
↓ 1 callersMethodaddAnchor
(String anchor)
storm-client/src/jvm/org/apache/storm/multilang/ShellMsg.java:64
↓ 1 callersMethodaddAssignmentsForNode
Add an assignments for a node/supervisor for distribution. @param node node id of supervisor. @param host host name for the node. @param serverPort no
storm-server/src/main/java/org/apache/storm/nimbus/AssignmentDistributionService.java:156
↓ 1 callersFunctionaddAvailableStream
(streamId, streamIdSanitized)
storm-webapp/src/main/webapp/js/visualization.js:348
↓ 1 callersMethodaddBatch
(Tuple tuple)
storm-client/src/jvm/org/apache/storm/utils/BatchHelper.java:66
↓ 1 callersMethodaddBolt
(TopologyBuilder topologyBuilder, String boltId,
storm-client/src/jvm/org/apache/storm/streams/StreamBuilder.java:464
↓ 1 callersMethodaddBolt
(String id, Object bolt)
flux/flux-core/src/main/java/org/apache/storm/flux/model/ExecutionContext.java:62
↓ 1 callersMethodaddBoltAggStats
If aggStats are not populated, compute common and component(bolt) agg and create placeholder stat. This allow the topology page to show component spec
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4554
↓ 1 callersMethodaddCheckPointInputs
For bolts that has incoming streams from spouts (the root bolts), add checkpoint stream from checkpoint spout to its input. For other bolts, add check
storm-client/src/jvm/org/apache/storm/topology/TopologyBuilder.java:530
↓ 1 callersMethodaddComponent
(String id, Object value)
flux/flux-core/src/main/java/org/apache/storm/flux/model/ExecutionContext.java:70
↓ 1 callersMethodaddCounter
(String name, Counter counter)
storm-client/src/jvm/org/apache/storm/metrics2/TaskMetricRepo.java:37
↓ 1 callersMethodaddCpuSetBindings
(List<String> cores, String memoryNode)
storm-server/src/main/java/org/apache/storm/container/docker/DockerRunCommand.java:183
↓ 1 callersMethodaddDefaultResforExec
Add default resource requirements for a executor.
storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:544
↓ 1 callersMethodaddEventLogger
(Map<String, Object> conf, StormTopology topology)
storm-client/src/jvm/org/apache/storm/daemon/StormCommon.java:344
↓ 1 callersMethodaddExecCommand
Add the command to run from inside container. @param commandInContainer the command to run from inside container @return the self
storm-server/src/main/java/org/apache/storm/container/docker/DockerExecCommand.java:37
↓ 1 callersMethodaddGauge
(String name, Gauge gauge)
storm-client/src/jvm/org/apache/storm/metrics2/TaskMetricRepo.java:41
↓ 1 callersMethodaddHistogram
(String name, Histogram histogram)
storm-client/src/jvm/org/apache/storm/metrics2/TaskMetricRepo.java:49
↓ 1 callersMethodaddInputs
(BoltDeclarer declarer, Map<GlobalStreamId, Grouping> inputs)
storm-client/src/jvm/org/apache/storm/Thrift.java:259
↓ 1 callersMethodaddKeyType
(KeyType type)
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/StringMetadata.java:50
↓ 1 callersMethodaddLagResultForKafkaSpout
(Map<String, Map<String, Object>> finalResult, String spoutId, SpoutSpec spoutSpec)
storm-core/src/jvm/org/apache/storm/utils/TopologySpoutLag.java:114
↓ 1 callersMethodaddLocalSupervisor
(Supervisor supervisor)
storm-server/src/main/java/org/apache/storm/nimbus/AssignmentDistributionService.java:178
↓ 1 callersMethodaddMem
(Double value)
storm-server/src/main/java/org/apache/storm/scheduler/SupervisorResources.java:100
↓ 1 callersMethodaddMeter
(String name, Meter meter)
storm-client/src/jvm/org/apache/storm/metrics2/TaskMetricRepo.java:45
↓ 1 callersMethodaddMetricComponents
(Map<String, Object> conf, StormTopology topology)
storm-client/src/jvm/org/apache/storm/daemon/StormCommon.java:419
↓ 1 callersMethodaddMetricStreams
(StormTopology topology)
storm-client/src/jvm/org/apache/storm/daemon/StormCommon.java:310
↓ 1 callersMethodaddNodes
(List<ProcessorNode> nodes)
storm-client/src/jvm/org/apache/storm/streams/StatefulProcessorBolt.java:87
↓ 1 callersMethodaddOnHeap
(final double onHeap)
storm-server/src/main/java/org/apache/storm/scheduler/resource/normalization/NormalizedResourceRequest.java:223
↓ 1 callersMethodaddOrReplace
(Rankable r)
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/Rankings.java:94
↓ 1 callersMethodaddOrphanedSlot
(WorkerSlot ws)
storm-server/src/main/java/org/apache/storm/scheduler/multitenant/Node.java:189
↓ 1 callersMethodaddOutputStream
(String streamId)
storm-client/src/jvm/org/apache/storm/streams/Node.java:139
↓ 1 callersMethodaddPortToSupervisors
(Map<String, SupervisorDetails> supervisorDetailsMap, String supervisor, int port)
storm-server/src/test/java/org/apache/storm/scheduler/blacklist/TestUtilsForBlacklistScheduler.java:87
↓ 1 callersMethodaddPredicate
(Predicate<? super T> predicate, String stream)
storm-client/src/jvm/org/apache/storm/streams/processors/BranchProcessor.java:22
↓ 1 callersMethodaddProfilerActions
(Set<TopoProfileAction> actions)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:974
↓ 1 callersMethodaddReceiveCount
(String from, int amount)
storm-client/src/jvm/org/apache/storm/messaging/netty/Server.java:125
↓ 1 callersMethodaddReceiver
(TridentProcessor p)
storm-client/src/jvm/org/apache/storm/trident/planner/SubtopologyBolt.java:231
↓ 1 callersMethodaddReferences
(List<LocalResource> localresource, PortAndAssignment pna, BlobChangingCallback cb)
storm-server/src/test/java/org/apache/storm/localizer/AsyncLocalizerTest.java:995
↓ 1 callersMethodaddRequestContextFilter
Add a request context filter to the Servlet Context Handler. @param context The Servlet Context handler @param configName Config name @param conf Conf
storm-webapp/src/main/java/org/apache/storm/daemon/drpc/DRPCServer.java:66
↓ 1 callersMethodaddRequestContextFilter
addRequestContextFilter. @param context context @param configName configName @param conf conf
storm-webapp/src/main/java/org/apache/storm/daemon/ui/UIServer.java:75
↓ 1 callersMethodaddResourcesForExec
add resource requirements for a executor.
storm-server/src/main/java/org/apache/storm/scheduler/TopologyDetails.java:533
↓ 1 callersMethodaddSelfTo
(Map<String, Map<String, Number>> fullPool)
storm-server/src/test/java/org/apache/storm/scheduler/resource/TestUtilsForResourceAwareScheduler.java:83
↓ 1 callersMethodaddShutdownHooks
(MyThread... threads)
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/JCQueuePerfTest.java:128
← previousnext →6,501–6,600 of 27,770, ranked by callers