Skip to content
Permalink
Browse files
re-throw any exceptions in outputSchema() as runtime exceptions
  • Loading branch information
jmalkin committed Jun 30, 2017
1 parent 7d28742 commit 42b2a240162a7b5cc086f1da68c752ee9e536eaf
Showing 5 changed files with 5 additions and 5 deletions.
@@ -147,7 +147,7 @@ public Schema outputSchema(final Schema input) {
.getClass().getName().toLowerCase(), input), DataType.BYTEARRAY));
}
catch (final FrontendException e) {
return null;
throw new RuntimeException(e);
}
}
}
@@ -62,7 +62,7 @@ public Schema outputSchema(final Schema input) {
return new Schema(new Schema.FieldSchema(getSchemaName(this
.getClass().getName().toLowerCase(), input), weightedSampleSchema, DataType.BAG));
} catch (final FrontendException e) {
return null;
throw new RuntimeException(e);
}
}
}
@@ -129,7 +129,7 @@ public Schema outputSchema(final Schema input) {
.getClass().getName().toLowerCase(), source), recordSchema, DataType.TUPLE));
}
catch (final FrontendException e) {
// fall through
throw new RuntimeException(e);
}
}
return null;
@@ -130,7 +130,7 @@ public Schema outputSchema(final Schema input) {
.getClass().getName().toLowerCase(), source), source, DataType.TUPLE));
}
} catch (final FrontendException e) {
// fall through
throw new RuntimeException(e);
}
}

@@ -137,7 +137,7 @@ public Schema outputSchema(final Schema input) {
.getClass().getName().toLowerCase(), record), weightedSampleSchema, DataType.BAG));
}
catch (final FrontendException e) {
return null;
throw new RuntimeException(e);
}
}

0 comments on commit 42b2a24

Please sign in to comment.