You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by mb...@apache.org on 2015/08/12 11:33:26 UTC
flink git commit: [FLINK-2507] [storm-compat] Rename the function
tansformAndEmit
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 <86...@qq.com>
Authored: Wed Aug 12 08:36:11 2015 +0800
Committer: mbalassi <mb...@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);
}