Flink多流和和维表实现对比
2020-04-08 本文已影响0人
zh_harry
/**
* Operator used for directing tuples to specific named outputs using an
* {@link org.apache.flink.streaming.api.collector.selector.OutputSelector}.
* Calling this method on an operator creates a new {@link SplitStream}.
*
* @param outputSelector
* The user defined
* {@link org.apache.flink.streaming.api.collector.selector.OutputSelector}
* for directing the tuples.
* @return The {@link SplitStream}
* @deprecated Please use side ouput instead.
*/
@Deprecated
public SplitStream<T> split(OutputSelector<T> outputSelector) {
return new SplitStream<>(this, clean(outputSelector));
}
维表方案对比
| header 1 | 预加载DB数据到内存 | Distrbuted Cache | 热存储关联 | 广播维表 | Temporal Table Function join |
|---|---|---|---|---|---|
| 实现复杂度 | 低 | 低 | 中 | 低 | 低 |
| 维表数据量 | 低 | 低 | 高 | 低 | 高 |
| 维表更新频率 | 低 | 低 | 中 | 高 | 高 |
| 维表更新实时性 | 低 | 低 | 中 | 高 | 高 |
| 维表形式 | DB | 文件 | 热存储 | 实时流 | 实时流 |
| 是否依赖外部存储 | 是 | 是 | 否 | 否 |
