[docs] Fixed typo in Storm Compatibility page This closes #1618
Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/aeee6efd Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/aeee6efd Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/aeee6efd Branch: refs/heads/tableOnCalcite Commit: aeee6efd451dcbdda37ed05779bda74291079ed5 Parents: 0a63797 Author: Georgios Andrianakis <geo...@gmail.com> Authored: Wed Feb 10 14:30:46 2016 +0200 Committer: mjsax <mj...@apache.org> Committed: Wed Feb 10 14:51:14 2016 +0100 ---------------------------------------------------------------------- docs/apis/streaming/storm_compatibility.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/aeee6efd/docs/apis/streaming/storm_compatibility.md ---------------------------------------------------------------------- diff --git a/docs/apis/streaming/storm_compatibility.md b/docs/apis/streaming/storm_compatibility.md index d646040..4d5715c 100644 --- a/docs/apis/streaming/storm_compatibility.md +++ b/docs/apis/streaming/storm_compatibility.md @@ -228,8 +228,8 @@ DataStream<SplitStreamType<SomeType>> multiStream = ... SplitStream<SplitStreamType<SomeType>> splitStream = multiStream.split(new StormStreamSelector<SomeType>()); // remove SplitStreamType using SplitStreamMapper to get data stream of type SomeType -DataStream<SomeType> s1 = splitStream.select("s1").map(new SplitStreamMapper<SomeType>()).returns(SomeType.classs); -DataStream<SomeType> s2 = splitStream.select("s2").map(new SplitStreamMapper<SomeType>()).returns(SomeType.classs); +DataStream<SomeType> s1 = splitStream.select("s1").map(new SplitStreamMapper<SomeType>()).returns(SomeType.class); +DataStream<SomeType> s2 = splitStream.select("s2").map(new SplitStreamMapper<SomeType>()).returns(SomeType.class); // do further processing on s1 and s2 [...]
