From 386a33289dcaec76224845ceb2db0f410568fa23 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?M=C3=A1rton=20Balassi?= Date: Mon, 14 Jul 2014 16:29:20 +0200 Subject: [PATCH] [streaming] Licensing added --- .../CollaborativeFilteringMap.java | 15 +++++++++++++++ .../examples/iterative/kmeans/KMeansMap.java | 15 +++++++++++++++ .../examples/iterative/pagerank/PageRankMap.java | 15 +++++++++++++++ .../examples/iterative/sssp/SSSPLocal.java | 2 +- .../window/wordcount/WindowWordCountLocal.java | 7 ++++--- .../stratosphere/streaming/util/ClusterUtil.java | 1 - .../stratosphere/streaming/util/TestDataUtil.java | 15 +++++++++++++++ .../eu/stratosphere/streaming/api/BatchTest.java | 15 +++++++++++++++ .../streaming/api/TypeExtractTest.java | 15 +++++++++++++++ .../streaming/api/streamrecord/MyGeneric.java | 15 +++++++++++++++ .../streaming/api/streamrecord/MyGeneric2.java | 15 +++++++++++++++ 11 files changed, 125 insertions(+), 5 deletions(-) diff --git a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/collaborativefilter/CollaborativeFilteringMap.java b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/collaborativefilter/CollaborativeFilteringMap.java index 7cf326c6fdd..a983022a6a6 100644 --- a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/collaborativefilter/CollaborativeFilteringMap.java +++ b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/collaborativefilter/CollaborativeFilteringMap.java @@ -1,3 +1,18 @@ +/*********************************************************************************************************************** + * + * Copyright (C) 2010-2014 by the Stratosphere project (http://stratosphere.eu) + * + * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on + * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the + * specific language governing permissions and limitations under the License. + * + **********************************************************************************************************************/ + package eu.stratosphere.streaming.examples.iterative.collaborativefilter; public class CollaborativeFilteringMap { diff --git a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/kmeans/KMeansMap.java b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/kmeans/KMeansMap.java index 9321dd6e091..d520d93c966 100644 --- a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/kmeans/KMeansMap.java +++ b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/kmeans/KMeansMap.java @@ -1,3 +1,18 @@ +/*********************************************************************************************************************** + * + * Copyright (C) 2010-2014 by the Stratosphere project (http://stratosphere.eu) + * + * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on + * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the + * specific language governing permissions and limitations under the License. + * + **********************************************************************************************************************/ + package eu.stratosphere.streaming.examples.iterative.kmeans; public class KMeansMap { diff --git a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/pagerank/PageRankMap.java b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/pagerank/PageRankMap.java index 348b666e590..144f0f319cb 100644 --- a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/pagerank/PageRankMap.java +++ b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/pagerank/PageRankMap.java @@ -1,3 +1,18 @@ +/*********************************************************************************************************************** + * + * Copyright (C) 2010-2014 by the Stratosphere project (http://stratosphere.eu) + * + * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on + * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the + * specific language governing permissions and limitations under the License. + * + **********************************************************************************************************************/ + package eu.stratosphere.streaming.examples.iterative.pagerank; public class PageRankMap { diff --git a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/sssp/SSSPLocal.java b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/sssp/SSSPLocal.java index fcc4751a102..91c7447ba5b 100644 --- a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/sssp/SSSPLocal.java +++ b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/iterative/sssp/SSSPLocal.java @@ -32,7 +32,7 @@ public class SSSPLocal { StreamExecutionEnvironment env = new StreamExecutionEnvironment(); // @SuppressWarnings("unused") -// DataStream> dataStream = context +// DataStream> dataStream = env // .addSource(new SSSPSource()) // .flatMap(new SSSPCounter()) // .addSink(new SSSPSink()); diff --git a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/window/wordcount/WindowWordCountLocal.java b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/window/wordcount/WindowWordCountLocal.java index d8ae6a5a5c8..60cb3f00fba 100644 --- a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/window/wordcount/WindowWordCountLocal.java +++ b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/examples/window/wordcount/WindowWordCountLocal.java @@ -22,15 +22,16 @@ import eu.stratosphere.streaming.api.StreamExecutionEnvironment; public class WindowWordCountLocal { public static void main(String[] args) { - StreamExecutionEnvironment context = new StreamExecutionEnvironment(); + StreamExecutionEnvironment env = new StreamExecutionEnvironment(); + @SuppressWarnings("unused") - DataStream> dataStream = context + DataStream> dataStream = env .addSource(new WindowWordCountSource()) .flatMap(new WindowWordCountSplitter()) .partitionBy(0) .flatMap(new WindowWordCountCounter()) .addSink(new WindowWordCountSink()); - context.execute(); + env.execute(); } } diff --git a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/util/ClusterUtil.java b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/util/ClusterUtil.java index d0a89415cba..163c72e2ea8 100755 --- a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/util/ClusterUtil.java +++ b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/util/ClusterUtil.java @@ -13,7 +13,6 @@ * **********************************************************************************************************************/ - package eu.stratosphere.streaming.util; import java.net.InetSocketAddress; diff --git a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/util/TestDataUtil.java b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/util/TestDataUtil.java index 7bb33120b1d..967257a4285 100644 --- a/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/util/TestDataUtil.java +++ b/flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/util/TestDataUtil.java @@ -1,3 +1,18 @@ +/*********************************************************************************************************************** + * + * Copyright (C) 2010-2014 by the Stratosphere project (http://stratosphere.eu) + * + * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on + * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the + * specific language governing permissions and limitations under the License. + * + **********************************************************************************************************************/ + package eu.stratosphere.streaming.util; import java.io.BufferedReader; diff --git a/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/BatchTest.java b/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/BatchTest.java index f69e51c5681..53c8b5c1cf9 100644 --- a/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/BatchTest.java +++ b/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/BatchTest.java @@ -1,3 +1,18 @@ +/*********************************************************************************************************************** + * + * Copyright (C) 2010-2014 by the Stratosphere project (http://stratosphere.eu) + * + * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on + * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the + * specific language governing permissions and limitations under the License. + * + **********************************************************************************************************************/ + package eu.stratosphere.streaming.api; import static org.junit.Assert.assertEquals; diff --git a/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/TypeExtractTest.java b/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/TypeExtractTest.java index 97fae1b5127..f892ea2a55d 100755 --- a/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/TypeExtractTest.java +++ b/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/TypeExtractTest.java @@ -1,3 +1,18 @@ +/*********************************************************************************************************************** + * + * Copyright (C) 2010-2014 by the Stratosphere project (http://stratosphere.eu) + * + * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on + * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the + * specific language governing permissions and limitations under the License. + * + **********************************************************************************************************************/ + package eu.stratosphere.streaming.api; import java.io.ByteArrayInputStream; diff --git a/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/MyGeneric.java b/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/MyGeneric.java index f04ab965032..83a8e94b3a8 100755 --- a/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/MyGeneric.java +++ b/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/MyGeneric.java @@ -1,3 +1,18 @@ +/*********************************************************************************************************************** + * + * Copyright (C) 2010-2014 by the Stratosphere project (http://stratosphere.eu) + * + * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on + * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the + * specific language governing permissions and limitations under the License. + * + **********************************************************************************************************************/ + package eu.stratosphere.streaming.api.streamrecord; import java.io.Serializable; diff --git a/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/MyGeneric2.java b/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/MyGeneric2.java index 4959e1a2df4..38c0d03c57b 100755 --- a/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/MyGeneric2.java +++ b/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/MyGeneric2.java @@ -1,3 +1,18 @@ +/*********************************************************************************************************************** + * + * Copyright (C) 2010-2014 by the Stratosphere project (http://stratosphere.eu) + * + * Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on + * an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the + * specific language governing permissions and limitations under the License. + * + **********************************************************************************************************************/ + package eu.stratosphere.streaming.api.streamrecord; import eu.stratosphere.api.java.tuple.Tuple1; -- GitLab