Class

com.twitter.scalding

NullTap

Related Doc: package scalding

Permalink

class NullTap[Config, Input, Output, SourceContext, SinkContext] extends SinkTap[Config, Output]

A tap that output nothing. It is used to drive execution of a task for side effect only. This can be used to drive a pipe without actually writing to HDFS.

Source
Source.scala
Linear Supertypes
SinkTap[Config, Output], Tap[Config, Void, Output], Traceable, FlowElement, Serializable, AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. NullTap
  2. SinkTap
  3. Tap
  4. Traceable
  5. FlowElement
  6. Serializable
  7. AnyRef
  8. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new NullTap()

    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. def commitResource(arg0: Config): Boolean

    Permalink
    Definition Classes
    Tap
    Annotations
    @throws( classOf[java.io.IOException] )
  7. def createResource(conf: Config): Boolean

    Permalink
    Definition Classes
    NullTap → Tap
  8. def createResource(arg0: FlowProcess[Config]): Boolean

    Permalink
    Definition Classes
    Tap
    Annotations
    @throws( classOf[java.io.IOException] )
  9. def deleteResource(conf: Config): Boolean

    Permalink
    Definition Classes
    NullTap → Tap
  10. def deleteResource(arg0: FlowProcess[Config]): Boolean

    Permalink
    Definition Classes
    Tap
    Annotations
    @throws( classOf[java.io.IOException] )
  11. final def eq(arg0: AnyRef): Boolean

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

    Permalink
    Definition Classes
    Tap → AnyRef → Any
  13. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  14. def flowConfInit(arg0: Flow[Config]): Unit

    Permalink
    Definition Classes
    Tap
  15. final def getClass(): Class[_]

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

    Permalink
    Definition Classes
    Tap → FlowElement
  17. def getFullIdentifier(arg0: Config): String

    Permalink
    Definition Classes
    Tap
  18. def getFullIdentifier(arg0: FlowProcess[Config]): String

    Permalink
    Definition Classes
    Tap
  19. def getIdentifier(): String

    Permalink
    Definition Classes
    NullTap → Tap
  20. def getModifiedTime(conf: Config): Long

    Permalink
    Definition Classes
    NullTap → Tap
  21. def getModifiedTime(arg0: FlowProcess[Config]): Long

    Permalink
    Definition Classes
    Tap
    Annotations
    @throws( classOf[java.io.IOException] )
  22. def getScheme(): Scheme[Config, Void, Output, _, _]

    Permalink
    Definition Classes
    Tap
  23. def getSinkFields(): Fields

    Permalink
    Definition Classes
    Tap
  24. def getSinkMode(): SinkMode

    Permalink
    Definition Classes
    Tap
  25. def getSourceFields(): Fields

    Permalink
    Definition Classes
    SinkTap → Tap
  26. def getStepConfigDef(): ConfigDef

    Permalink
    Definition Classes
    Tap → FlowElement
  27. def getTrace(): String

    Permalink
    Definition Classes
    Tap → Traceable
  28. def hasConfigDef(): Boolean

    Permalink
    Definition Classes
    Tap → FlowElement
  29. def hasStepConfigDef(): Boolean

    Permalink
    Definition Classes
    Tap → FlowElement
  30. def hashCode(): Int

    Permalink
    Definition Classes
    Tap → AnyRef → Any
  31. def isEquivalentTo(arg0: FlowElement): Boolean

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

    Permalink
    Definition Classes
    Any
  33. def isKeep(): Boolean

    Permalink
    Definition Classes
    Tap
  34. def isReplace(): Boolean

    Permalink
    Definition Classes
    Tap
  35. def isSink(): Boolean

    Permalink
    Definition Classes
    Tap
  36. def isSource(): Boolean

    Permalink
    Definition Classes
    SinkTap → Tap
  37. def isTemporary(): Boolean

    Permalink
    Definition Classes
    Tap
  38. def isUpdate(): Boolean

    Permalink
    Definition Classes
    Tap
  39. final def ne(arg0: AnyRef): Boolean

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

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

    Permalink
    Definition Classes
    AnyRef
  42. def openForRead(arg0: FlowProcess[Config], arg1: Void): TupleEntryIterator

    Permalink
    Definition Classes
    SinkTap → Tap
    Annotations
    @throws( classOf[java.io.IOException] )
  43. def openForRead(arg0: FlowProcess[Config]): TupleEntryIterator

    Permalink
    Definition Classes
    Tap
    Annotations
    @throws( classOf[java.io.IOException] )
  44. def openForWrite(flowProcess: FlowProcess[Config], output: Output): TupleEntryCollector

    Permalink
    Definition Classes
    NullTap → Tap
  45. def openForWrite(arg0: FlowProcess[Config]): TupleEntryCollector

    Permalink
    Definition Classes
    Tap
    Annotations
    @throws( classOf[java.io.IOException] )
  46. def outgoingScopeFor(arg0: Set[Scope]): Scope

    Permalink
    Definition Classes
    Tap → FlowElement
  47. def presentSinkFields(arg0: FlowProcess[Config], arg1: Fields): Unit

    Permalink
    Definition Classes
    Tap
  48. def presentSourceFields(arg0: FlowProcess[Config], arg1: Fields): Unit

    Permalink
    Definition Classes
    Tap
  49. def resolveIncomingOperationArgumentFields(arg0: Scope): Fields

    Permalink
    Definition Classes
    Tap → FlowElement
  50. def resolveIncomingOperationPassThroughFields(arg0: Scope): Fields

    Permalink
    Definition Classes
    Tap → FlowElement
  51. def resourceExists(conf: Config): Boolean

    Permalink
    Definition Classes
    NullTap → Tap
  52. def resourceExists(arg0: FlowProcess[Config]): Boolean

    Permalink
    Definition Classes
    Tap
    Annotations
    @throws( classOf[java.io.IOException] )
  53. def retrieveSinkFields(arg0: FlowProcess[Config]): Fields

    Permalink
    Definition Classes
    Tap
  54. def retrieveSourceFields(arg0: FlowProcess[Config]): Fields

    Permalink
    Definition Classes
    Tap
  55. def rollbackResource(arg0: Config): Boolean

    Permalink
    Definition Classes
    Tap
    Annotations
    @throws( classOf[java.io.IOException] )
  56. def setScheme(arg0: Scheme[Config, Void, Output, _, _]): Unit

    Permalink
    Attributes
    protected[cascading.tap]
    Definition Classes
    Tap
  57. def sinkConfInit(arg0: FlowProcess[Config], arg1: Config): Unit

    Permalink
    Definition Classes
    Tap
  58. def sourceConfInit(arg0: FlowProcess[Config], arg1: Config): Unit

    Permalink
    Definition Classes
    SinkTap → Tap
  59. final def synchronized[T0](arg0: ⇒ T0): T0

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

    Permalink
    Definition Classes
    Tap → AnyRef → Any
  61. final def wait(): Unit

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

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

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

Inherited from SinkTap[Config, Output]

Inherited from Tap[Config, Void, Output]

Inherited from Traceable

Inherited from FlowElement

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped