adding missing data bean serializable changes
Project: http://git-wip-us.apache.org/repos/asf/gora/repo Commit: http://git-wip-us.apache.org/repos/asf/gora/commit/4fdbf6c8 Tree: http://git-wip-us.apache.org/repos/asf/gora/tree/4fdbf6c8 Diff: http://git-wip-us.apache.org/repos/asf/gora/diff/4fdbf6c8 Branch: refs/heads/master Commit: 4fdbf6c810a951918ed142d8fc3e83f985b5672c Parents: c9d11af Author: Kevin Ratnasekera <[email protected]> Authored: Mon Aug 1 10:02:33 2016 +0530 Committer: Kevin Ratnasekera <[email protected]> Committed: Mon Aug 1 10:02:33 2016 +0530 ---------------------------------------------------------------------- .../apache/gora/goraci/generated/CINode.java | 29 +++++++++++++++++++- .../apache/gora/goraci/generated/Flushed.java | 29 +++++++++++++++++++- 2 files changed, 56 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/gora/blob/4fdbf6c8/gora-goraci/src/main/java/org/apache/gora/goraci/generated/CINode.java ---------------------------------------------------------------------- diff --git a/gora-goraci/src/main/java/org/apache/gora/goraci/generated/CINode.java b/gora-goraci/src/main/java/org/apache/gora/goraci/generated/CINode.java index da02248..0545c34 100644 --- a/gora-goraci/src/main/java/org/apache/gora/goraci/generated/CINode.java +++ b/gora-goraci/src/main/java/org/apache/gora/goraci/generated/CINode.java @@ -7,7 +7,7 @@ package org.apache.gora.goraci.generated; @SuppressWarnings("all") public class CINode extends org.apache.gora.persistency.impl.PersistentBase implements org.apache.avro.specific.SpecificRecord, org.apache.gora.persistency.Persistent { public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"CINode\",\"namespace\":\"org.apache.gora.goraci.generated\",\"fields\":[{\"name\":\"prev\",\"type\":\"long\",\"default\":0},{\"name\":\"client\",\"type\":[\"null\",\"string\"],\"default\":null},{\"name\":\"count\",\"type\":\"long\",\"default\":0}]}"); - + private static final long serialVersionUID = -6468893532296148608L; /** Enum containing all data bean's fields. */ public static enum Field { PREV(0, "prev"), @@ -402,6 +402,33 @@ public class CINode extends org.apache.gora.persistency.impl.PersistentBase impl } + + private static final org.apache.avro.io.DatumWriter + DATUM_WRITER$ = new org.apache.avro.specific.SpecificDatumWriter(SCHEMA$); + private static final org.apache.avro.io.DatumReader + DATUM_READER$ = new org.apache.avro.specific.SpecificDatumReader(SCHEMA$); + + @Override + public void writeExternal(java.io.ObjectOutput out) + throws java.io.IOException { + out.write(super.getDirtyBytes().array()); + DATUM_WRITER$.write + (this, org.apache.avro.io.EncoderFactory.get() + .directBinaryEncoder((java.io.OutputStream) out, + null)); + } + + @Override + public void readExternal(java.io.ObjectInput in) + throws java.io.IOException { + byte[] __g__dirty = new byte[getFieldsCount()]; + in.read(__g__dirty); + super.setDirtyBytes(java.nio.ByteBuffer.wrap(__g__dirty)); + DATUM_READER$.read + (this, org.apache.avro.io.DecoderFactory.get() + .directBinaryDecoder((java.io.InputStream) in, + null)); + } } http://git-wip-us.apache.org/repos/asf/gora/blob/4fdbf6c8/gora-goraci/src/main/java/org/apache/gora/goraci/generated/Flushed.java ---------------------------------------------------------------------- diff --git a/gora-goraci/src/main/java/org/apache/gora/goraci/generated/Flushed.java b/gora-goraci/src/main/java/org/apache/gora/goraci/generated/Flushed.java index 0fd140c..6f27717 100644 --- a/gora-goraci/src/main/java/org/apache/gora/goraci/generated/Flushed.java +++ b/gora-goraci/src/main/java/org/apache/gora/goraci/generated/Flushed.java @@ -7,7 +7,7 @@ package org.apache.gora.goraci.generated; @SuppressWarnings("all") public class Flushed extends org.apache.gora.persistency.impl.PersistentBase implements org.apache.avro.specific.SpecificRecord, org.apache.gora.persistency.Persistent { public static final org.apache.avro.Schema SCHEMA$ = new org.apache.avro.Schema.Parser().parse("{\"type\":\"record\",\"name\":\"Flushed\",\"namespace\":\"org.apache.gora.goraci.generated\",\"fields\":[{\"name\":\"count\",\"type\":\"long\",\"default\":0}]}"); - + private static final long serialVersionUID = -6468883532296148608L; /** Enum containing all data bean's fields. */ public static enum Field { COUNT(0, "count"), @@ -241,6 +241,33 @@ public class Flushed extends org.apache.gora.persistency.impl.PersistentBase imp } + + private static final org.apache.avro.io.DatumWriter + DATUM_WRITER$ = new org.apache.avro.specific.SpecificDatumWriter(SCHEMA$); + private static final org.apache.avro.io.DatumReader + DATUM_READER$ = new org.apache.avro.specific.SpecificDatumReader(SCHEMA$); + + @Override + public void writeExternal(java.io.ObjectOutput out) + throws java.io.IOException { + out.write(super.getDirtyBytes().array()); + DATUM_WRITER$.write + (this, org.apache.avro.io.EncoderFactory.get() + .directBinaryEncoder((java.io.OutputStream) out, + null)); + } + + @Override + public void readExternal(java.io.ObjectInput in) + throws java.io.IOException { + byte[] __g__dirty = new byte[getFieldsCount()]; + in.read(__g__dirty); + super.setDirtyBytes(java.nio.ByteBuffer.wrap(__g__dirty)); + DATUM_READER$.read + (this, org.apache.avro.io.DecoderFactory.get() + .directBinaryDecoder((java.io.InputStream) in, + null)); + } }
