Class

com.twitter.scalding

MRMBy

Related Doc: package scalding

Permalink

class MRMBy[T, X, U] extends AggregateBy

MapReduceMapBy Class

Source
Operations.scala
Linear Supertypes
AggregateBy, SubAssembly, Pipe, Traceable, FlowElement, Serializable, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MRMBy
  2. AggregateBy
  3. SubAssembly
  4. Pipe
  5. Traceable
  6. FlowElement
  7. Serializable
  8. AnyRef
  9. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new MRMBy(arguments: Fields, middleFields: Fields, declaredFields: Fields, mfn: (T) ⇒ X, rfn: (X, X) ⇒ X, mfn2: (X) ⇒ U, startConv: TupleConverter[T], midSet: TupleSetter[X], midConv: TupleConverter[X], endSet: TupleSetter[U])

    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. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  5. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  6. final def eq(arg0: AnyRef): Boolean

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

    Permalink
    Definition Classes
    Pipe → AnyRef → Any
  8. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  9. def getAggregators(): Array[Aggregator]

    Permalink
    Attributes
    protected[cascading.pipe.assembly]
    Definition Classes
    AggregateBy
  10. def getArgumentFields(): Array[Fields]

    Permalink
    Attributes
    protected[cascading.pipe.assembly]
    Definition Classes
    AggregateBy
  11. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  12. def getConfigDef(): ConfigDef

    Permalink
    Definition Classes
    Pipe → FlowElement
  13. def getFieldDeclarations(): Array[Fields]

    Permalink
    Definition Classes
    AggregateBy
  14. def getFunctors(): Array[Functor]

    Permalink
    Attributes
    protected[cascading.pipe.assembly]
    Definition Classes
    AggregateBy
  15. def getGroupBy(): GroupBy

    Permalink
    Definition Classes
    AggregateBy
  16. def getGroupingFields(): Fields

    Permalink
    Definition Classes
    AggregateBy
  17. def getHeads(): Array[Pipe]

    Permalink
    Definition Classes
    Pipe
  18. def getName(): String

    Permalink
    Definition Classes
    SubAssembly → Pipe
  19. def getParent(): Pipe

    Permalink
    Definition Classes
    Pipe
  20. def getPrevious(): Array[Pipe]

    Permalink
    Definition Classes
    SubAssembly → Pipe
  21. def getStepConfigDef(): ConfigDef

    Permalink
    Definition Classes
    Pipe → FlowElement
  22. def getTailNames(): Array[String]

    Permalink
    Definition Classes
    SubAssembly
  23. def getTails(): Array[Pipe]

    Permalink
    Definition Classes
    SubAssembly
  24. def getThreshold(): Int

    Permalink
    Definition Classes
    AggregateBy
    Annotations
    @PropertyConfigured() @PropertyDescription() @Property()
  25. def getTrace(): String

    Permalink
    Definition Classes
    Pipe → Traceable
  26. def hasConfigDef(): Boolean

    Permalink
    Definition Classes
    Pipe → FlowElement
  27. def hasStepConfigDef(): Boolean

    Permalink
    Definition Classes
    Pipe → FlowElement
  28. def hashCode(): Int

    Permalink
    Definition Classes
    Pipe → AnyRef → Any
  29. def initialize(arg0: Fields, arg1: Array[Pipe], arg2: Array[Fields], arg3: Array[Functor], arg4: Array[Aggregator]): Unit

    Permalink
    Attributes
    protected[cascading.pipe.assembly]
    Definition Classes
    AggregateBy
  30. def initialize(arg0: Fields, arg1: Array[Pipe], arg2: Fields, arg3: Functor, arg4: Aggregator): Unit

    Permalink
    Attributes
    protected[cascading.pipe.assembly]
    Definition Classes
    AggregateBy
  31. def isEquivalentTo(arg0: FlowElement): Boolean

    Permalink
    Definition Classes
    Pipe → FlowElement
  32. final def isInstanceOf[T0]: Boolean

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

    Permalink
    Definition Classes
    AnyRef
  34. final def notify(): Unit

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

    Permalink
    Definition Classes
    AnyRef
  36. def outgoingScopeFor(arg0: Set[Scope]): Scope

    Permalink
    Definition Classes
    Pipe → FlowElement
  37. def print(arg0: Scope): String

    Permalink
    Definition Classes
    Pipe
  38. def printInternal(arg0: StringBuffer, arg1: Scope): Unit

    Permalink
    Attributes
    protected[cascading.pipe]
    Definition Classes
    Pipe
  39. def resolveIncomingOperationArgumentFields(arg0: Scope): Fields

    Permalink
    Definition Classes
    Pipe → FlowElement
  40. def resolveIncomingOperationPassThroughFields(arg0: Scope): Fields

    Permalink
    Definition Classes
    Pipe → FlowElement
  41. def setParent(arg0: Pipe): Unit

    Permalink
    Attributes
    protected[cascading.pipe]
    Definition Classes
    Pipe
  42. def setPrevious(arg0: <repeated...>[Pipe]): Unit

    Permalink
    Attributes
    protected[cascading.pipe]
    Definition Classes
    SubAssembly
  43. def setTails(arg0: <repeated...>[Pipe]): Unit

    Permalink
    Attributes
    protected[cascading.pipe]
    Definition Classes
    SubAssembly
  44. final def synchronized[T0](arg0: ⇒ T0): T0

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

    Permalink
    Definition Classes
    Pipe → AnyRef → Any
  46. def verify(): Unit

    Permalink
    Attributes
    protected[cascading.pipe.assembly]
    Definition Classes
    AggregateBy
  47. final def wait(): Unit

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

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

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

Inherited from AggregateBy

Inherited from SubAssembly

Inherited from Pipe

Inherited from Traceable

Inherited from FlowElement

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped