Class 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 Detail

      • MainTopicIngestionStatus

        public MainTopicIngestionStatus​(java.lang.String topicName)
    • Method Detail

      • setPartitionIngestionStatusToLocalIngestion

        public void setPartitionIngestionStatusToLocalIngestion​(int partitionId)
      • setPartitionIngestionStatusToIsolatedIngestion

        public void setPartitionIngestionStatusToIsolatedIngestion​(int partitionId)
      • removePartitionIngestionStatus

        public void removePartitionIngestionStatus​(int partitionId)
      • getIngestingPartitionCount

        public long getIngestingPartitionCount()
      • getTopicName

        public java.lang.String getTopicName()