Package com.linkedin.davinci.kafka.consumer

Class StoreIngestionTaskFactory.Builder

java.lang.Object

com.linkedin.davinci.kafka.consumer.StoreIngestionTaskFactory.Builder

Enclosing class:

StoreIngestionTaskFactory

public static class StoreIngestionTaskFactory.Builder
extends Object

Builder class for StoreIngestionTaskFactory; once the build() function is invoked, no modification is allowed on any parameters.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
StoreIngestionTaskFactory	build()
ExecutorService	getAAWCWorkLoadProcessingThreadPool()
AggKafkaConsumerService	getAggKafkaConsumerService()
StorageEngineBackedCompressorFactory	getCompressorFactory()
DiskUsage	getDiskUsage()
HeartbeatMonitoringService	getHeartbeatMonitoringService()
AggHostLevelIngestionStats	getIngestionStats()
Queue<VeniceNotifier>	getLeaderFollowerNotifiers()
ReadOnlyStoreRepository	getMetadataRepo()
MetaStoreWriter	getMetaStoreWriter()
InternalAvroSpecificSerializer<PartitionState>	getPartitionStateSerializer()
PubSubTopicRepository	getPubSubTopicRepository()
RemoteIngestionRepairService	getRemoteIngestionRepairService()
Runnable	getRunnableForKillIngestionTasksForNonCurrentVersions()
ReadOnlySchemaRepository	getSchemaRepo()
VeniceServerConfig	getServerConfig()
StorageEngineRepository	getStorageEngineRepository()
StorageMetadataService	getStorageMetadataService()
AbstractStoreBufferService	getStoreBufferService()
TopicManagerRepository	getTopicManagerRepository()
VeniceViewWriterFactory	getVeniceViewWriterFactory()
VeniceWriterFactory	getVeniceWriterFactory()
AggVersionedDIVStats	getVersionedDIVStats()
AggVersionedIngestionStats	getVersionedStorageIngestionStats()
boolean	isDaVinciClient()
StoreIngestionTaskFactory.Builder	setAAWCWorkLoadProcessingThreadPool(ExecutorService executorService)
StoreIngestionTaskFactory.Builder	setAggKafkaConsumerService(AggKafkaConsumerService aggKafkaConsumerService)
StoreIngestionTaskFactory.Builder	setCompressorFactory(StorageEngineBackedCompressorFactory compressorFactory)
StoreIngestionTaskFactory.Builder	setDiskUsage(DiskUsage diskUsage)
StoreIngestionTaskFactory.Builder	setHeartbeatMonitoringService(HeartbeatMonitoringService heartbeatMonitoringService)
StoreIngestionTaskFactory.Builder	setHostLevelIngestionStats(AggHostLevelIngestionStats storeIngestionStats)
StoreIngestionTaskFactory.Builder	setIsDaVinciClient(boolean isDaVinciClient)
StoreIngestionTaskFactory.Builder	setLeaderFollowerNotifiersQueue(Queue<VeniceNotifier> leaderFollowerNotifiers)
StoreIngestionTaskFactory.Builder	setMetadataRepository(ReadOnlyStoreRepository metadataRepo)
StoreIngestionTaskFactory.Builder	setMetaStoreWriter(MetaStoreWriter metaStoreWriter)
StoreIngestionTaskFactory.Builder	setPartitionStateSerializer(InternalAvroSpecificSerializer<PartitionState> partitionStateSerializer)
StoreIngestionTaskFactory.Builder	setPubSubTopicRepository(PubSubTopicRepository pubSubTopicRepository)
StoreIngestionTaskFactory.Builder	setRemoteIngestionRepairService(RemoteIngestionRepairService repairService)
StoreIngestionTaskFactory.Builder	setRunnableForKillIngestionTasksForNonCurrentVersions(Runnable runnable)
StoreIngestionTaskFactory.Builder	setSchemaRepository(ReadOnlySchemaRepository schemaRepo)
StoreIngestionTaskFactory.Builder	setServerConfig(VeniceServerConfig serverConfig)
StoreIngestionTaskFactory.Builder	setStorageEngineRepository(StorageEngineRepository storageEngineRepository)
StoreIngestionTaskFactory.Builder	setStorageMetadataService(StorageMetadataService storageMetadataService)
StoreIngestionTaskFactory.Builder	setStoreBufferService(AbstractStoreBufferService storeBufferService)
StoreIngestionTaskFactory.Builder	setTopicManagerRepository(TopicManagerRepository topicManagerRepository)
StoreIngestionTaskFactory.Builder	setVeniceViewWriterFactory(VeniceViewWriterFactory viewWriterFactory)
StoreIngestionTaskFactory.Builder	setVeniceWriterFactory(VeniceWriterFactory writerFactory)
StoreIngestionTaskFactory.Builder	setVersionedDIVStats(AggVersionedDIVStats versionedDIVStats)
StoreIngestionTaskFactory.Builder	setVersionedIngestionStats(AggVersionedIngestionStats versionedStorageIngestionStats)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

build

public StoreIngestionTaskFactory build()

getVeniceWriterFactory

public VeniceWriterFactory getVeniceWriterFactory()

getHeartbeatMonitoringService

public HeartbeatMonitoringService getHeartbeatMonitoringService()

getVeniceViewWriterFactory

public VeniceViewWriterFactory getVeniceViewWriterFactory()

setVeniceWriterFactory

public StoreIngestionTaskFactory.Builder setVeniceWriterFactory(VeniceWriterFactory writerFactory)

setHeartbeatMonitoringService

public StoreIngestionTaskFactory.Builder setHeartbeatMonitoringService(HeartbeatMonitoringService heartbeatMonitoringService)

setVeniceViewWriterFactory

public StoreIngestionTaskFactory.Builder setVeniceViewWriterFactory(VeniceViewWriterFactory viewWriterFactory)

setRemoteIngestionRepairService

public StoreIngestionTaskFactory.Builder setRemoteIngestionRepairService(RemoteIngestionRepairService repairService)

getRemoteIngestionRepairService

public RemoteIngestionRepairService getRemoteIngestionRepairService()

setMetaStoreWriter

public StoreIngestionTaskFactory.Builder setMetaStoreWriter(MetaStoreWriter metaStoreWriter)

getMetaStoreWriter

public MetaStoreWriter getMetaStoreWriter()

getStorageEngineRepository

public StorageEngineRepository getStorageEngineRepository()

getStorageMetadataService

public StorageMetadataService getStorageMetadataService()

setStorageEngineRepository

public StoreIngestionTaskFactory.Builder setStorageEngineRepository(StorageEngineRepository storageEngineRepository)

setStorageMetadataService

public StoreIngestionTaskFactory.Builder setStorageMetadataService(StorageMetadataService storageMetadataService)

getLeaderFollowerNotifiers

public Queue<VeniceNotifier> getLeaderFollowerNotifiers()

setLeaderFollowerNotifiersQueue

public StoreIngestionTaskFactory.Builder setLeaderFollowerNotifiersQueue(Queue<VeniceNotifier> leaderFollowerNotifiers)

getSchemaRepo

public ReadOnlySchemaRepository getSchemaRepo()

setSchemaRepository

public StoreIngestionTaskFactory.Builder setSchemaRepository(ReadOnlySchemaRepository schemaRepo)

getMetadataRepo

public ReadOnlyStoreRepository getMetadataRepo()

setMetadataRepository

public StoreIngestionTaskFactory.Builder setMetadataRepository(ReadOnlyStoreRepository metadataRepo)

getTopicManagerRepository

public TopicManagerRepository getTopicManagerRepository()

setTopicManagerRepository

public StoreIngestionTaskFactory.Builder setTopicManagerRepository(TopicManagerRepository topicManagerRepository)

getIngestionStats

public AggHostLevelIngestionStats getIngestionStats()

setHostLevelIngestionStats

public StoreIngestionTaskFactory.Builder setHostLevelIngestionStats(AggHostLevelIngestionStats storeIngestionStats)

getVersionedDIVStats

public AggVersionedDIVStats getVersionedDIVStats()

setVersionedDIVStats

public StoreIngestionTaskFactory.Builder setVersionedDIVStats(AggVersionedDIVStats versionedDIVStats)

getVersionedStorageIngestionStats

public AggVersionedIngestionStats getVersionedStorageIngestionStats()

setVersionedIngestionStats

public StoreIngestionTaskFactory.Builder setVersionedIngestionStats(AggVersionedIngestionStats versionedStorageIngestionStats)

getStoreBufferService

public AbstractStoreBufferService getStoreBufferService()

setStoreBufferService

public StoreIngestionTaskFactory.Builder setStoreBufferService(AbstractStoreBufferService storeBufferService)

getServerConfig

public VeniceServerConfig getServerConfig()

setServerConfig

public StoreIngestionTaskFactory.Builder setServerConfig(VeniceServerConfig serverConfig)

getDiskUsage

public DiskUsage getDiskUsage()

setDiskUsage

public StoreIngestionTaskFactory.Builder setDiskUsage(DiskUsage diskUsage)

getAggKafkaConsumerService

public AggKafkaConsumerService getAggKafkaConsumerService()

setAggKafkaConsumerService

public StoreIngestionTaskFactory.Builder setAggKafkaConsumerService(AggKafkaConsumerService aggKafkaConsumerService)

getPartitionStateSerializer

public InternalAvroSpecificSerializer<PartitionState> getPartitionStateSerializer()

setPartitionStateSerializer

public StoreIngestionTaskFactory.Builder setPartitionStateSerializer(InternalAvroSpecificSerializer<PartitionState> partitionStateSerializer)

isDaVinciClient

public boolean isDaVinciClient()

setIsDaVinciClient

public StoreIngestionTaskFactory.Builder setIsDaVinciClient(boolean isDaVinciClient)

getCompressorFactory

public StorageEngineBackedCompressorFactory getCompressorFactory()

setCompressorFactory

public StoreIngestionTaskFactory.Builder setCompressorFactory(StorageEngineBackedCompressorFactory compressorFactory)

getPubSubTopicRepository

public PubSubTopicRepository getPubSubTopicRepository()

setPubSubTopicRepository

public StoreIngestionTaskFactory.Builder setPubSubTopicRepository(PubSubTopicRepository pubSubTopicRepository)

getRunnableForKillIngestionTasksForNonCurrentVersions

public Runnable getRunnableForKillIngestionTasksForNonCurrentVersions()

setRunnableForKillIngestionTasksForNonCurrentVersions

public StoreIngestionTaskFactory.Builder setRunnableForKillIngestionTasksForNonCurrentVersions(Runnable runnable)

setAAWCWorkLoadProcessingThreadPool

public StoreIngestionTaskFactory.Builder setAAWCWorkLoadProcessingThreadPool(ExecutorService executorService)

getAAWCWorkLoadProcessingThreadPool

public ExecutorService getAAWCWorkLoadProcessingThreadPool()