Package org.apache.flink.table.descriptors

Class RowtimeValidator

java.lang.Object

org.apache.flink.table.descriptors.RowtimeValidator

All Implemented Interfaces:

org.apache.flink.table.descriptors.DescriptorValidator

@PublicEvolving
@Deprecated
public class RowtimeValidator
extends Object
implements org.apache.flink.table.descriptors.DescriptorValidator

Deprecated.

See Rowtime for details.

Validator for Rowtime.

Constructor Summary

Constructors

Constructor	Description
RowtimeValidator(boolean supportsSourceTimestamps, boolean supportsSourceWatermarks)	Deprecated.
RowtimeValidator(boolean supportsSourceTimestamps, boolean supportsSourceWatermarks, String prefix)	Deprecated.

Method Summary

Modifier and Type	Method	Description
static Optional<org.apache.flink.api.java.tuple.Tuple2<org.apache.flink.table.sources.tsextractors.TimestampExtractor,org.apache.flink.table.sources.wmstrategies.WatermarkStrategy>>	getRowtimeComponents(org.apache.flink.table.descriptors.DescriptorProperties properties, String prefix)	Deprecated.
void	validate(org.apache.flink.table.descriptors.DescriptorProperties properties)	Deprecated.

Methods inherited from class java.lang.Object

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

Constructor Detail

RowtimeValidator

public RowtimeValidator(boolean supportsSourceTimestamps,
                        boolean supportsSourceWatermarks)

Deprecated.

RowtimeValidator

public RowtimeValidator(boolean supportsSourceTimestamps,
                        boolean supportsSourceWatermarks,
                        String prefix)

Deprecated.

Method Detail

validate

public void validate(org.apache.flink.table.descriptors.DescriptorProperties properties)

Deprecated.

Specified by:

validate in interface org.apache.flink.table.descriptors.DescriptorValidator

getRowtimeComponents

public static Optional<org.apache.flink.api.java.tuple.Tuple2<org.apache.flink.table.sources.tsextractors.TimestampExtractor,org.apache.flink.table.sources.wmstrategies.WatermarkStrategy>> getRowtimeComponents(org.apache.flink.table.descriptors.DescriptorProperties properties,
                                                                                                                                                                                                                        String prefix)

Deprecated.