Package org.apache.tajo.engine.planner

Examples of org.apache.tajo.engine.planner.PlanString.addExplan()

99
100
101
102
103
104
105
106
107
108
109
        if (i < targets.length - 1) {
          sb.append(", ");
        }
      }
    }
    planStr.addExplan(sb.toString());
    if (getOutSchema() != null) {
      planStr.addExplan("out schema: " + getOutSchema().toString());
    }
    if (getInSchema() != null) {
      planStr.addExplan("in  schema: " + getInSchema().toString());
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
        }
      }
    }
    planStr.addExplan(sb.toString());
    if (getOutSchema() != null) {
      planStr.addExplan("out schema: " + getOutSchema().toString());
    }
    if (getInSchema() != null) {
      planStr.addExplan("in  schema: " + getInSchema().toString());
    }
View Full Code Here
104
105
106
107
108
109
110
111
112
113
114
    planStr.addExplan(sb.toString());
    if (getOutSchema() != null) {
      planStr.addExplan("out schema: " + getOutSchema().toString());
    }
    if (getInSchema() != null) {
      planStr.addExplan("in  schema: " + getInSchema().toString());
    }

    return planStr;
  }
}
View Full Code Here
122
123
124
125
126
127
128
129
130
131
132
    if (hasAlias()) {
      planStr.appendTitle(" as ").appendTitle(alias);
    }

    if (hasQual()) {
      planStr.addExplan("filter: ").appendExplain(this.qual.toString());
    }

    if (hasTargets()) {
      planStr.addExplan("target list: ");
      boolean first = true;
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
    if (hasQual()) {
      planStr.addExplan("filter: ").appendExplain(this.qual.toString());
    }

    if (hasTargets()) {
      planStr.addExplan("target list: ");
      boolean first = true;
      for (Target target : targets) {
        if (!first) {
          planStr.appendExplain(", ");
        }
View Full Code Here
141
142
143
144
145
146
147
148
149
150
151
    planStr.addDetail("out schema: ").appendDetail(getOutSchema().toString());
    planStr.addDetail("in schema: ").appendDetail(getInSchema().toString());

    if (inputPaths != null) {
      planStr.addExplan("num of filtered paths: ").appendExplain(""+ inputPaths.length);
      int i = 0;
      for (Path path : inputPaths) {
        planStr.addDetail((i++) + ": ").appendDetail(path.toString());
      }
    }
View Full Code Here
170
171
172
173
174
175
176
177
178
179
180
    PlanString planString = new PlanString(this);
    planString.appendTitle(" INTO ");
    if (hasTargetTable()) {
      planString.appendTitle(getTableName());
      if (hasTargetSchema()) {
        planString.addExplan(getTargetSchema().toString());
      }
    } else {
      planString.addExplan("LOCATION " + path);
    }
    return planString;
View Full Code Here
173
174
175
176
177
178
179
180
181
182
      planString.appendTitle(getTableName());
      if (hasTargetSchema()) {
        planString.addExplan(getTargetSchema().toString());
      }
    } else {
      planString.addExplan("LOCATION " + path);
    }
    return planString;
  }
}
View Full Code Here
186
187
188
189
190
191
192
193
194
195
196
      sb.append(targets[i]);
      if( i < targets.length - 1) {
        sb.append(", ");
      }
    }
    planStr.addExplan(sb.toString());

    planStr.addDetail("out schema:").appendDetail(getOutSchema().toString());
    planStr.addDetail("in schema:").appendDetail(getInSchema().toString());

    return planStr;
View Full Code Here
69
70
71
72
73
74
75
76
77
78
79
          .append(sortKeys[i].isAscending() ? "asc" : "desc");
      if( i < sortKeys.length - 1) {
        sb.append(",");
      }
    }
    planStr.addExplan(sb.toString());
    return planStr;
  }

  public String toString() {
    StringBuilder sb = new StringBuilder("Sort [key= ");
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. 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.