You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@reef.apache.org by yu...@apache.org on 2015/06/23 17:21:01 UTC
[7/7] incubator-reef git commit: Escape IOExceptions in the
AvroClassHierarchySerializer
Escape IOExceptions in the AvroClassHierarchySerializer
Project: http://git-wip-us.apache.org/repos/asf/incubator-reef/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-reef/commit/ba431c45
Tree: http://git-wip-us.apache.org/repos/asf/incubator-reef/tree/ba431c45
Diff: http://git-wip-us.apache.org/repos/asf/incubator-reef/diff/ba431c45
Branch: refs/heads/REEF-395
Commit: ba431c4566226b03380b44bf340814cacc8fd927
Parents: d040261
Author: Yunseong Lee <yu...@apache.org>
Authored: Tue Jun 23 22:12:24 2015 +0900
Committer: Yunseong Lee <yu...@apache.org>
Committed: Tue Jun 23 22:12:24 2015 +0900
----------------------------------------------------------------------
.../formats/AvroClassHierarchySerializer.java | 24 +++++---------------
1 file changed, 6 insertions(+), 18 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-reef/blob/ba431c45/lang/java/reef-tang/tang/src/main/java/org/apache/reef/tang/formats/AvroClassHierarchySerializer.java
----------------------------------------------------------------------
diff --git a/lang/java/reef-tang/tang/src/main/java/org/apache/reef/tang/formats/AvroClassHierarchySerializer.java b/lang/java/reef-tang/tang/src/main/java/org/apache/reef/tang/formats/AvroClassHierarchySerializer.java
index 8dbc0af..b6acd29 100644
--- a/lang/java/reef-tang/tang/src/main/java/org/apache/reef/tang/formats/AvroClassHierarchySerializer.java
+++ b/lang/java/reef-tang/tang/src/main/java/org/apache/reef/tang/formats/AvroClassHierarchySerializer.java
@@ -203,8 +203,6 @@ public final class AvroClassHierarchySerializer implements ClassHierarchySeriali
requestWriter.write(toAvro(classHierarchy), encoder);
encoder.flush();
return out.toByteArray();
- } catch (IOException e) {
- throw new RuntimeException(e);
}
}
@@ -217,8 +215,6 @@ public final class AvroClassHierarchySerializer implements ClassHierarchySeriali
encoder.flush();
out.flush();
return out.toString(JSON_CHARSET);
- } catch (IOException e) {
- throw new RuntimeException(e);
}
}
@@ -241,24 +237,16 @@ public final class AvroClassHierarchySerializer implements ClassHierarchySeriali
@Override
public ClassHierarchy fromByteArray(final byte[] theBytes) throws IOException {
- try {
- final BinaryDecoder decoder = DecoderFactory.get().binaryDecoder(theBytes, null);
- final SpecificDatumReader<AvroNode> reader = new SpecificDatumReader<>(AvroNode.class);
- return fromAvro(reader.read(null, decoder));
- } catch (IOException e) {
- throw new RuntimeException(e);
- }
+ final BinaryDecoder decoder = DecoderFactory.get().binaryDecoder(theBytes, null);
+ final SpecificDatumReader<AvroNode> reader = new SpecificDatumReader<>(AvroNode.class);
+ return fromAvro(reader.read(null, decoder));
}
@Override
public ClassHierarchy fromString(final String theString) throws IOException {
- try {
- final JsonDecoder decoder = DecoderFactory.get().jsonDecoder(AvroNode.getClassSchema(), theString);
- final SpecificDatumReader<AvroNode> reader = new SpecificDatumReader<>(AvroNode.class);
- return fromAvro(reader.read(null, decoder));
- } catch (IOException e) {
- throw new RuntimeException(e);
- }
+ final JsonDecoder decoder = DecoderFactory.get().jsonDecoder(AvroNode.getClassSchema(), theString);
+ final SpecificDatumReader<AvroNode> reader = new SpecificDatumReader<>(AvroNode.class);
+ return fromAvro(reader.read(null, decoder));
}
@Override