com.twitter.summingbird

planner

package planner

Visibility
  1. Public
  2. All

Type Members

  1. case class ComposedFlatMap[A, B, C](first: (A) ⇒ TraversableOnce[B], second: (B) ⇒ TraversableOnce[C]) extends (A) ⇒ TraversableOnce[C] with IrreducibleContainer with Product with Serializable

    When optimizing and composing flatMaps, this class can be used so that we can recover the parts if needed.

  2. case class ComposedOptionFlat[A, B, C](first: (A) ⇒ Option[B], second: (B) ⇒ TraversableOnce[C]) extends (A) ⇒ TraversableOnce[C] with IrreducibleContainer with Product with Serializable

  3. case class ComposedOptionMap[A, B, C](first: (A) ⇒ Option[B], second: (B) ⇒ Option[C]) extends (A) ⇒ Option[C] with IrreducibleContainer with Product with Serializable

    Composing optionMaps

  4. case class Dag[P <: Platform[P]](originalTail: TailProducer[P, _], producerToPriorityNames: Map[Producer[P, Any], List[String]], tail: TailProducer[P, _], producerToNode: Map[Producer[P, _], Node[P]], nodes: List[Node[P]], nodeToName: Map[Node[P], String] = ..., nameToNode: Map[String, Node[P]] = ..., dependenciesOfM: Map[Node[P], List[Node[P]]] = ..., dependantsOfM: Map[Node[P], List[Node[P]]] = ...) extends Product with Serializable

  5. trait DagOptimizer[P <: Platform[P]] extends AnyRef

  6. case class FlatAsFilter[A](useAsFilter: (A) ⇒ TraversableOnce[Nothing]) extends (A) ⇒ Option[A] with IrreducibleContainer with Product with Serializable

  7. case class FlatMapNode[P <: Platform[P]](members: List[Producer[P, _]] = immutable.this.Nil) extends Node[P] with Product with Serializable

  8. trait IrreducibleContainer extends AnyRef

    This is a marker trait that indicates that the subclass holds one or more irreducible items passed by the user.

  9. case class MergeResults[A, B](left: (A) ⇒ TraversableOnce[B], right: (A) ⇒ TraversableOnce[B]) extends (A) ⇒ TraversableOnce[B] with IrreducibleContainer with Product with Serializable

    (a.

  10. sealed trait Node[P <: Platform[P]] extends AnyRef

  11. case class NodeIdentifier(identifier: String) extends Product with Serializable

  12. class OnlinePlan[P <: Platform[P], V] extends AnyRef

  13. case class OptionToFlat[A, B](optionMap: (A) ⇒ Option[B]) extends (A) ⇒ TraversableOnce[B] with IrreducibleContainer with Product with Serializable

  14. case class ProducerF[P <: Platform[P]](oldSources: List[Producer[P, Any]], oldRef: Producer[P, Any], f: (List[Producer[P, Any]]) ⇒ Producer[P, Any]) extends Product with Serializable

  15. case class SourceNode[P <: Platform[P]](members: List[Producer[P, _]] = immutable.this.Nil) extends Node[P] with Product with Serializable

  16. case class SummerNode[P <: Platform[P]](members: List[Producer[P, _]] = immutable.this.Nil) extends Node[P] with Product with Serializable

Value Members

  1. object Dag extends Serializable

  2. object IrreducibleContainer

  3. object OnlinePlan

  4. object StripNamedNode

Ungrouped