public class TierFetchResult
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
java.util.List<kafka.log.AbortedTxn> |
abortedTxns |
java.lang.Throwable |
exception |
org.apache.kafka.common.record.Records |
records |
Constructor and Description |
---|
TierFetchResult(org.apache.kafka.common.record.Records records,
java.util.List<kafka.log.AbortedTxn> abortedTxns,
java.lang.Throwable exception) |
Modifier and Type | Method and Description |
---|---|
static TierFetchResult |
emptyFetchResult() |
boolean |
isEmpty() |
public final org.apache.kafka.common.record.Records records
public final java.lang.Throwable exception
public final java.util.List<kafka.log.AbortedTxn> abortedTxns
public TierFetchResult(org.apache.kafka.common.record.Records records, java.util.List<kafka.log.AbortedTxn> abortedTxns, java.lang.Throwable exception)
public static TierFetchResult emptyFetchResult()
public boolean isEmpty()