Packages

package process

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. case class CheckpointConfig(checkpointInterval: FiniteDuration, minPauseBetweenCheckpoints: Option[FiniteDuration] = None, maxConcurrentCheckpoints: Option[Int] = None, tolerableCheckpointFailureNumber: Option[Int] = None) extends Product with Serializable
  2. trait ExceptionHandlerFunction extends RichFunction
  3. trait ExecutionConfigPreparer extends AnyRef

    This is strategy how Flink's ExecutionConfig will be set up before process registration

  4. trait FlinkCompatibilityProvider extends AnyRef
  5. trait ProcessPartFunction extends ExceptionHandlerFunction

Value Members

  1. object ExecutionConfigPreparer extends LazyLogging

Ungrouped