org.apache.flink.api.common.operators.Operator.getCompilerHints()方法的使用及代码示例

x33g5p2x  于2022-01-26 转载在 其他  
字(5.5k)|赞(0)|评价(0)|浏览(92)

本文整理了Java中org.apache.flink.api.common.operators.Operator.getCompilerHints()方法的一些代码示例,展示了Operator.getCompilerHints()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Operator.getCompilerHints()方法的具体详情如下:
包路径:org.apache.flink.api.common.operators.Operator
类名称:Operator
方法名:getCompilerHints

Operator.getCompilerHints介绍

[英]Gets the compiler hints for this contract instance. In the compiler hints, different fields may be set (for example the selectivity) that will be evaluated by the pact compiler when generating plan alternatives.
[中]获取此协定实例的编译器提示。在编译器提示中,可以设置不同的字段(例如选择性),pact编译器在生成计划替代方案时将对这些字段进行评估。

代码示例

代码示例来源:origin: apache/flink

protected void readUniqueFieldsAnnotation() {
  if (this.operator.getCompilerHints() != null) {
    Set<FieldSet> uniqueFieldSets = operator.getCompilerHints().getUniqueFields();
    if (uniqueFieldSets != null) {
      if (this.uniqueFields == null) {
        this.uniqueFields = new HashSet<FieldSet>();
      }
      this.uniqueFields.addAll(uniqueFieldSets);
    }
  }
}

代码示例来源:origin: apache/flink

if (n.getOperator().getCompilerHints() != null) {
  CompilerHints hints = n.getOperator().getCompilerHints();
  CompilerHints defaults = new CompilerHints();

代码示例来源:origin: apache/flink

if (getOperator() == null || getOperator().getCompilerHints() == null) {
  return ;
CompilerHints hints = getOperator().getCompilerHints();
if (hints.getOutputSize() >= 0) {
  this.estimatedOutputSize = hints.getOutputSize();

代码示例来源:origin: apache/flink

if (optNode.getOperator().getCompilerHints() != null) {
  CompilerHints hints = optNode.getOperator().getCompilerHints();
  CompilerHints defaults = new CompilerHints();

代码示例来源:origin: com.alibaba.blink/flink-optimizer

protected void readUniqueFieldsAnnotation() {
  if (this.operator.getCompilerHints() != null) {
    Set<FieldSet> uniqueFieldSets = operator.getCompilerHints().getUniqueFields();
    if (uniqueFieldSets != null) {
      if (this.uniqueFields == null) {
        this.uniqueFields = new HashSet<FieldSet>();
      }
      this.uniqueFields.addAll(uniqueFieldSets);
    }
  }
}

代码示例来源:origin: org.apache.flink/flink-optimizer_2.11

protected void readUniqueFieldsAnnotation() {
  if (this.operator.getCompilerHints() != null) {
    Set<FieldSet> uniqueFieldSets = operator.getCompilerHints().getUniqueFields();
    if (uniqueFieldSets != null) {
      if (this.uniqueFields == null) {
        this.uniqueFields = new HashSet<FieldSet>();
      }
      this.uniqueFields.addAll(uniqueFieldSets);
    }
  }
}

代码示例来源:origin: org.apache.flink/flink-optimizer_2.10

protected void readUniqueFieldsAnnotation() {
  if (this.operator.getCompilerHints() != null) {
    Set<FieldSet> uniqueFieldSets = operator.getCompilerHints().getUniqueFields();
    if (uniqueFieldSets != null) {
      if (this.uniqueFields == null) {
        this.uniqueFields = new HashSet<FieldSet>();
      }
      this.uniqueFields.addAll(uniqueFieldSets);
    }
  }
}

代码示例来源:origin: org.apache.flink/flink-optimizer

protected void readUniqueFieldsAnnotation() {
  if (this.operator.getCompilerHints() != null) {
    Set<FieldSet> uniqueFieldSets = operator.getCompilerHints().getUniqueFields();
    if (uniqueFieldSets != null) {
      if (this.uniqueFields == null) {
        this.uniqueFields = new HashSet<FieldSet>();
      }
      this.uniqueFields.addAll(uniqueFieldSets);
    }
  }
}

代码示例来源:origin: org.apache.flink/flink-optimizer

if (n.getOperator().getCompilerHints() != null) {
  CompilerHints hints = n.getOperator().getCompilerHints();
  CompilerHints defaults = new CompilerHints();

代码示例来源:origin: com.alibaba.blink/flink-optimizer

if (n.getOperator().getCompilerHints() != null) {
  CompilerHints hints = n.getOperator().getCompilerHints();
  CompilerHints defaults = new CompilerHints();

代码示例来源:origin: org.apache.flink/flink-optimizer_2.10

if (n.getOperator().getCompilerHints() != null) {
  CompilerHints hints = n.getOperator().getCompilerHints();
  CompilerHints defaults = new CompilerHints();

代码示例来源:origin: org.apache.flink/flink-optimizer_2.11

if (n.getOperator().getCompilerHints() != null) {
  CompilerHints hints = n.getOperator().getCompilerHints();
  CompilerHints defaults = new CompilerHints();

代码示例来源:origin: org.apache.flink/flink-optimizer_2.10

if (optNode.getOperator().getCompilerHints() != null) {
  CompilerHints hints = optNode.getOperator().getCompilerHints();
  CompilerHints defaults = new CompilerHints();

代码示例来源:origin: org.apache.flink/flink-optimizer_2.11

if (getOperator() == null || getOperator().getCompilerHints() == null) {
  return ;
CompilerHints hints = getOperator().getCompilerHints();
if (hints.getOutputSize() >= 0) {
  this.estimatedOutputSize = hints.getOutputSize();

代码示例来源:origin: org.apache.flink/flink-optimizer

if (getOperator() == null || getOperator().getCompilerHints() == null) {
  return ;
CompilerHints hints = getOperator().getCompilerHints();
if (hints.getOutputSize() >= 0) {
  this.estimatedOutputSize = hints.getOutputSize();

代码示例来源:origin: org.apache.flink/flink-optimizer_2.10

if (getOperator() == null || getOperator().getCompilerHints() == null) {
  return ;
CompilerHints hints = getOperator().getCompilerHints();
if (hints.getOutputSize() >= 0) {
  this.estimatedOutputSize = hints.getOutputSize();

代码示例来源:origin: com.alibaba.blink/flink-optimizer

if (getOperator() == null || getOperator().getCompilerHints() == null) {
  return ;
CompilerHints hints = getOperator().getCompilerHints();
if (hints.getOutputSize() >= 0) {
  this.estimatedOutputSize = hints.getOutputSize();

代码示例来源:origin: org.apache.flink/flink-optimizer_2.11

if (optNode.getOperator().getCompilerHints() != null) {
  CompilerHints hints = optNode.getOperator().getCompilerHints();
  CompilerHints defaults = new CompilerHints();

代码示例来源:origin: com.alibaba.blink/flink-optimizer

if (optNode.getOperator().getCompilerHints() != null) {
  CompilerHints hints = optNode.getOperator().getCompilerHints();
  CompilerHints defaults = new CompilerHints();

代码示例来源:origin: org.apache.flink/flink-optimizer

if (optNode.getOperator().getCompilerHints() != null) {
  CompilerHints hints = optNode.getOperator().getCompilerHints();
  CompilerHints defaults = new CompilerHints();

相关文章