Package org.apache.nemo.examples.beam
Class ObjectCoderForString
- java.lang.Object
-
- org.apache.beam.sdk.coders.Coder<T>
-
- org.apache.beam.sdk.coders.StructuredCoder<T>
-
- org.apache.beam.sdk.coders.AtomicCoder<java.lang.Object>
-
- org.apache.nemo.examples.beam.ObjectCoderForString
-
- All Implemented Interfaces:
java.io.Serializable
public final class ObjectCoderForString extends org.apache.beam.sdk.coders.AtomicCoder<java.lang.Object>
This coder acts like an object coder to conform the type, but is actually just aStringUtf8Coder
. This should only be used in a context where the actual type is aString
. Used inEDGARTop10BadRefererDocs
.- See Also:
- Serialized Form
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description java.lang.Object
decode(java.io.InputStream inStream)
void
encode(java.lang.Object value, java.io.OutputStream outStream)
static ObjectCoderForString
of()
Public accessor of the coder.-
Methods inherited from class org.apache.beam.sdk.coders.AtomicCoder
equals, getCoderArguments, getComponents, hashCode, verifyDeterministic
-
-
-
-
Method Detail
-
of
public static ObjectCoderForString of()
Public accessor of the coder.- Returns:
- the coder.
-
encode
public void encode(java.lang.Object value, java.io.OutputStream outStream) throws java.io.IOException
- Specified by:
encode
in classorg.apache.beam.sdk.coders.Coder<java.lang.Object>
- Throws:
java.io.IOException
-
decode
public java.lang.Object decode(java.io.InputStream inStream) throws java.io.IOException
- Specified by:
decode
in classorg.apache.beam.sdk.coders.Coder<java.lang.Object>
- Throws:
java.io.IOException
-
-