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:

  • 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, getEncodedTypeDescriptor, isRegisterByteSizeObserverCheap, registerByteSizeObserver, structuralValue, verifyDeterministic, verifyDeterministic

    Methods inherited from class java.lang.Object

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