Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
2 changes: 1 addition & 1 deletion docs/internal_add_operator.md
Original file line number Diff line number Diff line change
Expand Up @@ -100,7 +100,7 @@ void setInput(DataSet<IN> inputData);
DataSet<OUT> createResult();
~~~

The {% gh_link /flink-addons/flink-spargel/src/main/java/org/apache/flink/spargel/java/VertexCentricIteration.java "VertexCentricIteration" %} operator is implemented that way. Below is an example how to implement the *count()* operator that way.
The {% gh_link /flink-staging/flink-spargel/src/main/java/org/apache/flink/spargel/java/VertexCentricIteration.java "VertexCentricIteration" %} operator is implemented that way. Below is an example how to implement the *count()* operator that way.

~~~ java
public class Counter<T> implements CustomUnaryOperation<T, Long> {
Expand Down
3 changes: 2 additions & 1 deletion docs/internal_general_arch.md
Original file line number Diff line number Diff line change
Expand Up @@ -75,12 +75,13 @@ In addition to the projects listed in the figure above, Flink currently contains
- `flink-dist`: The *distribution* project. It defines how to assemble the compiled code, scripts, and other resources
into the final folder structure that is ready to use.

- `flink-addons`: A series of projects that are in an early version. Currently contains
- `flink-staging`: A series of projects that are in an early version. Currently contains
among other things projects for YARN support, JDBC data sources and sinks, hadoop compatibility,
graph specific operators, and HBase connectors.

- `flink-quickstart`: Scripts, maven archetypes, and example programs for the quickstarts and tutorials.

- `flink-contrib`: Useful tools contributed by users. The code is maintained mainly by external contributors. The requirements for code being accepted into `flink-contrib` are lower compared to the rest of the code.



Expand Down
6 changes: 3 additions & 3 deletions docs/streaming_guide.md
Original file line number Diff line number Diff line change
Expand Up @@ -857,7 +857,7 @@ After installing Docker an image can be pulled for each connector. Containers ca
For the easiest set up create a jar with all the dependencies of the *flink-streaming-connectors* project.

~~~batch
cd /PATH/TO/GIT/incubator-flink/flink-addons/flink-streaming-connectors
cd /PATH/TO/GIT/flink/flink-staging/flink-streaming-connectors
mvn assembly:assembly
~~~batch

Expand Down Expand Up @@ -974,14 +974,14 @@ Now a terminal started running from the image with all the necessary configurati

To have the latest version of Flink type:
~~~batch
cd /git/incubator-flink/
cd /git/flink/
git pull
~~~

Then build the code with:

~~~batch
cd /git/incubator-flink/flink-addons/flink-streaming/flink-streaming-connectors/
cd /git/flink/flink-staging/flink-streaming/flink-streaming-connectors/
mvn install -DskipTests
~~~

Expand Down
41 changes: 41 additions & 0 deletions flink-contrib/pom.xml
Original file line number Diff line number Diff line change
@@ -0,0 +1,41 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
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.

-->
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

<modelVersion>4.0.0</modelVersion>

<parent>
<groupId>org.apache.flink</groupId>
<artifactId>flink-parent</artifactId>
<version>0.9-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>

<artifactId>flink-contrib</artifactId>
<name>flink-contrib</name>

<packaging>jar</packaging>

<dependencies>
</dependencies>

</project>
Empty file.
Empty file.
Empty file.
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ under the License.

<parent>
<groupId>org.apache.flink</groupId>
<artifactId>flink-addons</artifactId>
<artifactId>flink-staging</artifactId>
<version>0.9-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ under the License.

<parent>
<groupId>org.apache.flink</groupId>
<artifactId>flink-addons</artifactId>
<artifactId>flink-staging</artifactId>
<version>0.9-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ under the License.

<parent>
<groupId>org.apache.flink</groupId>
<artifactId>flink-addons</artifactId>
<artifactId>flink-staging</artifactId>
<version>0.9-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ under the License.

<parent>
<groupId>org.apache.flink</groupId>
<artifactId>flink-addons</artifactId>
<artifactId>flink-staging</artifactId>
<version>0.9-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ under the License.

<parent>
<groupId>org.apache.flink</groupId>
<artifactId>flink-addons</artifactId>
<artifactId>flink-staging</artifactId>
<version>0.9-SNAPSHOT</version>
<relativePath>..</relativePath>
</parent>
Expand Down
Loading