Packages

package hdfs

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package javadsl
  2. package scaladsl

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 class HdfsWritingSettings extends AnyRef
  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

Value Members

  1. object FilePathGenerator
  2. object FileUnit extends Serializable
  3. object HdfsWriteMessage extends Serializable
  4. object HdfsWritingSettings
  5. object RotationStrategy
  6. object SyncStrategy

Ungrouped