File tree 1 file changed +7
-2
lines changed
1 file changed +7
-2
lines changed Original file line number Diff line number Diff line change 1
1
# Flink Streaming Example
2
2
3
+ ## Prerequisites
4
+
5
+ * [ Java Development Kit (JDK) 1.8] ( https://www.oracle.com/java/technologies/javase/javase8u211-later-archive-downloads.html )
6
+ * [ Apache Maven] ( http://maven.apache.org/download.cgi ) and [ install] ( http://maven.apache.org/install.html ) a Maven binary archive
7
+
3
8
## Build Flink Job
4
9
5
10
```
6
11
mvn clean package
7
12
```
8
13
9
- ### Custom Flink Streaming Source & Sink
14
+ ## Custom Flink Streaming Source & Sink
10
15
11
16
Flink has 3 types of custom streaming source:
12
17
@@ -19,7 +24,7 @@ Flink has 2 types of custom streaming sink:
19
24
* Implements SinkFunction with single parallelism.
20
25
* Implements RichSinkFunction with single parallelism, with open() to initialize resource, close() to dispose resource.
21
26
22
- ### Flink Batch Stream Alignment
27
+ ## Flink Batch Stream Alignment
23
28
24
29
Flink has raised new kind of Source & Sink API for Batch Stream Alignment
25
30
You can’t perform that action at this time.
0 commit comments