public class TableRowJsonCoder extends AtomicCoder<TableRow>
Coder.Context, Coder.NonDeterministicException| Modifier and Type | Method and Description |
|---|---|
TableRow |
decode(java.io.InputStream inStream)
Decodes a value of type
T from the given input stream in
the given context. |
TableRow |
decode(java.io.InputStream inStream,
Coder.Context context)
Decodes a value of type
T from the given input stream in
the given context. |
void |
encode(TableRow value,
java.io.OutputStream outStream)
Encodes the given value of type
T onto the given output stream. |
void |
encode(TableRow value,
java.io.OutputStream outStream,
Coder.Context context)
Encodes the given value of type
T onto the given output stream
in the given context. |
protected long |
getEncodedElementByteSize(TableRow value)
Returns the size in bytes of the encoded value using this coder.
|
TypeDescriptor<TableRow> |
getEncodedTypeDescriptor()
Returns the
TypeDescriptor for the type encoded. |
static TableRowJsonCoder |
of() |
void |
verifyDeterministic()
Throw
Coder.NonDeterministicException if the coding is not deterministic. |
equals, getCoderArguments, getComponents, hashCodeconsistentWithEquals, structuralValue, toStringisRegisterByteSizeObserverCheap, registerByteSizeObserver, verifyDeterministic, verifyDeterministicpublic static TableRowJsonCoder of()
public void encode(TableRow value, java.io.OutputStream outStream) throws java.io.IOException
CoderT onto the given output stream.encode in class Coder<TableRow>java.io.IOException - if writing to the OutputStream fails
for some reasonCoderException - if the value could not be encoded for some reasonpublic void encode(TableRow value, java.io.OutputStream outStream, Coder.Context context) throws java.io.IOException
CoderT onto the given output stream
in the given context.encode in class Coder<TableRow>java.io.IOException - if writing to the OutputStream fails
for some reasonCoderException - if the value could not be encoded for some reasonpublic TableRow decode(java.io.InputStream inStream) throws java.io.IOException
CoderT from the given input stream in
the given context. Returns the decoded value.decode in class Coder<TableRow>java.io.IOException - if reading from the InputStream fails
for some reasonCoderException - if the value could not be decoded for some reasonpublic TableRow decode(java.io.InputStream inStream, Coder.Context context) throws java.io.IOException
CoderT from the given input stream in
the given context. Returns the decoded value.decode in class Coder<TableRow>java.io.IOException - if reading from the InputStream fails
for some reasonCoderException - if the value could not be decoded for some reasonprotected long getEncodedElementByteSize(TableRow value) throws java.lang.Exception
CodergetEncodedElementByteSize in class Coder<TableRow>java.lang.Exceptionpublic void verifyDeterministic()
throws Coder.NonDeterministicException
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.
Unless overridden, does not throw. An AtomicCoder is presumed to be deterministic
verifyDeterministic in class AtomicCoder<TableRow>NonDeterministicException - always. A TableRow can hold arbitrary
Object instances, which makes the encoding non-deterministic.Coder.NonDeterministicException - if this coder is not deterministic.public TypeDescriptor<TableRow> getEncodedTypeDescriptor()
CoderTypeDescriptor for the type encoded.getEncodedTypeDescriptor in class StructuredCoder<TableRow>