public static class GlobalWindow.Coder extends StructuredCoder<GlobalWindow>
GlobalWindow.Coder
for encoding and decoding GlobalWindow
s.Coder.Context, Coder.NonDeterministicException
Modifier and Type | Field and Description |
---|---|
static GlobalWindow.Coder |
INSTANCE |
Modifier and Type | Method and Description |
---|---|
boolean |
consistentWithEquals()
|
GlobalWindow |
decode(java.io.InputStream inStream)
Decodes a value of type
T from the given input stream in the given context. |
void |
encode(GlobalWindow window,
java.io.OutputStream outStream)
Encodes the given value of type
T onto the given output stream. |
java.util.List<Coder<?>> |
getCoderArguments()
|
void |
verifyDeterministic()
Throw
Coder.NonDeterministicException if the coding is not deterministic. |
equals, getComponents, hashCode, toString
decode, encode, getEncodedElementByteSize, getEncodedTypeDescriptor, isRegisterByteSizeObserverCheap, registerByteSizeObserver, structuralValue, verifyDeterministic, verifyDeterministic
public static final GlobalWindow.Coder INSTANCE
public void encode(GlobalWindow window, java.io.OutputStream outStream)
Coder
T
onto the given output stream.encode
in class Coder<GlobalWindow>
public GlobalWindow decode(java.io.InputStream inStream)
Coder
T
from the given input stream in the given context. Returns the
decoded value.decode
in class Coder<GlobalWindow>
public void verifyDeterministic()
Coder
Coder.NonDeterministicException
if the coding is not deterministic.
In order for a Coder
to be considered deterministic, the following must be true:
Object.equals()
or Comparable.compareTo()
, if supported) have the same encoding.
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.
verifyDeterministic
in class Coder<GlobalWindow>
public boolean consistentWithEquals()
Coder
true
if this Coder
is injective with respect to Object.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 for null
.
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.
consistentWithEquals
in class Coder<GlobalWindow>
public final java.util.List<Coder<?>> getCoderArguments()
Coder
Coder
for a parameterized type, returns the list of Coder
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 this Coder
does not encode/decode a
parameterized type, returns the empty list.getCoderArguments
in class Coder<GlobalWindow>