本文整理了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
[英]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();
内容来源于网络,如有侵权,请联系作者删除!