You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@apex.apache.org by "Francis Fernandes (JIRA)" <ji...@apache.org> on 2017/03/27 10:26:41 UTC

[jira] [Created] (APEXMALHAR-2456) AbstractFileInputOperator doesn't work with static partitioning

Francis Fernandes created APEXMALHAR-2456:
---------------------------------------------

             Summary: AbstractFileInputOperator doesn't work with static partitioning
                 Key: APEXMALHAR-2456
                 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2456
             Project: Apache Apex Malhar
          Issue Type: Bug
    Affects Versions: 3.6.0
            Reporter: Francis Fernandes
            Assignee: Francis Fernandes
             Fix For: 3.7.0


{code}
  public void populateDAG(DAG dag, Configuration conf)
  {
    LineByLineFileInputOperator reader = dag.addOperator("Reader", new LineByLineFileInputOperator());
    StringFileOutputOperator writer = dag.addOperator("Writer", new StringFileOutputOperator());
    dag.addStream("data", reader.output, writer.input);
  }
{code}

Config settings
{code}
{code}




--
This message was sent by Atlassian JIRA
(v6.3.15#6346)