Repository: incubator-gearpump Updated Branches: refs/heads/master f6f8903bf -> 86e9709b4
fix #121 DataSourceProcessor and DataSinkProcessor default parallelism Set DataSourceProcessor and DataSinkProcessor's default parallelism value to 1. When user startup a processor could don't set parallelism . [GEARPUMP-121](https://issues.apache.org/jira/browse/GEARPUMP-121) Author: darionyaphet <[email protected]> Closes #13 from darionyaphet/GEARPUMP-121. Project: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/commit/86e9709b Tree: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/tree/86e9709b Diff: http://git-wip-us.apache.org/repos/asf/incubator-gearpump/diff/86e9709b Branch: refs/heads/master Commit: 86e9709b495b431fe084e84e480aca91a98f642f Parents: f6f8903 Author: darionyaphet <[email protected]> Authored: Fri May 20 12:50:55 2016 +0800 Committer: huafengw <[email protected]> Committed: Fri May 20 12:50:55 2016 +0800 ---------------------------------------------------------------------- conf/masters | 0 conf/slaves | 0 .../org/apache/gearpump/streaming/sink/DataSinkProcessor.scala | 2 +- .../org/apache/gearpump/streaming/source/DataSourceProcessor.scala | 2 +- 4 files changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/86e9709b/conf/masters ---------------------------------------------------------------------- diff --git a/conf/masters b/conf/masters new file mode 100644 index 0000000..e69de29 http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/86e9709b/conf/slaves ---------------------------------------------------------------------- diff --git a/conf/slaves b/conf/slaves new file mode 100644 index 0000000..e69de29 http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/86e9709b/streaming/src/main/scala/org/apache/gearpump/streaming/sink/DataSinkProcessor.scala ---------------------------------------------------------------------- diff --git a/streaming/src/main/scala/org/apache/gearpump/streaming/sink/DataSinkProcessor.scala b/streaming/src/main/scala/org/apache/gearpump/streaming/sink/DataSinkProcessor.scala index 973e371..60920d4 100644 --- a/streaming/src/main/scala/org/apache/gearpump/streaming/sink/DataSinkProcessor.scala +++ b/streaming/src/main/scala/org/apache/gearpump/streaming/sink/DataSinkProcessor.scala @@ -39,7 +39,7 @@ import org.apache.gearpump.streaming.Processor object DataSinkProcessor { def apply( dataSink: DataSink, - parallelism: Int, + parallelism: Int = 1, description: String = "", taskConf: UserConfig = UserConfig.empty)(implicit system: ActorSystem) : Processor[DataSinkTask] = { http://git-wip-us.apache.org/repos/asf/incubator-gearpump/blob/86e9709b/streaming/src/main/scala/org/apache/gearpump/streaming/source/DataSourceProcessor.scala ---------------------------------------------------------------------- diff --git a/streaming/src/main/scala/org/apache/gearpump/streaming/source/DataSourceProcessor.scala b/streaming/src/main/scala/org/apache/gearpump/streaming/source/DataSourceProcessor.scala index ddd6c27..4e3600f 100644 --- a/streaming/src/main/scala/org/apache/gearpump/streaming/source/DataSourceProcessor.scala +++ b/streaming/src/main/scala/org/apache/gearpump/streaming/source/DataSourceProcessor.scala @@ -39,7 +39,7 @@ import org.apache.gearpump.streaming.Processor object DataSourceProcessor { def apply( dataSource: DataSource, - parallelism: Int, + parallelism: Int = 1, description: String = "", taskConf: UserConfig = UserConfig.empty)(implicit system: ActorSystem) : Processor[DataSourceTask] = {
