Class MainTopicIngestionStatus
- java.lang.Object
-
- com.linkedin.davinci.ingestion.main.MainTopicIngestionStatus
-
public class MainTopicIngestionStatus extends java.lang.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 Summary
Constructors Constructor Description MainTopicIngestionStatus(java.lang.String topicName)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description long
getIngestingPartitionCount()
MainPartitionIngestionStatus
getPartitionIngestionStatus(int partitionId)
java.util.Map<java.lang.Integer,MainPartitionIngestionStatus>
getPartitionIngestionStatusSet()
java.lang.String
getTopicName()
boolean
hasPartitionIngestingInIsolatedProcess()
void
removePartitionIngestionStatus(int partitionId)
void
setPartitionIngestionStatusToIsolatedIngestion(int partitionId)
void
setPartitionIngestionStatusToLocalIngestion(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()
-
-