object KafkaWrapperFlows
Mid-Level Kafka Interface: Defines the akka sources, flows, and sinks, which the high-level interface (KafkaConnectors) builds executable wrappers for the StatelessComponents with.
- Alphabetic
- By Inheritance
- KafkaWrapperFlows
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Type Members
- type Environment = KafkaExecutorEnvironment
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
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... ) @native()
-
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 flowCheck[T]: Flow[Tracked[T], T, NotUsed]
- def flowCheckMulti[T]: Flow[Tracked[Seq[T]], T, NotUsed]
- def flowLogIn[T <: Tracked[_]](implicit env: Environment): Flow[T, T, NotUsed]
- def flowLogOut[T <: Tracked[_]](implicit env: Environment): Flow[T, T, NotUsed]
- def flowRespond[T[X] <: Tracked[X], In, Out](component: StatelessComponent[In, Out]): Flow[T[In], T[Out], NotUsed]
- def flowRespondAll[T[X] <: Tracked[X], In, Out](component: StatelessComponent[In, Out]): Flow[T[Seq[In]], T[Seq[Out]], NotUsed]
-
def
flowSequencer[T[X] <: Tracked[X]]: Flow[T[PiiHistory], T[Seq[AnyMsg]], NotUsed]
Synchronous handling intended for consuming a single
PiiHistory
partition.Synchronous handling intended for consuming a single
PiiHistory
partition. Blocks until a ReduceRequest is released by receiving both a PiiUpdate *and* at least one SequenceRequest. All SequenceRequests received are responded to, even if this requires sending a ReduceRequest for a PiiUpdate that contains no SequenceRequests.- returns
Akka flow capable of sequencing a single
PiiHistory
partition into a ReduceRequest stream.
- def flowWaitFuture[T[X] <: Tracked[X], Msg](parallelism: Int)(implicit env: Environment): Flow[T[Future[Msg]], T[Msg], NotUsed]
-
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()
- def run[T](source: Source[T, Control], sink: Sink[T, Future[Done]])(implicit env: Environment): DrainingControl[Done]
- def sinkPlain(implicit env: Environment): Sink[AnyMsg, Future[Done]]
-
def
srcAll(implicit env: Environment): Source[CommitTracked[AnyMsg], Control]
Kafka Consumers for each topic merged into a single Akka source.
Kafka Consumers for each topic merged into a single Akka source.
- returns
Merged source for all topics.
-
def
srcAssignment[T[X] <: Tracked[X]](implicit env: Environment, f: TrackedSource[T]): Source[T[Assignment], Control]
Kafka Consumer for the
Assignment
topic.Kafka Consumer for the
Assignment
topic.- returns
Akka source containing messages published to the
Assignment
topic.
-
def
srcPiiHistory[T[X] <: Tracked[X]](implicit env: Environment, f: TrackedSource[T]): Source[T[PiiHistory], Control]
Kafka Consumer for the
PiiHistory
topic.Kafka Consumer for the
PiiHistory
topic. Exposes the individual partition sources so they handled individually byflowPartition
argument.- returns
Akka source containing the processed output messages of each partition.
-
def
srcReduceRequest[T[X] <: Tracked[X]](implicit env: Environment, f: TrackedSource[T]): Source[T[ReduceRequest], Control]
Kafka Consumer for the
ReduceRequest
topic.Kafka Consumer for the
ReduceRequest
topic.- returns
Akka source containing messages published to the
ReduceRequest
topic.
-
def
srcResult[T[X] <: Tracked[X]](groupId: String)(implicit env: Environment, f: TrackedSource[T]): Source[T[PiiLog], Control]
Kafka Consumer for the
Result
topic.Kafka Consumer for the
Result
topic. Configurable Group Id to allow control of the starting point of consumption.- groupId
GroupId for the Kafka Consumer.
- returns
Akka source containing messages published to the
Results
topic.
-
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()