Package com.linkedin.davinci.kafka.consumer

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 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(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)

Methods inherited from class java.lang.Object

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

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,
                                              DaVinciRecordTransformerFunctionalInterface recordTransformerFunction)

builder

public static StoreIngestionTaskFactory.Builder builder()

Returns:

a new builder for the StoreIngestionTaskFactory