“Flink实时数据处理”的版本间的差异

来自CloudWiki
跳转至： 导航， 搜索
（→‎1.pom.xml配置,打开IDEA）
（→‎1.pom.xml配置,打开IDEA）
第30行： 第30行：
 
(3)修改pom.xml依赖(根据以下代码进行局部更改)
 
(3)修改pom.xml依赖(根据以下代码进行局部更改)
  
−
<nowiki>
+
<properties>
−
<properties>
+
        <maven.compiler.target>1.8</maven.compiler.target>
−
   
+
        <maven.compiler.source>1.8</maven.compiler.source>
−
    <maven.compiler.target>1.8</maven.compiler.target>
+
</properties>
  
−
     <maven.compiler.source>1.8</maven.compiler.source>
+
<build>
−
 
+
     <plugins>
−
</properties>
+
        <plugin>
−
</nowiki>
+
            <groupId>org.apache.maven.plugins</groupId>
 +
            <artifactId>maven-compiler-plugin</artifactId>
 +
            <version>3.6.1</version>
 +
            <configuration>
 +
                <source>1.8</source>
 +
                <target>1.8</target>
 +
            </configuration>
 +
        </plugin>
 +
    </plugins>
 +
</build>

2020年8月2日 (日) 10:23的版本

Flink实时统计目标:

1.编程读取kafka缓存数据

2.商品实时统计:

(1)每日销售额,每日访问流量实时统计

(2)每日每家门店总销售额实时统计

(3)每日商品销量实时统计,并选出10大热销商品

(实现过程中,时间单位设置为1~2分钟)

配置开发环境:intellij & IDEA && Maven &&JDK

1.pom.xml配置,打开IDEA<我这里使用的是2018.3.6版本>

(1)首先创建一个新项目Create New Project,操作如下

Newproject1.png

Newproject2.png

Newproject3.png

Newproject4.png

(2)右下角都会出现 Maven projects need to be imported（项目需要导入依赖）<IDEA2020版本取消了导入默认依赖提示>

(3)修改pom.xml依赖(根据以下代码进行局部更改) 

<properties>
       <maven.compiler.target>1.8</maven.compiler.target>
       <maven.compiler.source>1.8</maven.compiler.source>
</properties>

<build>
   <plugins>
       <plugin>
           <groupId>org.apache.maven.plugins</groupId>
           <artifactId>maven-compiler-plugin</artifactId>
           <version>3.6.1</version>
           <configuration>
               <source>1.8</source>
               <target>1.8</target>
           </configuration>
       </plugin>
   </plugins>
</build>
取自“http://www.openbrains.net/mediawiki/index.php?title=Flink实时数据处理&oldid=19917”