添加链接 注册    登录
link管理
链接快照平台
  • 输入网页链接，自动生成快照
  • 标签化管理网页链接
相关文章推荐
聪明伶俐的跑步鞋  ·  ApacheLog4j2远程代码执行漏洞CV ...·  5 天前    · 
腼腆的香菇  ·  Apache HertzBeat · An ...·  3 天前    · 
沉着的生菜  ·  python3 ...·  4 月前    · 
坚韧的绿茶  ·  联想小新超薄笔记本锐龙CPU Ryzen ...·  5 月前    · 
讲道义的脆皮肠  ·  必须啃下中高考改革这块“硬骨头”-中国法院网·  5 月前    · 
胆小的冰淇淋  ·  设置display:flex之后width失 ...·  10 月前    · 
含蓄的红薯  ·  Javascript数据结构之字典和散列表 ...·  1 年前    · 
link管理  ›  Uses of Interface org.apache.flink.api.dag.Pipeline (Flink : 1.12-SNAPSHOT API)
string apache
https://nightlies.apache.org/flink/flink-docs-release-1.12/api/java/org/apache/flink/api/dag/class-use/Pipeline.html
小眼睛的火车
3 月前

Uses of Pipeline in org.apache.flink.api.common

Classes in org.apache.flink.api.common that implement Pipeline Modifier and Type Class and Description class
This class represents Flink programs, in the form of dataflow plans.

Uses of Pipeline in org.apache.flink.client

Methods in org.apache.flink.client with parameters of type Pipeline Modifier and Type Method and Description boolean StreamGraphTranslator. canTranslate ( Pipeline pipeline) boolean FlinkPipelineTranslator. canTranslate ( Pipeline pipeline) boolean PlanTranslator. canTranslate ( Pipeline pipeline) static JobGraph FlinkPipelineTranslationUtil. getJobGraph ( Pipeline pipeline, Configuration optimizerConfiguration, int defaultParallelism)
Transmogrifies the given Pipeline to a JobGraph .
static JobGraph FlinkPipelineTranslationUtil. getJobGraphUnderUserClassLoader ( ClassLoader userClassloader, Pipeline pipeline, Configuration configuration, int defaultParallelism)
Transmogrifies the given Pipeline under the userClassloader to a JobGraph .
JobGraph StreamGraphTranslator. translateToJobGraph ( Pipeline pipeline, Configuration optimizerConfiguration, int defaultParallelism) JobGraph FlinkPipelineTranslator. translateToJobGraph ( Pipeline pipeline, Configuration optimizerConfiguration, int defaultParallelism)
Creates a JobGraph from the given Pipeline and attaches the given jar files and classpaths to the JobGraph .
JobGraph PlanTranslator. translateToJobGraph ( Pipeline pipeline, Configuration optimizerConfiguration, int defaultParallelism) static String FlinkPipelineTranslationUtil. translateToJSONExecutionPlan ( Pipeline pipeline)
Extracts the execution plan (as JSON) from the given Pipeline .
String StreamGraphTranslator. translateToJSONExecutionPlan ( Pipeline pipeline) String FlinkPipelineTranslator. translateToJSONExecutionPlan ( Pipeline pipeline)
Extracts the execution plan (as JSON) from the given Pipeline .
String PlanTranslator. translateToJSONExecutionPlan ( Pipeline pipeline)

Uses of Pipeline in org.apache.flink.client.deployment.application.executors

Methods in org.apache.flink.client.deployment.application.executors with parameters of type Pipeline Modifier and Type Method and Description CompletableFuture < JobClient > EmbeddedExecutor. execute ( Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)

Uses of Pipeline in org.apache.flink.client.deployment.executors

Methods in org.apache.flink.client.deployment.executors with parameters of type Pipeline Modifier and Type Method and Description CompletableFuture < JobClient > LocalExecutor. execute ( Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader) CompletableFuture < JobClient > AbstractJobClusterExecutor. execute ( Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader) CompletableFuture < JobClient > AbstractSessionClusterExecutor. execute ( Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader) static JobGraph PipelineExecutorUtils. getJobGraph ( Pipeline pipeline, Configuration configuration)
Creates the JobGraph corresponding to the provided Pipeline .

Uses of Pipeline in org.apache.flink.client.program

Methods in org.apache.flink.client.program that return Pipeline Modifier and Type Method and Description Pipeline OptimizerPlanEnvironment. getPipeline () Pipeline StreamPlanEnvironment. getPipeline () static Pipeline PackagedProgramUtils. getPipelineFromProgram ( PackagedProgram program, Configuration configuration, int parallelism, boolean suppressOutput)

Uses of Pipeline in org.apache.flink.core.execution

Methods in org.apache.flink.core.execution with parameters of type Pipeline Modifier and Type Method and Description CompletableFuture < JobClient > PipelineExecutor. execute ( Pipeline pipeline, Configuration configuration, ClassLoader userCodeClassloader)
Executes a Pipeline based on the provided configuration and returns a JobClient which allows to interact with the job being executed, e.g.

Uses of Pipeline in org.apache.flink.streaming.api.graph

Classes in org.apache.flink.streaming.api.graph that implement Pipeline Modifier and Type Class and Description class StreamGraph
Class representing the streaming topology.

Uses of Pipeline in org.apache.flink.table.api.bridge.java.internal

Methods in org.apache.flink.table.api.bridge.java.internal that return Pipeline Modifier and Type Method and Description Pipeline StreamTableEnvironmentImpl. getPipeline ( String jobName)
This method is used for sql client to submit job.

Uses of Pipeline in org.apache.flink.table.client.gateway.local

Methods in org.apache.flink.table.client.gateway.local that return Pipeline Modifier and Type Method and Description Pipeline ExecutionContext. createPipeline ( String name) Constructors in org.apache.flink.table.client.gateway.local with parameters of type Pipeline Constructor and Description ProgramDeployer ( Configuration configuration, String jobName, Pipeline pipeline, ClassLoader userCodeClassloader)
Deploys a table program on the cluster.

Uses of Pipeline in org.apache.flink.table.delegation

Methods in org.apache.flink.table.delegation that return Pipeline Modifier and Type Method and Description Pipeline Executor. createPipeline ( List < Transformation <?>> transformations, TableConfig tableConfig, String jobName)
Translates the given transformations to a Pipeline.
Methods in org.apache.flink.table.delegation with parameters of type Pipeline Modifier and Type Method and Description JobExecutionResult Executor. execute ( Pipeline pipeline)
Executes the given pipeline.
JobClient Executor. executeAsync ( Pipeline pipeline)
Executes the given pipeline asynchronously.

Uses of Pipeline in org.apache.flink.table.executor

Methods in org.apache.flink.table.executor that return Pipeline Modifier and Type Method and Description Pipeline StreamExecutor. createPipeline ( List < Transformation <?>> transformations, TableConfig tableConfig, String jobName) Methods in org.apache.flink.table.executor with parameters of type Pipeline Modifier and Type Method and Description JobExecutionResult StreamExecutor. execute ( Pipeline pipeline) JobClient StreamExecutor. executeAsync ( Pipeline pipeline)

Uses of Pipeline in org.apache.flink.table.planner.delegation

Methods in org.apache.flink.table.planner.delegation that return Pipeline Modifier and Type Method and Description Pipeline BatchExecutor. createPipeline ( List < Transformation <?>> transformations, TableConfig tableConfig, String jobName) Pipeline StreamExecutor. createPipeline ( List < Transformation <?>> transformations, TableConfig tableConfig, String jobName) Methods in org.apache.flink.table.planner.delegation with parameters of type Pipeline Modifier and Type Method and Description JobExecutionResult ExecutorBase. execute ( Pipeline pipeline) JobClient ExecutorBase. executeAsync ( Pipeline pipeline)
 
推荐文章
聪明伶俐的跑步鞋  ·  ApacheLog4j2远程代码执行漏洞CVE-2021-44228 - 应用实时监控服务ARMS - 阿里云
5 天前
腼腆的香菇  ·  Apache HertzBeat · An open source, real-time monitoring tool with custom-monitor and agentLess. | Ap
3 天前
沉着的生菜  ·  python3 获取html中js的某一个变量,这个html中有多个script标签 - CSDN文库
4 月前
坚韧的绿茶  ·  联想小新超薄笔记本锐龙CPU Ryzen R5 3500U重装WIN7系统→小鱼儿yr系统
5 月前
讲道义的脆皮肠  ·  必须啃下中高考改革这块“硬骨头”-中国法院网
5 月前
胆小的冰淇淋  ·  设置display:flex之后width失效_min-width生效而width不生效-CSDN博客
10 月前
含蓄的红薯  ·  Javascript数据结构之字典和散列表 - 前端开发
1 年前
Link管理   ·   51好读   ·   Sov5搜索   ·   小百科
link管理 - 链接快照平台