org.apache.pulsar.client.api

Class KeySharedPolicy

java.lang.Object

org.apache.pulsar.client.api.KeySharedPolicy

Direct Known Subclasses:

KeySharedPolicy.KeySharedPolicyAutoSplit, KeySharedPolicy.KeySharedPolicySticky

public abstract class KeySharedPolicy
extends Object

KeyShared policy for KeyShared subscription.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KeySharedPolicy.KeySharedPolicyAutoSplit Auto split hash range key shared policy.
static class	KeySharedPolicy.KeySharedPolicySticky Sticky attach topic with fixed hash range.

Field Summary

Fields

Modifier and Type	Field and Description
static int	DEFAULT_HASH_RANGE_SIZE
protected KeySharedMode	keySharedMode

Constructor Summary

Constructors

Constructor and Description
KeySharedPolicy()

Method Summary

Modifier and Type	Method and Description
static KeySharedPolicy.KeySharedPolicyAutoSplit	autoSplitHashRange()
int	getHashRangeTotal()
KeySharedMode	getKeySharedMode()
static KeySharedPolicy.KeySharedPolicySticky	stickyHashRange()
abstract void	validate()

Methods inherited from class java.lang.Object

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

Field Detail

keySharedMode

protected KeySharedMode keySharedMode

DEFAULT_HASH_RANGE_SIZE

public static final int DEFAULT_HASH_RANGE_SIZE

See Also:

Constant Field Values

Constructor Detail

KeySharedPolicy

public KeySharedPolicy()

Method Detail

autoSplitHashRange

public static KeySharedPolicy.KeySharedPolicyAutoSplit autoSplitHashRange()

stickyHashRange

public static KeySharedPolicy.KeySharedPolicySticky stickyHashRange()

validate

public abstract void validate()

getKeySharedMode

public KeySharedMode getKeySharedMode()

getHashRangeTotal

public int getHashRangeTotal()