Trait

com.twitter.scalding.bdd

TBddDsl

Related Doc: package bdd

Permalink

trait TBddDsl extends FieldConversions with TypedPipeOperationsConversions

Source
TBddDsl.scala
Linear Supertypes
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TBddDsl
  2. TypedPipeOperationsConversions
  3. FieldConversions
  4. LowPriorityFieldConversions
  5. AnyRef
  6. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. case class CompleteTestCase[OutputType](sources: List[TypedTestSource[_]], operation: TBddDsl.TypedPipeOperation[OutputType], assertion: (Buffer[OutputType]) ⇒ Unit)(implicit evidence$12: Manifest[OutputType]) extends Product with Serializable

    Permalink
  2. class ListOfTypedPipesOperations[TypeOut] extends TypedPipeOperation[TypeOut]

    Permalink
  3. class OneTypedPipeOperation[TypeIn, TypeOut] extends TypedPipeOperation[TypeOut]

    Permalink
  4. class SimpleTypedTestSource[T] extends TypedTestSource[T]

    Permalink
  5. case class TestCaseGiven1[TypeIn](source: TypedTestSource[TypeIn]) extends Product with Serializable

    Permalink
  6. case class TestCaseGiven2[TypeIn1, TypeIn2](source: TypedTestSource[TypeIn1], other: TypedTestSource[TypeIn2]) extends Product with Serializable

    Permalink
  7. case class TestCaseGiven3[TypeIn1, TypeIn2, TypeIn3](source: TypedTestSource[TypeIn1], other: TypedTestSource[TypeIn2], third: TypedTestSource[TypeIn3]) extends Product with Serializable

    Permalink
  8. case class TestCaseGivenList(sources: List[TypedTestSource[_]]) extends Product with Serializable

    Permalink
  9. case class TestCaseWhen[OutputType](sources: List[TypedTestSource[_]], operation: TBddDsl.TypedPipeOperation[OutputType])(implicit evidence$11: Manifest[OutputType]) extends Product with Serializable

    Permalink
  10. class ThreeTypedPipesOperation[TypeIn1, TypeIn2, TypeIn3, TypeOut] extends TypedPipeOperation[TypeOut]

    Permalink
  11. class TwoTypedPipesOperation[TypeIn1, TypeIn2, TypeOut] extends TypedPipeOperation[TypeOut]

    Permalink
  12. trait TypedPipeOperation[TypeOut] extends AnyRef

    Permalink
  13. abstract class TypedTestSource[T] extends AnyRef

    Permalink

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. def Given[TypeIn](source: TypedTestSource[TypeIn]): TestCaseGiven1[TypeIn]

    Permalink
  5. def GivenSources(sources: List[TypedTestSource[_]]): TestCaseGivenList

    Permalink
  6. def anyToFieldArg(f: Any): Comparable[_]

    Permalink
    Attributes
    protected
    Definition Classes
    LowPriorityFieldConversions
  7. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  8. def asList(f: Fields): List[Comparable[_]]

    Permalink
    Definition Classes
    FieldConversions
  9. def asSet(f: Fields): Set[Comparable[_]]

    Permalink
    Definition Classes
    FieldConversions
  10. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  11. def defaultMode(fromFields: Fields, toFields: Fields): Fields

    Permalink

    Rather than give the full power of cascading's selectors, we have a simpler set of rules encoded below: 1) if the input is non-definite (ALL, GROUP, ARGS, etc...) ALL is the output.

    Rather than give the full power of cascading's selectors, we have a simpler set of rules encoded below: 1) if the input is non-definite (ALL, GROUP, ARGS, etc...) ALL is the output. Perhaps only fromFields=ALL will make sense 2) If one of from or to is a strict super set of the other, SWAP is used. 3) If they are equal, REPLACE is used. 4) Otherwise, ALL is used.

    Definition Classes
    FieldConversions
  12. final def ensureUniqueFields(left: Fields, right: Fields, rightPipe: Pipe): (Fields, Pipe)

    Permalink
    Definition Classes
    FieldConversions
  13. implicit def enumValueToFields(x: Value): Fields

    Permalink
    Definition Classes
    FieldConversions
  14. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  15. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  16. implicit def fieldFields[T <: TraversableOnce[Field[_]]](f: T): RichFields

    Permalink
    Definition Classes
    FieldConversions
  17. implicit def fieldToFields(f: Field[_]): RichFields

    Permalink
    Definition Classes
    FieldConversions
  18. implicit def fields[T <: TraversableOnce[Symbol]](f: T): Fields

    Permalink
    Definition Classes
    FieldConversions
  19. implicit def fieldsToRichFields(fields: Fields): RichFields

    Permalink

    We can't set the field Manifests because cascading doesn't (yet) expose field type information in the Fields API.

    We can't set the field Manifests because cascading doesn't (yet) expose field type information in the Fields API.

    Definition Classes
    FieldConversions
  20. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  21. implicit def fromEnum[T <: Enumeration](enumeration: T): Fields

    Permalink

    Multi-entry fields.

    Multi-entry fields. This are higher priority than Product conversions so that List will not conflict with Product.

    Definition Classes
    FieldConversions
  22. implicit def fromListOfTypedPipesFunctionToOperation[TypeOut](op: (List[TypedPipe[_]]) ⇒ TypedPipe[TypeOut]): ListOfTypedPipesOperations[TypeOut]

    Permalink
  23. implicit def fromSimpleTypeToTypedSource[T](data: Iterable[T]): SimpleTypedTestSource[T]

    Permalink
  24. implicit def fromSingleTypedPipeFunctionToOperation[TypeIn, TypeOut](op: (TypedPipe[TypeIn]) ⇒ TypedPipe[TypeOut]): OneTypedPipeOperation[TypeIn, TypeOut]

    Permalink
  25. implicit def fromThreeTypedPipesFunctionToOperation[TypeIn1, TypeIn2, TypeIn3, TypeOut](op: (TypedPipe[TypeIn1], TypedPipe[TypeIn2], TypedPipe[TypeIn3]) ⇒ TypedPipe[TypeOut]): ThreeTypedPipesOperation[TypeIn1, TypeIn2, TypeIn3, TypeOut]

    Permalink
  26. implicit def fromTwoTypedPipesFunctionToOperation[TypeIn1, TypeIn2, TypeOut](op: (TypedPipe[TypeIn1], TypedPipe[TypeIn2]) ⇒ TypedPipe[TypeOut]): TwoTypedPipesOperation[TypeIn1, TypeIn2, TypeOut]

    Permalink
  27. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  28. def getField(f: Fields, idx: Int): Fields

    Permalink
    Definition Classes
    FieldConversions
  29. def hasInts(f: Fields): Boolean

    Permalink
    Definition Classes
    FieldConversions
  30. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  31. implicit def intFields[T <: TraversableOnce[Int]](f: T): Fields

    Permalink
    Definition Classes
    FieldConversions
  32. implicit def intToFields(x: Int): Fields

    Permalink
    Definition Classes
    FieldConversions
  33. implicit def integerToFields(x: Integer): Fields

    Permalink
    Definition Classes
    FieldConversions
  34. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  35. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  36. final def newSymbol(avoid: Set[Symbol], guess: Symbol, trial: Int = 0): Symbol

    Permalink
    Definition Classes
    FieldConversions
    Annotations
    @tailrec()
  37. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  38. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  39. implicit def parseAnySeqToFields[T <: TraversableOnce[Any]](anyf: T): Fields

    Permalink

    Useful to convert f : Any* to Fields.

    Useful to convert f : Any* to Fields. This handles mixed cases ("hey", 'you). Not sure we should be this flexible, but given that Cascading will throw an exception before scheduling the job, I guess this is okay.

    Definition Classes
    FieldConversions
  40. implicit def productToFields(f: Product): Fields

    Permalink

    Handles treating any TupleN as a Fields object.

    Handles treating any TupleN as a Fields object. This is low priority because List is also a Product, but this method will not work for List (because List is Product2(head, tail) and so productIterator won't work as expected. Lists are handled by an implicit in FieldConversions, which have higher priority.

    Definition Classes
    LowPriorityFieldConversions
  41. implicit def strFields[T <: TraversableOnce[String]](f: T): Fields

    Permalink
    Definition Classes
    FieldConversions
  42. implicit def stringToFields(x: String): Fields

    Permalink
    Definition Classes
    FieldConversions
  43. implicit def symbolToFields(x: Symbol): Fields

    Permalink

    '* means Fields.ALL, otherwise we take the .name

    '* means Fields.ALL, otherwise we take the .name

    Definition Classes
    FieldConversions
  44. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  45. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  46. implicit def tuple2ToFieldsPair[T, U](pair: (T, U))(implicit tf: (T) ⇒ Fields, uf: (U) ⇒ Fields): (Fields, Fields)

    Permalink
    Definition Classes
    FieldConversions
  47. implicit def unitToFields(u: Unit): Fields

    Permalink
    Definition Classes
    FieldConversions
  48. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  49. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  50. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from FieldConversions

Inherited from AnyRef

Inherited from Any

Ungrouped