Java与大数据架构：07-FFSF2020-薛康.pdf

1、 ? ? Flink ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?F? ? StreamSQL ? Flink CEP ? ? ? ?F? StreamSQL? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? CREATE TABLE orderTable ( start_

2、time $.start_time STRING, end_time$.data.end_time STRING, passenger$.data.passenger STRING, id INT ) WITH ( stype = kafka, topics = topic1, brokers = , encode = json ); ? ?/? ? ?/? ? ? ?/? ? ?D ? ? ? ? ? CREATE TABLE binlogSource ( binlog_db varchar, binlog_time varchar, binlog_table varchar, binlog

3、_event varchar, order_id varchar, - actual business field columns_origin MAP, columns_v MAP, all_fields MAP ) WITH ( stype = kafka, encode = binlog ) ?/? ?/? ?EB ? ? UDX Library ? ? ? ? Hive ? ? ? ? ? ? ? ? ? 1? 1? ?2? ?2?2?2?2? ? 1? ?2? ?2?2? ? ?1?2? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? Web? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ?23-? ?23-? ?23-? ? ? ? ?