Package org.apache.beam.sdk.util
Class WindowedValue.WindowedValueCoder<T>
- java.lang.Object
-
- org.apache.beam.sdk.coders.Coder<T>
-
- org.apache.beam.sdk.coders.StructuredCoder<WindowedValue<T>>
-
- org.apache.beam.sdk.util.WindowedValue.WindowedValueCoder<T>
-
- All Implemented Interfaces:
java.io.Serializable
- Direct Known Subclasses:
WindowedValue.FullWindowedValueCoder
,WindowedValue.ValueOnlyWindowedValueCoder
- Enclosing class:
- WindowedValue<T>
public abstract static class WindowedValue.WindowedValueCoder<T> extends StructuredCoder<WindowedValue<T>>
Abstract class forWindowedValue
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
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description Coder<T>
getValueCoder()
Returns the value coder.abstract <NewT> WindowedValue.WindowedValueCoder<NewT>
withValueCoder(Coder<NewT> valueCoder)
Returns a newWindowedValueCoder
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, getEncodedTypeDescriptor, isRegisterByteSizeObserverCheap, registerByteSizeObserver, structuralValue, verifyDeterministic, verifyDeterministic, verifyDeterministic
-
-
-
-
Method Detail
-
withValueCoder
public abstract <NewT> WindowedValue.WindowedValueCoder<NewT> withValueCoder(Coder<NewT> valueCoder)
Returns a newWindowedValueCoder
that is a copy of this one, but with a different value coder.
-
-