Uses of Interface
org.apache.storm.tuple.Tuple
-
-
Uses of Tuple in org.apache.storm
Methods in org.apache.storm that return Tuple Modifier and Type Method Description static TupleTesting. testTuple(List<Object> values)Create aTuplefor use with testing.static TupleTesting. testTuple(List<Object> values, MkTupleParam param)Create aTuplefor use with testing.Methods in org.apache.storm with parameters of type Tuple Modifier and Type Method Description voidExclamationTopology.ExclamationBolt. execute(Tuple tuple) -
Uses of Tuple in org.apache.storm.bolt
Methods in org.apache.storm.bolt with parameters of type Tuple Modifier and Type Method Description protected ObjectJoinBolt. lookupField(JoinBolt.FieldSelector fieldSelector, Tuple tuple)Method parameters in org.apache.storm.bolt with type arguments of type Tuple Modifier and Type Method Description protected JoinBolt.JoinAccumulatorJoinBolt. doInnerJoin(JoinBolt.JoinAccumulator probe, Map<Object,ArrayList<Tuple>> buildInput, JoinBolt.JoinInfo joinInfo, boolean finalJoin)protected JoinBolt.JoinAccumulatorJoinBolt. doJoin(JoinBolt.JoinAccumulator probe, HashMap<Object,ArrayList<Tuple>> buildInput, JoinBolt.JoinInfo joinInfo, boolean finalJoin)protected JoinBolt.JoinAccumulatorJoinBolt. doLeftJoin(JoinBolt.JoinAccumulator probe, Map<Object,ArrayList<Tuple>> buildInput, JoinBolt.JoinInfo joinInfo, boolean finalJoin)protected ArrayList<Object>JoinBolt. doProjection(ArrayList<Tuple> tuples, JoinBolt.FieldSelector[] projectionFields)protected JoinBolt.JoinAccumulatorJoinBolt. hashJoin(List<Tuple> tuples)Constructors in org.apache.storm.bolt with parameters of type Tuple Constructor Description ResultRecord(JoinBolt.ResultRecord lhs, Tuple rhs, boolean generateOutputFields)ResultRecord(Tuple tuple, boolean generateOutputFields) -
Uses of Tuple in org.apache.storm.clojure
Classes in org.apache.storm.clojure that implement Tuple Modifier and Type Class Description classClojureTupleMethods in org.apache.storm.clojure with parameters of type Tuple Modifier and Type Method Description voidClojureBolt. execute(Tuple input)Constructors in org.apache.storm.clojure with parameters of type Tuple Constructor Description ClojureTuple(Tuple t) -
Uses of Tuple in org.apache.storm.coordination
Methods in org.apache.storm.coordination with parameters of type Tuple Modifier and Type Method Description voidBatchOutputCollectorImpl. ack(Tuple tup)voidCoordinatedBolt.CoordinatedOutputCollector. ack(Tuple tuple)voidBatchBoltExecutor. execute(Tuple input)voidCoordinatedBolt. execute(Tuple tuple)voidIBatchBolt. execute(Tuple tuple)voidBatchOutputCollectorImpl. fail(Tuple tup)voidCoordinatedBolt.CoordinatedOutputCollector. fail(Tuple tuple)voidCoordinatedBolt.CoordinatedOutputCollector. resetTimeout(Tuple tuple)Method parameters in org.apache.storm.coordination with type arguments of type Tuple Modifier and Type Method Description List<Integer>CoordinatedBolt.CoordinatedOutputCollector. emit(String stream, Collection<Tuple> anchors, List<Object> tuple)voidCoordinatedBolt.CoordinatedOutputCollector. emitDirect(int task, String stream, Collection<Tuple> anchors, List<Object> tuple) -
Uses of Tuple in org.apache.storm.daemon
Methods in org.apache.storm.daemon that return Tuple Modifier and Type Method Description TupleTask. getTuple(String stream, List values)Methods in org.apache.storm.daemon with parameters of type Tuple Modifier and Type Method Description voidAcker. execute(Tuple input) -
Uses of Tuple in org.apache.storm.drpc
Methods in org.apache.storm.drpc with parameters of type Tuple Modifier and Type Method Description voidJoinResult. execute(Tuple tuple)voidKeyedFairBolt. execute(Tuple input)voidPrepareRequest. execute(Tuple tuple, BasicOutputCollector collector)voidReturnResults. execute(Tuple input) -
Uses of Tuple in org.apache.storm.executor.bolt
Methods in org.apache.storm.executor.bolt with parameters of type Tuple Modifier and Type Method Description voidBoltOutputCollectorImpl. ack(Tuple input)voidBoltOutputCollectorImpl. fail(Tuple input)voidBoltOutputCollectorImpl. resetTimeout(Tuple input)Method parameters in org.apache.storm.executor.bolt with type arguments of type Tuple Modifier and Type Method Description List<Integer>BoltOutputCollectorImpl. emit(String streamId, Collection<Tuple> anchors, List<Object> tuple)voidBoltOutputCollectorImpl. emitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple) -
Uses of Tuple in org.apache.storm.flux.examples
Methods in org.apache.storm.flux.examples with parameters of type Tuple Modifier and Type Method Description voidStatefulWordCounter. execute(Tuple tuple)voidTestPrintBolt. execute(Tuple tuple, BasicOutputCollector collector)voidWordCounter. execute(Tuple input, BasicOutputCollector collector) -
Uses of Tuple in org.apache.storm.flux.wrappers.bolts
Methods in org.apache.storm.flux.wrappers.bolts with parameters of type Tuple Modifier and Type Method Description voidLogInfoBolt. execute(Tuple tuple, BasicOutputCollector basicOutputCollector) -
Uses of Tuple in org.apache.storm.hdfs.bolt
Methods in org.apache.storm.hdfs.bolt with parameters of type Tuple Modifier and Type Method Description voidAbstractHdfsBolt. execute(Tuple tuple)voidHdfsFileTopology.MyBolt. execute(Tuple tuple)voidSequenceFileTopology.MyBolt. execute(Tuple tuple)protected org.apache.hadoop.fs.PathAbstractHdfsBolt. getBasePathForNextFile(Tuple tuple)protected abstract StringAbstractHdfsBolt. getWriterKey(Tuple tuple)protected StringAvroGenericRecordBolt. getWriterKey(Tuple tuple)AvroGenericRecordBolt must override this method because messages with different schemas cannot be written to the same file.protected StringHdfsBolt. getWriterKey(Tuple tuple)protected StringSequenceFileBolt. getWriterKey(Tuple tuple)protected abstract WriterAbstractHdfsBolt. makeNewWriter(org.apache.hadoop.fs.Path path, Tuple tuple)protected AbstractHDFSWriterAvroGenericRecordBolt. makeNewWriter(org.apache.hadoop.fs.Path path, Tuple tuple)protected AbstractHDFSWriterHdfsBolt. makeNewWriter(org.apache.hadoop.fs.Path path, Tuple tuple)protected AbstractHDFSWriterSequenceFileBolt. makeNewWriter(org.apache.hadoop.fs.Path path, Tuple tuple)longWriter. write(Tuple tuple) -
Uses of Tuple in org.apache.storm.hdfs.bolt.format
Methods in org.apache.storm.hdfs.bolt.format with parameters of type Tuple Modifier and Type Method Description byte[]DelimitedRecordFormat. format(Tuple tuple)byte[]RecordFormat. format(Tuple tuple)org.apache.hadoop.io.WritableDefaultSequenceFormat. key(Tuple tuple)ObjectSequenceFormat. key(Tuple tuple)Given a tuple, return the key that should be written to the sequence file.org.apache.hadoop.io.WritableDefaultSequenceFormat. value(Tuple tuple)ObjectSequenceFormat. value(Tuple tuple)Given a tuple, return the value that should be written to the sequence file. -
Uses of Tuple in org.apache.storm.hdfs.bolt.rotation
Methods in org.apache.storm.hdfs.bolt.rotation with parameters of type Tuple Modifier and Type Method Description booleanFileRotationPolicy. mark(Tuple tuple, long offset)Called for every tuple the HdfsBolt executes.booleanFileSizeRotationPolicy. mark(Tuple tuple, long offset)booleanNoRotationPolicy. mark(Tuple tuple, long offset)booleanTimedRotationPolicy. mark(Tuple tuple, long offset)Called for every tuple the HdfsBolt executes. -
Uses of Tuple in org.apache.storm.hdfs.bolt.sync
Methods in org.apache.storm.hdfs.bolt.sync with parameters of type Tuple Modifier and Type Method Description booleanCountSyncPolicy. mark(Tuple tuple, long offset)booleanSyncPolicy. mark(Tuple tuple, long offset)Called for every tuple the HdfsBolt executes. -
Uses of Tuple in org.apache.storm.hdfs.common
Methods in org.apache.storm.hdfs.common with parameters of type Tuple Modifier and Type Method Description protected abstract voidAbstractHDFSWriter. doWrite(Tuple tuple)protected voidAvroGenericRecordHDFSWriter. doWrite(Tuple tuple)protected voidHDFSWriter. doWrite(Tuple tuple)protected voidSequenceFileWriter. doWrite(Tuple tuple)StringNullPartitioner. getPartitionPath(Tuple tuple)StringPartitioner. getPartitionPath(Tuple tuple)Return a relative path that the tuple should be written to.longAbstractHDFSWriter. write(Tuple tuple) -
Uses of Tuple in org.apache.storm.hdfs.spout
Methods in org.apache.storm.hdfs.spout with parameters of type Tuple Modifier and Type Method Description voidHdfsSpoutTopology.ConstBolt. execute(Tuple tuple) -
Uses of Tuple in org.apache.storm.hive.bolt
Methods in org.apache.storm.hive.bolt with parameters of type Tuple Modifier and Type Method Description voidHiveBolt. execute(Tuple tuple)Deprecated, for removal: This API element is subject to removal in a future version. -
Uses of Tuple in org.apache.storm.hive.bolt.mapper
Methods in org.apache.storm.hive.bolt.mapper with parameters of type Tuple Modifier and Type Method Description List<String>DelimitedRecordHiveMapper. mapPartitions(Tuple tuple)Deprecated, for removal: This API element is subject to removal in a future version.List<String>HiveMapper. mapPartitions(Tuple tuple)Deprecated, for removal: This API element is subject to removal in a future version.Given a tuple, return a hive partition values list.List<String>JsonRecordHiveMapper. mapPartitions(Tuple tuple)Deprecated, for removal: This API element is subject to removal in a future version.byte[]DelimitedRecordHiveMapper. mapRecord(Tuple tuple)Deprecated, for removal: This API element is subject to removal in a future version.byte[]HiveMapper. mapRecord(Tuple tuple)Deprecated, for removal: This API element is subject to removal in a future version.Given a tuple, maps to a HiveRecord based on columnFields.byte[]JsonRecordHiveMapper. mapRecord(Tuple tuple)Deprecated, for removal: This API element is subject to removal in a future version.voidDelimitedRecordHiveMapper. write(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch, Tuple tuple)Deprecated, for removal: This API element is subject to removal in a future version.voidHiveMapper. write(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch, Tuple tuple)Deprecated, for removal: This API element is subject to removal in a future version.voidJsonRecordHiveMapper. write(org.apache.hive.hcatalog.streaming.TransactionBatch txnBatch, Tuple tuple)Deprecated, for removal: This API element is subject to removal in a future version. -
Uses of Tuple in org.apache.storm.hooks.info
Fields in org.apache.storm.hooks.info declared as Tuple Modifier and Type Field Description TupleBoltAckInfo. tupleTupleBoltExecuteInfo. tupleTupleBoltFailInfo. tupleConstructors in org.apache.storm.hooks.info with parameters of type Tuple Constructor Description BoltAckInfo(Tuple tuple, int ackingTaskId, Long processLatencyMs)BoltExecuteInfo(Tuple tuple, int executingTaskId, Long executeLatencyMs)BoltFailInfo(Tuple tuple, int failingTaskId, Long failLatencyMs) -
Uses of Tuple in org.apache.storm.jdbc.bolt
Methods in org.apache.storm.jdbc.bolt with parameters of type Tuple Modifier and Type Method Description protected voidJdbcInsertBolt. process(Tuple tuple)protected voidJdbcLookupBolt. process(Tuple tuple) -
Uses of Tuple in org.apache.storm.jms.bolt
Methods in org.apache.storm.jms.bolt with parameters of type Tuple Modifier and Type Method Description protected voidJmsBolt. process(Tuple input)Consumes a tuple and sends a JMS message. -
Uses of Tuple in org.apache.storm.jms.example
Methods in org.apache.storm.jms.example with parameters of type Tuple Modifier and Type Method Description voidGenericBolt. execute(Tuple input) -
Uses of Tuple in org.apache.storm.kafka.bolt
Methods in org.apache.storm.kafka.bolt with parameters of type Tuple Modifier and Type Method Description protected voidKafkaBolt. process(Tuple input) -
Uses of Tuple in org.apache.storm.kafka.bolt.mapper
Methods in org.apache.storm.kafka.bolt.mapper with parameters of type Tuple Modifier and Type Method Description KFieldNameBasedTupleToKafkaMapper. getKeyFromTuple(Tuple tuple)KTupleToKafkaMapper. getKeyFromTuple(Tuple tuple)VFieldNameBasedTupleToKafkaMapper. getMessageFromTuple(Tuple tuple)VTupleToKafkaMapper. getMessageFromTuple(Tuple tuple) -
Uses of Tuple in org.apache.storm.kafka.bolt.selector
Methods in org.apache.storm.kafka.bolt.selector with parameters of type Tuple Modifier and Type Method Description StringDefaultTopicSelector. getTopic(Tuple tuple)StringFieldIndexTopicSelector. getTopic(Tuple tuple)StringFieldNameTopicSelector. getTopic(Tuple tuple)StringKafkaTopicSelector. getTopic(Tuple tuple) -
Uses of Tuple in org.apache.storm.kafka.spout
Methods in org.apache.storm.kafka.spout with parameters of type Tuple Modifier and Type Method Description voidKafkaSpoutTestBolt. execute(Tuple input) -
Uses of Tuple in org.apache.storm.lambda
Methods in org.apache.storm.lambda with parameters of type Tuple Modifier and Type Method Description voidLambdaBiConsumerBolt. execute(Tuple input, BasicOutputCollector collector)voidLambdaConsumerBolt. execute(Tuple input, BasicOutputCollector collector)Constructor parameters in org.apache.storm.lambda with type arguments of type Tuple Constructor Description LambdaBiConsumerBolt(SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer, String[] fields)LambdaConsumerBolt(SerializableConsumer<Tuple> consumer) -
Uses of Tuple in org.apache.storm.loadgen
Methods in org.apache.storm.loadgen with parameters of type Tuple Modifier and Type Method Description voidLoadBolt. execute(Tuple input)voidThroughputVsLatency.SplitSentence. execute(Tuple tuple, BasicOutputCollector collector)voidThroughputVsLatency.WordCount. execute(Tuple tuple, BasicOutputCollector collector) -
Uses of Tuple in org.apache.storm.metric
Methods in org.apache.storm.metric with parameters of type Tuple Modifier and Type Method Description voidEventLoggerBolt. execute(Tuple input)voidMetricsConsumerBolt. execute(Tuple input)voidSystemBolt. execute(Tuple input) -
Uses of Tuple in org.apache.storm.perf
Methods in org.apache.storm.perf with parameters of type Tuple Modifier and Type Method Description byte[]KafkaClientHdfsTopo.LineWriter. format(Tuple tuple)byte[]StrGenSpoutHdfsBoltTopo.LineWriter. format(Tuple tuple) -
Uses of Tuple in org.apache.storm.perf.bolt
Methods in org.apache.storm.perf.bolt with parameters of type Tuple Modifier and Type Method Description voidCountBolt. execute(Tuple tuple, BasicOutputCollector collector)voidDevNullBolt. execute(Tuple tuple)voidIdBolt. execute(Tuple tuple)voidSplitSentenceBolt. execute(Tuple input, BasicOutputCollector collector) -
Uses of Tuple in org.apache.storm.perf.utils
Methods in org.apache.storm.perf.utils with parameters of type Tuple Modifier and Type Method Description voidIdentityBolt. execute(Tuple tuple) -
Uses of Tuple in org.apache.storm.redis.bolt
Methods in org.apache.storm.redis.bolt with parameters of type Tuple Modifier and Type Method Description voidRedisFilterBolt. process(Tuple input)Process a single non-tick tuple of input.voidRedisLookupBolt. process(Tuple input)Process a single non-tick tuple of input.voidRedisStoreBolt. process(Tuple input)Process a single non-tick tuple of input. -
Uses of Tuple in org.apache.storm.redis.topology
Methods in org.apache.storm.redis.topology with parameters of type Tuple Modifier and Type Method Description voidLookupWordCount.PrintWordTotalCountBolt. execute(Tuple input)voidWhitelistWordCount.PrintWordTotalCountBolt. execute(Tuple input)voidWordCounter. execute(Tuple input, BasicOutputCollector collector) -
Uses of Tuple in org.apache.storm.serialization
Methods in org.apache.storm.serialization that return Tuple Modifier and Type Method Description TupleITupleDeserializer. deserialize(byte[] ser)Methods in org.apache.storm.serialization with parameters of type Tuple Modifier and Type Method Description byte[]ITupleSerializer. serialize(Tuple tuple)byte[]KryoTupleSerializer. serialize(Tuple tuple) -
Uses of Tuple in org.apache.storm.spout
Methods in org.apache.storm.spout with parameters of type Tuple Modifier and Type Method Description static booleanCheckpointSpout. isCheckpoint(Tuple input) -
Uses of Tuple in org.apache.storm.sql.runtime.datasource.socket.bolt
Methods in org.apache.storm.sql.runtime.datasource.socket.bolt with parameters of type Tuple Modifier and Type Method Description voidSocketBolt. execute(Tuple input) -
Uses of Tuple in org.apache.storm.sql.runtime.streams.functions
Methods in org.apache.storm.sql.runtime.streams.functions with parameters of type Tuple Modifier and Type Method Description ValuesStreamsScanTupleValueMapper. apply(Tuple input) -
Uses of Tuple in org.apache.storm.st.topology.window.data
Methods in org.apache.storm.st.topology.window.data with parameters of type Tuple Modifier and Type Method Description static TimeDataTimeData. fromTuple(Tuple tuple) -
Uses of Tuple in org.apache.storm.starter
Methods in org.apache.storm.starter with parameters of type Tuple Modifier and Type Method Description voidAnchoredWordCount.SplitSentence. execute(Tuple tuple, BasicOutputCollector collector)voidAnchoredWordCount.WordCount. execute(Tuple tuple, BasicOutputCollector collector)voidBasicDRPCTopology.ExclaimBolt. execute(Tuple tuple, BasicOutputCollector collector)voidBlobStoreAPIWordCountTopology.FilterWords. execute(Tuple tuple, BasicOutputCollector collector)voidExclamationTopology.ExclamationBolt. execute(Tuple tuple)voidFastWordCountTopology.SplitSentence. execute(Tuple tuple, BasicOutputCollector collector)voidFastWordCountTopology.WordCount. execute(Tuple tuple, BasicOutputCollector collector)voidInOrderDeliveryTest.Check. execute(Tuple tuple, BasicOutputCollector collector)voidManualDRPC.ExclamationBolt. execute(Tuple tuple, BasicOutputCollector collector)voidMultipleLoggerTopology.ExclamationLoggingBolt. execute(Tuple tuple)voidMultiThreadWordCountTopology.MultiThreadedSplitSentence. execute(Tuple input)voidReachTopology.CountAggregator. execute(Tuple tuple)voidReachTopology.GetFollowers. execute(Tuple tuple, BasicOutputCollector collector)voidReachTopology.GetTweeters. execute(Tuple tuple, BasicOutputCollector collector)voidReachTopology.PartialUniquer. execute(Tuple tuple)voidResourceAwareExampleTopology.ExclamationBolt. execute(Tuple tuple)voidStatefulTopology.PrinterBolt. execute(Tuple tuple, BasicOutputCollector collector)voidWordCountTopologyNode.WordCount. execute(Tuple tuple, BasicOutputCollector collector) -
Uses of Tuple in org.apache.storm.starter.bolt
Methods in org.apache.storm.starter.bolt with parameters of type Tuple Modifier and Type Method Description voidAbstractRankerBolt. execute(Tuple tuple, BasicOutputCollector collector)This method functions as a template method (design pattern).voidPrinterBolt. execute(Tuple tuple, BasicOutputCollector collector)voidRollingCountAggBolt. execute(Tuple tuple)voidRollingCountBolt. execute(Tuple tuple)voidSingleJoinBolt. execute(Tuple tuple)voidWordCountBolt. execute(Tuple tuple, BasicOutputCollector collector) -
Uses of Tuple in org.apache.storm.starter.tools
Methods in org.apache.storm.starter.tools with parameters of type Tuple Modifier and Type Method Description static RankableObjectWithFieldsRankableObjectWithFields. from(Tuple tuple)Construct a new instance based on the providedTuple. -
Uses of Tuple in org.apache.storm.state
Methods in org.apache.storm.state with parameters of type Tuple Modifier and Type Method Description voidISubscribedState. set(Object id, Tuple tuple) -
Uses of Tuple in org.apache.storm.streams
Methods in org.apache.storm.streams that return Tuple Modifier and Type Method Description TupleRefCountedTuple. tuple()Methods in org.apache.storm.streams that return types with arguments of type Tuple Modifier and Type Method Description Stream<Tuple>StreamBuilder. newStream(IRichSpout spout)Creates a newStreamof tuples from the givenIRichSpout.Stream<Tuple>StreamBuilder. newStream(IRichSpout spout, int parallelism)Creates a newStreamof tuples from the givenIRichSpoutwith the given parallelism. -
Uses of Tuple in org.apache.storm.streams.operations.mappers
Methods in org.apache.storm.streams.operations.mappers with parameters of type Tuple Modifier and Type Method Description Pair<K,V>PairValueMapper. apply(Tuple input)TValueMapper. apply(Tuple input)ValuesValuesMapper. apply(Tuple input) -
Uses of Tuple in org.apache.storm.task
Methods in org.apache.storm.task with parameters of type Tuple Modifier and Type Method Description voidIOutputCollector. ack(Tuple input)voidOutputCollector. ack(Tuple input)List<Integer>OutputCollector. emit(String streamId, Tuple anchor, List<Object> tuple)Emits a new tuple to a specific stream with a single anchor.List<Integer>OutputCollector. emit(Tuple anchor, List<Object> tuple)Emits a new tuple to the default stream anchored on a single tuple.voidOutputCollector. emitDirect(int taskId, String streamId, Tuple anchor, List<Object> tuple)Emits a tuple directly to the specified task id on the specified stream.voidOutputCollector. emitDirect(int taskId, Tuple anchor, List<Object> tuple)Emits a tuple directly to the specified task id on the default stream.voidIBolt. execute(Tuple input)Process a single tuple of input.voidShellBolt. execute(Tuple input)voidIOutputCollector. fail(Tuple input)voidOutputCollector. fail(Tuple input)voidIOutputCollector. resetTimeout(Tuple input)voidOutputCollector. resetTimeout(Tuple input)Resets the message timeout for any tuple trees to which the given tuple belongs.Method parameters in org.apache.storm.task with type arguments of type Tuple Modifier and Type Method Description List<Integer>IOutputCollector. emit(String streamId, Collection<Tuple> anchors, List<Object> tuple)Returns the task ids that received the tuples.List<Integer>OutputCollector. emit(String streamId, Collection<Tuple> anchors, List<Object> tuple)List<Integer>OutputCollector. emit(Collection<Tuple> anchors, List<Object> tuple)Emits a new tuple to the default stream anchored on a group of input tuples.voidIOutputCollector. emitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple)voidOutputCollector. emitDirect(int taskId, String streamId, Collection<Tuple> anchors, List<Object> tuple)voidOutputCollector. emitDirect(int taskId, Collection<Tuple> anchors, List<Object> tuple)Emits a tuple directly to the specified task id on the default stream. -
Uses of Tuple in org.apache.storm.testing
Methods in org.apache.storm.testing with parameters of type Tuple Modifier and Type Method Description voidIdentityBolt. execute(Tuple input, BasicOutputCollector collector)voidNonRichBoltTracker. execute(Tuple input)voidPrepareBatchBolt. execute(Tuple input, BasicOutputCollector collector)voidTestAggregatesCounter. execute(Tuple input)voidTestConfBolt. execute(Tuple input, BasicOutputCollector collector)voidTestEventOrderCheckBolt. execute(Tuple input)voidTestGlobalCount. execute(Tuple input)voidTestPlannerBolt. execute(Tuple input)voidTestWordCounter. execute(Tuple input, BasicOutputCollector collector)voidTupleCaptureBolt. execute(Tuple input)protected StringTestWordBytesCounter. getTupleValue(Tuple t, int idx)protected StringTestWordCounter. getTupleValue(Tuple t, int idx) -
Uses of Tuple in org.apache.storm.topology
Methods in org.apache.storm.topology that return types with arguments of type Tuple Modifier and Type Method Description protected WindowLifecycleListener<Tuple>PersistentWindowedBoltExecutor. newWindowLifecycleListener()protected WindowLifecycleListener<Tuple>StatefulWindowedBoltExecutor. newWindowLifecycleListener()protected WindowLifecycleListener<Tuple>WindowedBoltExecutor. newWindowLifecycleListener()Methods in org.apache.storm.topology with parameters of type Tuple Modifier and Type Method Description voidBaseStatefulBoltExecutor. execute(Tuple input)voidBasicBoltExecutor. execute(Tuple input)voidIBasicBolt. execute(Tuple input, BasicOutputCollector collector)Process the input tuple and optionally emit new tuples based on the input tuple.voidIStatefulBolt. execute(Tuple input)Analogue to bolt function.voidPersistentWindowedBoltExecutor. execute(Tuple input)voidStatefulWindowedBoltExecutor. execute(Tuple input)voidWindowedBoltExecutor. execute(Tuple input)longTupleFieldTimestampExtractor. extractTimestamp(Tuple tuple)protected abstract voidBaseStatefulBoltExecutor. handleCheckpoint(Tuple checkpointTuple, CheckPointState.Action action, long txid)Sub-classes can implement the logic for handling checkpoint tuple.protected voidCheckpointTupleForwarder. handleCheckpoint(Tuple checkpointTuple, CheckPointState.Action action, long txid)Forwards the checkpoint tuple downstream.protected voidStatefulBoltExecutor. handleCheckpoint(Tuple checkpointTuple, CheckPointState.Action action, long txid)protected abstract voidBaseStatefulBoltExecutor. handleTuple(Tuple input)Sub-classes can implement the logic for handling the tuple.protected voidCheckpointTupleForwarder. handleTuple(Tuple input)Hands off tuple to the wrapped bolt to execute.protected voidStatefulBoltExecutor. handleTuple(Tuple input)voidBasicOutputCollector. resetTimeout(Tuple tuple)Resets the message timeout for any tuple trees to which the given tuple belongs.voidIBasicOutputCollector. resetTimeout(Tuple tuple)voidBasicOutputCollector. setContext(Tuple inputTuple)Method parameters in org.apache.storm.topology with type arguments of type Tuple Modifier and Type Method Description protected voidWindowedBoltExecutor. boltExecute(Supplier<Iterator<Tuple>> tuples, Supplier<Iterator<Tuple>> newTuples, Supplier<Iterator<Tuple>> expiredTuples, Long timestamp)protected voidWindowedBoltExecutor. boltExecute(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples, Long timestamp)protected voidWindowedBoltExecutor. doPrepare(Map<String,Object> topoConf, TopologyContext context, OutputCollector collector, Collection<Event<Tuple>> queue, boolean stateful)BoltDeclarerTopologyBuilder. setBolt(String id, SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer, Number parallelismHint, String... fields)Define a new bolt in this topology.BoltDeclarerTopologyBuilder. setBolt(String id, SerializableBiConsumer<Tuple,BasicOutputCollector> biConsumer, String... fields)Define a new bolt in this topology.BoltDeclarerTopologyBuilder. setBolt(String id, SerializableConsumer<Tuple> consumer)Define a new bolt in this topology.BoltDeclarerTopologyBuilder. setBolt(String id, SerializableConsumer<Tuple> consumer, Number parallelismHint)Define a new bolt in this topology. -
Uses of Tuple in org.apache.storm.topology.base
Methods in org.apache.storm.topology.base with parameters of type Tuple Modifier and Type Method Description voidBaseTickTupleAwareRichBolt. execute(Tuple tuple)Process a single tuple of input.protected voidBaseTickTupleAwareRichBolt. onTickTuple(Tuple tuple)Process a single tick tuple of input.protected abstract voidBaseTickTupleAwareRichBolt. process(Tuple tuple)Process a single non-tick tuple of input. -
Uses of Tuple in org.apache.storm.trident.planner
Methods in org.apache.storm.trident.planner with parameters of type Tuple Modifier and Type Method Description voidSubtopologyBolt. execute(BatchInfo batchInfo, Tuple tuple)voidSubtopologyBolt.InitialReceiver. receive(ProcessorContext context, Tuple tuple) -
Uses of Tuple in org.apache.storm.trident.spout
Methods in org.apache.storm.trident.spout with parameters of type Tuple Modifier and Type Method Description voidTridentSpoutCoordinator. execute(Tuple tuple, BasicOutputCollector collector)voidTridentSpoutExecutor. execute(BatchInfo info, Tuple input) -
Uses of Tuple in org.apache.storm.trident.topology
Methods in org.apache.storm.trident.topology with parameters of type Tuple Modifier and Type Method Description voidITridentBatchBolt. execute(BatchInfo batchInfo, Tuple tuple)voidTridentBoltExecutor. execute(Tuple tuple) -
Uses of Tuple in org.apache.storm.trident.tuple
Methods in org.apache.storm.trident.tuple with parameters of type Tuple Modifier and Type Method Description TridentTupleTridentTupleView.RootFactory. create(Tuple parent) -
Uses of Tuple in org.apache.storm.tuple
Classes in org.apache.storm.tuple that implement Tuple Modifier and Type Class Description classTupleImplFields in org.apache.storm.tuple declared as Tuple Modifier and Type Field Description TupleAddressedTuple. tupleMethods in org.apache.storm.tuple that return Tuple Modifier and Type Method Description TupleAddressedTuple. getTuple()Constructors in org.apache.storm.tuple with parameters of type Tuple Constructor Description AddressedTuple(int dest, Tuple tuple)TupleImpl(Tuple t) -
Uses of Tuple in org.apache.storm.utils
Methods in org.apache.storm.utils that return types with arguments of type Tuple Modifier and Type Method Description List<Tuple>BatchHelper. getBatchTuples()Methods in org.apache.storm.utils with parameters of type Tuple Modifier and Type Method Description voidBatchHelper. addBatch(Tuple tuple)static booleanTupleUtils. isTick(Tuple tuple)booleanBatchHelper. shouldHandle(Tuple tuple) -
Uses of Tuple in org.apache.storm.windowing
Methods in org.apache.storm.windowing that return types with arguments of type Tuple Modifier and Type Method Description List<Tuple>TupleWindowImpl. get()List<Tuple>TupleWindowIterImpl. get()List<Tuple>TupleWindowImpl. getExpired()List<Tuple>TupleWindowIterImpl. getExpired()Iterator<Tuple>TupleWindowIterImpl. getIter()List<Tuple>TupleWindowImpl. getNew()List<Tuple>TupleWindowIterImpl. getNew()Methods in org.apache.storm.windowing with parameters of type Tuple Modifier and Type Method Description longTimestampExtractor. extractTimestamp(Tuple tuple)Return the tuple timestamp indicating the time when the event happened.Constructor parameters in org.apache.storm.windowing with type arguments of type Tuple Constructor Description TupleWindowImpl(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples)TupleWindowImpl(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples, Long startTimestamp, Long endTimestamp)TupleWindowIterImpl(Supplier<Iterator<Tuple>> tuplesIt, Supplier<Iterator<Tuple>> newTuplesIt, Supplier<Iterator<Tuple>> expiredTuplesIt, Long startTimestamp, Long endTimestamp)
-