Class MainIngestionRequestClient

  • All Implemented Interfaces:
    java.io.Closeable, java.lang.AutoCloseable

    public class MainIngestionRequestClient
    extends java.lang.Object
    implements java.io.Closeable
    This class sends requests to isolated ingestion process and retrieves responses.
    • Constructor Detail

      • MainIngestionRequestClient

        public MainIngestionRequestClient​(VeniceConfigLoader configLoader)
    • Method Detail

      • startForkedIngestionProcess

        public java.lang.Process startForkedIngestionProcess​(VeniceConfigLoader configLoader)
      • startConsumption

        public boolean startConsumption​(java.lang.String topicName,
                                        int partitionId)
      • stopConsumption

        public boolean stopConsumption​(java.lang.String topicName,
                                       int partitionId)
      • killConsumptionTask

        public void killConsumptionTask​(java.lang.String topicName)
      • shutdownIngestionTask

        public void shutdownIngestionTask​(java.lang.String topicName)
      • removeStorageEngine

        public void removeStorageEngine​(java.lang.String topicName)
      • openStorageEngine

        public void openStorageEngine​(java.lang.String topicName)
      • removeTopicPartition

        public boolean removeTopicPartition​(java.lang.String topicName,
                                            int partitionId)
      • resetTopicPartition

        public void resetTopicPartition​(java.lang.String topicName,
                                        int partitionId)
      • shutdownForkedProcessComponent

        public void shutdownForkedProcessComponent​(IngestionComponentType ingestionComponentType)
      • sendHeartbeatRequest

        public boolean sendHeartbeatRequest()
      • close

        public void close()
        Specified by:
        close in interface java.lang.AutoCloseable
        Specified by:
        close in interface java.io.Closeable
      • setHttpClientTransport

        protected void setHttpClientTransport​(HttpClientTransport clientTransport)