Package org.apache.storm.kafka.spout
Class KafkaTuple
- All Implemented Interfaces:
- Serializable,- Cloneable,- Iterable<Object>,- Collection<Object>,- List<Object>,- RandomAccess
A list of Values in a tuple that can be routed 
 to a given stream: 
RecordTranslator.apply(org.apache.kafka.clients.consumer.ConsumerRecord<K, V>).- See Also:
- 
Field SummaryFields inherited from class java.util.AbstractListmodCount
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionSets the target stream of this Tuple.Methods inherited from class java.util.ArrayListadd, add, addAll, addAll, clear, clone, contains, ensureCapacity, equals, forEach, get, hashCode, indexOf, isEmpty, iterator, lastIndexOf, listIterator, listIterator, remove, remove, removeAll, removeIf, removeRange, replaceAll, retainAll, set, size, sort, spliterator, subList, toArray, toArray, trimToSizeMethods inherited from class java.util.AbstractCollectioncontainsAll, toStringMethods inherited from class java.lang.Objectfinalize, getClass, notify, notifyAll, wait, wait, waitMethods inherited from interface java.util.CollectionparallelStream, stream, toArrayMethods inherited from interface java.util.ListcontainsAll
- 
Constructor Details- 
KafkaTuplepublic KafkaTuple()
- 
KafkaTuple
 
- 
- 
Method Details- 
routedToSets the target stream of this Tuple.- Parameters:
- stream- The target stream
- Returns:
- This
 
- 
getStream
 
-