Update retention SQL to use org.apache.gobblin classes
Project: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/commit/1737fde8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/tree/1737fde8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-gobblin/diff/1737fde8 Branch: refs/heads/master Commit: 1737fde840357899c709bee9a5cbf998e329f414 Parents: f609274 Author: Abhishek Tiwari <[email protected]> Authored: Sun Jul 30 22:14:16 2017 -0700 Committer: Abhishek Tiwari <[email protected]> Committed: Sun Jul 30 22:14:16 2017 -0700 ---------------------------------------------------------------------- .../data/management/retention/sql/SqlBasedRetentionPoc.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-gobblin/blob/1737fde8/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlBasedRetentionPoc.java ---------------------------------------------------------------------- diff --git a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlBasedRetentionPoc.java b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlBasedRetentionPoc.java index e3d56f3..ab62d5b 100644 --- a/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlBasedRetentionPoc.java +++ b/gobblin-data-management/src/test/java/org/apache/gobblin/data/management/retention/sql/SqlBasedRetentionPoc.java @@ -67,7 +67,7 @@ public class SqlBasedRetentionPoc { execute("CREATE TABLE Daily_Partitions (dataset_path VARCHAR(255), path VARCHAR(255), ts TIMESTAMP)"); // Register UDFs - execute("CREATE FUNCTION TIMESTAMP_DIFF(timestamp1 TIMESTAMP, timestamp2 TIMESTAMP, unitString VARCHAR(50)) RETURNS BIGINT PARAMETER STYLE JAVA NO SQL LANGUAGE JAVA EXTERNAL NAME 'gobblin.data.management.retention.sql.SqlUdfs.timestamp_diff'"); + execute("CREATE FUNCTION TIMESTAMP_DIFF(timestamp1 TIMESTAMP, timestamp2 TIMESTAMP, unitString VARCHAR(50)) RETURNS BIGINT PARAMETER STYLE JAVA NO SQL LANGUAGE JAVA EXTERNAL NAME 'org.apache.gobblin.data.management.retention.sql.SqlUdfs.timestamp_diff'"); } @AfterClass
