From 1ab82ba2e6707d574362db8baf63c5a4b66fdfe6 Mon Sep 17 00:00:00 2001
From: zentol <s.motsu@web.de>
Date: Sun, 16 Nov 2014 16:28:28 +0100
Subject: [PATCH] [FLINK-1244] setCombinable() returns operator

---
 .../apache/flink/api/java/operators/GroupReduceOperator.java  | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/flink-java/src/main/java/org/apache/flink/api/java/operators/GroupReduceOperator.java b/flink-java/src/main/java/org/apache/flink/api/java/operators/GroupReduceOperator.java
index a040b145d1c39..327d12f6b7f88 100644
--- a/flink-java/src/main/java/org/apache/flink/api/java/operators/GroupReduceOperator.java
+++ b/flink-java/src/main/java/org/apache/flink/api/java/operators/GroupReduceOperator.java
@@ -102,13 +102,15 @@ public boolean isCombinable() {
 		return combinable;
 	}
 	
-	public void setCombinable(boolean combinable) {
+	public GroupReduceOperator<IN, OUT> setCombinable(boolean combinable) {
 		// sanity check that the function is a subclass of the combine interface
 		if (combinable && !(function instanceof FlatCombineFunction)) {
 			throw new IllegalArgumentException("The function does not implement the combine interface.");
 		}
 		
 		this.combinable = combinable;
+		
+		return this;
 	}
 	
 	@Override