当前位置： 首页 > news >正文

Table SQL connectors以及FileSystem、JDBC connector

news 来源：原创 2024/9/19 23:41:10

目录

Flink支持的连接器

 如何使用连接器 

FileSystem SQL Connector

 文件格式

分区文件

Source

目录监控

 元数据

Streaming Sink

滚动策略

文件合并

JDBC SQL Connector

依赖

如何创建JDBC表

连接器配置

案例

pom依赖

代码

测试

        Flink的Table API和SQL程序可以连接到其他外部系统，用于读取和写入批处理和流表（ batch and streaming tables）。表源（Table Source）提供对存储在外部系统（如数据库、键值存储、消息队列或文件系统)中的数据的访问。表接收器（Table Sink）将表发送到外部存储系统。根据源和接收的类型，它们支持不同的格式，如CSV、Avro、Parquet或ORC。

Flink支持的连接器

        Flink原生支持各种连接器。下表列出了所有可用的连接器。

名称版本SourceSink
FilesystemBounded and Unbounded ScanStreaming Sink, Batch Sink

相关文章：

  • 北京网站建设多少钱？
  • 辽宁网页制作哪家好_网站建设
  • 高端品牌网站建设_汉中网站制作
  • Redis学习[6] ——Redis缓存设计
  • 付费进群系统源码原版最新修复全开源版
  • C#中静态方法与动态方法的区别
  • Node Red 与axios简易测试环境的搭建
  • 用TensorFlow训练自己的第一个模型
  • 【传知代码】辅助任务改进社交帖子多模态分类（论文复现）
  • 离线安装MeterSphere遇到的问题
  • LabVIEW做二次开发时应该注意哪些方面？
  • TS中什么是字面量类型？
  • 如何用3个月零基础入门网络安全？_网络安全零基础怎么学习
  • Vue.js学习笔记（六）element表单校验规则
  • 雨量气象站：实时、准确地监测并记录降水情况
  • 【基础篇】MySQL数据库详解：基础知识详解
  • 每日一面系列之美团面试拷打：ConcurrentHashMap 为何不能插入 null？HashMap 为何可以
  • 从零开始写一个微信小程序
  • es6要点
  • JavaScript 基础知识 - 入门篇(一)
  • java小心机(3)| 浅析finalize()
  • java中具有继承关系的类及其对象初始化顺序
  • js对象的深浅拷贝
  • Making An Indicator With Pure CSS
  • Redis 懒删除(lazy free)简史
  • Three.js 再探 - 写一个跳一跳极简版游戏
  • Vue 2.3、2.4 知识点小结
  • vue从入门到进阶：计算属性computed与侦听器watch（三）
  • 基于Android乐音识别(2)
  • 技术胖1-4季视频复习— (看视频笔记)
  • 老板让我十分钟上手nx-admin
  • 利用阿里云 OSS 搭建私有 Docker 仓库
  • 那些被忽略的 JavaScript 数组方法细节
  • 为视图添加丝滑的水波纹
  • 长三角G60科创走廊智能驾驶产业联盟揭牌成立，近80家企业助力智能驾驶行业发展 ...
  • ​​​【收录 Hello 算法】10.4 哈希优化策略
  • ​Java基础复习笔记 第16章：网络编程
  • ​Linux·i2c驱动架构​
  • （~_~)
  • （19）夹钳(用于送货)
  • （1综述）从零开始的嵌入式图像图像处理(PI+QT+OpenCV)实战演练
  • （C语言）二分查找 超详细
  • (Matlab)遗传算法优化的BP神经网络实现回归预测
  • （pycharm）安装python库函数Matplotlib步骤
  • （Windows环境）FFMPEG编译，包含编译x264以及x265
  • （翻译）Quartz官方教程——第一课：Quartz入门
  • (分享)自己整理的一些简单awk实用语句
  • （六）什么是Vite——热更新时vite、webpack做了什么
  • （论文阅读23/100）Hierarchical Convolutional Features for Visual Tracking
  • （一）Docker基本介绍
  • (原創) X61用戶，小心你的上蓋!! (NB) (ThinkPad) (X61)
  • ******之网络***——物理***
  • ***通过什么方式***网吧
  • .NET Core中Emit的使用
  • .NET/C# 使用 #if 和 Conditional 特性来按条件编译代码的不同原理和适用场景
  • .NET连接MongoDB数据库实例教程
  • .NET序列化 serializable，反序列化
  • .Net中间语言BeforeFieldInit