Package com.linkedin.davinci.ingestion.main

Class MainIngestionRequestClient

java.lang.Object

com.linkedin.davinci.ingestion.main.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 Summary

Constructors

Constructor	Description
MainIngestionRequestClient(VeniceConfigLoader configLoader)

Method Summary

Modifier and Type	Method	Description
void	close()
LoadedStoreUserPartitionMapping	getLoadedStoreUserPartitionMapping()
void	killConsumptionTask(java.lang.String topicName)
void	openStorageEngine(java.lang.String topicName)
void	removeStorageEngine(java.lang.String topicName)
boolean	removeTopicPartition(java.lang.String topicName, int partitionId)
void	resetTopicPartition(java.lang.String topicName, int partitionId)
boolean	sendHeartbeatRequest()
protected void	setHttpClientTransport(HttpClientTransport clientTransport)
void	shutdownForkedProcessComponent(IngestionComponentType ingestionComponentType)
void	shutdownIngestionTask(java.lang.String topicName)
boolean	startConsumption(java.lang.String topicName, int partitionId)
java.lang.Process	startForkedIngestionProcess(VeniceConfigLoader configLoader)
boolean	stopConsumption(java.lang.String topicName, int partitionId)
boolean	updateMetadata(IngestionStorageMetadata ingestionStorageMetadata)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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)

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 java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

setHttpClientTransport

protected void setHttpClientTransport(HttpClientTransport clientTransport)