public class BigQueryInsertErrorCoder extends org.apache.beam.sdk.coders.AtomicCoder<BigQueryInsertError>
Coder
that encodes BigQuery BigQueryInsertError
objects.Constructor and Description |
---|
BigQueryInsertErrorCoder() |
Modifier and Type | Method and Description |
---|---|
BigQueryInsertError |
decode(java.io.InputStream inStream) |
void |
encode(BigQueryInsertError value,
java.io.OutputStream outStream) |
protected long |
getEncodedElementByteSize(BigQueryInsertError value) |
org.apache.beam.sdk.values.TypeDescriptor<BigQueryInsertError> |
getEncodedTypeDescriptor() |
static BigQueryInsertErrorCoder |
of() |
void |
verifyDeterministic() |
equals, getCoderArguments, getComponents, hashCode
public static BigQueryInsertErrorCoder of()
public void encode(BigQueryInsertError value, java.io.OutputStream outStream) throws java.io.IOException
encode
in class org.apache.beam.sdk.coders.Coder<BigQueryInsertError>
java.io.IOException
public BigQueryInsertError decode(java.io.InputStream inStream) throws java.io.IOException
decode
in class org.apache.beam.sdk.coders.Coder<BigQueryInsertError>
java.io.IOException
protected long getEncodedElementByteSize(BigQueryInsertError value) throws java.lang.Exception
getEncodedElementByteSize
in class org.apache.beam.sdk.coders.Coder<BigQueryInsertError>
java.lang.Exception
public void verifyDeterministic() throws org.apache.beam.sdk.coders.Coder.NonDeterministicException
verifyDeterministic
in class org.apache.beam.sdk.coders.AtomicCoder<BigQueryInsertError>
NonDeterministicException
- always. A TableRow
can hold arbitrary Object
instances, which makes the encoding non-deterministic.org.apache.beam.sdk.coders.Coder.NonDeterministicException
public org.apache.beam.sdk.values.TypeDescriptor<BigQueryInsertError> getEncodedTypeDescriptor()
getEncodedTypeDescriptor
in class org.apache.beam.sdk.coders.Coder<BigQueryInsertError>