Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/apache/storm
/ functions
Functions
27,770 in github.com/apache/storm
⨍
Functions
27,770
◇
Types & classes
4,363
Method
emit
(List<Object> values)
storm-client/src/jvm/org/apache/storm/trident/spout/TridentSpoutExecutor.java:123
Method
emit
(List<Object> values)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/GroupCollector.java:30
Method
emit
(List<Object> values)
storm-client/src/jvm/org/apache/storm/trident/operation/impl/CaptureCollector.java:28
Method
emit
(String stream, Collection<Tuple> anchors, List<Object> tuple)
storm-client/src/jvm/org/apache/storm/trident/topology/TridentBoltExecutor.java:396
Method
emit
Emits a new tuple to a specific stream with a single anchor. The emitted values must be immutable. @param streamId the stream to emit to @param ancho
storm-client/src/jvm/org/apache/storm/task/OutputCollector.java:41
Method
emit
(String streamId, List<Object> tuple)
storm-client/src/jvm/org/apache/storm/topology/BasicOutputCollector.java:30
Method
emit
(String streamId, List<Object> tuple)
storm-client/src/jvm/org/apache/storm/topology/BaseStatefulBoltExecutor.java:151
Method
emit
(String streamId, List<Object> tuple)
storm-client/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java:402
Method
emit
(String streamId, List<Object> tuple, Object messageId)
storm-client/src/jvm/org/apache/storm/executor/spout/SpoutOutputCollectorImpl.java:67
Method
emit
(String streamId, Collection<Tuple> anchors, List<Object> tuple)
storm-client/src/jvm/org/apache/storm/executor/bolt/BoltOutputCollectorImpl.java:62
Method
emit
(EmitInfo info)
storm-client/src/jvm/org/apache/storm/hooks/BaseTaskHook.java:33
Method
emit
(String streamId, List<Object> tuple, Object messageId)
storm-client/src/jvm/org/apache/storm/testing/SpoutTracker.java:88
Method
emit
(String streamId, List<Object> tuple)
storm-client/src/jvm/org/apache/storm/coordination/BatchOutputCollectorImpl.java:26
Method
emit
Emits a tuple to the default output stream.
storm-client/src/jvm/org/apache/storm/coordination/BatchOutputCollector.java:29
Method
emit
(String stream, Collection<Tuple> anchors, List<Object> tuple)
storm-client/src/jvm/org/apache/storm/coordination/CoordinatedBolt.java:311
Method
emit
(final String streamId, final Collection<Tuple> anchors, final List<Object> tuple)
external/storm-redis/src/test/java/org/apache/storm/redis/util/outputcollector/StubOutputCollector.java:32
Method
emit
(String streamId, List<Object> tuple, Object messageId)
external/storm-jms/src/test/java/org/apache/storm/jms/spout/MockSpoutOutputCollector.java:29
Method
emit
Emit a message. @param msg the message
external/storm-jms/src/main/java/org/apache/storm/jms/spout/JmsSpout.java:382
Method
emit
(final Message msg)
external/storm-jms/src/main/java/org/apache/storm/jms/spout/JmsSpout.java:431
Method
emit
(List<Object> tuple, Object messageId)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestHdfsSpout.java:720
Method
emit
(EmitInfo info)
storm-core/test/jvm/org/apache/storm/integration/TopologyIntegrationTest.java:777
Method
emitBatch
(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)
storm-client/src/jvm/org/apache/storm/trident/spout/BatchSpoutExecutor.java:71
Method
emitBatch
(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)
storm-client/src/jvm/org/apache/storm/trident/spout/OpaquePartitionedTridentSpoutExecutor.java:124
Method
emitBatch
(long batchId, TridentCollector collector)
storm-client/src/jvm/org/apache/storm/trident/spout/IBatchSpout.java:23
Method
emitBatch
(final TransactionAttempt tx, final Object coordinatorMeta, final TridentCollector collector)
storm-client/src/jvm/org/apache/storm/trident/spout/PartitionedTridentSpoutExecutor.java:127
Method
emitBatch
(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchExecutor.java:145
Method
emitBatch
(TransactionAttempt tx, Map<Integer, List<List<Object>>> coordinatorMeta, TridentCollector collector)
storm-client/src/jvm/org/apache/storm/trident/testing/FeederBatchSpout.java:93
Method
emitBatch
(long batchId, TridentCollector collector)
storm-client/src/jvm/org/apache/storm/trident/testing/FixedBatchSpout.java:50
Method
emitBatch
(TransactionAttempt tx, Object coordinatorMeta, TridentCollector collector)
storm-client/src/jvm/org/apache/storm/trident/testing/FeederCommitterBatchSpout.java:75
Method
emitBatch
(long batchId, TridentCollector collector)
examples/storm-hdfs-examples/src/main/java/org/apache/storm/hdfs/trident/FixedBatchSpout.java:55
Method
emitBatch
(long batchId, TridentCollector collector)
examples/storm-starter/src/jvm/org/apache/storm/starter/spout/RandomNumberGeneratorSpout.java:46
Method
emitBatch
(TransactionAttempt tx, JmsBatch coordinatorMeta, TridentCollector collector)
external/storm-jms/src/main/java/org/apache/storm/jms/trident/TridentJmsSpout.java:290
Method
emitBatchNew
Emit a batch of tuples for the partitions that's never been emitted before. Return the metadata that can be used to reconstruct this partition/batch i
storm-client/src/jvm/org/apache/storm/trident/spout/IPartitionedTridentSpout.java:64
Method
emitBatchNew
(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions,
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentTransactionalSpoutEmitter.java:46
Method
emitBatchNew
(TransactionAttempt tx, TridentCollector collector, Set<KafkaTridentSpoutTopicPartition> partitions,
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentOpaqueSpoutEmitter.java:41
Method
emitBatchNew
Emit a new batch.
external/storm-kafka-client/src/main/java/org/apache/storm/kafka/spout/trident/KafkaTridentSpoutEmitter.java:167
Function
emitDirect
(task, *args, **kwargs)
storm-multilang/python/src/main/resources/resources/storm.py:106
Method
emitDirect
Emits a tuple to the specified task on the specified output stream. This output stream must have been declared as a direct stream, and the specified t
storm-client/src/jvm/org/apache/storm/spout/SpoutOutputCollector.java:81
Method
emitDirect
(int task, String ignore, List<Object> values, Object msgId)
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchTriggerer.java:163
Method
emitDirect
(int task, String stream, List<Object> values, Object id)
storm-client/src/jvm/org/apache/storm/trident/spout/RichSpoutBatchExecutor.java:106
Method
emitDirect
(int task, String stream, Collection<Tuple> anchors, List<Object> tuple)
storm-client/src/jvm/org/apache/storm/trident/topology/TridentBoltExecutor.java:403
Method
emitDirect
Emits a tuple directly to the specified task id on the specified stream. If the target bolt does not subscribe to this bolt using a direct grouping, t
storm-client/src/jvm/org/apache/storm/task/OutputCollector.java:106
Method
emitDirect
(int taskId, String streamId, List<Object> tuple)
storm-client/src/jvm/org/apache/storm/topology/BasicOutputCollector.java:43
Method
emitDirect
(int taskId, String streamId, List<Object> tuple)
storm-client/src/jvm/org/apache/storm/topology/BaseStatefulBoltExecutor.java:156
Method
emitDirect
(int taskId, String streamId, List<Object> tuple)
storm-client/src/jvm/org/apache/storm/topology/WindowedBoltExecutor.java:407
Method
emitDirect
(int taskId, String streamId, List<Object> tuple, Object messageId)
storm-client/src/jvm/org/apache/storm/executor/spout/SpoutOutputCollectorImpl.java:77
Method
emitDirect
(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple)
storm-client/src/jvm/org/apache/storm/executor/bolt/BoltOutputCollectorImpl.java:72
Method
emitDirect
(int taskId, String streamId, List<Object> tuple, Object messageId)
storm-client/src/jvm/org/apache/storm/testing/SpoutTracker.java:95
Method
emitDirect
(int taskId, String streamId, List<Object> tuple)
storm-client/src/jvm/org/apache/storm/coordination/BatchOutputCollectorImpl.java:31
Method
emitDirect
Emits a tuple to the specified task on the default output stream. This output stream must have been declared as a direct stream, and the specified tas
storm-client/src/jvm/org/apache/storm/coordination/BatchOutputCollector.java:39
Method
emitDirect
(int task, String stream, Collection<Tuple> anchors, List<Object> tuple)
storm-client/src/jvm/org/apache/storm/coordination/CoordinatedBolt.java:318
Method
emitDirect
(final int taskId, final String streamId, final Collection<Tuple> anchors, final List<Object> tuple)
external/storm-redis/src/test/java/org/apache/storm/redis/util/outputcollector/StubOutputCollector.java:42
Method
emitDirect
(int taskId, String streamId, List<Object> tuple, Object messageId)
external/storm-jms/src/test/java/org/apache/storm/jms/spout/MockSpoutOutputCollector.java:35
Method
emitDirect
(int arg0, String arg1, List<Object> arg2, Object arg3)
external/storm-hdfs/src/test/java/org/apache/storm/hdfs/spout/TestHdfsSpout.java:732
Method
emitted
()
external/storm-jms/src/test/java/org/apache/storm/jms/spout/MockSpoutOutputCollector.java:49
Method
emittedTuple
(String streamId)
storm-client/src/jvm/org/apache/storm/metrics2/TaskMetrics.java:97
Method
empty
()
storm-clojure/src/main/java/org/apache/storm/clojure/IndifferentAccessMap.java:130
Method
emptySaveConfigResultsInAllUnchangedActions
()
storm-server/src/test/java/org/apache/storm/daemon/nimbus/NimbusClojurePortTest.java:291
Method
enableDetach
Enable detach. @return the self
storm-server/src/main/java/org/apache/storm/container/docker/DockerRunCommand.java:245
Method
encode
(ChannelHandlerContext ctx, BackPressureStatus msg, List<Object> out)
storm-client/src/jvm/org/apache/storm/messaging/netty/BackPressureStatusEncoder.java:32
Method
encode
(ChannelHandlerContext ctx, INettySerializable msg, ByteBuf out)
storm-client/src/jvm/org/apache/storm/messaging/netty/NettySerializableMessageEncoder.java:27
Method
encodeKey
(K key)
storm-client/src/jvm/org/apache/storm/state/DefaultStateEncoder.java:43
Method
encodeLength
()
storm-client/src/jvm/org/apache/storm/messaging/netty/MessageBatch.java:76
Method
encodeLength
()
storm-client/src/jvm/org/apache/storm/messaging/netty/SaslMessageToken.java:81
Method
encodeLength
()
storm-client/src/jvm/org/apache/storm/messaging/netty/ControlMessage.java:55
Method
encodeValue
(V value)
storm-client/src/jvm/org/apache/storm/state/DefaultStateEncoder.java:48
Method
entryAt
(Object k)
storm-clojure/src/main/java/org/apache/storm/clojure/ClojureTuple.java:376
Method
entryAt
(Object k)
storm-clojure/src/main/java/org/apache/storm/clojure/IndifferentAccessMap.java:117
Method
entrySet
Get the map of the cache contents. Provided to allow writing the data to RocksDB on shutdown. @return the string metadata map entrySet
storm-server/src/main/java/org/apache/storm/metricstore/rocksdb/StringMetadataCache.java:195
Method
entrySet
()
storm-clojure/src/main/java/org/apache/storm/clojure/ClojureTuple.java:410
Method
entrySet
()
storm-clojure/src/main/java/org/apache/storm/clojure/IndifferentAccessMap.java:151
Method
enumForId
(short id)
storm-client/src/jvm/org/apache/storm/generated/Grouping.java:551
Method
enumForId
(short id)
storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java:262
Method
enumForId
(short id)
storm-client/src/jvm/org/apache/storm/generated/HBMessageData.java:430
Method
enumForId
(short id)
storm-client/src/jvm/org/apache/storm/generated/ComponentObject.java:308
Method
enumForId
(short id)
storm-client/src/jvm/org/apache/storm/generated/JavaObjectArg.java:424
Method
enumForId
(short id)
storm-client/src/jvm/org/apache/storm/generated/ExecutorSpecificStats.java:262
Method
enumForId
(short id)
storm-client/src/jvm/org/apache/storm/generated/TopologyActionOptions.java:262
Method
equals
(Object o)
storm-client/src/jvm/org/apache/storm/windowing/TupleWindowImpl.java:75
Method
equals
(Object object)
storm-client/src/jvm/org/apache/storm/container/cgroup/SubSystem.java:79
Method
equals
(Object obj)
storm-client/src/jvm/org/apache/storm/container/cgroup/Hierarchy.java:64
Method
equals
(Object obj)
storm-client/src/jvm/org/apache/storm/container/cgroup/core/DevicesCore.java:150
Method
equals
(Object o)
storm-client/src/jvm/org/apache/storm/scheduler/WorkerSlot.java:54
Method
equals
(Object other)
storm-client/src/jvm/org/apache/storm/tuple/MessageId.java:74
Method
equals
(Object other)
storm-client/src/jvm/org/apache/storm/tuple/TupleImpl.java:263
Method
equals
(Object o)
storm-client/src/jvm/org/apache/storm/trident/windowing/AbstractTridentWindowManager.java:190
Method
equals
(Object o)
storm-client/src/jvm/org/apache/storm/trident/util/IndexedEdge.java:34
Method
equals
(java.lang.Object other)
storm-client/src/jvm/org/apache/storm/generated/Grouping.java:717
Method
equals
(java.lang.Object other)
storm-client/src/jvm/org/apache/storm/generated/SpecificAggregateStats.java:310
Method
equals
(java.lang.Object other)
storm-client/src/jvm/org/apache/storm/generated/HBMessageData.java:560
Method
equals
(java.lang.Object that)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:10719
Method
equals
(java.lang.Object that)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:11362
Method
equals
(java.lang.Object that)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:12051
Method
equals
(java.lang.Object that)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:12753
Method
equals
(java.lang.Object that)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:13242
Method
equals
(java.lang.Object that)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:13668
Method
equals
(java.lang.Object that)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:14151
Method
equals
(java.lang.Object that)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:14636
Method
equals
(java.lang.Object that)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:15069
Method
equals
(java.lang.Object that)
storm-client/src/jvm/org/apache/storm/generated/Nimbus.java:15495
← previous
next →
16,001–16,100 of 27,770, ranked by callers