Package org.apache.kafka.streams.kstream.internals.foreignkeyjoin

Class SubscriptionWrapper<K>

java.lang.Object

org.apache.kafka.streams.kstream.internals.foreignkeyjoin.SubscriptionWrapper<K>

public class SubscriptionWrapper<K>
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	SubscriptionWrapper.Instruction

Constructor Summary

Constructors

Constructor	Description
SubscriptionWrapper(long[] hash, SubscriptionWrapper.Instruction instruction, K primaryKey)
SubscriptionWrapper(long[] hash, SubscriptionWrapper.Instruction instruction, K primaryKey, byte version)

Method Summary

Modifier and Type	Method	Description
long[]	getHash()
SubscriptionWrapper.Instruction	getInstruction()
K	getPrimaryKey()
byte	getVersion()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

SubscriptionWrapper

public SubscriptionWrapper(long[] hash,
                           SubscriptionWrapper.Instruction instruction,
                           K primaryKey)

SubscriptionWrapper

public SubscriptionWrapper(long[] hash,
                           SubscriptionWrapper.Instruction instruction,
                           K primaryKey,
                           byte version)

Method Detail

getInstruction

public SubscriptionWrapper.Instruction getInstruction()

getHash

public long[] getHash()

getPrimaryKey

public K getPrimaryKey()

getVersion

public byte getVersion()

toString

public String toString()

Overrides:

toString in class Object