Package akka.remote.artery.compress

Class CompressionTable<T>

java.lang.Object

akka.remote.artery.compress.CompressionTable<T>

public final class CompressionTable<T>
extends java.lang.Object

INTERNAL API: Versioned compression table to be advertised between systems

param: version Either -1 for disabled or a version between 0 and 127

Constructor Summary

Constructors

Constructor	Description
CompressionTable(long originUid, byte version, org.agrona.collections.Object2IntHashMap<T> _dictionary)

Method Summary

Modifier and Type	Method	Description
static <T> CompressionTable<T>	apply(long originUid, byte version, scala.collection.immutable.Map<T,java.lang.Object> dictionary)
static <T> java.util.Comparator<scala.Tuple2<T,java.lang.Object>>	compareBy2ndValue()
static java.util.Comparator<scala.Tuple2<java.lang.Object,java.lang.Object>>	CompareBy2ndValue()
int	compress(T value)
scala.collection.immutable.Map<T,java.lang.Object>	dictionary()
static <T> CompressionTable<T>	empty()
boolean	equals(java.lang.Object obj)
int	hashCode()
DecompressionTable<T>	invert()
static int	NotCompressedId()
long	originUid()
java.lang.String	toString()
byte	version()

Methods inherited from class java.lang.Object

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

Constructor Detail

CompressionTable

public CompressionTable(long originUid,
                        byte version,
                        org.agrona.collections.Object2IntHashMap<T> _dictionary)

Method Detail

NotCompressedId

public static final int NotCompressedId()

CompareBy2ndValue

public static final java.util.Comparator<scala.Tuple2<java.lang.Object,java.lang.Object>> CompareBy2ndValue()

compareBy2ndValue

public static <T> java.util.Comparator<scala.Tuple2<T,java.lang.Object>> compareBy2ndValue()

empty

public static <T> CompressionTable<T> empty()

apply

public static <T> CompressionTable<T> apply(long originUid,
                                            byte version,
                                            scala.collection.immutable.Map<T,java.lang.Object> dictionary)

originUid

public long originUid()

version

public byte version()

dictionary

public scala.collection.immutable.Map<T,java.lang.Object> dictionary()

compress

public int compress(T value)

invert

public DecompressionTable<T> invert()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object