flink從檔案中讀取使用者資料，並轉化成樣例類
1
,男,張三,20,
1605970941
2,女,莉莉,30,
1605970922
3,女,紅紅,30,
1605970913
4,男,李四,24,
1605970904
5,男,王五,25,
1605970965
6,男,小明,20,
1605970946
package com.day
import org.apache.flink.streaming.api.scala._
//使用者資訊樣例類
case
class user(id:
string
, name:
string
, ***:
string
, age:
int, ts:
long
)//source之讀取檔案
object sourcefile
)// 3、列印資料
datastream.print(
)// 4、執行任務
env.execute(
"sourcefile job")}
}
<
!-- 屬性配置 --
>
1.11
.2<
/flink.version>
compile<
/scope>
<
/properties>
<
!-- flink 依賴 --
>
org.apache.flink<
/groupid>
flink-clients_2.
11<
/artifactid>
$<
/version>
<
/dependency>
org.apache.flink<
/groupid>
flink-streaming-scala_2.
11<
/artifactid>
$<
/version>
$<
/scope>
<
/dependency>
<
/dependencies>
ExtJS入門之三 查詢
在web開發中，對htmldom進行查詢是必不可少的，extjs提供了高效能的查詢功能，支援css3選擇器 selector 查詢和基本的xpath查詢。extjs的查詢對xml和html均成立 看下面的html divid mydiv input type checkbox value 1 inp...
ExtJS入門之三 查詢
在web開發中，對htmldom進行查詢是必不可少的，extjs提供了高效能的查詢功能，支援css3選擇器 selector 查詢和基本的xpath查詢。extjs的查詢對xml和html均成立 看下面的html divid mydiv input type checkbox value 1 inp...
lua入門之三module
1 模組與包23 定義乙個名為 module 的模組 4module 56 module.consta 這是乙個常量 7 8function module func1 9io.write func1共有函式 n 10end 1112 local function func2 13io.write f...