object Transformer
- Source
- Transformer.scala
- Alphabetic
- By Inheritance
- Transformer
- AnyRef
- Any
- Hide All
- Show All
- Public
- Protected
Type Members
- trait BoundHandler[-In] extends HandlerWrite[In]
A
Handler
which has been bound to some "downstream" receiver of outputs, so that thepush
andfinish
methods will delegate to that downstream rather than requiring a downstream receiver to be passed as a method parameter.A
Handler
which has been bound to some "downstream" receiver of outputs, so that thepush
andfinish
methods will delegate to that downstream rather than requiring a downstream receiver to be passed as a method parameter.- In
The handler's input type
- trait Handler[-In, +Out] extends AnyRef
An internally-mutable "handler" that performs a Transformer's input/output logic.
- trait HandlerLinkage[+Out] extends AnyRef
Specialization for a
BoundHandler
whose "downstream" can be changed at will.Specialization for a
BoundHandler
whose "downstream" can be changed at will.- Out
The handler's output type
- trait HandlerWrite[-Out] extends AnyRef
Represents the "downstream" of a handler.
Represents the "downstream" of a handler. Whenever a handler is told to
push
orfinish
, it uses a HandlerWrite to receive its output. A HandlerWrite could be an object that collects the values to a buffer which you can manually inspect later (see BoundHandler.ToBuilder), or a wrapper around some secondary Handler i.e. the next transformation step.- Out
The output event type from the upstream handler, which acts as the input to this receiver
- trait Stateless[-In, +Out] extends Transformer[In, Out] with Handler[In, Out]
A stateless transformer acts as its own handler
A stateless transformer acts as its own handler
- In
The incoming event type
- Out
The outgoing event type
- implicit final class TransformerKVParsingOps[In, K, V] extends AnyVal
Extra methods for transformers whose
Out
type is a Tuple2 - implicit final class TransformerParsingOps[In, A] extends AnyVal
Extra transformer methods that had to be defined separately from the trait due to either
In
orOut
needing to be invariant.
Value Members
- final def !=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- final def ##: Int
- Definition Classes
- AnyRef → Any
- final def ==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
- def apply[In]: TransformerApplyWithBoundInput[In]
Convenience for creating transformers whose input type is bound to
In
.Convenience for creating transformers whose input type is bound to
In
.This is particularly nice when the
Out
type can be inferred by the compiler, e.g.Transformer[Int].op(i => Emit.one(i * 2)) // versus Transformer.op[Int, Int](i => Emit.one(i * 2))
- final def asInstanceOf[T0]: T0
- Definition Classes
- Any
- def clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.CloneNotSupportedException]) @native()
- def collect[In, Out](pf: PartialFunction[In, Out]): Transformer[In, Out]
- def drop[In](n: Int): Transformer[In, In]
- def dropWhile[In](f: (In) => Boolean): Transformer[In, In]
- final def eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
- def equals(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef → Any
- def filter[In](f: (In) => Boolean): Transformer[In, In]
- def finalize(): Unit
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.Throwable])
- final def getClass(): Class[_ <: AnyRef]
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native()
- def identity[In]: Transformer[In, In]
- final def isInstanceOf[T0]: Boolean
- Definition Classes
- Any
- def map[In, Out](f: (In) => Out): Transformer[In, Out]
- def mapFlatten[In, Out](f: (In) => Iterable[Out]): Transformer[In, Out]
- 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()
- def spacFrame[In](elems: SpacTraceElement*): Transformer[In, In]
- final def synchronized[T0](arg0: => T0): T0
- Definition Classes
- AnyRef
- def take[In](n: Int): Transformer[In, In]
- def takeWhile[In](f: (In) => Boolean): Transformer[In, In]
- def tap[In](f: (In) => Unit): Transformer[In, In]
- def toString(): String
- Definition Classes
- AnyRef → Any
- final def wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException])
- final def wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws(classOf[java.lang.InterruptedException]) @native()
- object BoundHandler
- object Handler