Class FilteringPrimitiveConverter
- java.lang.Object
-
- org.apache.parquet.io.api.Converter
-
- org.apache.parquet.io.api.PrimitiveConverter
-
- org.apache.parquet.filter2.recordlevel.FilteringPrimitiveConverter
-
public class FilteringPrimitiveConverter extends PrimitiveConverter
seeFilteringRecordMaterializer
This pass-through proxy for a delegatePrimitiveConverter
also updates theIncrementallyUpdatedFilterPredicate.ValueInspector
s of aIncrementallyUpdatedFilterPredicate
-
-
Constructor Summary
Constructors Constructor Description FilteringPrimitiveConverter(PrimitiveConverter delegate, IncrementallyUpdatedFilterPredicate.ValueInspector[] valueInspectors)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
addBinary(Binary value)
void
addBoolean(boolean value)
void
addDouble(double value)
void
addFloat(float value)
void
addInt(int value)
void
addLong(long value)
void
addValueFromDictionary(int dictionaryId)
add a value based on the dictionary set with setDictionary() Will be used if the Converter has dictionary support and the data was encoded using a dictionaryboolean
hasDictionarySupport()
if it returns true we will attempt to use dictionary based conversion insteadvoid
setDictionary(Dictionary dictionary)
Set the dictionary to use if the data was encoded using dictionary encoding and the converter hasDictionarySupport().-
Methods inherited from class org.apache.parquet.io.api.PrimitiveConverter
asPrimitiveConverter, isPrimitive
-
Methods inherited from class org.apache.parquet.io.api.Converter
asGroupConverter
-
-
-
-
Constructor Detail
-
FilteringPrimitiveConverter
public FilteringPrimitiveConverter(PrimitiveConverter delegate, IncrementallyUpdatedFilterPredicate.ValueInspector[] valueInspectors)
-
-
Method Detail
-
hasDictionarySupport
public boolean hasDictionarySupport()
Description copied from class:PrimitiveConverter
if it returns true we will attempt to use dictionary based conversion instead- Overrides:
hasDictionarySupport
in classPrimitiveConverter
- Returns:
- if dictionary is supported
-
setDictionary
public void setDictionary(Dictionary dictionary)
Description copied from class:PrimitiveConverter
Set the dictionary to use if the data was encoded using dictionary encoding and the converter hasDictionarySupport().- Overrides:
setDictionary
in classPrimitiveConverter
- Parameters:
dictionary
- the dictionary to use for conversion
-
addValueFromDictionary
public void addValueFromDictionary(int dictionaryId)
Description copied from class:PrimitiveConverter
add a value based on the dictionary set with setDictionary() Will be used if the Converter has dictionary support and the data was encoded using a dictionary- Overrides:
addValueFromDictionary
in classPrimitiveConverter
- Parameters:
dictionaryId
- the id in the dictionary of the value to add
-
addBinary
public void addBinary(Binary value)
- Overrides:
addBinary
in classPrimitiveConverter
- Parameters:
value
- value to set
-
addBoolean
public void addBoolean(boolean value)
- Overrides:
addBoolean
in classPrimitiveConverter
- Parameters:
value
- value to set
-
addDouble
public void addDouble(double value)
- Overrides:
addDouble
in classPrimitiveConverter
- Parameters:
value
- value to set
-
addFloat
public void addFloat(float value)
- Overrides:
addFloat
in classPrimitiveConverter
- Parameters:
value
- value to set
-
addInt
public void addInt(int value)
- Overrides:
addInt
in classPrimitiveConverter
- Parameters:
value
- value to set
-
addLong
public void addLong(long value)
- Overrides:
addLong
in classPrimitiveConverter
- Parameters:
value
- value to set
-
-