Class GlobalWindow.Coder
- java.lang.Object
-
- org.apache.beam.sdk.coders.Coder<T>
-
- org.apache.beam.sdk.coders.StructuredCoder<GlobalWindow>
-
- org.apache.beam.sdk.transforms.windowing.GlobalWindow.Coder
-
- All Implemented Interfaces:
java.io.Serializable
- Enclosing class:
- GlobalWindow
public static class GlobalWindow.Coder extends StructuredCoder<GlobalWindow>
GlobalWindow.Coder
for encoding and decodingGlobalWindow
s.- See Also:
- Serialized Form
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.beam.sdk.coders.Coder
Coder.Context, Coder.NonDeterministicException
-
-
Field Summary
Fields Modifier and Type Field Description static GlobalWindow.Coder
INSTANCE
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
consistentWithEquals()
GlobalWindow
decode(java.io.InputStream inStream)
Decodes a value of typeT
from the given input stream in the given context.void
encode(GlobalWindow window, java.io.OutputStream outStream)
Encodes the given value of typeT
onto the given output stream.java.util.List<Coder<?>>
getCoderArguments()
void
verifyDeterministic()
ThrowCoder.NonDeterministicException
if the coding is not deterministic.-
Methods inherited from class org.apache.beam.sdk.coders.StructuredCoder
equals, getComponents, hashCode, toString
-
Methods inherited from class org.apache.beam.sdk.coders.Coder
decode, encode, getEncodedElementByteSize, getEncodedTypeDescriptor, isRegisterByteSizeObserverCheap, registerByteSizeObserver, structuralValue, verifyDeterministic, verifyDeterministic
-
-
-
-
Field Detail
-
INSTANCE
public static final GlobalWindow.Coder INSTANCE
-
-
Method Detail
-
encode
public void encode(GlobalWindow window, java.io.OutputStream outStream)
Description copied from class:Coder
Encodes the given value of typeT
onto the given output stream.- Specified by:
encode
in classCoder<GlobalWindow>
-
decode
public GlobalWindow decode(java.io.InputStream inStream)
Description copied from class:Coder
Decodes a value of typeT
from the given input stream in the given context. Returns the decoded value.- Specified by:
decode
in classCoder<GlobalWindow>
-
verifyDeterministic
public void verifyDeterministic()
Description copied from class:Coder
ThrowCoder.NonDeterministicException
if the coding is not deterministic.In order for a
Coder
to be considered deterministic, the following must be true:- two values that compare as equal (via
Object.equals()
orComparable.compareTo()
, if supported) have the same encoding. - the
Coder
always produces a canonical encoding, which is the same for an instance of an object even if produced on different computers at different times.
- Specified by:
verifyDeterministic
in classCoder<GlobalWindow>
- two values that compare as equal (via
-
consistentWithEquals
public boolean consistentWithEquals()
Description copied from class:Coder
Returnstrue
if thisCoder
is injective with respect toObject.equals(java.lang.Object)
.Whenever the encoded bytes of two values are equal, then the original values are equal according to
Objects.equals()
. Note that this is well-defined fornull
.This condition is most notably false for arrays. More generally, this condition is false whenever
equals()
compares object identity, rather than performing a semantic/structural comparison.By default, returns false.
- Overrides:
consistentWithEquals
in classCoder<GlobalWindow>
-
getCoderArguments
public final java.util.List<Coder<?>> getCoderArguments()
Description copied from class:Coder
If this is aCoder
for a parameterized type, returns the list ofCoder
s being used for each of the parameters in the same order they appear within the parameterized type's type signature. If this cannot be done, or thisCoder
does not encode/decode a parameterized type, returns the empty list.- Specified by:
getCoderArguments
in classCoder<GlobalWindow>
-
-