Class StoreIngestionTaskFactory
- java.lang.Object
-
- com.linkedin.davinci.kafka.consumer.StoreIngestionTaskFactory
-
public class StoreIngestionTaskFactory extends java.lang.Object
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static class
StoreIngestionTaskFactory.Builder
Builder class forStoreIngestionTaskFactory
; once the build() function is invoked, no modification is allowed on any parameters.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static StoreIngestionTaskFactory.Builder
builder()
StoreIngestionTask
getNewIngestionTask(StorageService storageService, Store store, Version version, java.util.Properties kafkaConsumerProperties, java.util.function.BooleanSupplier isCurrentVersion, VeniceStoreVersionConfig storeConfig, int partitionId, boolean isIsolatedIngestion, java.util.Optional<ObjectCacheBackend> cacheBackend, DaVinciRecordTransformerFunctionalInterface recordTransformerFunction, Lazy<org.apache.helix.manager.zk.ZKHelixAdmin> zkHelixAdmin)
-
-
-
Method Detail
-
getNewIngestionTask
public StoreIngestionTask getNewIngestionTask(StorageService storageService, Store store, Version version, java.util.Properties kafkaConsumerProperties, java.util.function.BooleanSupplier isCurrentVersion, VeniceStoreVersionConfig storeConfig, int partitionId, boolean isIsolatedIngestion, java.util.Optional<ObjectCacheBackend> cacheBackend, DaVinciRecordTransformerFunctionalInterface recordTransformerFunction, Lazy<org.apache.helix.manager.zk.ZKHelixAdmin> zkHelixAdmin)
-
builder
public static StoreIngestionTaskFactory.Builder builder()
- Returns:
- a new builder for the
StoreIngestionTaskFactory
-
-