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 <[email protected]> Authored: Wed Jan 1 16:18:30 2014 -0600 Committer: Micah Whitacre <[email protected]> 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 {
