org.apache.flink.table.sources.tsextractors

Class ExistingField

java.lang.Object

org.apache.flink.table.sources.tsextractors.TimestampExtractor

org.apache.flink.table.sources.tsextractors.ExistingField

All Implemented Interfaces:

Serializable, Descriptor, FieldComputer<Long>

@PublicEvolving
public final class ExistingField
extends TimestampExtractor

Converts an existing Long, Timestamp, or timestamp formatted java.lang.String field (e.g., "2018-05-28 12:34:56.000") into a rowtime attribute.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ExistingField(String field)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
String[]	getArgumentFields() Returns the names of all fields that the expression of the field computer accesses.
Expression	getExpression(ResolvedFieldReference[] fieldAccesses) 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.
int	hashCode()
Map<String,String>	toProperties() This method is a default implementation that uses java serialization and it is discouraged.
void	validateArgumentFields(TypeInformation<?>[] argumentFieldTypes) Validates that the fields that the expression references have the correct types.

Methods inherited from class org.apache.flink.table.sources.tsextractors.TimestampExtractor

getReturnType

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ExistingField

public ExistingField(String field)

Parameters:

field - The field to convert into a rowtime attribute.

Method Detail

getArgumentFields

public String[] getArgumentFields()

Description copied from interface: FieldComputer

Returns the names of all fields that the expression of the field computer accesses.

Returns:

An array with the names of all accessed fields.

validateArgumentFields

public void validateArgumentFields(TypeInformation<?>[] argumentFieldTypes)

Description copied from interface: FieldComputer

Validates that the fields that the expression references have the correct types.

Parameters:

argumentFieldTypes - The types of the physical input fields.

getExpression

public Expression getExpression(ResolvedFieldReference[] fieldAccesses)

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.

Parameters:

fieldAccesses - Field access expressions for the argument fields.

Returns:

The expression to extract the timestamp from the TableSource return type.

toProperties

public Map<String,String> toProperties()

Description copied from class: TimestampExtractor

This method is a default implementation that uses java serialization and it is discouraged. All implementation should provide a more specific set of properties.

Specified by:

toProperties in interface Descriptor

Overrides:

toProperties in class TimestampExtractor

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object