Configuration for application-specific event serializers.
Spark streaming context.
Creates a Spark DStream[DurableEvent]
from an event log that is managed by a ReplicationEndpoint
under given logName
.
Creates a Spark DStream[DurableEvent]
from an event log that is managed by a ReplicationEndpoint
under given logName
. The stream is updated with both, replayed events starting at fromSequenceNr
and live events that have been written to the event log after the streaming context
has been started.
Unique, application-defined stream id.
Replication endpoint host.
Replication endpoint port.
Event log name.
Remote actor system name.
Sequence number from where to start the stream.
Storage level of the RDDs in the event stream.
Eventuate Spark adapter for stream processing events from event logs.