MCPcopy Create free account

hub / github.com/apache/storm / functions

Functions27,770 in github.com/apache/storm

⨍ Functions 27,770◇ Types & classes 4,363
MethodfinishBlobUpload_call
(java.lang.String session, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.s
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:2509
MethodfinishBlobUpload_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:26558
MethodfinishFileUpload
(java.lang.String location, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:246
MethodfinishFileUpload
(java.lang.String location)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:1120
MethodfinishFileUpload
(java.lang.String location, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:2966
MethodfinishFileUpload
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:5062
MethodfinishFileUpload
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:8371
MethodfinishFileUpload
Parameters: - location
storm-client/src/py/storm/Nimbus.py:296
MethodfinishFileUpload
Parameters: - location
storm-client/src/py/storm/Nimbus.py:1539
MethodfinishFileUpload
(String location)
storm-server/src/main/java/org/apache/storm/LocalCluster.java:978
MethodfinishFileUpload
(String location)
storm-server/src/main/java/org/apache/storm/daemon/nimbus/Nimbus.java:4164
MethodfinishFileUpload_args
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:37454
MethodfinishFileUpload_call
(java.lang.String location, org.apache.storm.thrift.async.AsyncMethodCallback<Void> resultHandler, org.apache.
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:2976
MethodfinishFileUpload_result
()
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:37830
MethodfinishedId
(Object id)
storm-client/src/jvm/org/apache/storm/drpc/KeyedFairBolt.java:82
MethodfinishedId
(Object id)
storm-client/src/jvm/org/apache/storm/coordination/BatchBoltExecutor.java:67
MethodfinishedId
(Object id)
storm-server/src/test/java/org/apache/storm/drpc/DRPCIntegrationTest.java:131
MethodfinishedId
(Object id)
storm-server/src/test/java/org/apache/storm/drpc/DRPCIntegrationTest.java:162
MethodfinishedId
(Object id)
storm-server/src/test/java/org/apache/storm/drpc/DRPCIntegrationTest.java:204
MethodfinishedId
(Object id)
storm-server/src/test/java/org/apache/storm/drpc/DRPCIntegrationTest.java:231
MethodfinishedId
(Object id)
storm-clojure/src/main/java/org/apache/storm/clojure/ClojureBolt.java:106
MethodflatMap
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/streams/Stream.java:119
MethodflatMapToPair
Returns a stream consisting of the results of replacing each value of this stream with the key-value pairs produced by applying the provided mapping f
storm-client/src/jvm/org/apache/storm/streams/Stream.java:135
MethodflatMapValues
Return a new stream by applying a {@link FlatMapFunction} function to the value of each key-value pairs in this stream. @param function the flatmap f
storm-client/src/jvm/org/apache/storm/streams/PairStream.java:75
Methodflush
()
storm-client/test/jvm/org/apache/storm/utils/JCQueueTest.java:55
Methodflush
()
storm-client/test/jvm/org/apache/storm/utils/JCQueueBackpressureTest.java:90
Methodflush
()
storm-client/test/jvm/org/apache/storm/executor/ExecutorTransferMultiThreadingTest.java:197
Methodflush
()
storm-client/src/jvm/org/apache/storm/spout/SpoutOutputCollector.java:115
Methodflush
()
storm-client/src/jvm/org/apache/storm/utils/JCQueue.java:260
Methodflush
()
storm-client/src/jvm/org/apache/storm/utils/JCQueue.java:315
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/planner/BridgeReceiver.java:33
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/AppendCollector.java:49
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/FreshCollector.java:46
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/EachProcessor.java:52
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/MultiReducerProcessor.java:78
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/PartitionPersistProcessor.java:74
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/StateQueryProcessor.java:76
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/MapProcessor.java:68
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/ProjectedProcessor.java:60
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/planner/processor/AggregateProcessor.java:69
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/windowing/WindowTridentProcessor.java:167
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/windowing/AbstractTridentWindowManager.java:169
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchTriggerer.java:168
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchExecutor.java:111
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/spout/TridentSpoutExecutor.java:128
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/operation/impl/GroupCollector.java:38
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/operation/impl/CaptureCollector.java:33
Methodflush
()
storm-client/src/jvm/org/apache/storm/trident/topology/TridentBoltExecutor.java:424
Methodflush
()
storm-client/src/jvm/org/apache/storm/task/OutputCollector.java:205
Methodflush
()
storm-client/src/jvm/org/apache/storm/executor/Executor.java:325
Methodflush
()
storm-client/src/jvm/org/apache/storm/executor/ExecutorTransfer.java:73
Methodflush
()
storm-client/src/jvm/org/apache/storm/executor/spout/SpoutOutputCollectorImpl.java:87
Methodflush
()
storm-client/src/jvm/org/apache/storm/executor/bolt/BoltOutputCollectorImpl.java:178
Methodflush
()
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerTransfer.java:98
Methodflush
()
storm-client/src/jvm/org/apache/storm/testing/SpoutTracker.java:101
Methodflush
()
storm-client/src/jvm/org/apache/storm/coordination/BatchOutputCollectorImpl.java:36
Methodflush
Flush any buffered tuples (when batching is enabled).
storm-client/src/jvm/org/apache/storm/coordination/BatchOutputCollector.java:48
Methodflush
()
storm-client/src/jvm/org/apache/storm/coordination/CoordinatedBolt.java:354
Methodflush
()
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Forwarder.java:65
Methodflush
()
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Acker.java:57
Methodflush
()
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/AckingProducer.java:57
Methodflush
()
examples/storm-perf/src/main/java/org/apache/storm/perf/queuetest/Consumer.java:58
Methodflush
()
external/storm-redis/src/test/java/org/apache/storm/redis/util/outputcollector/StubOutputCollector.java:62
Methodflush
()
external/storm-jms/src/test/java/org/apache/storm/jms/spout/MockSpoutOutputCollector.java:40
MethodflushRemotes
()
storm-client/src/jvm/org/apache/storm/daemon/worker/WorkerTransfer.java:131
MethodforceCloseLockFile
()
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/spout/FileLock.java:265
MethodforceKill
(String user, String workerId)
storm-server/src/test/java/org/apache/storm/daemon/supervisor/ContainerTest.java:296
MethodforceKill
Kill the given worker forcefully. @param user the user that the worker is running as @param workerId the id of the worker to kill @throws IOException
storm-server/src/main/java/org/apache/storm/container/ResourceIsolationInterface.java:107
MethodforceKill
(String user, String workerId)
storm-server/src/main/java/org/apache/storm/container/DefaultResourceIsolationManager.java:104
MethodforceKill
(String user, String workerId)
storm-server/src/main/java/org/apache/storm/container/oci/RuncLibContainerManager.java:513
MethodforceKill
(String user, String workerId)
storm-server/src/main/java/org/apache/storm/container/docker/DockerManager.java:225
MethodforceKill
()
storm-server/src/main/java/org/apache/storm/daemon/supervisor/Container.java:216
Methodformat
(Tuple tuple)
examples/storm-perf/src/main/java/org/apache/storm/perf/StrGenSpoutHdfsBoltTopo.java:154
Methodformat
(Tuple tuple)
examples/storm-perf/src/main/java/org/apache/storm/perf/KafkaClientHdfsTopo.java:166
Methodformat
(Object o)
examples/storm-loadgen/src/main/java/org/apache/storm/loadgen/LoadMetricsServer.java:579
Methodformat
(TridentTuple tuple)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/format/DelimitedRecordFormat.java:54
Methodformat
(TridentTuple tuple)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/trident/format/RecordFormat.java:22
Methodformat
(Tuple tuple)
external/storm-hdfs/src/main/java/org/apache/storm/hdfs/bolt/format/DelimitedRecordFormat.java:60
FunctionformatConfigData
(data)
storm-webapp/src/main/webapp/js/script.js:256
FunctionformatErrorTimeSecs
(response)
storm-webapp/src/main/webapp/js/script.js:269
Methodforward
(Pair<Integer, Pair<List<Integer>, List<Integer>>> input)
storm-client/test/jvm/org/apache/storm/streams/processors/CoGroupByKeyProcessorTest.java:34
Methodforward
(Pair<Integer, Pair<Integer, Integer>> input)
storm-client/test/jvm/org/apache/storm/streams/processors/JoinProcessorTest.java:32
Methodforward
(T input)
storm-client/src/jvm/org/apache/storm/streams/processors/ForwardingProcessorContext.java:38
Methodforward
(T input)
storm-client/src/jvm/org/apache/storm/streams/processors/EmittingProcessorContext.java:57
Methodforward
(T input)
storm-client/src/jvm/org/apache/storm/streams/processors/ChainedProcessorContext.java:37
MethodforwardSchemaChangeWorks
()
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/bolt/AvroGenericRecordBoltTest.java:165
MethodframeworkClasspath
(SimpleVersion version)
storm-server/src/test/java/org/apache/storm/daemon/supervisor/BasicContainerTest.java:708
MethodfromJson
(String jsonStr)
integration-test/src/main/java/org/apache/storm/st/topology/window/data/TimeData.java:58
MethodfromJson
(String jsonStr)
integration-test/src/main/java/org/apache/storm/st/topology/window/data/TimeDataWindow.java:50
MethodfromTuple
(Tuple tuple)
integration-test/src/main/java/org/apache/storm/st/topology/window/data/TimeData.java:54
MethodfullOuterJoin
Does a full outer join of the values of this stream with the values having the same key from the other stream. <p> Note: The parallelism of this strea
storm-client/src/jvm/org/apache/storm/streams/PairStream.java:279
MethodgenerateCountWindows
()
integration-test/src/test/java/org/apache/storm/st/tests/window/SlidingWindowTest.java:33
MethodgenerateSupervisorId
()
storm-server/src/main/java/org/apache/storm/LocalCluster.java:770
MethodgenerateTimeWindows
()
integration-test/src/test/java/org/apache/storm/st/tests/window/SlidingWindowTest.java:63
MethodgenerateTumbleTimes
()
integration-test/src/test/java/org/apache/storm/st/tests/window/TumblingWindowTest.java:64
MethodgenerateWindows
()
integration-test/src/test/java/org/apache/storm/st/tests/window/TumblingWindowTest.java:35
Methodgeoadd
(final String key, final double longitude, final double latitude, final String value)
external/storm-redis/src/test/java/org/apache/storm/redis/util/JedisTestHelper.java:42
Methodgeoadd
(final String key, final double longitude, final double latitude, final String member)
external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisClusterContainer.java:51
Methodgeoadd
(final String key, final double longitude, final double latitude, final String member)
external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisContainer.java:78
Methodgeopos
(final String key, final String... members)
external/storm-redis/src/main/java/org/apache/storm/redis/common/container/JedisClusterContainer.java:56
← previousnext →17,401–17,500 of 27,770, ranked by callers