Package org.apache.beam.runners.dataflow.internal

Class IsmFormat.KeyPrefix

java.lang.Object

org.apache.beam.runners.dataflow.internal.IsmFormat.KeyPrefix

Enclosing class:

IsmFormat

public abstract static class IsmFormat.KeyPrefix
extends Object

The prefix used before each key which contains the number of shared and unshared bytes from the previous key that was read. The key prefix along with the previous key and the unshared key bytes allows one to construct the current key by doing the following currentKey = previousKey[0 : sharedBytes] + read(unsharedBytes).

The key prefix is encoded as:

• number of shared key bytes (variable length integer coding)
• number of unshared key bytes (variable length integer coding)

Constructor Summary

Constructors

Constructor	Description
KeyPrefix()

Method Summary

Modifier and Type	Method	Description
abstract int	getSharedKeySize()
abstract int	getUnsharedKeySize()
static IsmFormat.KeyPrefix	of(int sharedKeySize, int unsharedKeySize)

Methods inherited from class java.lang.Object

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

Constructor Details

KeyPrefix

public KeyPrefix()

Method Details

getSharedKeySize

public abstract int getSharedKeySize()

getUnsharedKeySize

public abstract int getUnsharedKeySize()

of

public static IsmFormat.KeyPrefix of(int sharedKeySize,
 int unsharedKeySize)