org.apache.flink.table.sources.tsextractors

Class StreamRecordTimestamp

java.lang.Object

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

org.apache.flink.table.sources.tsextractors.StreamRecordTimestamp

All Implemented Interfaces:

Serializable, Descriptor, FieldComputer<Long>

@PublicEvolving
public final class StreamRecordTimestamp
extends TimestampExtractor

Extracts the timestamp of a StreamRecord into a rowtime attribute.

Note: This extractor only works for StreamTableSources.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static StreamRecordTimestamp	INSTANCE

Constructor Summary

Constructors

Constructor and Description
StreamRecordTimestamp()

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 the Expression that computes the value of the field.
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

Field Detail

INSTANCE

public static final StreamRecordTimestamp INSTANCE

Constructor Detail

StreamRecordTimestamp

public StreamRecordTimestamp()

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)

Description copied from interface: FieldComputer

Returns the Expression that computes the value of the field.

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