Packages

object HdfsWriteMessage extends Serializable

Source
model.scala
Linear Supertypes
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. HdfsWriteMessage
  2. Serializable
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def apply[T](source: T): HdfsWriteMessage[T, NotUsed]

    Scala API - creates HdfsWriteMessage to use when not using passThrough

    Scala API - creates HdfsWriteMessage to use when not using passThrough

    source

    a message

  2. def create[T, P](source: T, passThrough: P): HdfsWriteMessage[T, P]

    Java API - creates HdfsWriteMessage to use with passThrough

    Java API - creates HdfsWriteMessage to use with passThrough

    source

    a message

    passThrough

    pass-through data

  3. def create[T](source: T): HdfsWriteMessage[T, NotUsed]

    Java API - creates HdfsWriteMessage to use when not using passThrough

    Java API - creates HdfsWriteMessage to use when not using passThrough

    source

    a message