public class TableRowJsonCoder
extends org.apache.beam.sdk.coders.AtomicCoder<com.google.api.services.bigquery.model.TableRow>
Coder
that encodes BigQuery TableRow
objects in their native JSON format.Modifier and Type | Method and Description |
---|---|
com.google.api.services.bigquery.model.TableRow |
decode(java.io.InputStream inStream) |
com.google.api.services.bigquery.model.TableRow |
decode(java.io.InputStream inStream,
org.apache.beam.sdk.coders.Coder.Context context) |
void |
encode(com.google.api.services.bigquery.model.TableRow value,
java.io.OutputStream outStream) |
void |
encode(com.google.api.services.bigquery.model.TableRow value,
java.io.OutputStream outStream,
org.apache.beam.sdk.coders.Coder.Context context) |
long |
getEncodedElementByteSize(com.google.api.services.bigquery.model.TableRow value) |
org.apache.beam.sdk.values.TypeDescriptor<com.google.api.services.bigquery.model.TableRow> |
getEncodedTypeDescriptor() |
static TableRowJsonCoder |
of() |
void |
verifyDeterministic() |
equals, getCoderArguments, getComponents, hashCode
public static TableRowJsonCoder of()
public void encode(com.google.api.services.bigquery.model.TableRow value, java.io.OutputStream outStream) throws java.io.IOException
encode
in class org.apache.beam.sdk.coders.Coder<com.google.api.services.bigquery.model.TableRow>
java.io.IOException
public void encode(com.google.api.services.bigquery.model.TableRow value, java.io.OutputStream outStream, org.apache.beam.sdk.coders.Coder.Context context) throws java.io.IOException
encode
in class org.apache.beam.sdk.coders.Coder<com.google.api.services.bigquery.model.TableRow>
java.io.IOException
public com.google.api.services.bigquery.model.TableRow decode(java.io.InputStream inStream) throws java.io.IOException
decode
in class org.apache.beam.sdk.coders.Coder<com.google.api.services.bigquery.model.TableRow>
java.io.IOException
public com.google.api.services.bigquery.model.TableRow decode(java.io.InputStream inStream, org.apache.beam.sdk.coders.Coder.Context context) throws java.io.IOException
decode
in class org.apache.beam.sdk.coders.Coder<com.google.api.services.bigquery.model.TableRow>
java.io.IOException
public long getEncodedElementByteSize(com.google.api.services.bigquery.model.TableRow value) throws java.lang.Exception
getEncodedElementByteSize
in class org.apache.beam.sdk.coders.Coder<com.google.api.services.bigquery.model.TableRow>
java.lang.Exception
public void verifyDeterministic() throws org.apache.beam.sdk.coders.Coder.NonDeterministicException
verifyDeterministic
in class org.apache.beam.sdk.coders.AtomicCoder<com.google.api.services.bigquery.model.TableRow>
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<com.google.api.services.bigquery.model.TableRow> getEncodedTypeDescriptor()
getEncodedTypeDescriptor
in class org.apache.beam.sdk.coders.Coder<com.google.api.services.bigquery.model.TableRow>