Skip to content

Commit 2337ca0

Browse files
committed
fix imports
1 parent 1431f67 commit 2337ca0

2 files changed

Lines changed: 15 additions & 15 deletions

File tree

exec/java-exec/src/main/java/org/apache/drill/exec/planner/sql/handlers/DefaultSqlHandler.java

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -105,11 +105,11 @@
105105
import org.apache.drill.exec.util.Utilities;
106106
import org.apache.drill.exec.work.foreman.ForemanSetupException;
107107
import org.apache.drill.exec.work.foreman.SqlUnsupportedException;
108-
import org.apache.drill.shaded.guava.com.google.common.base.Preconditions;
109-
import org.apache.drill.shaded.guava.com.google.common.base.Stopwatch;
110-
import org.apache.drill.shaded.guava.com.google.common.collect.ImmutableList;
111-
import org.apache.drill.shaded.guava.com.google.common.collect.Lists;
112-
import org.apache.drill.shaded.guava.com.google.common.collect.Sets;
108+
import com.google.common.base.Preconditions;
109+
import com.google.common.base.Stopwatch;
110+
import com.google.common.collect.ImmutableList;
111+
import com.google.common.collect.Lists;
112+
import com.google.common.collect.Sets;
113113
import org.slf4j.Logger;
114114
import org.slf4j.LoggerFactory;
115115

@@ -365,7 +365,7 @@ protected RelNode transform(PlannerType plannerType, PlannerPhase phase, RelNode
365365
* @param log Whether to log the planning phase.
366366
* @return The transformed relnode.
367367
*/
368-
368+
369369

370370
// A simple cache key class that uses the relevant parameters
371371
public static class CacheKey {
@@ -389,26 +389,26 @@ public boolean equals(Object o) {
389389
logger.info("Compare phase {} {} ,{} ", phase.equals(cacheKey.phase), phase.name(), cacheKey.phase.name());
390390
logger.info("Compare plannerType {} {} {}", plannerType.equals(cacheKey.plannerType), plannerType.name() , cacheKey.plannerType.name());
391391
logger.info("Compare input {}", input.deepEquals(cacheKey.input));
392-
return phase.name().equals(cacheKey.phase.name()) &&
392+
return phase.name().equals(cacheKey.phase.name()) &&
393393
plannerType.name().equals(cacheKey.plannerType.name()) &&
394-
input.deepEquals(cacheKey.input) &&
394+
input.deepEquals(cacheKey.input) &&
395395
targetTraits.equals(cacheKey.targetTraits);
396396
}
397-
397+
398398
@Override
399399
public int hashCode() {
400400
return Objects.hash(phase.name(), plannerType.name(), input.deepHashCode(), targetTraits);
401401
}
402402

403403
}
404404

405-
405+
406406
protected RelNode transform(PlannerType plannerType, PlannerPhase phase, RelNode input, RelTraitSet targetTraits,
407407
boolean log) {
408408
final Stopwatch watch = Stopwatch.createStarted();
409409
final RuleSet rules = config.getRules(phase, input);
410410
final RelTraitSet toTraits = targetTraits.simplify();
411-
411+
412412
// Create a cache key based on the input parameters
413413
CacheKey key = new CacheKey(plannerType, phase, input, targetTraits);
414414

@@ -417,7 +417,7 @@ protected RelNode transform(PlannerType plannerType, PlannerPhase phase, RelNode
417417
CustomCacheManager.logCacheStats();
418418
return cachedResult;
419419
}
420-
420+
421421
final RelNode output;
422422
switch (plannerType) {
423423
case HEP_BOTTOM_UP:

exec/java-exec/src/main/java/org/apache/drill/exec/work/foreman/Foreman.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -66,8 +66,8 @@
6666
import org.apache.drill.exec.work.foreman.rm.QueryQueue.QueryQueueException;
6767
import org.apache.drill.exec.work.foreman.rm.QueryQueue.QueueTimeoutException;
6868
import org.apache.drill.exec.work.foreman.rm.QueryResourceManager;
69-
import org.apache.drill.shaded.guava.com.google.common.base.Preconditions;
70-
import org.apache.drill.shaded.guava.com.google.common.collect.Lists;
69+
import com.google.common.base.Preconditions;
70+
import com.google.common.collect.Lists;
7171
import org.slf4j.Logger;
7272
import org.slf4j.LoggerFactory;
7373

@@ -606,7 +606,7 @@ private void runSQL(final String sql) throws ExecutionSetupException {
606606
} else {
607607
logger.info("Using cached plan");
608608
}
609-
609+
610610
if(sql.trim().startsWith("SELECT")) {
611611
CustomCacheManager.putQueryPlan(sql, plan);
612612
CustomCacheManager.logCacheStats();

0 commit comments

Comments
 (0)