Trait

com.twitter.scalding.bdd

BddDsl

Related Doc: package bdd

Permalink

trait BddDsl extends FieldConversions with PipeOperationsConversions

Source
BddDsl.scala
Linear Supertypes
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. BddDsl
  2. PipeOperationsConversions
  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[TestSource], operation: BddDsl.PipeOperation, assertion: (Buffer[OutputType]) ⇒ Unit)(implicit conv: TupleConverter[OutputType]) extends Product with Serializable

    Permalink
  2. class ListPipesOperation extends PipeOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  3. class ListRichPipesOperation extends PipeOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  4. class OnePipeOperation extends PipeOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  5. trait PipeOperation extends AnyRef

    Permalink
    Definition Classes
    PipeOperationsConversions
  6. class SimpleTypeTestSourceWithoutSchema[T] extends TestSourceWithoutSchema

    Permalink
  7. case class TestCaseGiven1(source: TestSource) extends Product with Serializable

    Permalink
  8. case class TestCaseGiven2(source: TestSource, other: TestSource) extends Product with Serializable

    Permalink
  9. case class TestCaseGiven3(source: TestSource, other: TestSource, third: TestSource) extends Product with Serializable

    Permalink
  10. case class TestCaseGivenList(sources: List[TestSource]) extends Product with Serializable

    Permalink
  11. case class TestCaseWhen(sources: List[TestSource], operation: BddDsl.PipeOperation) extends Product with Serializable

    Permalink
  12. class TestSource extends AnyRef

    Permalink
  13. trait TestSourceWithoutSchema extends AnyRef

    Permalink
  14. class ThreePipesOperation extends PipeOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  15. class TwoPipesOperation extends PipeOperation

    Permalink
    Definition Classes
    PipeOperationsConversions

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(sources: List[TestSource]): TestCaseGivenList

    Permalink
  5. def Given(source: TestSource): TestCaseGiven1

    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 val fromListPipeFunctionToOperation: ((List[Pipe]) ⇒ RichPipe) ⇒ ListPipesOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  23. implicit val fromListRichPipeToPipeFunctionToOperation: ((List[Pipe]) ⇒ Pipe) ⇒ ListPipesOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  24. implicit val fromRichPipeListFunctionToOperation: ((List[RichPipe]) ⇒ RichPipe) ⇒ ListRichPipesOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  25. implicit val fromRichPipeListToPipeFunctionToOperation: ((List[RichPipe]) ⇒ Pipe) ⇒ ListRichPipesOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  26. implicit def fromSimpleTypeDataToSourceWithoutSchema[T](data: Iterable[T])(implicit setter: TupleSetter[T]): SimpleTypeTestSourceWithoutSchema[T]

    Permalink
  27. implicit val fromSinglePipeFunctionToOperation: ((Pipe) ⇒ RichPipe) ⇒ OnePipeOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  28. implicit val fromSinglePipeToRichPipeFunctionToOperation: ((Pipe) ⇒ Pipe) ⇒ OnePipeOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  29. implicit val fromSingleRichPipeFunctionToOperation: ((RichPipe) ⇒ RichPipe) ⇒ OnePipeOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  30. implicit val fromSingleRichPipeToPipeFunctionToOperation: ((RichPipe) ⇒ Pipe) ⇒ OnePipeOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  31. implicit val fromThreePipeFunctionToOperation: ((Pipe, Pipe, Pipe) ⇒ RichPipe) ⇒ ThreePipesOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  32. implicit val fromThreeRichPipeToPipeFunctionToOperation: ((Pipe, Pipe, Pipe) ⇒ Pipe) ⇒ ThreePipesOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  33. implicit val fromThreeRichPipesFunctionToOperation: ((RichPipe, RichPipe, RichPipe) ⇒ RichPipe) ⇒ ThreePipesOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  34. implicit val fromThreeRichPipesToPipeFunctionToOperation: ((RichPipe, RichPipe, RichPipe) ⇒ Pipe) ⇒ ThreePipesOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  35. implicit val fromTwoPipeFunctionToOperation: ((Pipe, Pipe) ⇒ RichPipe) ⇒ TwoPipesOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  36. implicit val fromTwoRichPipeToPipeFunctionToOperation: ((Pipe, Pipe) ⇒ Pipe) ⇒ TwoPipesOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  37. implicit val fromTwoRichPipesFunctionToOperation: ((RichPipe, RichPipe) ⇒ RichPipe) ⇒ TwoPipesOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  38. implicit val fromTwoRichPipesToRichPipeFunctionToOperation: ((RichPipe, RichPipe) ⇒ Pipe) ⇒ TwoPipesOperation

    Permalink
    Definition Classes
    PipeOperationsConversions
  39. final def getClass(): Class[_]

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

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

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

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

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

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

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

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

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

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

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

    Permalink
    Definition Classes
    AnyRef
  51. 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
  52. 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
  53. implicit def strFields[T <: TraversableOnce[String]](f: T): Fields

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

    Permalink
    Definition Classes
    FieldConversions
  55. 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
  56. final def synchronized[T0](arg0: ⇒ T0): T0

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

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

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

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

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

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

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

Inherited from PipeOperationsConversions

Inherited from FieldConversions

Inherited from AnyRef

Inherited from Any

Ungrouped