Package com.linkedin.davinci.kafka.consumer

Class StatusReportAdapter

java.lang.Object

com.linkedin.davinci.kafka.consumer.StatusReportAdapter

public class StatusReportAdapter
extends java.lang.Object

This class forwards status report requests to IngestionNotificationDispatcher at USER partition level. It will record all sub-partitions status reporting and report only once for each user-partition when all the sub-partitions have reported the status.

Constructor Summary

Constructors

Constructor	Description
StatusReportAdapter(com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher notificationDispatcher, AmplificationFactorAdapter amplificationFactorAdapter)

Method Summary

Modifier and Type	Method	Description
void	initializePartitionReportStatus(int userPartition)	This method is expected to be invoked when StoreIngestionTask is subscribing to a user partition.
void	reportCatchUpVersionTopicOffsetLag(PartitionConsumptionState pcs)
void	reportCompleted(PartitionConsumptionState pcs)
void	reportCompleted(PartitionConsumptionState pcs, boolean forceCompletion)
void	reportDataRecoveryCompleted(PartitionConsumptionState pcs)
void	reportEndOfIncrementalPushReceived(PartitionConsumptionState pcs, java.lang.String version)
void	reportEndOfPushReceived(PartitionConsumptionState pcs)
void	reportError(int errorPartitionId, java.lang.String message, java.lang.Exception consumerEx)
void	reportError(java.util.Collection<PartitionConsumptionState> pcsList, java.lang.String message, java.lang.Exception consumerEx)
void	reportKilled(java.util.Collection<PartitionConsumptionState> pcsList, VeniceIngestionTaskKilledException ke)
void	reportProgress(PartitionConsumptionState pcs)
void	reportQuotaNotViolated(PartitionConsumptionState pcs)
void	reportQuotaViolated(PartitionConsumptionState pcs)
void	reportRestarted(PartitionConsumptionState pcs)
void	reportStarted(PartitionConsumptionState pcs)
void	reportStartOfIncrementalPushReceived(PartitionConsumptionState pcs, java.lang.String version)
void	reportStopped(PartitionConsumptionState pcs)
void	reportTopicSwitchReceived(PartitionConsumptionState pcs)

Methods inherited from class java.lang.Object

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

Constructor Detail

StatusReportAdapter

public StatusReportAdapter(com.linkedin.davinci.kafka.consumer.IngestionNotificationDispatcher notificationDispatcher,
                           AmplificationFactorAdapter amplificationFactorAdapter)

Method Detail

initializePartitionReportStatus

public void initializePartitionReportStatus(int userPartition)

This method is expected to be invoked when StoreIngestionTask is subscribing to a user partition. Here it performs initialization by creating a new StatusReportAdapter.PartitionReportStatus so old status will not be reused.

reportError

public void reportError(int errorPartitionId,
                        java.lang.String message,
                        java.lang.Exception consumerEx)

reportError

public void reportError(java.util.Collection<PartitionConsumptionState> pcsList,
                        java.lang.String message,
                        java.lang.Exception consumerEx)

reportKilled

public void reportKilled(java.util.Collection<PartitionConsumptionState> pcsList,
                         VeniceIngestionTaskKilledException ke)

reportQuotaViolated

public void reportQuotaViolated(PartitionConsumptionState pcs)

reportQuotaNotViolated

public void reportQuotaNotViolated(PartitionConsumptionState pcs)

reportStopped

public void reportStopped(PartitionConsumptionState pcs)

reportDataRecoveryCompleted

public void reportDataRecoveryCompleted(PartitionConsumptionState pcs)

reportStarted

public void reportStarted(PartitionConsumptionState pcs)

reportRestarted

public void reportRestarted(PartitionConsumptionState pcs)

reportEndOfPushReceived

public void reportEndOfPushReceived(PartitionConsumptionState pcs)

reportProgress

public void reportProgress(PartitionConsumptionState pcs)

reportTopicSwitchReceived

public void reportTopicSwitchReceived(PartitionConsumptionState pcs)

reportCatchUpVersionTopicOffsetLag

public void reportCatchUpVersionTopicOffsetLag(PartitionConsumptionState pcs)

reportCompleted

public void reportCompleted(PartitionConsumptionState pcs)

reportCompleted

public void reportCompleted(PartitionConsumptionState pcs,
                            boolean forceCompletion)

reportStartOfIncrementalPushReceived

public void reportStartOfIncrementalPushReceived(PartitionConsumptionState pcs,
                                                 java.lang.String version)

reportEndOfIncrementalPushReceived

public void reportEndOfIncrementalPushReceived(PartitionConsumptionState pcs,
                                               java.lang.String version)