flink-examples-streaming
Used in:
components
- OverviewOverview
- VersionsVersions
- DependentsDependents
- DependenciesDependencies
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-examples-streaming</artifactId>
<version>2.2.1</version>
</dependency><?xml version="1.0" encoding="UTF-8"?>
<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">
<parent>
<artifactId>flink-examples</artifactId>
<groupId>org.apache.flink</groupId>
<version>2.2.1</version>
</parent>
<modelVersion>4.0.0</modelVersion>
<artifactId>flink-examples-streaming</artifactId>
<name>Flink : Examples : Streaming</name>
<build>
<plugins>
<plugin>
<artifactId>maven-jar-plugin</artifactId>
<version>2.4</version>
<executions>
<execution>
<phase>package</phase>
<goals>
<goal>test-jar</goal>
</goals>
</execution>
<execution>
<id>WindowJoin</id>
<phase>package</phase>
<goals>
<goal>jar</goal>
</goals>
<configuration>
<classifier>WindowJoin</classifier>
<archive>
<manifestEntries>
<program-class>org.apache.flink.streaming.examples.join.WindowJoin</program-class>
</manifestEntries>
</archive>
<includes>
<include>org/apache/flink/streaming/examples/join/*.class</include>
<include>org/apache/flink/streaming/examples/utils/ThrottledIterator.class</include>
<include>META-INF/LICENSE</include>
<include>META-INF/NOTICE</include>
</includes>
</configuration>
</execution>
<execution>
<id>WordCount</id>
<phase>package</phase>
<goals>
<goal>jar</goal>
</goals>
<configuration>
<classifier>WordCount</classifier>
<archive>
<manifestEntries>
<program-class>org.apache.flink.streaming.examples.wordcount.WordCount</program-class>
</manifestEntries>
</archive>
<includes>
<include>org/apache/flink/streaming/examples/wordcount/WordCount.class</include>
<include>org/apache/flink/streaming/examples/wordcount/WordCount$*.class</include>
<include>org/apache/flink/streaming/examples/wordcount/util/WordCountData.class</include>
<include>org/apache/flink/streaming/examples/wordcount/util/CLI.class</include>
<include>META-INF/LICENSE</include>
<include>META-INF/NOTICE</include>
</includes>
</configuration>
</execution>
<execution>
<id>SocketWindowWordCount</id>
<phase>package</phase>
<goals>
<goal>jar</goal>
</goals>
<configuration>
<classifier>SocketWindowWordCount</classifier>
<archive>
<manifestEntries>
<program-class>org.apache.flink.streaming.examples.socket.SocketWindowWordCount</program-class>
</manifestEntries>
</archive>
<includes>
<include>org/apache/flink/streaming/examples/socket/SocketWindowWordCount.class</include>
<include>org/apache/flink/streaming/examples/socket/SocketWindowWordCount$*.class</include>
<include>META-INF/LICENSE</include>
<include>META-INF/NOTICE</include>
</includes>
</configuration>
</execution>
</executions>
</plugin>
<plugin>
<artifactId>maven-shade-plugin</artifactId>
<executions>
<execution>
<id>AsyncIO</id>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<shadeTestJar>false</shadeTestJar>
<finalName>AsyncIO</finalName>
<shadedArtifactAttached>true</shadedArtifactAttached>
<shadedClassifierName>AsyncIO</shadedClassifierName>
<artifactSet>
<includes>
<include>org.apache.flink:flink-connector-datagen</include>
</includes>
</artifactSet>
<filters>
<filter>
<artifact>org.apache.flink:*</artifact>
<includes>
<include>org/apache/flink/connector/datagen/**</include>
<include>org/apache/flink/streaming/examples/async/*.class</include>
<include>META-INF/LICENSE</include>
<include>META-INF/NOTICE</include>
</includes>
</filter>
</filters>
<transformers>
<transformer>
<mainClass>org.apache.flink.streaming.examples.async.AsyncIOExample</mainClass>
</transformer>
</transformers>
</configuration>
</execution>
<execution>
<id>MatrixVectorMul</id>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<shadeTestJar>false</shadeTestJar>
<finalName>MatrixVectorMul</finalName>
<artifactSet>
<includes>
<include>org.apache.flink:flink-connector-datagen</include>
<include>org.jcuda:*</include>
</includes>
</artifactSet>
<filters>
<filter>
<artifact>org.apache.flink:*</artifact>
<includes>
<include>org/apache/flink/connector/datagen/**</include>
<include>org/apache/flink/streaming/examples/gpu/MatrixVectorMul.class</include>
<include>org/apache/flink/streaming/examples/gpu/MatrixVectorMul$*.class</include>
</includes>
</filter>
</filters>
<transformers>
<transformer>
<mainClass>org.apache.flink.streaming.examples.gpu.MatrixVectorMul</mainClass>
</transformer>
</transformers>
</configuration>
</execution>
<execution>
<id>TopSpeedWindowing</id>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<shadeTestJar>false</shadeTestJar>
<finalName>TopSpeedWindowing</finalName>
<shadedArtifactAttached>true</shadedArtifactAttached>
<shadedClassifierName>TopSpeedWindowing</shadedClassifierName>
<artifactSet>
<includes>
<include>org.apache.flink:flink-connector-datagen</include>
</includes>
</artifactSet>
<filters>
<filter>
<artifact>org.apache.flink:*</artifact>
<includes>
<include>org/apache/flink/connector/datagen/**</include>
<include>org/apache/flink/streaming/examples/windowing/TopSpeedWindowing.class</include>
<include>org/apache/flink/streaming/examples/windowing/TopSpeedWindowing$*.class</include>
<include>org/apache/flink/streaming/examples/windowing/util/CarGeneratorFunction.class</include>
<include>org/apache/flink/streaming/examples/wordcount/util/CLI.class</include>
<include>META-INF/LICENSE</include>
<include>META-INF/NOTICE</include>
</includes>
</filter>
</filters>
<transformers>
<transformer>
<mainClass>org.apache.flink.streaming.examples.windowing.TopSpeedWindowing</mainClass>
</transformer>
</transformers>
</configuration>
</execution>
<execution>
<id>SessionWindowing</id>
<phase>package</phase>
<goals>
<goal>shade</goal>
</goals>
<configuration>
<shadeTestJar>false</shadeTestJar>
<finalName>SessionWindowing</finalName>
<shadedArtifactAttached>true</shadedArtifactAttached>
<shadedClassifierName>SessionWindowing</shadedClassifierName>
<artifactSet>
<includes>
<include>org.apache.flink:flink-connector-datagen</include>
</includes>
</artifactSet>
<filters>
<filter>
<artifact>org.apache.flink:*</artifact>
<includes>
<include>org/apache/flink/connector/datagen/**</include>
<include>org/apache/flink/streaming/examples/windowing/SessionWindowing.class</include>
<include>org/apache/flink/streaming/examples/windowing/SessionWindowing$*.class</include>
<include>META-INF/LICENSE</include>
<include>META-INF/NOTICE</include>
</includes>
</filter>
</filters>
<transformers>
<transformer>
<mainClass>org.apache.flink.streaming.examples.windowing.SessionWindowing</mainClass>
</transformer>
</transformers>
</configuration>
</execution>
</executions>
<configuration>
<createDependencyReducedPom>false</createDependencyReducedPom>
</configuration>
</plugin>
<plugin>
<artifactId>maven-antrun-plugin</artifactId>
<executions>
<execution>
<id>rename</id>
<configuration>
<target>
<copy />
<copy />
<copy />
</target>
</configuration>
</execution>
</executions>
</plugin>
</plugins>
</build>
<dependencies>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-streaming-java</artifactId>
<version>2.2.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-clients</artifactId>
<version>2.2.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-files</artifactId>
<version>2.2.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-kafka</artifactId>
<version>3.0.0-1.17</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-csv</artifactId>
<version>2.2.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-connector-datagen</artifactId>
<version>2.2.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-shaded-jackson</artifactId>
<version>2.18.2-20.0</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-test-utils</artifactId>
<version>2.2.1</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>flink-table-common</artifactId>
<groupId>org.apache.flink</groupId>
</exclusion>
<exclusion>
<artifactId>flink-table-api-java</artifactId>
<groupId>org.apache.flink</groupId>
</exclusion>
<exclusion>
<artifactId>flink-runtime</artifactId>
<groupId>org.apache.flink</groupId>
</exclusion>
<exclusion>
<artifactId>flink-core</artifactId>
<groupId>org.apache.flink</groupId>
</exclusion>
<exclusion>
<artifactId>flink-rpc-akka-loader</artifactId>
<groupId>org.apache.flink</groupId>
</exclusion>
<exclusion>
<artifactId>flink-streaming-java</artifactId>
<groupId>org.apache.flink</groupId>
</exclusion>
<exclusion>
<artifactId>flink-statebackend-changelog</artifactId>
<groupId>org.apache.flink</groupId>
</exclusion>
<exclusion>
<artifactId>flink-dstl-dfs</artifactId>
<groupId>org.apache.flink</groupId>
</exclusion>
<exclusion>
<artifactId>curator-test</artifactId>
<groupId>org.apache.curator</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-statebackend-rocksdb</artifactId>
<version>2.2.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-statebackend-forst</artifactId>
<version>2.2.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.jcuda</groupId>
<artifactId>jcuda</artifactId>
<version>10.0.0</version>
<scope>compile</scope>
<exclusions>
<exclusion>
<artifactId>jcuda-natives</artifactId>
<groupId>org.jcuda</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.jcuda</groupId>
<artifactId>jcublas</artifactId>
<version>10.0.0</version>
<scope>compile</scope>
<exclusions>
<exclusion>
<artifactId>jcublas-natives</artifactId>
<groupId>org.jcuda</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-core</artifactId>
<version>2.2.1</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-slf4j-impl</artifactId>
<version>2.24.3</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-api</artifactId>
<version>2.24.3</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
<version>2.24.3</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.flink</groupId>
<artifactId>flink-test-utils-junit</artifactId>
<version>2.2.1</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>testcontainers</artifactId>
<groupId>org.testcontainers</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>1.7.36</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>com.google.code.findbugs</groupId>
<artifactId>jsr305</artifactId>
<version>1.3.9</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.junit.jupiter</groupId>
<artifactId>junit-jupiter</artifactId>
<version>5.11.4</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>junit-jupiter-api</artifactId>
<groupId>org.junit.jupiter</groupId>
</exclusion>
<exclusion>
<artifactId>junit-jupiter-params</artifactId>
<groupId>org.junit.jupiter</groupId>
</exclusion>
<exclusion>
<artifactId>junit-jupiter-engine</artifactId>
<groupId>org.junit.jupiter</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.junit.vintage</groupId>
<artifactId>junit-vintage-engine</artifactId>
<version>5.11.4</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>junit-platform-engine</artifactId>
<groupId>org.junit.platform</groupId>
</exclusion>
<exclusion>
<artifactId>junit</artifactId>
<groupId>junit</groupId>
</exclusion>
<exclusion>
<artifactId>apiguardian-api</artifactId>
<groupId>org.apiguardian</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.assertj</groupId>
<artifactId>assertj-core</artifactId>
<version>3.27.3</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>byte-buddy</artifactId>
<groupId>net.bytebuddy</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-core</artifactId>
<version>5.19.0</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>byte-buddy-agent</artifactId>
<groupId>net.bytebuddy</groupId>
</exclusion>
<exclusion>
<artifactId>byte-buddy</artifactId>
<groupId>net.bytebuddy</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.mockito</groupId>
<artifactId>mockito-junit-jupiter</artifactId>
<version>5.19.0</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>junit-jupiter-api</artifactId>
<groupId>org.junit.jupiter</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.hamcrest</groupId>
<artifactId>hamcrest-all</artifactId>
<version>1.3</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.testcontainers</groupId>
<artifactId>junit-jupiter</artifactId>
<version>1.21.4</version>
<scope>test</scope>
<exclusions>
<exclusion>
<artifactId>testcontainers</artifactId>
<groupId>org.testcontainers</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-1.2-api</artifactId>
<version>2.24.3</version>
<scope>test</scope>
</dependency>
</dependencies>
<properties>
<jcuda.version>10.0.0</jcuda.version>
<surefire.module.config>--add-opens=java.base/java.util=ALL-UNNAMED</surefire.module.config>
</properties>
</project>