Package | Description |
---|---|
org.apache.flink.table.sources | |
org.apache.flink.table.sources.tsextractors |
Modifier and Type | Method and Description |
---|---|
Expression |
FieldComputer.getExpression(ResolvedFieldReference[] fieldAccesses)
Deprecated.
Returns the
Expression that computes the value of the field. |
Modifier and Type | Method and Description |
---|---|
static ResolvedFieldReference[] |
TimestampExtractorUtils.getAccessedFields(TimestampExtractor timestampExtractor,
DataType physicalInputType,
Function<String,String> nameRemapping)
Retrieves all field accesses needed for the given
TimestampExtractor . |
Modifier and Type | Method and Description |
---|---|
Expression |
ExistingField.getExpression(ResolvedFieldReference[] fieldAccesses)
Deprecated.
Returns an
Expression that casts a Long , Timestamp , or timestamp
formatted String field (e.g., "2018-05-28 12:34:56.000") into a rowtime attribute. |
Expression |
StreamRecordTimestamp.getExpression(ResolvedFieldReference[] fieldAccesses)
Deprecated.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.