Instance Constructors
-
new
KafkaStream
(queue: BlockingQueue[FetchedDataChunk], consumerTimeoutMs: Int, keyDecoder: Decoder[K], valueDecoder: Decoder[V], clientId: String)
Value Members
-
def
!=
(arg0: AnyRef): Boolean
-
def
!=
(arg0: Any): Boolean
-
def
##
(): Int
-
def
++
[B >: MessageAndMetadata[K, V], That]
(that: TraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That
-
def
++
[B >: MessageAndMetadata[K, V], That]
(that: GenTraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That
-
def
++:
[B >: MessageAndMetadata[K, V], That]
(that: Traversable[B])(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That
-
def
++:
[B >: MessageAndMetadata[K, V], That]
(that: TraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That
-
def
/:
[B]
(z: B)(op: (B, MessageAndMetadata[K, V]) ⇒ B): B
-
def
/:\
[A1 >: MessageAndMetadata[K, V]]
(z: A1)(op: (A1, A1) ⇒ A1): A1
-
def
:\
[B]
(z: B)(op: (MessageAndMetadata[K, V], B) ⇒ B): B
-
def
==
(arg0: AnyRef): Boolean
-
def
==
(arg0: Any): Boolean
-
def
addString
(b: StringBuilder): StringBuilder
-
def
addString
(b: StringBuilder, sep: String): StringBuilder
-
def
addString
(b: StringBuilder, start: String, sep: String, end: String): StringBuilder
-
def
aggregate
[B]
(z: B)(seqop: (B, MessageAndMetadata[K, V]) ⇒ B, combop: (B, B) ⇒ B): B
-
def
asInstanceOf
[T0]
: T0
-
def
canEqual
(that: Any): Boolean
-
def
clear
(): Unit
-
val
clientId
: String
-
def
clone
(): AnyRef
-
def
collect
[B, That]
(pf: PartialFunction[MessageAndMetadata[K, V], B])(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That
-
def
collectFirst
[B]
(pf: PartialFunction[MessageAndMetadata[K, V], B]): Option[B]
-
def
companion
: GenericCompanion[Iterable]
-
def
copyToArray
[B >: MessageAndMetadata[K, V]]
(xs: Array[B], start: Int, len: Int): Unit
-
def
copyToArray
[B >: MessageAndMetadata[K, V]]
(xs: Array[B]): Unit
-
def
copyToArray
[B >: MessageAndMetadata[K, V]]
(xs: Array[B], start: Int): Unit
-
def
copyToBuffer
[B >: MessageAndMetadata[K, V]]
(dest: Buffer[B]): Unit
-
def
count
(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Int
-
-
def
dropRight
(n: Int): Iterable[MessageAndMetadata[K, V]]
-
-
def
eq
(arg0: AnyRef): Boolean
-
def
equals
(arg0: Any): Boolean
-
def
exists
(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Boolean
-
-
-
def
finalize
(): Unit
-
-
def
flatMap
[B, That]
(f: (MessageAndMetadata[K, V]) ⇒ GenTraversableOnce[B])(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That
-
def
flatten
[B]
(implicit asTraversable: (MessageAndMetadata[K, V]) ⇒ TraversableOnce[B]): Traversable[B]
-
def
fold
[A1 >: MessageAndMetadata[K, V]]
(z: A1)(op: (A1, A1) ⇒ A1): A1
-
def
foldLeft
[B]
(z: B)(op: (B, MessageAndMetadata[K, V]) ⇒ B): B
-
def
foldRight
[B]
(z: B)(op: (MessageAndMetadata[K, V], B) ⇒ B): B
-
def
forall
(p: (MessageAndMetadata[K, V]) ⇒ Boolean): Boolean
-
def
foreach
[U]
(f: (MessageAndMetadata[K, V]) ⇒ U): Unit
-
def
genericBuilder
[B]
: Builder[B, Iterable[B]]
-
def
getClass
(): java.lang.Class[_]
-
-
def
grouped
(size: Int): Iterator[Iterable[MessageAndMetadata[K, V]]]
-
def
hasDefiniteSize
: Boolean
-
def
hashCode
(): Int
-
-
-
-
def
inits
: Iterator[Iterable[MessageAndMetadata[K, V]]]
-
def
isEmpty
: Boolean
-
def
isInstanceOf
[T0]
: Boolean
-
def
isTraversableAgain
: Boolean
-
-
-
-
def
map
[B, That]
(f: (MessageAndMetadata[K, V]) ⇒ B)(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That
-
-
-
-
-
def
mkString
: String
-
def
mkString
(sep: String): String
-
def
mkString
(start: String, sep: String, end: String): String
-
def
ne
(arg0: AnyRef): Boolean
-
-
def
nonEmpty
: Boolean
-
def
notify
(): Unit
-
def
notifyAll
(): Unit
-
-
-
-
def
product
[B >: MessageAndMetadata[K, V]]
(implicit num: Numeric[B]): B
-
def
reduce
[A1 >: MessageAndMetadata[K, V]]
(op: (A1, A1) ⇒ A1): A1
-
-
-
def
reduceOption
[A1 >: MessageAndMetadata[K, V]]
(op: (A1, A1) ⇒ A1): Option[A1]
-
-
-
-
-
def
sameElements
[B >: MessageAndMetadata[K, V]]
(that: Iterable[B]): Boolean
-
def
sameElements
[B >: MessageAndMetadata[K, V]]
(that: GenIterable[B]): Boolean
-
def
scan
[B >: MessageAndMetadata[K, V], That]
(z: B)(op: (B, B) ⇒ B)(implicit cbf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That
-
def
scanLeft
[B, That]
(z: B)(op: (B, MessageAndMetadata[K, V]) ⇒ B)(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That
-
def
scanRight
[B, That]
(z: B)(op: (MessageAndMetadata[K, V], B) ⇒ B)(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], B, That]): That
-
-
def
size
: Int
-
def
slice
(from: Int, until: Int): Iterable[MessageAndMetadata[K, V]]
-
def
sliding
[B >: MessageAndMetadata[K, V]]
(size: Int, step: Int): Iterator[Iterable[MessageAndMetadata[K, V]]]
-
-
-
-
def
stringPrefix
: String
-
def
sum
[B >: MessageAndMetadata[K, V]]
(implicit num: Numeric[B]): B
-
def
synchronized
[T0]
(arg0: ⇒ T0): T0
-
-
def
tails
: Iterator[Iterable[MessageAndMetadata[K, V]]]
-
-
def
takeRight
(n: Int): Iterable[MessageAndMetadata[K, V]]
-
-
def
thisCollection
: Iterable[MessageAndMetadata[K, V]]
-
def
toArray
[B >: MessageAndMetadata[K, V]]
(implicit arg0: ClassManifest[B]): Array[B]
-
def
toBuffer
[B >: MessageAndMetadata[K, V]]
: Buffer[B]
-
-
def
toIndexedSeq
[B >: MessageAndMetadata[K, V]]
: IndexedSeq[B]
-
-
-
-
def
toMap
[T, U]
(implicit ev: <:<[MessageAndMetadata[K, V], (T, U)]): Map[T, U]
-
-
-
-
def
toString
(): String
-
def
toTraversable
: Traversable[MessageAndMetadata[K, V]]
-
def
transpose
[B]
(implicit asTraversable: (MessageAndMetadata[K, V]) ⇒ TraversableOnce[B]): Traversable[Traversable[B]]
-
def
unzip
[A1, A2]
(implicit asPair: (MessageAndMetadata[K, V]) ⇒ (A1, A2)): (Iterable[A1], Iterable[A2])
-
def
unzip3
[A1, A2, A3]
(implicit asTriple: (MessageAndMetadata[K, V]) ⇒ (A1, A2, A3)): (Iterable[A1], Iterable[A2], Iterable[A3])
-
-
-
def
wait
(): Unit
-
def
wait
(arg0: Long, arg1: Int): Unit
-
def
wait
(arg0: Long): Unit
-
-
def
zip
[A1 >: MessageAndMetadata[K, V], B, That]
(that: Iterable[B])(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], (A1, B), That]): That
-
def
zip
[A1 >: MessageAndMetadata[K, V], B, That]
(that: GenIterable[B])(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], (A1, B), That]): That
-
def
zipAll
[B, A1 >: MessageAndMetadata[K, V], That]
(that: Iterable[B], thisElem: A1, thatElem: B)(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], (A1, B), That]): That
-
def
zipAll
[B, A1 >: MessageAndMetadata[K, V], That]
(that: GenIterable[B], thisElem: A1, thatElem: B)(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], (A1, B), That]): That
-
def
zipWithIndex
[A1 >: MessageAndMetadata[K, V], That]
(implicit bf: CanBuildFrom[Iterable[MessageAndMetadata[K, V]], (A1, Int), That]): That
Inherited from Equals
Inherited from AnyRef
Inherited from Any