Package com.linkedin.venice.spark.input.kafka.ttl

package com.linkedin.venice.spark.input.kafka.ttl

Classes

Class	Description
SparkChunkedPayloadTTLFilter	Spark adapter for TTL filtering of assembled (post-chunk-assembly) records.
SparkChunkedPayloadTTLFilter.AssembledRowWrapper	Wrapper around assembled Spark Row that adapts it to the VeniceRmdTTLFilter interface.
SparkChunkedPayloadTTLFilter.FilterResult	Result of TTL filtering that includes both the filter decision and the potentially modified wrapper.
SparkKafkaInputTTLFilter	Spark-compatible TTL filter for repush workloads that filters records based on RMD timestamps.