Package io.streamthoughts.azkarra.api.streams

Class KafkaStreamsMetadata

java.lang.Object

io.streamthoughts.azkarra.api.streams.KafkaStreamsMetadata

public class KafkaStreamsMetadata
extends Object

A KafkaStreamsMetadata regroups information about resources assigned to a stream application instance, i.e., a set of Topic/Partitions and state stores.

Field Summary

Fields

Modifier and Type	Field	Description
static KafkaStreamsMetadata	EMPTY

Constructor Summary

Constructors

Constructor	Description
KafkaStreamsMetadata(Set<String> stateStores, Set<TopicPartitions> assignments, Set<String> standbyStateStores, Set<TopicPartitions> standbyAssignments)	Creates a new KafkaStreamsMetadata instance.

Method Summary

Modifier and Type	Method	Description
Set<TopicPartitions>	assignments()	Gets the set of topic-partitions assigned to this instance.
Set<TopicPartitions>	standbyAssignments()	Gets the set of topic-partitions assigned to this instance for standby state stores.
Set<String>	standbyStateStores()	Gets the set of standby state store names hosted by this instance.
Set<String>	stateStores()	Gets the set of store names hosted by this instance.

Methods inherited from class java.lang.Object

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

Field Detail

EMPTY

public static final KafkaStreamsMetadata EMPTY

Constructor Detail

KafkaStreamsMetadata

public KafkaStreamsMetadata(Set<String> stateStores,
                            Set<TopicPartitions> assignments,
                            Set<String> standbyStateStores,
                            Set<TopicPartitions> standbyAssignments)

Creates a new KafkaStreamsMetadata instance.

Method Detail

stateStores

public Set<String> stateStores()

Gets the set of store names hosted by this instance.

Returns:

the set of stores.

assignments

public Set<TopicPartitions> assignments()

Gets the set of topic-partitions assigned to this instance.

Returns:

the set of TopicPartitions.

standbyStateStores

public Set<String> standbyStateStores()

Gets the set of standby state store names hosted by this instance.

Returns:

the set of stores.

standbyAssignments

public Set<TopicPartitions> standbyAssignments()

Gets the set of topic-partitions assigned to this instance for standby state stores.

Returns:

the set of TopicPartitions.