Package com.linkedin.venice.views

Class ViewUtils

java.lang.Object

com.linkedin.venice.views.ViewUtils

Direct Known Subclasses:

ViewWriterUtils

public class ViewUtils
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	ETERNAL_TOPIC_RETENTION_ENABLED
static final String	LOG_COMPACTION_ENABLED
static final String	NEARLINE_PRODUCER_COMPRESSION_ENABLED
static final String	NEARLINE_PRODUCER_COUNT_PER_WRITER
static final String	PARTITION_COUNT
static final String	USE_FAST_KAFKA_OPERATION_TIMEOUT

Constructor Summary

Constructors

Constructor	Description
ViewUtils()

Method Summary

Modifier and Type	Method	Description
static Map<String,Set<Integer>>	extractViewPartitionMap(PubSubMessageHeaders pubSubMessageHeaders)
static String	flatViewConfigMapString(Map<String,ViewConfig> viewConfigMap)
static VeniceView	getVeniceView(String viewClass, Properties params, String veniceStoreName, Map<String,String> extraParameters)
static PubSubMessageHeader	getViewDestinationPartitionHeader(Map<String,Set<Integer>> destinationPartitionMap)
static Map<String,VeniceProperties>	getViewTopicsAndConfigs(Collection<ViewConfig> viewConfigs, Properties veniceViewProperties, String storeName, int version)
static Map<String,ViewConfig>	parseViewConfigMapString(String flatViewConfigMapString)

Methods inherited from class java.lang.Object

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

Field Details

PARTITION_COUNT

public static final String PARTITION_COUNT

See Also:

• Constant Field Values

USE_FAST_KAFKA_OPERATION_TIMEOUT

public static final String USE_FAST_KAFKA_OPERATION_TIMEOUT

See Also:

• Constant Field Values

LOG_COMPACTION_ENABLED

public static final String LOG_COMPACTION_ENABLED

See Also:

• Constant Field Values

ETERNAL_TOPIC_RETENTION_ENABLED

public static final String ETERNAL_TOPIC_RETENTION_ENABLED

See Also:

• Constant Field Values

NEARLINE_PRODUCER_COMPRESSION_ENABLED

public static final String NEARLINE_PRODUCER_COMPRESSION_ENABLED

See Also:

• Constant Field Values

NEARLINE_PRODUCER_COUNT_PER_WRITER

public static final String NEARLINE_PRODUCER_COUNT_PER_WRITER

See Also:

• Constant Field Values

Constructor Details

ViewUtils

public ViewUtils()

Method Details

getVeniceView

public static VeniceView getVeniceView(String viewClass,
 Properties params,
 String veniceStoreName,
 Map<String,String> extraParameters)

flatViewConfigMapString

public static String flatViewConfigMapString(Map<String,ViewConfig> viewConfigMap)
                                      throws com.fasterxml.jackson.core.JsonProcessingException

Throws:

com.fasterxml.jackson.core.JsonProcessingException

parseViewConfigMapString

public static Map<String,ViewConfig> parseViewConfigMapString(String flatViewConfigMapString)
                                                       throws com.fasterxml.jackson.core.JsonProcessingException

Throws:

com.fasterxml.jackson.core.JsonProcessingException

getViewTopicsAndConfigs

public static Map<String,VeniceProperties> getViewTopicsAndConfigs(Collection<ViewConfig> viewConfigs,
 Properties veniceViewProperties,
 String storeName,
 int version)

extractViewPartitionMap

public static Map<String,Set<Integer>> extractViewPartitionMap(PubSubMessageHeaders pubSubMessageHeaders)

getViewDestinationPartitionHeader

public static PubSubMessageHeader getViewDestinationPartitionHeader(Map<String,Set<Integer>> destinationPartitionMap)