Packages

package hdfs

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. sealed abstract class FilePathGenerator extends (Long, Long) ⇒ Path
  2. sealed case class FileUnit(byteCount: Long) extends Product with Serializable
  3. final case class HdfsWriteMessage[T, P](source: T, passThrough: P) extends Product with Serializable
  4. final case class HdfsWritingSettings(overwrite: Boolean = true, newLine: Boolean = false, lineSeparator: String = ..., pathGenerator: FilePathGenerator = DefaultFilePathGenerator) extends Product with Serializable
  5. sealed abstract class OutgoingMessage[+P] extends AnyRef
  6. final case class RotationMessage(path: String, rotation: Int) extends OutgoingMessage[Nothing] with Product with Serializable

    Class RotationMessage represents an outgoing message of the rotation event

    Class RotationMessage represents an outgoing message of the rotation event

    path

    an absolute path of an output file in Hdfs

    rotation

    a number of rotation of an output

  7. abstract class RotationStrategy extends Strategy
  8. abstract class SyncStrategy extends Strategy
  9. final case class WrittenMessage[P](passThrough: P, inRotation: Int) extends OutgoingMessage[P] with Product with Serializable

    Class WrittenMessage represents an outgoing message of the writing event

    Class WrittenMessage represents an outgoing message of the writing event

    P

    type of the value of pass-through

    passThrough

    a value of pass-through

    inRotation

    a number of the rotation that writing event occurred

Ungrouped