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. case class FlinkJobConfig(checkpointConfig: Option[CheckpointConfig], rocksDB: Option[RocksDBStateBackendConfig], executionMode: Option[ExecutionMode]) extends Product with Serializable
  6. class FlinkScenarioNameValidator extends CustomProcessValidator
  7. class FlinkScenarioNameValidatorFactory extends CustomProcessValidatorFactory
  8. trait ProcessPartFunction extends ExceptionHandlerFunction

Value Members

  1. object ExecutionConfigPreparer extends LazyLogging
  2. object FlinkJobConfig extends Serializable

Ungrouped