Type Members

1.  case class Accumulator [Data](limit: Int = 50) extends Connector[Data] with Product with Serializable

   Created by edmundlam on 8/10/17.

2.  abstract class ActorConnector [Data] extends Connector[Data]
3.  class ActorConnectorActor [Data] extends Actor
4.  class ActorIncrTrackerJobQueue [Data <: Identifiable[Data]] extends ActorConnector[Data]
5.  abstract class Adaptor [Source, Target] extends Connector[Target]

   Created by edmundlam on 8/30/17.

6.  class IgnoreKeyAdaptor [Key, Source] extends Adaptor[Source, (Key, Source)]
7.  class IncrTrackerJobQueue [Data <: Identifiable[Data]] extends JobQueue[Data]

   This is a Connector that has a status map attached to it.

   This is a Connector that has a status map attached to it. As of right now, the status map is InMemDataMultiMap, along with a TextFileDataMap as a backup when the pipeline closes out since it is guaranteed that the file system is there on every system. However, eventually I would like to have this map be of the same medium as the Data Store chosen just in case that isn't actually a possibility and/or to save computation power if the status map is heavily used.

   Data

   The type of data that's being sent down the pipeline from this connector. In the case of the example, it's bigglue.examples.GitID for gitID, and bigglue.examples.GitCommitInfo for commitInfoMap. Needs to be of type Identifiable

8.  class JobQueue [Data] extends Connector[Data]

   This is a Connector that's the superclass to IncrTrackerJobQueue.

   This is a Connector that's the superclass to IncrTrackerJobQueue. It acts exactly the same, with the exception that there's no status map attached to it.

   Data

   The type of data that's being sent down the pipeline from this connector. In the case of the example, it's bigglue.examples.GitRepo for clonedMap.

9.  case class OpenTheFloodGates (send: Int = 0) extends Product with Serializable

   Created by chanceroberts on 11/16/17.

10.  class ParallelConnectors [Data] extends Connector[Data]

    Created by edmundlam on 8/13/17.

11.  case class PlatformStub [Data](platform: Platform) extends Connector[Data] with Product with Serializable

    This is a wrapper for the platform as a connector.

    This is a wrapper for the platform as a connector. This is only meant to be a downstream connector to the connectors in between the data store and the platform. In the terms of the example, this is

    Data

    The type of the data of the input that is sent into the platform.

    platform

    The platform that is connected to the various connectors.

12.  case class SequencedConnectors [Data](headConnector: Connector[Data], endConnector: Connector[Data]) extends Connector[Data] with Product with Serializable

    Created by edmundlam on 8/9/17.

13.  class WaitingActor [Data] extends Actor
14.  class WaitingConnector [Data] extends Connector[Data]