Package com.linkedin.venice.hadoop
Class AbstractVeniceFilter<INPUT_VALUE>
- java.lang.Object
-
- com.linkedin.venice.hadoop.AbstractVeniceFilter<INPUT_VALUE>
-
- All Implemented Interfaces:
java.io.Closeable
,java.lang.AutoCloseable
- Direct Known Subclasses:
VeniceRmdTTLFilter
public abstract class AbstractVeniceFilter<INPUT_VALUE> extends java.lang.Object implements java.io.Closeable
An abstraction to filter given data type. It can be used in conjunction withFilterChain
.
-
-
Constructor Summary
Constructors Constructor Description AbstractVeniceFilter()
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description abstract boolean
checkAndMaybeFilterValue(INPUT_VALUE value)
This function implements how to parse the value and determine if filtering is needed.
-
-
-
Method Detail
-
checkAndMaybeFilterValue
public abstract boolean checkAndMaybeFilterValue(INPUT_VALUE value)
This function implements how to parse the value and determine if filtering is needed. For certain value from Active/Active partial update enabled stores, it might filter out part of its input value and only keep the remaining fresh part based on filter timestamp.- Returns:
- true if the value should be filtered out, otherwise false.
-
-