游客qzzytmszf3zhq_个人页

2021年12月

• 12.07 20:43:18
  回答了问题 2021-12-07 20:43:18

  Flink SQL 自定义函数聚合函数(UDAGG)的示例是什么？

  赞0 踩0 评论0
• 12.07 20:38:27
  提交了问题 2021-12-07 20:38:27

  Flink SQL 自定义函数表值函数(UDTF)的示例是什么？

• 12.07 20:37:49
  提交了问题 2021-12-07 20:37:49

  Flink SQL 自定义函数标量函数(UDF)的示例是什么？

• 12.07 20:37:01
  提交了问题 2021-12-07 20:37:01

  TableAggregateFunction 的什么方法可以提升流式任务的效率呢？

• 12.07 20:36:31
  提交了问题 2021-12-07 20:36:31

  flink中TableAggregateFunction 的什么方法在某些特定场景下是必须要实现的？

• 12.07 20:35:47
  提交了问题 2021-12-07 20:35:47

  Flink SQL 自定义函数表值聚合函数(UDTAGG)是什么？

• 12.07 20:35:11
  提交了问题 2021-12-07 20:35:11

  flink中AggregateFunction 的什么方法在某些场景下是必须实现的？

• 12.07 20:34:33
  提交了问题 2021-12-07 20:34:33

  flink中每个 AggregateFunction 必须要实现的是什么方法？

• 12.07 20:33:40
  提交了问题 2021-12-07 20:33:40

  Flink SQL 自定义函数聚合函数(UDAGG)是什么？

• 12.07 20:33:09
  提交了问题 2021-12-07 20:33:09

  Flink SQL 自定义函数表值函数(UDTF)是什么？

• 12.07 20:32:28
  提交了问题 2021-12-07 20:32:28

  Flink SQL 自定义函数标量函数(UDF)是什么？

• 12.07 20:31:33
  提交了问题 2021-12-07 20:31:33

  Flink SQL 自定义函数有哪些？

• 12.07 20:30:52
  提交了问题 2021-12-07 20:30:52

  flink固定延迟时间戳分配器是什么？

• 12.07 20:30:21
  提交了问题 2021-12-07 20:30:21

  flink单调递增时间戳分配器是什么？

• 12.07 20:29:41
  提交了问题 2021-12-07 20:29:41

  flink的watermark使用方法是什么？

• 12.07 20:28:06
  提交了问题 2021-12-07 20:28:06

  flink中Kafka流表关联HBase维度表的计算逻辑是什么呢？

• 12.07 20:26:57
  提交了问题 2021-12-07 20:26:57

  flink创建Sink表的方法是什么？

• 12.07 20:26:31
  提交了问题 2021-12-07 20:26:31

  flink创建HBase维度表的方法是什么？

• 12.07 20:26:01
  提交了问题 2021-12-07 20:26:01

  flink创建Kafka流表的方法是什么？

• 12.07 20:22:44
  提交了问题 2021-12-07 20:22:44

  如果checkpoint时间过长，offset未提交到kafka重启之后的重复消费如何保证呢？

• 12.07 20:21:59
  提交了问题 2021-12-07 20:21:59

  partitioner 传 null 是 round-robin 发到每一个partition吗

• 12.07 20:21:01
  提交了问题 2021-12-07 20:21:01

  在flink consumer的并行度的设置是对应topic的partitions个数吗？

• 12.07 20:20:18
  提交了问题 2021-12-07 20:20:18

  Flink kafka Producer的容错是什么？

• 12.07 20:19:12
  提交了问题 2021-12-07 20:19:12

  Flink kafka Producer的Producer 分区是什么？

• 12.07 20:18:41
  提交了问题 2021-12-07 20:18:41

  Flink kafka Consumer的Timestamp Extraction的生成是什么意思？

• 12.07 20:17:59
  提交了问题 2021-12-07 20:17:59

  Flink kafka Consumer的commit offset方式有什么？

• 12.07 20:17:31
  提交了问题 2021-12-07 20:17:31

  Flink kafka Consumer的topic和partition动态发现是什么？

• 12.07 20:16:46
  提交了问题 2021-12-07 20:16:46

  Flink kafka Consumer的消费起始位置设置在哪里？

• 12.07 20:16:10
  提交了问题 2021-12-07 20:16:10

  Flink kafka Consumer的反序列化数据是什么？

• 12.07 20:15:18
  提交了问题 2021-12-07 20:15:18

  Async I/O是什么？

• 12.07 20:14:44
  提交了问题 2021-12-07 20:14:44

  Apache Bahir中的连接器是什么？

• 12.07 20:14:17
  提交了问题 2021-12-07 20:14:17

  Bundled Connectors是什么？

• 12.07 20:13:51
  提交了问题 2021-12-07 20:13:51

  Flink里基于内存 Collections、Iterators 的Source是什么？

• 12.07 20:13:12
  提交了问题 2021-12-07 20:13:12

  Flink里基于Socket的Source和Sink是什么？

• 12.07 20:12:37
  提交了问题 2021-12-07 20:12:37

  Flink里基于文件的source和sink是什么？

• 12.07 20:11:13
  提交了问题 2021-12-07 20:11:13

  Flink Streaming Connector是什么？

• 12.07 20:04:31
  提交了问题 2021-12-07 20:04:31

  Flink 程序在面对数据高峰期时如何处理？

• 12.07 20:04:04
  提交了问题 2021-12-07 20:04:04

  Flink 三种时间语义是什么，分别说出应用场景？

• 12.07 20:03:46
  提交了问题 2021-12-07 20:03:46

  Flink CEP 编程中当状态没有到达的时候会将数据保存在哪里？

• 12.07 20:03:28
  提交了问题 2021-12-07 20:03:28

  Flink 中 exactly-once 语义是如何实现的，状态是如何存储的？

• 12.07 20:03:10
  提交了问题 2021-12-07 20:03:10

  Flink 的 Watermark 机制是什么？

• 12.07 20:02:43
  提交了问题 2021-12-07 20:02:43

  Flink 的 checkpoint 机制对比 spark 有什么不同和优势？

• 12.07 20:02:25
  提交了问题 2021-12-07 20:02:25

  海量 key 去重的方法是什么？

• 12.07 20:01:51
  提交了问题 2021-12-07 20:01:51

  Flink 状态机制是什么？

• 12.07 20:01:30
  提交了问题 2021-12-07 20:01:30

  如果下级存储不支持事务，Flink 怎么保证 exactly-once？

• 12.07 20:01:07
  提交了问题 2021-12-07 20:01:07

  Flink 的 checkpoint 存在哪里？

• 12.07 20:00:37
  提交了问题 2021-12-07 20:00:37

  为什么使用 Flink 替代 Spark？

• 12.07 20:00:15
  提交了问题 2021-12-07 20:00:15

  怎么做压力测试和监控？

• 12.07 19:59:39
  提交了问题 2021-12-07 19:59:39

  flink中公司怎么提交的实时任务，有多少 Job Manager？

• 12.07 19:57:54
  提交了问题 2021-12-07 19:57:54

  FlinkSQL的是如何实现的？