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>

Deprecated.

This class will not be supported in the new source design around DynamicTableSource. See FLIP-95 for more information.

@Deprecated
 @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) Deprecated.

Method Summary

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

Deprecated.

Parameters:

field - The field to convert into a rowtime attribute.

Method Detail

getArgumentFields

public String[] getArgumentFields()

Deprecated.

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)

Deprecated.

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)

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.

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()

Deprecated.

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)

Deprecated.

Overrides:

equals in class Object

hashCode

public int hashCode()

Deprecated.

Overrides:

hashCode in class Object