项目案例
https://github.com/TaoPanfeng/case/tree/master/03-flink/flink-rabbitmq-oracle
文件内容
FlinkMain.java
1 | import org.apache.flink.api.common.serialization.SimpleStringSchema; |
SinkOracle.java
1 | import org.apache.flink.configuration.Configuration; |
pom.xml
1 | <dependencies> |
测试步骤
执行
Flink.java
中的主方法,往对应队列中传入数据,可以输入到控制台
读取配置文件
如果想把配置信息写文件
application.properties
的话
配置文件内容
1 | oracle.jdbc.OracleDriver = |
读取RabbitMQ
1 | import org.apache.flink.api.common.serialization.SimpleStringSchema; |
读取数据库
1 | public class CountrySinkOracle extends RichSinkFunction<String> |