MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
↓ 3 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/LSTopoHistory.java:519
↓ 3 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/Assignment.java:812
↓ 3 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/ShellComponent.java:338
↓ 3 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/SupervisorWorkerHeartbeat.java:431
↓ 3 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/HBRecords.java:286
↓ 3 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/StormBase.java:1040
↓ 3 callersMethodread
(org.apache.storm.thrift.protocol.TProtocol iprot)
storm-client/src/jvm/org/apache/storm/generated/SharedMemory.java:475
↓ 3 callersMethodread
()
storm-server/src/test/java/org/apache/storm/localizer/AsyncLocalizerTest.java:1066
↓ 3 callersMethodread
(Kryo kryo, Input input, Class<? extends GenericContainer> someClass)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/avro/AbstractAvroSerializer.java:59
↓ 3 callersMethodreadApproximateLatAvg
(long lat, long count, long timeSpent, long[] bucketTime, long[] latBuckets,
storm-client/src/jvm/org/apache/storm/metric/internal/LatencyStat.java:228
↓ 3 callersMethodreadApproximateTime
(long value, long timeSpent, long[] bucketTime, long[] buckets, long desiredTime)
storm-client/src/jvm/org/apache/storm/metric/internal/CountStat.java:153
↓ 3 callersMethodreadBlob
Wrapper around readBlobTo which returns a ByteArray output stream. @param key Key for the blob @param who Is the subject having the read privilege fo
storm-client/src/jvm/org/apache/storm/blobstore/BlobStore.java:304
↓ 3 callersMethodreadBlob
(final String key, final OutputStream os)
storm-core/src/jvm/org/apache/storm/command/Blobstore.java:275
↓ 3 callersMethodreadFile
(File file)
examples/storm-starter/src/jvm/org/apache/storm/starter/BlobStoreAPIWordCountTopology.java:130
↓ 3 callersMethodreadShellMsg
This method receives a shell message from the non-JVM process. @return shell message
storm-client/src/jvm/org/apache/storm/multilang/ISerializer.java:52
↓ 3 callersMethodreadSupervisorStormConfImpl
(Map<String, Object> conf, String stormId)
storm-client/src/jvm/org/apache/storm/utils/ConfigUtils.java:476
↓ 3 callersMethodreadSupervisorTopology
(Map<String, Object> conf, String stormId, AdvancedFSOps ops)
storm-client/src/jvm/org/apache/storm/utils/ConfigUtils.java:201
↓ 3 callersMethodreadWorkerHeartbeatsImpl
(Map<String, Object> conf)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/SupervisorUtils.java:190
↓ 3 callersFunctionread_lines
(path)
dev-tools/validate-license-files.py:131
↓ 3 callersMethodreconnectAsync
(final DRPCInvocationsClient client)
storm-client/src/jvm/org/apache/storm/drpc/DRPCSpout.java:82
↓ 3 callersMethodrecords
(HBRecords value)
storm-client/src/jvm/org/apache/storm/generated/HBMessageData.java:167
↓ 3 callersMethodrecv
A batch of new messages have arrived to be processed. @param batch the messages to be processed
storm-client/src/jvm/org/apache/storm/messaging/IConnectionCallback.java:26
↓ 3 callersMethodrefreshBpTaskList
()
storm-client/src/jvm/org/apache/storm/daemon/worker/BackPressureTracker.java:73
↓ 3 callersMethodregisterNode
(Node n)
storm-client/src/jvm/org/apache/storm/trident/TridentTopology.java:972
↓ 3 callersMethodregisterSerialization
(Map<String, Object> conf, Class klass)
storm-client/src/jvm/org/apache/storm/Config.java:2158
↓ 3 callersMethodregisterService
(Object service)
storm-client/src/jvm/org/apache/storm/utils/ServiceRegistry.java:23
↓ 3 callersMethodremap
Remap the names of components. @param remappedComponents old name to new name of components. @param remappedStreams old ID to new ID of streams. @retu
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/InputStream.java:246
↓ 3 callersMethodrepartition
Returns a new stream with the given value of parallelism. Further operations on this stream would execute at this level of parallelism. @param parall
storm-client/src/jvm/org/apache/storm/streams/Stream.java:255
↓ 3 callersMethodrequestDownloadBaseTopologyBlobs
(PortAndAssignment pna, BlobChangingCallback cb)
storm-server/src/main/java/org/apache/storm/localizer/AsyncLocalizer.java:252
↓ 3 callersMethodresetInstance
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/SupervisorUtils.java:56
↓ 3 callersMethodresolveReferences
(List<Object> args, ExecutionContext context)
flux/flux-core/src/main/java/org/apache/storm/flux/FluxBuilder.java:329
↓ 3 callersMethodretry
(long currentTimeNanos)
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/KafkaSpoutRetryExponentialBackoff.java:87
↓ 3 callersMethodreturnResult
(String id, String result)
storm-server/src/main/java/org/apache/storm/daemon/drpc/DRPC.java:180
↓ 3 callersMethodrmDependencyJarsInTopology
(String topoId)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:2852
↓ 3 callersMethodrotate
(long lat, long count, long timeSpent, long targetSize, long[] times, lon
storm-client/src/jvm/org/apache/storm/metric/internal/LatencyStat.java:175
↓ 3 callersMethodrotate
(long value, long timeSpent, long targetSize, long[] times, long[] buckets)
storm-client/src/jvm/org/apache/storm/metric/internal/CountStat.java:114
↓ 3 callersMethodrotateOutputFile
(boolean doRotateAction)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/HdfsState.java:219
↓ 3 callersMethodrpush
(String key, String... string)
external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisCommandsContainer.java:43
↓ 3 callersMethodrun
(Runnable producer, Runnable consumer, JCQueue queue)
storm-client/test/jvm/org/apache/storm/utils/JCQueueTest.java:123
↓ 3 callersMethodrunTest
(PrometheusPreparableReporter sut, Map<String, Object> daemonConf)
external/storm-metrics-prometheus/src/test/java/org/apache/storm/metrics/prometheus/PrometheusPreparableReporterTest.java:116
↓ 3 callersMethodrunWorkerShutdownHooks
()
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java:663
↓ 3 callersMethodrunWorkerStartHooks
()
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerState.java:656
↓ 3 callersMethodsaveNewAssignment
(LocalAssignment assignment)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:1000
↓ 3 callersMethodsaveTxState
(CheckPointState txState)
storm-client/src/jvm/org/apache/storm/spout/CheckpointSpout.java:209
↓ 3 callersMethodscaleThroughput
Scale the throughput of this component. @param v 1.0 is unchanged 0.5 will cut the throughput in half. @return a copy of this with the adjustments mad
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadCompConf.java:135
↓ 3 callersMethodscanRange
(RocksDbKey start, RocksDbKey end, RocksDbScanCallback fn)
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/RocksDbStore.java:314
↓ 3 callersMethodscard
(String key)
external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisCommandsContainer.java:47
↓ 3 callersMethodscheduleConnect
Enqueue a task message to be sent to server.
storm-client/src/jvm/org/apache/storm/messaging/netty/Client.java:262
↓ 3 callersMethodscheduleRecurringMs
Schedule a function to run recurrently. @param delayMs the number of millis to delay before running the function @param recurMs the time between each
storm-client/src/jvm/org/apache/storm/StormTimer.java:124
↓ 3 callersMethodscheme
(org.apache.storm.thrift.protocol.TProtocol proto)
storm-client/src/jvm/org/apache/storm/generated/Bolt.java:500
↓ 3 callersMethodsearchLogFileNotFound
(String callback)
storm-webapp/src/main/java/org/apache/storm/daemon/logviewer/handler/LogviewerLogSearchHandler.java:202
↓ 3 callersMethodsecondsSinceOldestModification
()
examples/storm-starter/src/jvm/org/apache/storm/starter/tools/NthLastModifiedTimeTracker.java:53
↓ 3 callersMethodsecsToMillis
(int secs)
storm-client/src/jvm/org/apache/storm/utils/Time.java:145
↓ 3 callersMethodseekToAvailableEntry
(PeekingIterator<Map.Entry<KENCODEDT, VENCODEDT>> iterator)
storm-client/src/jvm/org/apache/storm/state/BaseStateIterator.java:154
↓ 3 callersMethodselect
Select values out of tuple given a Fields selector Note that this function can throw a NullPointerException if the fields in selector are not found in
storm-client/src/jvm/org/apache/storm/tuple/Fields.java:55
↓ 3 callersMethodsendAll
(HBMessage m)
storm-client/src/jvm/org/apache/storm/pacemaker/PacemakerClientPool.java:59
↓ 3 callersMethodsendBackPressureStatus
Sends the back pressure metrics to all downstream connections.
storm-client/src/jvm/org/apache/storm/messaging/IConnection.java:34
↓ 3 callersMethodserialize
(T obj)
storm-client/src/jvm/org/apache/storm/state/DefaultStateSerializer.java:90
↓ 3 callersMethodserializeInto
(List<Object> values, Output out)
storm-client/src/jvm/org/apache/storm/serialization/KryoValuesSerializer.java:32
↓ 3 callersMethodserve
()
storm-client/src/jvm/org/apache/storm/security/auth/ThriftServer.java:67
↓ 3 callersMethodsetActive
(boolean flag)
storm-client/src/jvm/org/apache/storm/StormTimer.java:267
↓ 3 callersMethodsetActive
(final boolean active)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:5508
↓ 3 callersMethodsetArchiveDir
(String archiveDir)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java:156
↓ 3 callersMethodsetAssignments
Set assignments for cluster.
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:896
↓ 3 callersMethodsetBadFilesDir
(String badFilesDir)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java:161
↓ 3 callersMethodsetConstraintConfig
Set Config.TOPOLOGY_RAS_CONSTRAINTS (when consolidatedConfigFlag is true) or both Config.TOPOLOGY_RAS_CONSTRAINTS/Config.TOPOLOGY_SPREAD_COMPONENTS (w
storm-server/src/test/java/org/apache/storm/scheduler/resource/strategies/scheduling/TestConstraintSolverStrategy.java:157
↓ 3 callersMethodsetCurrBatch
(TrackedBatch batch)
storm-client/src/jvm/org/apache/storm/trident/topology/TridentBoltExecutor.java:392
↓ 3 callersMethodsetExecSorter
Set the pluggable sorter for ExecutorDetails. @param execSorter to use for sorting executorDetails when scheduling.
storm-server/src/main/java/org/apache/storm/scheduler/resource/strategies/scheduling/BaseResourceAwareStrategy.java:224
↓ 3 callersMethodsetExecutorId
(String id)
storm-server/src/main/java/org/apache/storm/metricstore/FilterOptions.java:85
↓ 3 callersMethodsetHdfsUri
(String hdfsUri)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java:141
↓ 3 callersMethodsetHeartbeat
()
storm-client/src/jvm/org/apache/storm/spout/ShellSpout.java:252
↓ 3 callersMethodsetId
(String id)
storm-client/src/jvm/org/apache/storm/multilang/BoltMsg.java:36
↓ 3 callersMethodsetInstance
(SupervisorUtils u)
storm-server/src/main/java/org/apache/storm/daemon/supervisor/SupervisorUtils.java:52
↓ 3 callersMethodsetJmsAcknowledgeMode
Sets the JMS Session acknowledgement mode for the JMS session. <p>Possible values: <ul> <li>jakarta.jms.Session.AUTO_ACKNOWLEDGE</li> <li>jakarta.jms
external/storm-jms/src/main/java/org/apache/storm/jms/spout/JmsSpout.java:127
↓ 3 callersMethodsetLastOverflowCount
(BackpressureState state, int value)
storm-client/src/jvm/org/apache/storm/daemon/worker/BackPressureTracker.java:108
↓ 3 callersMethodsetLoggerLevel
(LoggerContext logContext, String loggerName, String newLevelStr)
storm-client/src/jvm/org/apache/storm/daemon/worker/LogConfigManager.java:144
↓ 3 callersMethodsetNewAssignment
Set a new assignment asynchronously. @param newAssignment the new assignment for this slot to run, null to run nothing
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Slot.java:955
↓ 3 callersMethodsetNumTasks
Set the number of tasks for this component. @param val the number of tasks @return this for chaining.
storm-client/src/jvm/org/apache/storm/topology/ComponentConfigurationDeclarer.java:72
↓ 3 callersMethodsetParallelism
(int parallelism)
storm-client/src/jvm/org/apache/storm/streams/Node.java:102
↓ 3 callersMethodsetPollTimeoutMs
Specifies the time, in milliseconds, spent waiting in poll if data is not available. Default is 200ms. @param pollTimeoutMs time in ms
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/internal/CommonKafkaSpoutConfig.java:159
↓ 3 callersMethodsetReaderType
(String readerType)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java:146
↓ 3 callersMethodsetSourceDir
(String sourceDir)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/HdfsSpout.java:151
↓ 3 callersMethodsetStatusMap
set scheduler status map.
storm-server/src/main/java/org/apache/storm/scheduler/Cluster.java:1010
↓ 3 callersMethodsetTimeout
Sets timeout. @param timeout timeout @return Builder itself
external/storm-redis/src/main/java/org/apache/storm/redis/common/config/JedisPoolConfig.java:138
↓ 3 callersMethodsetTimestamp
(long timestamp)
storm-client/src/jvm/org/apache/storm/executor/TupleInfo.java:43
↓ 3 callersMethodsetTopologyLogConfig
(String stormId, LogConfig logConfig, Map<String, Object> topoConf)
storm-client/src/jvm/org/apache/storm/cluster/IStormClusterState.java:170
↓ 3 callersMethodsetUpProcessorBolt
(Processor<?> processor)
storm-client/test/jvm/org/apache/storm/streams/ProcessorBoltTest.java:121
↓ 3 callersMethodsetWorkerToken
Store a worker token in some credentials. It can be pulled back out by calling readWorkerToken. @param credentials the credentials map. @param token
storm-client/src/jvm/org/apache/storm/security/auth/ClientAuthUtils.java:326
↓ 3 callersMethodset_action
@see ProfileAction
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:21298
↓ 3 callersMethodset_assigned_cpu
(double assigned_cpu)
storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:636
↓ 3 callersMethodset_assigned_memoffheap
(double assigned_memoffheap)
storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:614
↓ 3 callersMethodset_assigned_memonheap
(double assigned_memonheap)
storm-client/src/jvm/org/apache/storm/generated/WorkerSummary.java:592
↓ 3 callersMethodset_assignments
(@org.apache.storm.thrift.annotation.Nullable SupervisorAssignments assignments)
storm-client/src/jvm/org/apache/storm/generated/Supervisor.java:791
↓ 3 callersMethodset_aze_isSet
(boolean value)
storm-client/src/jvm/org/apache/storm/generated/DistributedRPC.java:991
↓ 3 callersMethodset_binary_arg
(byte[] value)
storm-client/src/jvm/org/apache/storm/generated/JavaObjectArg.java:502
↓ 3 callersMethodset_bits
(byte[] bits)
storm-client/src/jvm/org/apache/storm/generated/ThriftSerializedObject.java:185
↓ 3 callersMethodset_blacklisted
(boolean blacklisted)
storm-client/src/jvm/org/apache/storm/generated/SupervisorSummary.java:559
↓ 3 callersMethodset_blobKey
(@org.apache.storm.thrift.annotation.Nullable java.lang.String blobKey)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:60453
↓ 3 callersMethodset_bolt
(BoltAggregateStats value)
storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java:282
↓ 3 callersMethodset_component
(@org.apache.storm.thrift.annotation.Nullable java.lang.String component)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:19374
← previousnext →3,801–3,900 of 27,770, ranked by callers