flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mbala...@apache.org
Subject flink git commit: [FLINK-2507] [storm-compat] Rename the function tansformAndEmit
Date Wed, 12 Aug 2015 09:33:26 GMT
Repository: flink
Updated Branches:
  refs/heads/master eeec1912b -> 54311aae8


[FLINK-2507] [storm-compat] Rename the function tansformAndEmit

Closes #1007


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/54311aae
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/54311aae
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/54311aae

Branch: refs/heads/master
Commit: 54311aae8ac20fa4ed1f6217b12bffb02fabf43a
Parents: eeec191
Author: ffbin <869218239@qq.com>
Authored: Wed Aug 12 08:36:11 2015 +0800
Committer: mbalassi <mbalassi@apache.org>
Committed: Wed Aug 12 11:30:22 2015 +0200

----------------------------------------------------------------------
 .../flink/stormcompatibility/wrappers/AbstractStormCollector.java  | 2 +-
 .../flink/stormcompatibility/wrappers/StormBoltCollector.java      | 2 +-
 .../flink/stormcompatibility/wrappers/StormSpoutCollector.java     | 2 +-
 3 files changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/54311aae/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/AbstractStormCollector.java
----------------------------------------------------------------------
diff --git a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/AbstractStormCollector.java
b/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/AbstractStormCollector.java
index dc77ca1..4a8fb7d 100644
--- a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/AbstractStormCollector.java
+++ b/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/AbstractStormCollector.java
@@ -82,7 +82,7 @@ abstract class AbstractStormCollector<OUT> {
 	 * @return the return value of {@link #doEmit(Object)}
 	 */
 	@SuppressWarnings("unchecked")
-	protected final List<Integer> tansformAndEmit(final List<Object> tuple) {
+	protected final List<Integer> transformAndEmit(final List<Object> tuple) {
 		List<Integer> taskIds;
 		if (this.numberOfAttributes > 0) {
 			assert (tuple.size() == this.numberOfAttributes);

http://git-wip-us.apache.org/repos/asf/flink/blob/54311aae/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/StormBoltCollector.java
----------------------------------------------------------------------
diff --git a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/StormBoltCollector.java
b/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/StormBoltCollector.java
index 8b088c3..81ad9a6 100644
--- a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/StormBoltCollector.java
+++ b/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/StormBoltCollector.java
@@ -72,7 +72,7 @@ class StormBoltCollector<OUT> extends AbstractStormCollector<OUT>
implements IOu
 
 	@Override
 	public List<Integer> emit(final String streamId, final Collection<Tuple> anchors,
final List<Object> tuple) {
-		return this.tansformAndEmit(tuple);
+		return this.transformAndEmit(tuple);
 	}
 
 	@Override

http://git-wip-us.apache.org/repos/asf/flink/blob/54311aae/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/StormSpoutCollector.java
----------------------------------------------------------------------
diff --git a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/StormSpoutCollector.java
b/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/StormSpoutCollector.java
index 01c980a..09a7ac7 100644
--- a/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/StormSpoutCollector.java
+++ b/flink-contrib/flink-storm-compatibility/flink-storm-compatibility-core/src/main/java/org/apache/flink/stormcompatibility/wrappers/StormSpoutCollector.java
@@ -68,7 +68,7 @@ class StormSpoutCollector<OUT> extends AbstractStormCollector<OUT>
implements IS
 
 	@Override
 	public List<Integer> emit(final String streamId, final List<Object> tuple, final
Object messageId) {
-		return this.tansformAndEmit(tuple);
+		return this.transformAndEmit(tuple);
 	}
 
 


Mime
View raw message