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:
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 toinjectForCreateStatement
SourcePropertiesUtil
is requested to getValueFormat