Class MainTopicIngestionStatus
- java.lang.Object
-
- com.linkedin.davinci.ingestion.main.MainTopicIngestionStatus
-
public class MainTopicIngestionStatus extends java.lang.ObjectThis 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 Summary
Constructors Constructor Description MainTopicIngestionStatus(java.lang.String topicName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longgetIngestingPartitionCount()MainPartitionIngestionStatusgetPartitionIngestionStatus(int partitionId)java.util.Map<java.lang.Integer,MainPartitionIngestionStatus>getPartitionIngestionStatusSet()java.lang.StringgetTopicName()booleanhasPartitionIngestingInIsolatedProcess()voidremovePartitionIngestionStatus(int partitionId)voidsetPartitionIngestionStatusToIsolatedIngestion(int partitionId)voidsetPartitionIngestionStatusToLocalIngestion(int partitionId)
-
-
-
Method Detail
-
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 java.util.Map<java.lang.Integer,MainPartitionIngestionStatus> getPartitionIngestionStatusSet()
-
getIngestingPartitionCount
public long getIngestingPartitionCount()
-
getTopicName
public java.lang.String getTopicName()
-
hasPartitionIngestingInIsolatedProcess
public boolean hasPartitionIngestingInIsolatedProcess()
-
-