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:

• withKeyValueSchemaName
• withPartitions
• withFormats

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:

• AstBuilder.Visitor is requested to visitCreateTable, visitCreateStream, visitAssertStream and visitAssertTable

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