Package com.linkedin.venice.hadoop.input.kafka.ttl
package com.linkedin.venice.hadoop.input.kafka.ttl
-
ClassDescriptionThe policy controls the TTL behavior regarding how batch writes are treated.This class is responsible to filter records based on the RMD information and the ttl config by taking chunked records
ChunkAssembler.ValueBytesAndSchemaId.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.