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(Store store, Version version, java.util.Properties kafkaConsumerProperties, java.util.function.BooleanSupplier isCurrentVersion, VeniceStoreVersionConfig storeConfig, int partitionId, boolean isIsolatedIngestion, java.util.Optional<ObjectCacheBackend> cacheBackend, java.util.function.Function<java.lang.Integer,DaVinciRecordTransformer> getRecordTransformer)
-
-
-
Method Detail
-
getNewIngestionTask
public StoreIngestionTask getNewIngestionTask(Store store, Version version, java.util.Properties kafkaConsumerProperties, java.util.function.BooleanSupplier isCurrentVersion, VeniceStoreVersionConfig storeConfig, int partitionId, boolean isIsolatedIngestion, java.util.Optional<ObjectCacheBackend> cacheBackend, java.util.function.Function<java.lang.Integer,DaVinciRecordTransformer> getRecordTransformer)
-
builder
public static StoreIngestionTaskFactory.Builder builder()
- Returns:
- a new builder for the
StoreIngestionTaskFactory
-
-