Skip to content

CreateSourceProperties

Creating Instance

CreateSourceProperties takes the following to be created:

  • Originals (Map<String, Literal>)
  • Duration Parser (Function<String, Duration>)

CreateSourceProperties is created using from factory and when:

While being created, CreateSourceProperties creates a PropertiesConfig and performs parameter validations.

Creating CreateSourceProperties

CreateSourceProperties from(
  Map<String, Literal> literals)

from creates a CreateSourceProperties (with the given literals and the default DurationParser).

from is used when:

PropertiesConfig

When created, CreateSourceProperties creates a PropertiesConfig with the following configuration properties.

SOURCE_CONNECTOR

Indicates that this source was created by a connector with the given name.

Default: null

WINDOW_SIZE

Window size of HOPPING or TUMBLING windows, e.g. 20 SECONDS

Default: null

WINDOW_TYPE

Supported values:

  • SESSION
  • HOPPING
  • TUMBLING

Default: null

value_format

Optional<FormatInfo> getValueFormat()

getValueFormat takes FORMAT (if defined) or defaults to VALUE_FORMAT property (using the PropertiesConfig).

If defined (using either configuration property), the value format is converted to FormatInfo (with getValueFormatProperties).

getValueFormat is used when:

  • DefaultFormatInjector is requested to injectForCreateStatement
  • SourcePropertiesUtil is requested to getValueFormat
Back to top