Class AbstractStoreBufferService

    • Constructor Detail

      • AbstractStoreBufferService

        public AbstractStoreBufferService()
    • Method Detail

      • drainBufferedRecordsFromTopicPartition

        public abstract void drainBufferedRecordsFromTopicPartition​(PubSubTopicPartition topicPartition)
                                                             throws java.lang.InterruptedException
        This method will wait for all the messages to be processed (persisted to disk) that are already queued up to drainer till now.
        Throws:
        java.lang.InterruptedException
      • getTotalMemoryUsage

        public abstract long getTotalMemoryUsage()
      • getTotalRemainingMemory

        public abstract long getTotalRemainingMemory()
      • getMaxMemoryUsagePerDrainer

        public abstract long getMaxMemoryUsagePerDrainer()
      • getMinMemoryUsagePerDrainer

        public abstract long getMinMemoryUsagePerDrainer()
      • execSyncOffsetCommandAsync

        public abstract java.util.concurrent.CompletableFuture<java.lang.Void> execSyncOffsetCommandAsync​(PubSubTopicPartition topicPartition,
                                                                                                          StoreIngestionTask ingestionTask)
                                                                                                   throws java.lang.InterruptedException
        Throws:
        java.lang.InterruptedException