Package org.apache.drill.common.logical.data

Examples of org.apache.drill.common.logical.data.LogicalOperator

40
41
42
43
44
45
46
47
48
49
    return new DrillFilterRel(getCluster(), traitSet, sole(inputs), getCondition());
  }

  @Override
  public LogicalOperator implement(DrillImplementor implementor) {
    final LogicalOperator input = implementor.visitChild(this, 0, getChild());
    Filter f = new Filter(getFilterExpression(implementor.getContext()));
    f.setInput(input);
    return f;
  }
View Full Code Here
38
39
40
41
42
43
44
45
46
47
48
    return new DrillWriterRel(getCluster(), traitSet, sole(inputs), getCreateTableEntry());
  }

  @Override
  public LogicalOperator implement(DrillImplementor implementor) {
    LogicalOperator childOp = implementor.visitChild(this, 0, getChild());
    return Writer
        .builder()
        .setInput(childOp)
        .setCreateTableEntry(getCreateTableEntry())
        .build();
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
  }


  @Override
  public LogicalOperator implement(DrillImplementor implementor) {
    LogicalOperator inputOp = implementor.visitChild(this, 0, getChild());
    Project.Builder builder = Project.builder();
    builder.setInput(inputOp);
    for (NamedExpression e: this.getProjectExpressions(implementor.getContext())) {
      builder.addExpr(e);
    }
View Full Code Here
57
58
59
60
61
62
63
64
      planBuilder.addStorageEngine(table.getStorageEngineName(), table.getStorageEngineConfig());
    }
  }

  public void go(DrillRel root) {
    LogicalOperator rootLOP = root.implement(this);
    rootLOP.accept(new AddOpsVisitor(), null);
  }
View Full Code Here
45
46
47
48
49
50
51
52
53
54
55
    return new DrillLimitRel(getCluster(), traitSet, sole(inputs), offset, fetch);
  }

  @Override
  public LogicalOperator implement(DrillImplementor implementor) {
    LogicalOperator inputOp = implementor.visitChild(this, 0, getChild());
   
    // First offset to include into results (inclusive). Null implies it is starting from offset 0
    int first = offset != null ? Math.max(0, RexLiteral.intValue(offset)) : 0;

    // Last offset to stop including into results (exclusive), translating fetch row counts into an offset.
View Full Code Here
40
41
42
43
44
45
46
47
    return new DrillScreenRel(getCluster(), traitSet, sole(inputs));
  }
 
  @Override
  public LogicalOperator implement(DrillImplementor implementor) {
    LogicalOperator childOp = implementor.visitChild(this, 0, getChild());
    return Store.builder().setInput(childOp).storageEngine("--SCREEN--").build();
  }
View Full Code Here
95
96
97
98
99
100
101
102
103
104
105
106
    assert isUnique(fields);
    final int leftCount = left.getRowType().getFieldCount();
    final List<String> leftFields = fields.subList(0, leftCount);
    final List<String> rightFields = fields.subList(leftCount, fields.size());

    final LogicalOperator leftOp = implementInput(implementor, 0, 0, left);
    final LogicalOperator rightOp = implementInput(implementor, 1, leftCount, right);

    Join.Builder builder = Join.builder();
    builder.type(joinType);
    builder.left(leftOp);
    builder.right(rightOp);
View Full Code Here
119
120
121
122
123
124
125
126
127
128
129
   * @param offset
   * @param input
   * @return
   */
  private LogicalOperator implementInput(DrillImplementor implementor, int i, int offset, RelNode input) {
    final LogicalOperator inputOp = implementor.visitChild(this, i, input);
    assert uniqueFieldNames(input.getRowType());
    final List<String> fields = getRowType().getFieldNames();
    final List<String> inputFields = input.getRowType().getFieldNames();
    final List<String> outputFields = fields.subList(offset, offset + inputFields.size());
    if (!outputFields.equals(inputFields)) {
View Full Code Here
40
41
42
43
44
45
46
47
48
49
    return new DrillFilterRel(getCluster(), traitSet, sole(inputs), getCondition());
  }

  @Override
  public LogicalOperator implement(DrillImplementor implementor) {
    final LogicalOperator input = implementor.visitChild(this, 0, getChild());
    Filter f = new Filter(getFilterExpression(implementor.getContext()));
    f.setInput(input);
    return f;
  }
View Full Code Here
54
55
56
57
58
59
60
61
62
63
64
  }


  @Override
  public LogicalOperator implement(DrillImplementor implementor) {
    LogicalOperator inputOp = implementor.visitChild(this, 0, getChild());
    Project.Builder builder = Project.builder();
    builder.setInput(inputOp);
    for (NamedExpression e: this.getProjectExpressions(implementor.getContext())) {
      builder.addExpr(e);
    }
View Full Code Here
TOP

Related Classes of org.apache.drill.common.logical.data.LogicalOperator

  • org.apache.drill.exec.planner.logical.DrillFilterRel
  • org.apache.drill.exec.planner.logical.DrillImplementor
  • org.apache.drill.exec.planner.logical.DrillJoinRel
  • org.apache.drill.exec.planner.logical.DrillLimitRel
  • org.apache.drill.exec.planner.logical.DrillProjectRel
  • org.apache.drill.exec.planner.logical.DrillScreenRel
  • org.apache.drill.exec.planner.logical.DrillWindowRel
  • org.apache.drill.exec.planner.logical.DrillWriterRel
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.