Package com.linkedin.venice.hadoop

Class AbstractVeniceFilter<INPUT_VALUE>

java.lang.Object

com.linkedin.venice.hadoop.AbstractVeniceFilter<INPUT_VALUE>

All Implemented Interfaces:

Closeable, AutoCloseable

Direct Known Subclasses:

VeniceRmdTTLFilter

public abstract class AbstractVeniceFilter<INPUT_VALUE>
extends Object
implements Closeable

An abstraction to filter given data type. It can be used in conjunction with FilterChain.

Constructor Summary

Constructors

Constructor	Description
AbstractVeniceFilter()

Method Summary

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.

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.io.Closeable

close

Constructor Details

AbstractVeniceFilter

public AbstractVeniceFilter()

Method Details

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.