crunch-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mkw...@apache.org
Subject git commit: CRUNCH-316: Converted SafeAvroSerialization to use DirectBinaryEncoder instead of BufferedBinaryEncoder.
Date Thu, 02 Jan 2014 17:44:49 GMT
Updated Branches:
  refs/heads/apache-crunch-0.8 ce9d7efb5 -> 011c46ccd


CRUNCH-316: Converted SafeAvroSerialization to use DirectBinaryEncoder instead of BufferedBinaryEncoder.


Project: http://git-wip-us.apache.org/repos/asf/crunch/repo
Commit: http://git-wip-us.apache.org/repos/asf/crunch/commit/011c46cc
Tree: http://git-wip-us.apache.org/repos/asf/crunch/tree/011c46cc
Diff: http://git-wip-us.apache.org/repos/asf/crunch/diff/011c46cc

Branch: refs/heads/apache-crunch-0.8
Commit: 011c46ccd51a80bdb547b0b30bc7d0c06730f95a
Parents: ce9d7ef
Author: Micah Whitacre <mkwhit@apache.org>
Authored: Wed Jan 1 16:18:30 2014 -0600
Committer: Micah Whitacre <mkwhit@apache.org>
Committed: Thu Jan 2 11:38:51 2014 -0600

----------------------------------------------------------------------
 .../java/org/apache/crunch/types/avro/SafeAvroSerialization.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/crunch/blob/011c46cc/crunch-core/src/main/java/org/apache/crunch/types/avro/SafeAvroSerialization.java
----------------------------------------------------------------------
diff --git a/crunch-core/src/main/java/org/apache/crunch/types/avro/SafeAvroSerialization.java
b/crunch-core/src/main/java/org/apache/crunch/types/avro/SafeAvroSerialization.java
index 7e323f1..f56991e 100644
--- a/crunch-core/src/main/java/org/apache/crunch/types/avro/SafeAvroSerialization.java
+++ b/crunch-core/src/main/java/org/apache/crunch/types/avro/SafeAvroSerialization.java
@@ -121,7 +121,7 @@ class SafeAvroSerialization<T> extends Configured implements Serialization<AvroW
 
     public void open(OutputStream out) {
       this.out = out;
-      this.encoder = new EncoderFactory().configureBlockSize(512).binaryEncoder(out, null);
+      this.encoder = new EncoderFactory().directBinaryEncoder(out, null);
     }
 
     public void serialize(AvroWrapper<T> wrapper) throws IOException {


Mime
View raw message