Packages

object FilePathGenerator

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

Value Members

  1. def apply(f: (Long, Long) => String, temp: String = DefaultTempDirectory): FilePathGenerator

    Scala API: creates FilePathGenerator to rotate output

    Scala API: creates FilePathGenerator to rotate output

    f

    a function that takes rotation count and timestamp to return path of output

    temp

    the temporary directory that org.apache.pekko.stream.connectors.hdfs.impl.HdfsFlowStage use

  2. def create(f: BiFunction[Long, Long, String], temp: String): FilePathGenerator

    Java API: creates FilePathGenerator to rotate output

    Java API: creates FilePathGenerator to rotate output

    f

    a function that takes rotation count and timestamp to return path of output

  3. def create(f: BiFunction[Long, Long, String]): FilePathGenerator

    Java API: creates FilePathGenerator to rotate output

    Java API: creates FilePathGenerator to rotate output

    f

    a function that takes rotation count and timestamp to return path of output