Package google.registry.rde

Class PendingDeposit.PendingDepositCoder

java.lang.Object

org.apache.beam.sdk.coders.Coder<PendingDeposit>

org.apache.beam.sdk.coders.StructuredCoder<PendingDeposit>

org.apache.beam.sdk.coders.AtomicCoder<PendingDeposit>

google.registry.rde.PendingDeposit.PendingDepositCoder

All Implemented Interfaces:

Serializable

Enclosing class:

PendingDeposit

public static class PendingDeposit.PendingDepositCoder
extends org.apache.beam.sdk.coders.AtomicCoder<PendingDeposit>

A deterministic coder for PendingDeposit used during a GroupBy transform.

We cannot use a SerializableCoder directly for two reasons: the default serialization does not guarantee determinism, which is required by GroupBy in Beam; and the default deserialization is not robust against deserialization-based attacks (See SafeObjectInputStream for more information).

See Also:

• Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.sdk.coders.Coder

org.apache.beam.sdk.coders.Coder.Context, org.apache.beam.sdk.coders.Coder.NonDeterministicException

Method Summary

Modifier and Type	Method	Description
PendingDeposit	decode(InputStream inStream)
void	encode(PendingDeposit value, OutputStream outStream)
static PendingDeposit.PendingDepositCoder	of()

Methods inherited from class org.apache.beam.sdk.coders.AtomicCoder

equals, getCoderArguments, getComponents, hashCode, verifyDeterministic

Methods inherited from class org.apache.beam.sdk.coders.StructuredCoder

toString

Methods inherited from class org.apache.beam.sdk.coders.Coder

consistentWithEquals, decode, encode, getEncodedElementByteSize, getEncodedElementByteSizeUsingCoder, getEncodedTypeDescriptor, isRegisterByteSizeObserverCheap, registerByteSizeObserver, structuralValue, verifyDeterministic, verifyDeterministic

Methods inherited from class java.lang.Object

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

Method Details

of

public static PendingDeposit.PendingDepositCoder of()

encode

public void encode(PendingDeposit value,
 OutputStream outStream)
            throws IOException

Specified by:

encode in class org.apache.beam.sdk.coders.Coder<PendingDeposit>

Throws:

IOException

decode

public PendingDeposit decode(InputStream inStream)
                      throws IOException

Specified by:

decode in class org.apache.beam.sdk.coders.Coder<PendingDeposit>

Throws:

IOException