org.apache.flink.api.common.typeinfo

Interface AtomicType<T>

All Known Implementing Classes:

BasicTypeInfo, BigDecimalTypeInfo, EnumTypeInfo, FractionalTypeInfo, GenericTypeInfo, IntegerTypeInfo, LegacyInstantTypeInfo, LegacyLocalDateTimeTypeInfo, LegacyTimestampTypeInfo, LocalTimeTypeInfo, NumericTypeInfo, PrimitiveArrayTypeInfo, SqlTimeTypeInfo, TimeIndicatorTypeInfo, TimeIntervalTypeInfo, ValueTypeInfo, WritableTypeInfo

@Public
public interface AtomicType<T>

An atomic type is a type that is treated as one indivisible unit and where the entire type acts as a key. The atomic type defines the method to create a comparator for this type as a key. Example atomic types are the basic types (int, long, String, ...) and comparable custom classes.

In contrast to atomic types are composite types, where the type information is aware of the individual fields and individual fields may be used as a key.

Method Summary

Modifier and Type	Method and Description
TypeComparator<T>	createComparator(boolean sortOrderAscending, ExecutionConfig executionConfig) Creates a comparator for this type.

Method Detail

createComparator

TypeComparator<T> createComparator(boolean sortOrderAscending,
                                   ExecutionConfig executionConfig)

Creates a comparator for this type.

Parameters:

sortOrderAscending - True, if the comparator should define the order to be ascending, false, if the comparator should define the order to be descending.

executionConfig - The config from which the comparator will be parametrized. Parametrization includes for example registration of class tags for frameworks like Kryo.

Returns:

A comparator for this type.