Packages

package table

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. All

Type Members

  1. class FlinkTableComponentProvider extends ComponentProvider with LazyLogging

    The config for this component provider is used in 2 contexts:

    The config for this component provider is used in 2 contexts:

    • designer: to have typing based on schema
    • flink executor: to configure tables in a flink job

    The file path of the sql file which is the source of component configuration is context dependent - for example if deploying inside docker container it has to point to a path inside the container. This is analogical to how the kafka and schema registry addresses are provided as environment variables that are different for designer and jobmanager/taskmanager services. For reference see the nussknacker-quickstart repository.

  2. final case class TableComponentProviderConfig(tableDefinitionFilePath: Option[String], catalogConfiguration: Option[Map[String, String]], testDataGenerationMode: Option[TestDataGenerationMode]) extends Product with Serializable
  3. final case class TableDefinition(tableId: ObjectIdentifier, schema: ResolvedSchema) extends Product with Serializable

Value Members

  1. object FlinkTableComponentProvider
  2. object TableComponentProviderConfig extends Serializable

Ungrouped