Package com.linkedin.davinci.kafka.consumer

Class StoreIngestionTaskFactory

java.lang.Object

com.linkedin.davinci.kafka.consumer.StoreIngestionTaskFactory

public class StoreIngestionTaskFactory
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	StoreIngestionTaskFactory.Builder	Builder class for StoreIngestionTaskFactory; once the build() function is invoked, no modification is allowed on any parameters.

Method Summary

Modifier and Type	Method	Description
static StoreIngestionTaskFactory.Builder	builder()
StoreIngestionTask	getNewIngestionTask(StorageService storageService, Store store, Version version, Properties kafkaConsumerProperties, BooleanSupplier isCurrentVersion, VeniceStoreVersionConfig storeConfig, int partitionId, boolean isIsolatedIngestion, Optional<ObjectCacheBackend> cacheBackend, DaVinciRecordTransformerConfig recordTransformerConfig, Lazy<org.apache.helix.manager.zk.ZKHelixAdmin> zkHelixAdmin)

Methods inherited from class java.lang.Object

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

Method Details

getNewIngestionTask

public StoreIngestionTask getNewIngestionTask(StorageService storageService,
 Store store,
 Version version,
 Properties kafkaConsumerProperties,
 BooleanSupplier isCurrentVersion,
 VeniceStoreVersionConfig storeConfig,
 int partitionId,
 boolean isIsolatedIngestion,
 Optional<ObjectCacheBackend> cacheBackend,
 DaVinciRecordTransformerConfig recordTransformerConfig,
 Lazy<org.apache.helix.manager.zk.ZKHelixAdmin> zkHelixAdmin)

builder

public static StoreIngestionTaskFactory.Builder builder()

Returns:

a new builder for the StoreIngestionTaskFactory