public static class RowMutation.RowMutationCoder extends org.apache.beam.sdk.coders.AtomicCoder<RowMutation>
Constructor and Description |
---|
RowMutationCoder() |
Modifier and Type | Method and Description |
---|---|
RowMutation |
decode(java.io.InputStream inStream) |
void |
encode(RowMutation value,
java.io.OutputStream outStream) |
static RowMutation.RowMutationCoder |
of() |
equals, getCoderArguments, getComponents, hashCode, verifyDeterministic
public static RowMutation.RowMutationCoder of()
public void encode(RowMutation value, java.io.OutputStream outStream) throws java.io.IOException
encode
in class org.apache.beam.sdk.coders.Coder<RowMutation>
java.io.IOException
public RowMutation decode(java.io.InputStream inStream) throws java.io.IOException
decode
in class org.apache.beam.sdk.coders.Coder<RowMutation>
java.io.IOException