Flink 다중 Sink의 구현

1028 단어 Flink다중 싱글
실제 생산 환경에서 우리의 Flink 작업은 여러 개의 저장소에 동시에 써야 할 수도 있다. 즉, 여러 개의 sink가 있을 수 있다. 물론 Flink는 여러 개의 sink를 지원하고 여러 개의 sink는 병행된 관계이기 때문에 서로 영향을 주지 않는다. 구체적인 실현 코드는 다음과 같다.
package flink.table

import java.sql.Timestamp
import java.util.TimeZone
import flink.util.CommonUtils
import org.apache.flink.api.common.time.Time
import org.apache.flink.configuration.Configuration
import org.apache.flink.streaming.api.{CheckpointingMode, TimeCharacteristic}
import org.apache.flink.streaming.api.functions.sink.RichSinkFunction
import org.apache.flink.table.api.TableEnvironment
import org.apache.flink.table.api.scala._
import org.apache.flink.streaming.api.scala.{StreamExecutionEnvironment, _}
import org.apache.hadoop.hbase.{HBaseConfiguration, TableName}
import org.apache.hadoop.hbase.client._
import org.apache.hadoop.hbase.util.Bytes
import org.apache.flink.streaming.connectors.fs.bucketing.{BucketingSink, DateTimeBucketer}
import org.apache.flink.streaming.connectors.fs.StringWriter

/**
  * Flink SQL  Process

좋은 웹페이지 즐겨찾기