[
https://issues.apache.org/jira/browse/FLINK-337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14212321#comment-14212321
]
ASF GitHub Bot commented on FLINK-337:
--------------------------------------
Github user zentol commented on a diff in the pull request:
https://github.com/apache/incubator-flink/pull/202#discussion_r20361989
--- Diff:
flink-addons/flink-language-binding/src/main/java/org/apache/flink/languagebinding/examples/java/python/wordcount/WordCount.java
---
@@ -0,0 +1,47 @@
+/**
+ * Licensed to the Apache Software Foundation (ASF) under one or more
contributor license agreements. See the NOTICE
+ * file distributed with this work for additional information regarding
copyright ownership. The ASF licenses this file
+ * to you 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 org.apache.flink.languagebinding.examples.java.python.wordcount;
+
+import org.apache.flink.api.java.DataSet;
+import org.apache.flink.api.java.ExecutionEnvironment;
+import org.apache.flink.api.java.operators.GroupReduceOperator;
+import org.apache.flink.api.java.tuple.Tuple2;
+import static
org.apache.flink.languagebinding.api.java.common.PlanBinder.INT;
+import static
org.apache.flink.languagebinding.api.java.common.PlanBinder.STRING;
+import org.apache.flink.languagebinding.api.java.python.PythonPlanBinder;
+import
org.apache.flink.languagebinding.api.java.python.functions.PythonFlatMap;
+import
org.apache.flink.languagebinding.api.java.python.functions.PythonGroupReduce;
+
+public class WordCount {
+ public static void main(String[] args) throws Exception {
--- End diff --
Will be changed to be inline with other examples.
> Fixed all JavaDoc warnings in pact-common.
> ------------------------------------------
>
> Key: FLINK-337
> URL: https://issues.apache.org/jira/browse/FLINK-337
> Project: Flink
> Issue Type: Bug
> Reporter: GitHub Import
> Labels: github-import
> Fix For: pre-apache
>
> Attachments: pull-request-337-8997712741697485992.patch
>
>
> Fixed all JavaDoc warnings in pact-common.
> I focused on fixing the build warnings but also added and updated some
> JavaDoc on the way.
> Adresses issue
> ([#330|https://github.com/stratosphere/stratosphere/issues/330] |
> [FLINK-330|https://issues.apache.org/jira/browse/FLINK-330]).
> ---------------- Imported from GitHub ----------------
> Url: https://github.com/stratosphere/stratosphere/pull/337
> Created by: [fhueske|https://github.com/fhueske]
> Labels:
> Created at: Wed Dec 11 17:50:03 CET 2013
> State: closed
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
