Alcaudon

Streaming data processing platform

trait Computation
    extends ProduceAPI
    with TimerAPI
    with StateAPI
    with SerializationAPI
    with RuntimeContext {
  var id = UUID.randomUUID().toString
  val inputStreams: List[String] = List.empty
  val outputStreams: List[String] = List.empty
  private var subscribedStreams: Set[String] = Set.empty

  def processRecord(record: Record): Unit
  def processTimer(timer: Timer): Unit

  def setId(externalId: String): Unit = id = externalId

  def setup(runtimeContext: AbstractRuntimeContext): Unit = {
    context = runtimeContext
  }
}