flink维表关联之实时查找mysql

1、引入依赖

  <dependency>
        <groupId>org.apache.flink</groupId>
        <artifactId>flink-connector-jdbc_2.11</artifactId>
        <version>${flink.version}</version>
        <scope>compile</scope>
  </dependency>
  <!-- mysql connector -->
  <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>5.1.44</version>
  </dependency>

2、自定义一个流模拟数据

package com.test;

import org.apache.flink.streaming.api.functions.source.SourceFunction;
import java.util.Random;

/**
 * 自定义Source
 */
class MyCustomSourceFunction implements SourceFunction<Long> {
    private boolean isRunning = true;
    private long count = 1L;
    @Override
    public void run(SourceContext<Long> ctx) throws Exception {
        while