Commit 881ebf5e authored by Steven Pisarski's avatar Steven Pisarski

More actor refactoring but failed to get the actors running in the spark...

More actor refactoring but failed to get the actors running in the spark cluster's remote actor system. To scale, we may have to introduce an external actor system that this code should support but it has not been tested.
parent 1068eb4b
......@@ -3,8 +3,7 @@ package com.cablelabs.eventgen
import java.util.Date
import _root_.akka.actor.Address
import com.cablelabs.eventgen.akka.GeneratorActors
import com.cablelabs.eventgen.akka.GeneratorActors.Event
import com.cablelabs.eventgen.akka.{Event, GeneratorActors}
import com.cablelabs.eventgen.algorithm.Model
import com.cablelabs.eventgen.model.{InputDefinition, OutputDefinition}
import com.typesafe.scalalogging.slf4j.Logger
......
......@@ -5,7 +5,6 @@ import java.util.Date
import akka.actor.Props
import akka.camel.CamelMessage
import com.cablelabs.eventgen.akka.GeneratorActors.{DimTimeEvent, ScheduleAndNotify}
import com.cablelabs.eventgen.model._
import com.cablelabs.eventgen.{Notifier, SparkTestUtils, TestActors}
import org.apache.spark.SparkEnv
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment