package api
Ordering
- Alphabetic
Visibility
- Public
- Protected
Package Members
- package compat
- package datastream
- package exception
- package process
- package timestampwatermark
- package typeinformation
Type Members
- case class ConfigGlobalParameters(explicitUidInStatefulOperators: Option[Boolean], useIOMonadInInterpreter: Option[Boolean], forceSyncInterpretationForSyncScenarioPart: Option[Boolean]) extends Product with Serializable
- trait FlinkEngineRuntimeContext extends EngineRuntimeContext
- case class NamespaceMetricsTags(tags: Map[String, String]) extends Product with Serializable
- case class NkGlobalParameters(buildInfo: String, processVersion: ProcessVersion, configParameters: Option[ConfigGlobalParameters], namespaceParameters: Option[NamespaceMetricsTags], additionalInformation: Map[String, String]) extends GlobalJobParameters with Product with Serializable
Value Members
- object NamespaceMetricsTags extends Serializable
- object NkGlobalParameters extends Serializable
- object TypedMultiset