abstract class Tracked[Value] extends AnyRef
Superclass wrapper around objects processed from objects in Kafka topics. The wrapper contains the information necessary to update to consume the input messages when the Tracked wrapper is eventually "Produced" to an "output" Kafka topic.
- Value
The type of the object contained by the tracking wrapper.
- Alphabetic
- By Inheritance
- Tracked
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
- new Tracked()
Abstract Value Members
-
abstract
def
fold[NewValue](fn: (Value, NewValue) ⇒ Value)(other: Tracked[NewValue]): Tracked[Value]
Apply a fold to 2 messages so that their tracking information can be combined.
Apply a fold to 2 messages so that their tracking information can be combined.
- NewValue
The type of the wrapped object of the other tracked object.
- fn
2 argument fold function to apply to the wrapped types.
- other
The other tracked type to merge.
- returns
A new Tracked object with the result of
fn
on each wrapped object which contains the merged tracking information.
- Attributes
- protected
-
abstract
def
map[NewValue](fn: (Value) ⇒ NewValue): Tracked[NewValue]
Modify the wrapped
Value
by the functionfn
and preserve the tracking information.Modify the wrapped
Value
by the functionfn
and preserve the tracking information.- NewValue
The result type of the function.
- fn
A function to apply to the wrapped
Value
.- returns
A new Tracked type with the same tracking, containing the new value.
- Attributes
- protected
- abstract def value: Value
Concrete Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- def ->[B](y: B): (Tracked[Value], B)
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- def ensuring(cond: (Tracked[Value]) ⇒ Boolean, msg: ⇒ Any): Tracked[Value]
- def ensuring(cond: (Tracked[Value]) ⇒ Boolean): Tracked[Value]
- def ensuring(cond: Boolean, msg: ⇒ Any): Tracked[Value]
- def ensuring(cond: Boolean): Tracked[Value]
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- def formatted(fmtstr: String): String
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
- def →[B](y: B): (Tracked[Value], B)