diff options
Diffstat (limited to 'contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcPrel.java')
| -rw-r--r-- | contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcPrel.java | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcPrel.java b/contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcPrel.java index 2433fbd3d..22894c932 100644 --- a/contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcPrel.java +++ b/contrib/storage-jdbc/src/main/java/org/apache/drill/exec/store/jdbc/JdbcPrel.java @@ -80,7 +80,8 @@ public class JdbcPrel extends AbstractRelNode implements Prel { @Override public PhysicalOperator getPhysicalOperator(PhysicalPlanCreator creator) throws IOException { - return new JdbcGroupScan(sql, convention.getPlugin(), rows); + JdbcGroupScan output = new JdbcGroupScan(sql, convention.getPlugin(), rows); + return creator.addMetadata(this, output); } @Override |