org.apache.paimon.casting

Class CastExecutors

java.lang.Object

org.apache.paimon.casting.CastExecutors

public class CastExecutors
extends Object

Cast executors for input type and output type.

Constructor Summary

Constructors

Constructor and Description
CastExecutors()

Method Summary

Modifier and Type	Method and Description
static Optional<List<Object>>	castLiteralsWithEvolution(List<Object> literals, DataType predicateType, DataType dataType) If a field type is modified, pushing down a filter of it is dangerous.
static CastExecutor<?,?>	identityCastExecutor()
static CastExecutor<?,?>	resolve(DataType inputType, DataType outputType) Resolve a CastExecutor for the provided input type and target type.

Methods inherited from class java.lang.Object

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

Constructor Detail

CastExecutors

public CastExecutors()

Method Detail

resolve

@Nullable
public static CastExecutor<?,?> resolve(DataType inputType,
                                                  DataType outputType)

Resolve a CastExecutor for the provided input type and target type. Returns null if no rule can be resolved.

Parameters:

inputType - the input value type.

outputType - the output value type.

Returns:

the CastExecutor instance.

identityCastExecutor

public static CastExecutor<?,?> identityCastExecutor()

castLiteralsWithEvolution

public static Optional<List<Object>> castLiteralsWithEvolution(List<Object> literals,
                                                               DataType predicateType,
                                                               DataType dataType)

If a field type is modified, pushing down a filter of it is dangerous. This method tries to cast the literals of filter to its original type. It only cast the literals when the CastRule is in whitelist. Otherwise, return Optional.empty().