fixes

uwescience · Sep 9, 2016 · d6100af · d6100af
1 parent 1d6d850
commit d6100af
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/src/edu/washington/escience/myria/io/DataSink.java b/src/edu/washington/escience/myria/io/DataSink.java
@@ -16,7 +16,8 @@
 @JsonSubTypes({
   @Type(name = "Pipe", value = PipeSink.class),
   @Type(name = "Bytes", value = ByteSink.class),
-  @Type(name = "Uri", value = UriSink.class)
+  @Type(name = "Uri", value = UriSink.class),
+  @Type(name = "File", value = FileSink.class)
 })
 public interface DataSink extends Serializable {
   /**

diff --git a/src/edu/washington/escience/myria/io/FileSink.java b/src/edu/washington/escience/myria/io/FileSink.java
@@ -14,15 +14,15 @@ public class FileSink implements DataSink {
   /** Required for Java serialization. */
   private static final long serialVersionUID = 1L;
 
-  @JsonProperty
-  private String filename;
+  @JsonProperty private String filename;
 
-  public FileSink(@JsonProperty(value = "filename", required = true) final String filename) throws CatalogException {
+  public FileSink(@JsonProperty(value = "filename", required = true) final String filename)
+      throws CatalogException {
     this.filename = filename;
   }
 
   @Override
   public OutputStream getOutputStream() throws IOException {
     return new FileOutputStream(filename);
   }
-}
+}