Package akka.remote.artery.compress
Class InboundManifestCompression
- java.lang.Object
-
- akka.remote.artery.compress.InboundCompression<java.lang.String>
-
- akka.remote.artery.compress.InboundManifestCompression
-
public final class InboundManifestCompression extends InboundCompression<java.lang.String>
INTERNAL API
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class akka.remote.artery.compress.InboundCompression
InboundCompression.Tables<T>, InboundCompression.Tables$
-
-
Constructor Summary
Constructors Constructor Description InboundManifestCompression(LoggingAdapter log, ArterySettings.Compression settings, long originUid, InboundContext inboundContext, TopHeavyHitters<java.lang.String> heavyHitters)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
advertiseCompressionTable(OutboundContext outboundContext, CompressionTable<java.lang.String> table)
Must be implemented by extending classes in order to send aControlMessage
of appropriate type to the remote system in order to advertise the compression table to it.OptionVal<java.lang.String>
decompress(byte incomingTableVersion, int idx)
Override and specialize if needed, for default compression logic delegate to 3-param overloadvoid
increment(Address remoteAddress, java.lang.String value, long n)
Addn
occurrence for the given key and callheavyHittedDetected
if element has become a heavy hitter.-
Methods inherited from class akka.remote.artery.compress.InboundCompression
confirmAdvertisement, decompressInternal, heavyHitters, KeepOldTablesNumber, log, originUid, runNextTableAdvertisement, settings, toString
-
-
-
-
Constructor Detail
-
InboundManifestCompression
public InboundManifestCompression(LoggingAdapter log, ArterySettings.Compression settings, long originUid, InboundContext inboundContext, TopHeavyHitters<java.lang.String> heavyHitters)
-
-
Method Detail
-
advertiseCompressionTable
public void advertiseCompressionTable(OutboundContext outboundContext, CompressionTable<java.lang.String> table)
Description copied from class:InboundCompression
Must be implemented by extending classes in order to send aControlMessage
of appropriate type to the remote system in order to advertise the compression table to it.- Specified by:
advertiseCompressionTable
in classInboundCompression<java.lang.String>
- Parameters:
outboundContext
- (undocumented)table
- (undocumented)
-
decompress
public OptionVal<java.lang.String> decompress(byte incomingTableVersion, int idx)
Description copied from class:InboundCompression
Override and specialize if needed, for default compression logic delegate to 3-param overload- Specified by:
decompress
in classInboundCompression<java.lang.String>
-
increment
public void increment(Address remoteAddress, java.lang.String value, long n)
Description copied from class:InboundCompression
Addn
occurrence for the given key and callheavyHittedDetected
if element has become a heavy hitter. Empty keys are omitted.- Overrides:
increment
in classInboundCompression<java.lang.String>
- Parameters:
remoteAddress
- (undocumented)value
- (undocumented)n
- (undocumented)
-
-