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	getAaWCIngestionStorageLookupThreadPool()
ExecutorService	getAAWCWorkLoadProcessingThreadPool()
AggKafkaConsumerService	getAggKafkaConsumerService()
StorageEngineBackedCompressorFactory	getCompressorFactory()
DiskUsage	getDiskUsage()
HeartbeatMonitoringService	getHeartbeatMonitoringService()
AggHostLevelIngestionStats	getIngestionStats()
Queue<VeniceNotifier>	getLeaderFollowerNotifiers()
ReadOnlyStoreRepository	getMetadataRepo()
MetaStoreWriter	getMetaStoreWriter()
InternalAvroSpecificSerializer<PartitionState>	getPartitionStateSerializer()
PubSubContext	getPubSubContext()
RemoteIngestionRepairService	getRemoteIngestionRepairService()
Supplier<IngestionTaskReusableObjects>	getReusableObjectsSupplier()
ReadOnlySchemaRepository	getSchemaRepo()
VeniceServerConfig	getServerConfig()
StorageMetadataService	getStorageMetadataService()
AbstractStoreBufferService	getStoreBufferService()
VeniceViewWriterFactory	getVeniceViewWriterFactory()
VeniceWriterFactory	getVeniceWriterFactory()
AggVersionedDIVStats	getVersionedDIVStats()
AggVersionedIngestionStats	getVersionedStorageIngestionStats()
boolean	isDaVinciClient()
StoreIngestionTaskFactory.Builder	setAAWCIngestionStorageLookupThreadPool(ExecutorService executorService)
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	setPubSubContext(PubSubContext pubSubContext)
StoreIngestionTaskFactory.Builder	setRemoteIngestionRepairService(RemoteIngestionRepairService repairService)
StoreIngestionTaskFactory.Builder	setReusableObjectsSupplier(Supplier<IngestionTaskReusableObjects> reusableObjectsSupplier)
StoreIngestionTaskFactory.Builder	setSchemaRepository(ReadOnlySchemaRepository schemaRepo)
StoreIngestionTaskFactory.Builder	setServerConfig(VeniceServerConfig serverConfig)
StoreIngestionTaskFactory.Builder	setStorageMetadataService(StorageMetadataService storageMetadataService)
StoreIngestionTaskFactory.Builder	setStoreBufferService(AbstractStoreBufferService storeBufferService)
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()

getStorageMetadataService

public StorageMetadataService getStorageMetadataService()

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)

setPubSubContext

public StoreIngestionTaskFactory.Builder setPubSubContext(PubSubContext pubSubContext)

getPubSubContext

public PubSubContext getPubSubContext()

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)

setAAWCWorkLoadProcessingThreadPool

public StoreIngestionTaskFactory.Builder setAAWCWorkLoadProcessingThreadPool(ExecutorService executorService)

setAAWCIngestionStorageLookupThreadPool

public StoreIngestionTaskFactory.Builder setAAWCIngestionStorageLookupThreadPool(ExecutorService executorService)

getAaWCIngestionStorageLookupThreadPool

public ExecutorService getAaWCIngestionStorageLookupThreadPool()

getAAWCWorkLoadProcessingThreadPool

public ExecutorService getAAWCWorkLoadProcessingThreadPool()

setReusableObjectsSupplier

public StoreIngestionTaskFactory.Builder setReusableObjectsSupplier(Supplier<IngestionTaskReusableObjects> reusableObjectsSupplier)

getReusableObjectsSupplier

public Supplier<IngestionTaskReusableObjects> getReusableObjectsSupplier()