org.apache.flink.table.descriptors

Class RowtimeValidator

java.lang.Object

org.apache.flink.table.descriptors.RowtimeValidator

All Implemented Interfaces:

DescriptorValidator

Deprecated.

See Rowtime for details.

@PublicEvolving
 @Deprecated
public class RowtimeValidator
extends Object
implements DescriptorValidator

Validator for Rowtime.

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
static Optional<Tuple2<TimestampExtractor,WatermarkStrategy>>	getRowtimeComponents(DescriptorProperties properties, String prefix) Deprecated.
void	validate(DescriptorProperties properties) Deprecated. Performs basic validation such as completeness tests.

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

Deprecated.

Description copied from interface: DescriptorValidator

Performs basic validation such as completeness tests.

Specified by:

validate in interface DescriptorValidator

getRowtimeComponents

public static Optional<Tuple2<TimestampExtractor,WatermarkStrategy>> getRowtimeComponents(DescriptorProperties properties,
                                                                                          String prefix)

Deprecated.