org.apache.flink.table.sources.tsextractors

Class TimestampExtractor

java.lang.Object

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

All Implemented Interfaces:

Serializable, Descriptor, FieldComputer<Long>

Direct Known Subclasses:

ExistingField, StreamRecordTimestamp

@PublicEvolving
public abstract class TimestampExtractor
extends Object
implements FieldComputer<Long>, Serializable, Descriptor

Provides an expression to extract the timestamp for a rowtime attribute.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
TimestampExtractor()

Method Summary

Modifier and Type	Method and Description
TypeInformation<Long>	getReturnType() Returns the result type of the expression.
Map<String,String>	toProperties() This method is a default implementation that uses java serialization and it is discouraged.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.flink.table.sources.FieldComputer

getArgumentFields, getExpression, validateArgumentFields

Constructor Detail

TimestampExtractor

public TimestampExtractor()

Method Detail

getReturnType

public TypeInformation<Long> getReturnType()

Description copied from interface: FieldComputer

Returns the result type of the expression.

Specified by:

getReturnType in interface FieldComputer<Long>

Returns:

The result type of the expression.

toProperties

public Map<String,String> toProperties()

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