Package cern.nxcals.api.domain

Class RecordKey

java.lang.Object

cern.nxcals.api.domain.RecordKey

public final class RecordKey
extends java.lang.Object

This class represents the Kafka record key for ingested data.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RecordKey.RecordKeyBuilder

Method Summary

Modifier and Type	Method	Description
static RecordKey.RecordKeyBuilder	builder()
static RecordKey	deserialize(byte[] array)
boolean	equals(java.lang.Object o)
long	getEntityId()
long	getPartitionId()
long	getSchemaId()
long	getSystemId()
long	getTimestamp()
int	hashCode()
static boolean	isValid(byte[] array)
byte[]	serialize()
static byte[]	serialize(long systemId, long partitionId, long schemaId, long entityId, long timestamp)
java.lang.String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Method Detail

serialize

public byte[] serialize()

serialize

public static byte[] serialize(long systemId,
                               long partitionId,
                               long schemaId,
                               long entityId,
                               long timestamp)

deserialize

public static RecordKey deserialize(byte[] array)

isValid

public static boolean isValid(byte[] array)

builder

public static RecordKey.RecordKeyBuilder builder()

getSystemId

public long getSystemId()

getPartitionId

public long getPartitionId()

getSchemaId

public long getSchemaId()

getEntityId

public long getEntityId()

getTimestamp

public long getTimestamp()

equals

public boolean equals(java.lang.Object o)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object