FlinkStreamingPipelineTranslator
1 所有的可用Translator:
// here you can find all the available translators.
static {
TRANSLATORS.put(Read.Bounded.class,new BoundedReadSourceTranslator());
TRANSLATORS.put(Read.Unbounded.class,new UnboundedReadSourceTranslator());
TRANSLATORS.put(TextIO.Write.Bound.class,new TextIOWriteBoundStreamingTranslator());
TRANSLATORS.put(ParDo.MultIoUtput.class,new ParDoStreamingTranslator());
TRANSLATORS.put(
SplittableParDo.ProcessElements.class,new SplittableProcessElementsstreamingTranslator());
TRANSLATORS.put(
SplittableParDo.GBKIntoKeyedWorkItems.class,new GBKIntoKeyedWorkItemsTranslator());
TRANSLATORS.put(Window.Assign.class,new WindowAssignTranslator());
TRANSLATORS.put(Flatten.PCollections.class,new FlattenPCollectionTranslator());
TRANSLATORS.put(
FlinkStreamingViewOverrides.CreateFlinkPCollectionView.class,new CreateViewStreamingTranslator());
TRANSLATORS.put(Reshuffle.class,new ReshuffleTranslatorStreaming());
TRANSLATORS.put(GroupByKey.class,new GroupByKeyTranslator());
TRANSLATORS.put(Combine.PerKey.class,new CombinePerKeyTranslator());
}
2 applyStreamingTransform:
基本逻辑:将PTransform关联到streamingContext
// create the applied PTransform on the streamingContext streamingContext.setCurrentTransform(node.toAppliedPTransform());
typedTranslator.translateNode(typedTransform,streamingContext);
12种类型的translator多态实现了StreamTransformTranslator.translateNode(T transform,FlinkStreamingTranslationContext context);
方法。
原文地址:https://www.jb51.cc/javaschema/283146.html
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。