Package com.linkedin.venice.hadoop.input.kafka.ttl
-
Class Summary Class Description VeniceChunkedPayloadTTLFilter This class is responsible to filter records based on the RMD information and the ttl config by taking chunked recordsChunkAssembler.ValueBytesAndSchemaId.VeniceKafkaInputTTLFilter This class is responsible to filter records based on the RMD information and the ttl config by taking KIF inputKafkaInputMapperValue.VeniceRmdTTLFilter<INPUT_VALUE> This class is responsible to filter records based on the RMD information and the ttl config. -
Enum Summary Enum Description TTLResolutionPolicy The policy controls the TTL behavior regarding how batch writes are treated.