[jira] [Created] (FLINK-3589) Allow setting Operator parallelism to default value

["Greg Hogan (JIRA)" <ji...@apache.org>]

Greg Hogan created FLINK-3589:
---------------------------------

             Summary: Allow setting Operator parallelism to default value
                 Key: FLINK-3589
                 URL: https://issues.apache.org/jira/browse/FLINK-3589
             Project: Flink
          Issue Type: Improvement
          Components: Java API
    Affects Versions: 1.1.0
            Reporter: Greg Hogan
            Assignee: Greg Hogan
            Priority: Minor


User's can override the parallelism for a single operator by calling {{Operator.setParallelism}}, which accepts a positive value. {{Operator}} uses {{-1}} to indicate default parallelism. It would be nice to name and accept this default value.

This would enable user algorithms to allow configurable parallelism while still chaining operator methods.

For example, currently:

{code}
	private int parallelism;
	...
	public void setParallelism(int parallelism) {
		this.parallelism = parallelism;
	}
	...
		MapOperator<Edge<K,LongValue>, Edge<K,IntValue>> newEdges = edges
			.map(new MyMapFunction<K>())
				.name("My map function");

		if (parallelism > 0) {
			newEdges.setParallelism(parallelism);
		}
{code}

Could be simplified to:

{code}
	private int parallelism = Operator.DEFAULT_PARALLELISM;
	...
	public void setParallelism(int parallelism) {
		this.parallelism = parallelism;
	}
	...
		DataSet<Edge<K,IntValue>> newEdges = edges
			.map(new MyMapFunction<K>())
			.setParallelism(parallelism)
				.name("My map function");
{code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)