Package com.linkedin.davinci.ingestion.main

Class MainIngestionRequestClient

java.lang.Object
com.linkedin.davinci.ingestion.main.MainIngestionRequestClient
All Implemented Interfaces:
Closeable, AutoCloseable
public class MainIngestionRequestClient extends Object implements Closeable
This class sends requests to isolated ingestion process and retrieves responses.

  • Constructor Details

    • MainIngestionRequestClient

      public MainIngestionRequestClient(VeniceConfigLoader configLoader)

  • Method Details

    • startForkedIngestionProcess

      public Process startForkedIngestionProcess(VeniceConfigLoader configLoader)

    • startConsumption

      public boolean startConsumption(String topicName, int partitionId)

    • stopConsumption

      public boolean stopConsumption(String topicName, int partitionId)

    • killConsumptionTask

      public void killConsumptionTask(String topicName)

    • shutdownIngestionTask

      public void shutdownIngestionTask(String topicName)

    • removeStorageEngine

      public void removeStorageEngine(String topicName)

    • openStorageEngine

      public void openStorageEngine(String topicName)

    • removeTopicPartition

      public boolean removeTopicPartition(String topicName, int partitionId)

    • resetTopicPartition

      public void resetTopicPartition(String topicName, int partitionId)

    • updateMetadata

      public boolean updateMetadata(IngestionStorageMetadata ingestionStorageMetadata)

    • shutdownForkedProcessComponent

      public void shutdownForkedProcessComponent(IngestionComponentType ingestionComponentType)

    • sendHeartbeatRequest

      public boolean sendHeartbeatRequest()

    • getLoadedStoreUserPartitionMapping

      public LoadedStoreUserPartitionMapping getLoadedStoreUserPartitionMapping()

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable
      Specified by:
      close in interface Closeable

    • setHttpClientTransport

      protected void setHttpClientTransport(HttpClientTransport clientTransport)