package edu.washington.escience.myria.api.encoding;

import java.util.List;
import java.util.Map;

import com.google.common.collect.ImmutableList;

import edu.washington.escience.myria.Schema;
import edu.washington.escience.myria.io.DataSource;
import edu.washington.escience.myria.operator.FileScan;
import edu.washington.escience.myria.operator.Operator;
import edu.washington.escience.myria.parallel.Server;

public class FileScanEncoding extends OperatorEncoding<FileScan> {
  public Schema schema;
  public DataSource source;
  public Character delimiter;
  private static final List<String> requiredArguments = ImmutableList.of("schema", "source");

  @Override
  public FileScan construct(final Server server) {
    return new FileScan(source, schema, delimiter);
  }

  @Override
  public void connect(Operator current, Map<String, Operator> operators) {
    /* Do nothing; no children. */
  }

  @Override
  protected List<String> getRequiredArguments() {
    return requiredArguments;
  }
}
@@ -554,16 +554,92 @@
 imiter;%0A
+  public Character quote;%0A  public Character escape;%0A  public Integer skip;%0A
   privat
@@ -837,16 +837,37 @@
 elimiter
+, quote, escape, skip
 );%0A  %7D%0A%0A

add all options