Package org.apache.flink.api.java.typeutils.runtime

Class RuntimeComparatorFactory<T>

java.lang.Object

org.apache.flink.api.java.typeutils.runtime.RuntimeComparatorFactory<T>

All Implemented Interfaces:

Serializable, TypeComparatorFactory<T>

@Internal
public final class RuntimeComparatorFactory<T>
extends Object
implements TypeComparatorFactory<T>, Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
RuntimeComparatorFactory()
RuntimeComparatorFactory(TypeComparator<T> comparator)

Method Summary

Modifier and Type	Method	Description
TypeComparator<T>	createComparator()
void	readParametersFromConfig(Configuration config, ClassLoader cl)
void	writeParametersToConfig(Configuration config)

Methods inherited from class java.lang.Object

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

Constructor Detail

RuntimeComparatorFactory

public RuntimeComparatorFactory()

RuntimeComparatorFactory

public RuntimeComparatorFactory(TypeComparator<T> comparator)

Method Detail

writeParametersToConfig

public void writeParametersToConfig(Configuration config)

Specified by:

writeParametersToConfig in interface TypeComparatorFactory<T>

readParametersFromConfig

public void readParametersFromConfig(Configuration config,
                                     ClassLoader cl)
                              throws ClassNotFoundException

Specified by:

readParametersFromConfig in interface TypeComparatorFactory<T>

Throws:

ClassNotFoundException

createComparator

public TypeComparator<T> createComparator()

Specified by:

createComparator in interface TypeComparatorFactory<T>