org.apache.flink.table.descriptors

Class StatisticsValidator

java.lang.Object

org.apache.flink.table.descriptors.StatisticsValidator

All Implemented Interfaces:

DescriptorValidator

@Internal
public class StatisticsValidator
extends Object
implements DescriptorValidator

Validator for Statistics.

Field Summary

Fields

Modifier and Type	Field and Description
static String	AVG_LENGTH
static String	DISTINCT_COUNT
static String	MAX_LENGTH
static String	MAX_VALUE
static String	MIN_VALUE
static String	NAME
static String	NULL_COUNT
static String	STATISTICS_COLUMNS
static String	STATISTICS_PROPERTY_VERSION
static String	STATISTICS_ROW_COUNT

Constructor Summary

Constructors

Constructor and Description
StatisticsValidator()

Method Summary

Modifier and Type	Method and Description
static Map<String,String>	normalizeColumnStats(ColumnStats columnStats)
static Map<String,ColumnStats>	readColumnStats(DescriptorProperties properties, String key)
void	validate(DescriptorProperties properties) Performs basic validation such as completeness tests.
static void	validateColumnStats(DescriptorProperties properties, String key)

Methods inherited from class java.lang.Object

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

Field Detail

STATISTICS_PROPERTY_VERSION

public static final String STATISTICS_PROPERTY_VERSION

See Also:

Constant Field Values

STATISTICS_ROW_COUNT

public static final String STATISTICS_ROW_COUNT

See Also:

Constant Field Values

STATISTICS_COLUMNS

public static final String STATISTICS_COLUMNS

See Also:

Constant Field Values

NAME

public static final String NAME

See Also:

Constant Field Values

DISTINCT_COUNT

public static final String DISTINCT_COUNT

See Also:

Constant Field Values

NULL_COUNT

public static final String NULL_COUNT

See Also:

Constant Field Values

AVG_LENGTH

public static final String AVG_LENGTH

See Also:

Constant Field Values

MAX_LENGTH

public static final String MAX_LENGTH

See Also:

Constant Field Values

MAX_VALUE

public static final String MAX_VALUE

See Also:

Constant Field Values

MIN_VALUE

public static final String MIN_VALUE

See Also:

Constant Field Values

Constructor Detail

StatisticsValidator

public StatisticsValidator()

Method Detail

validate

public void validate(DescriptorProperties properties)

Description copied from interface: DescriptorValidator

Performs basic validation such as completeness tests.

Specified by:

validate in interface DescriptorValidator

normalizeColumnStats

public static Map<String,String> normalizeColumnStats(ColumnStats columnStats)

validateColumnStats

public static void validateColumnStats(DescriptorProperties properties,
                                       String key)

readColumnStats

public static Map<String,ColumnStats> readColumnStats(DescriptorProperties properties,
                                                      String key)