Package com.linkedin.davinci.ingestion.main

Class MainTopicIngestionStatus

java.lang.Object
com.linkedin.davinci.ingestion.main.MainTopicIngestionStatus
public class MainTopicIngestionStatus extends Object
This class manages the ingestion status for each partition for a given topic when isolated ingestion is enabled. Each partition that exists in the status map will be either be hosted in main process or forked process.

  • Constructor Details

    • MainTopicIngestionStatus

      public MainTopicIngestionStatus(String topicName)

  • Method Details

    • setPartitionIngestionStatusToLocalIngestion

      public void setPartitionIngestionStatusToLocalIngestion(int partitionId)

    • setPartitionIngestionStatusToIsolatedIngestion

      public void setPartitionIngestionStatusToIsolatedIngestion(int partitionId)

    • removePartitionIngestionStatus

      public void removePartitionIngestionStatus(int partitionId)

    • getPartitionIngestionStatus

      public MainPartitionIngestionStatus getPartitionIngestionStatus(int partitionId)

    • getPartitionIngestionStatusSet

      public Map<Integer,MainPartitionIngestionStatus> getPartitionIngestionStatusSet()

    • getIngestingPartitionCount

      public long getIngestingPartitionCount()

    • getTopicName

      public String getTopicName()

    • hasPartitionIngestingInIsolatedProcess

      public boolean hasPartitionIngestingInIsolatedProcess()