Package com.linkedin.venice.pubsub.api

Class PubSubMessageHeaders

java.lang.Object

com.linkedin.venice.pubsub.api.PubSubMessageHeaders

All Implemented Interfaces:

Measurable, Iterable<PubSubMessageHeader>

Direct Known Subclasses:

EmptyPubSubMessageHeaders

public class PubSubMessageHeaders
extends Object
implements Measurable, Iterable<PubSubMessageHeader>

Set of key-value pairs to tagged with messages produced to a topic. In case of headers with the same key, only the most recently added headers value will be kept.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	EXECUTION_ID_KEY
static final String	VENICE_LEADER_COMPLETION_STATE_HEADER	Header to denote whether the leader is completed or not
static final String	VENICE_TRANSPORT_PROTOCOL_HEADER
static final String	VENICE_VIEW_PARTITIONS_MAP_HEADER	Header to provide the desired view partition mapping for the given message.

Constructor Summary

Constructors

Constructor	Description
PubSubMessageHeaders()

Method Summary

Modifier and Type	Method	Description
PubSubMessageHeaders	add(PubSubMessageHeader header)
PubSubMessageHeaders	add(String key, byte[] value)
PubSubMessageHeader	get(String key)
int	getHeapSize()
boolean	isEmpty()
Iterator<PubSubMessageHeader>	iterator()
PubSubMessageHeaders	remove(String key)
List<PubSubMessageHeader>	toList()

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.lang.Iterable

forEach, spliterator

Field Details

EXECUTION_ID_KEY

public static final String EXECUTION_ID_KEY

See Also:

• Constant Field Values

VENICE_TRANSPORT_PROTOCOL_HEADER

public static final String VENICE_TRANSPORT_PROTOCOL_HEADER

See Also:

• Constant Field Values

VENICE_LEADER_COMPLETION_STATE_HEADER

public static final String VENICE_LEADER_COMPLETION_STATE_HEADER

Header to denote whether the leader is completed or not

See Also:

• Constant Field Values

VENICE_VIEW_PARTITIONS_MAP_HEADER

public static final String VENICE_VIEW_PARTITIONS_MAP_HEADER

Header to provide the desired view partition mapping for the given message. Example usage: 1. A VPJ containing large messages write chunks with the header {"view1":[0], "view2":[1, 2]}. Partition leaders during NR pass-through in remote fabrics can forward chunks to their destination view partition(s) without any further processing. In the example, this chunk should be sent to view1's partition 0 and view2's partitions 1 & 2.

See Also:

• Constant Field Values

Constructor Details

PubSubMessageHeaders

public PubSubMessageHeaders()

Method Details

add

public PubSubMessageHeaders add(PubSubMessageHeader header)

add

public PubSubMessageHeaders add(String key,
 byte[] value)

remove

public PubSubMessageHeaders remove(String key)

get

public PubSubMessageHeader get(String key)

toList

public List<PubSubMessageHeader> toList()

Returns:

the headers as a List. Mutating this list will not affect the PubSubMessageHeaders. If no headers are present an empty list is returned.

isEmpty

public boolean isEmpty()

getHeapSize

public int getHeapSize()

Specified by:

getHeapSize in interface Measurable

iterator

public Iterator<PubSubMessageHeader> iterator()

Specified by:

iterator in interface Iterable<PubSubMessageHeader>