Package org.apache.beam.sdk.values

Class WindowedValues.WindowedValueCoder<T>

java.lang.Object

org.apache.beam.sdk.coders.Coder<WindowedValue<T>>

org.apache.beam.sdk.coders.StructuredCoder<WindowedValue<T>>

org.apache.beam.sdk.values.WindowedValues.WindowedValueCoder<T>

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

WindowedValues.FullWindowedValueCoder, WindowedValues.ValueOnlyWindowedValueCoder

Enclosing class:

WindowedValues

public abstract static class WindowedValues.WindowedValueCoder<T>
extends StructuredCoder<WindowedValue<T>>

Abstract class for WindowedValue coder.

See Also:

• Serialized Form

Nested Class Summary

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

Coder.Context, Coder.NonDeterministicException

Method Summary

Modifier and Type	Method	Description
Coder<T>	getValueCoder()	Returns the value coder.
static boolean	isMetadataSupported()
static void	setMetadataSupported()
abstract <NewT> WindowedValues.WindowedValueCoder<NewT>	withValueCoder(Coder<NewT> valueCoder)	Returns a new WindowedValueCoder that is a copy of this one, but with a different value coder.

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

equals, getComponents, hashCode, toString

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

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

Methods inherited from class java.lang.Object

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

Method Details

setMetadataSupported

public static void setMetadataSupported()

isMetadataSupported

public static boolean isMetadataSupported()

getValueCoder

public Coder<T> getValueCoder()

Returns the value coder.

withValueCoder

public abstract <NewT>
WindowedValues.WindowedValueCoder<NewT> withValueCoder(Coder<NewT> valueCoder)

Returns a new WindowedValueCoder that is a copy of this one, but with a different value coder.