class IncrTrackerJobQueue[Data <: Identifiable[Data]] extends JobQueue[Data]
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
- Alphabetic
- By Inheritance
- IncrTrackerJobQueue
- JobQueue
- Connector
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Instance Constructors
- new IncrTrackerJobQueue()
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
def
+(other: String): String
- Implicit
- This member is added by an implicit conversion from IncrTrackerJobQueue[Data] to any2stringadd[IncrTrackerJobQueue[Data]] performed by method any2stringadd in scala.Predef.
- Definition Classes
- any2stringadd
-
def
+>(connector: Connector[Data]): Connector[Data]
- Definition Classes
- Connector
-
def
->[B](y: B): (IncrTrackerJobQueue[Data], B)
- Implicit
- This member is added by an implicit conversion from IncrTrackerJobQueue[Data] to ArrowAssoc[IncrTrackerJobQueue[Data]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc
- Annotations
- @inline()
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
var
downstreamConnectorOpt: Option[Connector[Data]]
- Definition Classes
- Connector
-
def
ensuring(cond: (IncrTrackerJobQueue[Data]) ⇒ Boolean, msg: ⇒ Any): IncrTrackerJobQueue[Data]
- Implicit
- This member is added by an implicit conversion from IncrTrackerJobQueue[Data] to Ensuring[IncrTrackerJobQueue[Data]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: (IncrTrackerJobQueue[Data]) ⇒ Boolean): IncrTrackerJobQueue[Data]
- Implicit
- This member is added by an implicit conversion from IncrTrackerJobQueue[Data] to Ensuring[IncrTrackerJobQueue[Data]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean, msg: ⇒ Any): IncrTrackerJobQueue[Data]
- Implicit
- This member is added by an implicit conversion from IncrTrackerJobQueue[Data] to Ensuring[IncrTrackerJobQueue[Data]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
def
ensuring(cond: Boolean): IncrTrackerJobQueue[Data]
- Implicit
- This member is added by an implicit conversion from IncrTrackerJobQueue[Data] to Ensuring[IncrTrackerJobQueue[Data]] performed by method Ensuring in scala.Predef.
- Definition Classes
- Ensuring
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
-
def
formatted(fmtstr: String): String
- Implicit
- This member is added by an implicit conversion from IncrTrackerJobQueue[Data] to StringFormat[IncrTrackerJobQueue[Data]] performed by method StringFormat in scala.Predef.
- Definition Classes
- StringFormat
- Annotations
- @inline()
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
getDownstream(): Connector[Data]
- Definition Classes
- Connector
- def getStatusMap(): DataMultiMap[Status, Data]
-
def
getUpstream(): Connector[Data]
- Definition Classes
- Connector
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- def iMap: DataStore[Data]
- var iMapOpt: Option[DataStore[Data]]
- def init(conf: PipeConfig): Unit
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
-
def
persist(dataStore: DataStore[Data]): Unit
This is the section of the code that figures out what data from the Input Data Store to actually send down.
This is the section of the code that figures out what data from the Input Data Store to actually send down. To do this, it first reconstructs the status map from the TextFileDataMap backup of the status map and the version of the platform taken from registerPlatform. After reconstructing the status map, it then takes the data from the data store that needs to be resent (due to a status of being Not Done or Modified or of Error, and resends that information.
- dataStore
The input data store.
- Definition Classes
- IncrTrackerJobQueue → Connector
-
var
queue: DataQueue[Data]
- Definition Classes
- JobQueue
-
def
registerDownstreamConnector(connector: Connector[Data]): Unit
- Definition Classes
- Connector
-
def
registerPlatform(platform: Platform): Unit
This registers that platform used the by connector, and sets the version of this connector to the version of the platform.
This registers that platform used the by connector, and sets the version of this connector to the version of the platform.
- platform
The platform to be registered by the connector.
- Definition Classes
- IncrTrackerJobQueue → Connector
-
def
registerUpstreamConnector(connector: Connector[Data]): Unit
- Definition Classes
- Connector
-
def
reportUp(status: Status, data: Seq[Data]): Unit
- Definition Classes
- IncrTrackerJobQueue → JobQueue → Connector
-
def
reportUp(status: Status, data: Data): Unit
- Definition Classes
- Connector
-
def
retrieveUp(): Seq[Data]
- Definition Classes
- IncrTrackerJobQueue → JobQueue → Connector
-
def
sendDown(data: Seq[Data]): Unit
- Definition Classes
- IncrTrackerJobQueue → JobQueue → Connector
-
def
sendDown(data: Data): Unit
- Definition Classes
- Connector
-
def
sendDownModified(data: Seq[Data]): Unit
- Definition Classes
- IncrTrackerJobQueue → JobQueue → Connector
-
def
sendDownModified(data: Data): Unit
- Definition Classes
- Connector
- def signalDown(): Unit
- def size(): Int
- val statusMap: DataMultiMap[Status, Data]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
- def terminate(): Unit
- def textMap: TextFileDataMap
- var textMapOpt: Option[TextFileDataMap]
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
var
upstreamConnectorOpt: Option[Connector[Data]]
- Definition Classes
- Connector
- var ver: Option[String]
-
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( ... )
-
def
→[B](y: B): (IncrTrackerJobQueue[Data], B)
- Implicit
- This member is added by an implicit conversion from IncrTrackerJobQueue[Data] to ArrowAssoc[IncrTrackerJobQueue[Data]] performed by method ArrowAssoc in scala.Predef.
- Definition Classes
- ArrowAssoc