diff options
Diffstat (limited to 'exec/java-exec/src/main/java/org/apache/drill/exec/ops/FragmentContext.java')
-rw-r--r-- | exec/java-exec/src/main/java/org/apache/drill/exec/ops/FragmentContext.java | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/exec/java-exec/src/main/java/org/apache/drill/exec/ops/FragmentContext.java b/exec/java-exec/src/main/java/org/apache/drill/exec/ops/FragmentContext.java index fd965a704..80a78191d 100644 --- a/exec/java-exec/src/main/java/org/apache/drill/exec/ops/FragmentContext.java +++ b/exec/java-exec/src/main/java/org/apache/drill/exec/ops/FragmentContext.java @@ -22,6 +22,8 @@ import java.io.IOException; import java.util.List; import java.util.Map; +import net.hydromatic.optiq.SchemaPlus; + import org.apache.drill.common.config.DrillConfig; import org.apache.drill.exec.compile.ClassTransformer; import org.apache.drill.exec.compile.QueryClassLoader; @@ -75,6 +77,7 @@ public class FragmentContext implements Closeable { this.connection = connection; this.fragment = fragment; this.funcRegistry = funcRegistry; + logger.debug("Getting initial memory allocation of {}", fragment.getMemInitial()); this.allocator = context.getAllocator().getChildAllocator(fragment.getHandle(), fragment.getMemInitial(), fragment.getMemMax()); } @@ -91,6 +94,10 @@ public class FragmentContext implements Closeable { public DrillbitContext getDrillbitContext() { return context; } + + public SchemaPlus getRootSchema(){ + return null; + } /** * Get this node's identity. |