From dc304a6450241a81a198e737265f68af1b38e901 Mon Sep 17 00:00:00 2001 From: Jiadong Bai Date: Sat, 2 Nov 2024 10:34:00 -0700 Subject: [PATCH] add --- .../texera/dao/jooq/generated/Indexes.java | 18 + .../ics/texera/dao/jooq/generated/Keys.java | 30 + .../ics/texera/dao/jooq/generated/Tables.java | 30 + .../texera/dao/jooq/generated/TexeraDb.java | 39 +- .../tables/WorkflowRuntimeStatistics.java | 208 +++++++ .../tables/WorkflowUserActivity.java | 143 +++++ .../generated/tables/WorkflowUserClones.java | 161 ++++++ .../generated/tables/WorkflowUserLikes.java | 161 ++++++ .../generated/tables/WorkflowViewCount.java | 157 ++++++ .../daos/WorkflowRuntimeStatisticsDao.java | 198 +++++++ .../tables/daos/WorkflowUserClonesDao.java | 70 +++ .../tables/daos/WorkflowUserLikesDao.java | 70 +++ .../tables/daos/WorkflowViewCountDao.java | 76 +++ .../IWorkflowRuntimeStatistics.java | 143 +++++ .../interfaces/IWorkflowUserActivity.java | 82 +++ .../interfaces/IWorkflowUserClones.java | 51 ++ .../tables/interfaces/IWorkflowUserLikes.java | 51 ++ .../tables/interfaces/IWorkflowViewCount.java | 51 ++ .../pojos/WorkflowRuntimeStatistics.java | 231 ++++++++ .../tables/pojos/WorkflowUserActivity.java | 134 +++++ .../tables/pojos/WorkflowUserClones.java | 84 +++ .../tables/pojos/WorkflowUserLikes.java | 84 +++ .../tables/pojos/WorkflowViewCount.java | 84 +++ .../WorkflowRuntimeStatisticsRecord.java | 529 ++++++++++++++++++ .../records/WorkflowUserActivityRecord.java | 278 +++++++++ .../records/WorkflowUserClonesRecord.java | 165 ++++++ .../records/WorkflowUserLikesRecord.java | 165 ++++++ .../records/WorkflowViewCountRecord.java | 166 ++++++ 28 files changed, 3657 insertions(+), 2 deletions(-) create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowRuntimeStatistics.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowUserActivity.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowUserClones.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowUserLikes.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowViewCount.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowRuntimeStatisticsDao.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowUserClonesDao.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowUserLikesDao.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowViewCountDao.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowRuntimeStatistics.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowUserActivity.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowUserClones.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowUserLikes.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowViewCount.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowRuntimeStatistics.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowUserActivity.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowUserClones.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowUserLikes.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowViewCount.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowRuntimeStatisticsRecord.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowUserActivityRecord.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowUserClonesRecord.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowUserLikesRecord.java create mode 100644 core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowViewCountRecord.java diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/Indexes.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/Indexes.java index e5cfbaac85c..fc916ac9d54 100644 --- a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/Indexes.java +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/Indexes.java @@ -16,8 +16,12 @@ import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowExecutions; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowOfProject; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowOfUser; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowRuntimeStatistics; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserAccess; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserClones; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserLikes; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowVersion; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowViewCount; import org.jooq.Index; import org.jooq.OrderField; @@ -62,10 +66,17 @@ public class Indexes { public static final Index WORKFLOW_OF_PROJECT_PRIMARY = Indexes0.WORKFLOW_OF_PROJECT_PRIMARY; public static final Index WORKFLOW_OF_USER_PRIMARY = Indexes0.WORKFLOW_OF_USER_PRIMARY; public static final Index WORKFLOW_OF_USER_WID = Indexes0.WORKFLOW_OF_USER_WID; + public static final Index WORKFLOW_RUNTIME_STATISTICS_EXECUTION_ID = Indexes0.WORKFLOW_RUNTIME_STATISTICS_EXECUTION_ID; + public static final Index WORKFLOW_RUNTIME_STATISTICS_PRIMARY = Indexes0.WORKFLOW_RUNTIME_STATISTICS_PRIMARY; public static final Index WORKFLOW_USER_ACCESS_PRIMARY = Indexes0.WORKFLOW_USER_ACCESS_PRIMARY; public static final Index WORKFLOW_USER_ACCESS_WID = Indexes0.WORKFLOW_USER_ACCESS_WID; + public static final Index WORKFLOW_USER_CLONES_PRIMARY = Indexes0.WORKFLOW_USER_CLONES_PRIMARY; + public static final Index WORKFLOW_USER_CLONES_WID = Indexes0.WORKFLOW_USER_CLONES_WID; + public static final Index WORKFLOW_USER_LIKES_PRIMARY = Indexes0.WORKFLOW_USER_LIKES_PRIMARY; + public static final Index WORKFLOW_USER_LIKES_WID = Indexes0.WORKFLOW_USER_LIKES_WID; public static final Index WORKFLOW_VERSION_PRIMARY = Indexes0.WORKFLOW_VERSION_PRIMARY; public static final Index WORKFLOW_VERSION_WID = Indexes0.WORKFLOW_VERSION_WID; + public static final Index WORKFLOW_VIEW_COUNT_PRIMARY = Indexes0.WORKFLOW_VIEW_COUNT_PRIMARY; // ------------------------------------------------------------------------- // [#1459] distribute members to avoid static initialisers > 64kb @@ -100,9 +111,16 @@ private static class Indexes0 { public static Index WORKFLOW_OF_PROJECT_PRIMARY = Internal.createIndex("PRIMARY", WorkflowOfProject.WORKFLOW_OF_PROJECT, new OrderField[] { WorkflowOfProject.WORKFLOW_OF_PROJECT.WID, WorkflowOfProject.WORKFLOW_OF_PROJECT.PID }, true); public static Index WORKFLOW_OF_USER_PRIMARY = Internal.createIndex("PRIMARY", WorkflowOfUser.WORKFLOW_OF_USER, new OrderField[] { WorkflowOfUser.WORKFLOW_OF_USER.UID, WorkflowOfUser.WORKFLOW_OF_USER.WID }, true); public static Index WORKFLOW_OF_USER_WID = Internal.createIndex("wid", WorkflowOfUser.WORKFLOW_OF_USER, new OrderField[] { WorkflowOfUser.WORKFLOW_OF_USER.WID }, false); + public static Index WORKFLOW_RUNTIME_STATISTICS_EXECUTION_ID = Internal.createIndex("execution_id", WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS, new OrderField[] { WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.EXECUTION_ID }, false); + public static Index WORKFLOW_RUNTIME_STATISTICS_PRIMARY = Internal.createIndex("PRIMARY", WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS, new OrderField[] { WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.WORKFLOW_ID, WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.EXECUTION_ID, WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.OPERATOR_ID, WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.TIME }, true); public static Index WORKFLOW_USER_ACCESS_PRIMARY = Internal.createIndex("PRIMARY", WorkflowUserAccess.WORKFLOW_USER_ACCESS, new OrderField[] { WorkflowUserAccess.WORKFLOW_USER_ACCESS.UID, WorkflowUserAccess.WORKFLOW_USER_ACCESS.WID }, true); public static Index WORKFLOW_USER_ACCESS_WID = Internal.createIndex("wid", WorkflowUserAccess.WORKFLOW_USER_ACCESS, new OrderField[] { WorkflowUserAccess.WORKFLOW_USER_ACCESS.WID }, false); + public static Index WORKFLOW_USER_CLONES_PRIMARY = Internal.createIndex("PRIMARY", WorkflowUserClones.WORKFLOW_USER_CLONES, new OrderField[] { WorkflowUserClones.WORKFLOW_USER_CLONES.UID, WorkflowUserClones.WORKFLOW_USER_CLONES.WID }, true); + public static Index WORKFLOW_USER_CLONES_WID = Internal.createIndex("wid", WorkflowUserClones.WORKFLOW_USER_CLONES, new OrderField[] { WorkflowUserClones.WORKFLOW_USER_CLONES.WID }, false); + public static Index WORKFLOW_USER_LIKES_PRIMARY = Internal.createIndex("PRIMARY", WorkflowUserLikes.WORKFLOW_USER_LIKES, new OrderField[] { WorkflowUserLikes.WORKFLOW_USER_LIKES.UID, WorkflowUserLikes.WORKFLOW_USER_LIKES.WID }, true); + public static Index WORKFLOW_USER_LIKES_WID = Internal.createIndex("wid", WorkflowUserLikes.WORKFLOW_USER_LIKES, new OrderField[] { WorkflowUserLikes.WORKFLOW_USER_LIKES.WID }, false); public static Index WORKFLOW_VERSION_PRIMARY = Internal.createIndex("PRIMARY", WorkflowVersion.WORKFLOW_VERSION, new OrderField[] { WorkflowVersion.WORKFLOW_VERSION.VID }, true); public static Index WORKFLOW_VERSION_WID = Internal.createIndex("wid", WorkflowVersion.WORKFLOW_VERSION, new OrderField[] { WorkflowVersion.WORKFLOW_VERSION.WID }, false); + public static Index WORKFLOW_VIEW_COUNT_PRIMARY = Internal.createIndex("PRIMARY", WorkflowViewCount.WORKFLOW_VIEW_COUNT, new OrderField[] { WorkflowViewCount.WORKFLOW_VIEW_COUNT.WID }, true); } } diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/Keys.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/Keys.java index 0d068ee793c..12d73c1a08c 100644 --- a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/Keys.java +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/Keys.java @@ -16,8 +16,12 @@ import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowExecutions; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowOfProject; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowOfUser; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowRuntimeStatistics; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserAccess; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserClones; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserLikes; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowVersion; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowViewCount; import edu.uci.ics.texera.dao.jooq.generated.tables.records.DatasetRecord; import edu.uci.ics.texera.dao.jooq.generated.tables.records.DatasetUserAccessRecord; import edu.uci.ics.texera.dao.jooq.generated.tables.records.DatasetVersionRecord; @@ -30,8 +34,12 @@ import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowOfProjectRecord; import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowOfUserRecord; import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowRecord; +import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowRuntimeStatisticsRecord; import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowUserAccessRecord; +import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowUserClonesRecord; +import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowUserLikesRecord; import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowVersionRecord; +import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowViewCountRecord; import org.jooq.ForeignKey; import org.jooq.Identity; @@ -78,8 +86,12 @@ public class Keys { public static final UniqueKey KEY_WORKFLOW_EXECUTIONS_PRIMARY = UniqueKeys0.KEY_WORKFLOW_EXECUTIONS_PRIMARY; public static final UniqueKey KEY_WORKFLOW_OF_PROJECT_PRIMARY = UniqueKeys0.KEY_WORKFLOW_OF_PROJECT_PRIMARY; public static final UniqueKey KEY_WORKFLOW_OF_USER_PRIMARY = UniqueKeys0.KEY_WORKFLOW_OF_USER_PRIMARY; + public static final UniqueKey KEY_WORKFLOW_RUNTIME_STATISTICS_PRIMARY = UniqueKeys0.KEY_WORKFLOW_RUNTIME_STATISTICS_PRIMARY; public static final UniqueKey KEY_WORKFLOW_USER_ACCESS_PRIMARY = UniqueKeys0.KEY_WORKFLOW_USER_ACCESS_PRIMARY; + public static final UniqueKey KEY_WORKFLOW_USER_CLONES_PRIMARY = UniqueKeys0.KEY_WORKFLOW_USER_CLONES_PRIMARY; + public static final UniqueKey KEY_WORKFLOW_USER_LIKES_PRIMARY = UniqueKeys0.KEY_WORKFLOW_USER_LIKES_PRIMARY; public static final UniqueKey KEY_WORKFLOW_VERSION_PRIMARY = UniqueKeys0.KEY_WORKFLOW_VERSION_PRIMARY; + public static final UniqueKey KEY_WORKFLOW_VIEW_COUNT_PRIMARY = UniqueKeys0.KEY_WORKFLOW_VIEW_COUNT_PRIMARY; // ------------------------------------------------------------------------- // FOREIGN KEY definitions @@ -100,9 +112,16 @@ public class Keys { public static final ForeignKey WORKFLOW_OF_PROJECT_IBFK_2 = ForeignKeys0.WORKFLOW_OF_PROJECT_IBFK_2; public static final ForeignKey WORKFLOW_OF_USER_IBFK_1 = ForeignKeys0.WORKFLOW_OF_USER_IBFK_1; public static final ForeignKey WORKFLOW_OF_USER_IBFK_2 = ForeignKeys0.WORKFLOW_OF_USER_IBFK_2; + public static final ForeignKey WORKFLOW_RUNTIME_STATISTICS_IBFK_1 = ForeignKeys0.WORKFLOW_RUNTIME_STATISTICS_IBFK_1; + public static final ForeignKey WORKFLOW_RUNTIME_STATISTICS_IBFK_2 = ForeignKeys0.WORKFLOW_RUNTIME_STATISTICS_IBFK_2; public static final ForeignKey WORKFLOW_USER_ACCESS_IBFK_1 = ForeignKeys0.WORKFLOW_USER_ACCESS_IBFK_1; public static final ForeignKey WORKFLOW_USER_ACCESS_IBFK_2 = ForeignKeys0.WORKFLOW_USER_ACCESS_IBFK_2; + public static final ForeignKey WORKFLOW_USER_CLONES_IBFK_1 = ForeignKeys0.WORKFLOW_USER_CLONES_IBFK_1; + public static final ForeignKey WORKFLOW_USER_CLONES_IBFK_2 = ForeignKeys0.WORKFLOW_USER_CLONES_IBFK_2; + public static final ForeignKey WORKFLOW_USER_LIKES_IBFK_1 = ForeignKeys0.WORKFLOW_USER_LIKES_IBFK_1; + public static final ForeignKey WORKFLOW_USER_LIKES_IBFK_2 = ForeignKeys0.WORKFLOW_USER_LIKES_IBFK_2; public static final ForeignKey WORKFLOW_VERSION_IBFK_1 = ForeignKeys0.WORKFLOW_VERSION_IBFK_1; + public static final ForeignKey WORKFLOW_VIEW_COUNT_IBFK_1 = ForeignKeys0.WORKFLOW_VIEW_COUNT_IBFK_1; // ------------------------------------------------------------------------- // [#1459] distribute members to avoid static initialisers > 64kb @@ -134,8 +153,12 @@ private static class UniqueKeys0 { public static final UniqueKey KEY_WORKFLOW_EXECUTIONS_PRIMARY = Internal.createUniqueKey(WorkflowExecutions.WORKFLOW_EXECUTIONS, "KEY_workflow_executions_PRIMARY", WorkflowExecutions.WORKFLOW_EXECUTIONS.EID); public static final UniqueKey KEY_WORKFLOW_OF_PROJECT_PRIMARY = Internal.createUniqueKey(WorkflowOfProject.WORKFLOW_OF_PROJECT, "KEY_workflow_of_project_PRIMARY", WorkflowOfProject.WORKFLOW_OF_PROJECT.WID, WorkflowOfProject.WORKFLOW_OF_PROJECT.PID); public static final UniqueKey KEY_WORKFLOW_OF_USER_PRIMARY = Internal.createUniqueKey(WorkflowOfUser.WORKFLOW_OF_USER, "KEY_workflow_of_user_PRIMARY", WorkflowOfUser.WORKFLOW_OF_USER.UID, WorkflowOfUser.WORKFLOW_OF_USER.WID); + public static final UniqueKey KEY_WORKFLOW_RUNTIME_STATISTICS_PRIMARY = Internal.createUniqueKey(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS, "KEY_workflow_runtime_statistics_PRIMARY", WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.WORKFLOW_ID, WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.EXECUTION_ID, WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.OPERATOR_ID, WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.TIME); public static final UniqueKey KEY_WORKFLOW_USER_ACCESS_PRIMARY = Internal.createUniqueKey(WorkflowUserAccess.WORKFLOW_USER_ACCESS, "KEY_workflow_user_access_PRIMARY", WorkflowUserAccess.WORKFLOW_USER_ACCESS.UID, WorkflowUserAccess.WORKFLOW_USER_ACCESS.WID); + public static final UniqueKey KEY_WORKFLOW_USER_CLONES_PRIMARY = Internal.createUniqueKey(WorkflowUserClones.WORKFLOW_USER_CLONES, "KEY_workflow_user_clones_PRIMARY", WorkflowUserClones.WORKFLOW_USER_CLONES.UID, WorkflowUserClones.WORKFLOW_USER_CLONES.WID); + public static final UniqueKey KEY_WORKFLOW_USER_LIKES_PRIMARY = Internal.createUniqueKey(WorkflowUserLikes.WORKFLOW_USER_LIKES, "KEY_workflow_user_likes_PRIMARY", WorkflowUserLikes.WORKFLOW_USER_LIKES.UID, WorkflowUserLikes.WORKFLOW_USER_LIKES.WID); public static final UniqueKey KEY_WORKFLOW_VERSION_PRIMARY = Internal.createUniqueKey(WorkflowVersion.WORKFLOW_VERSION, "KEY_workflow_version_PRIMARY", WorkflowVersion.WORKFLOW_VERSION.VID); + public static final UniqueKey KEY_WORKFLOW_VIEW_COUNT_PRIMARY = Internal.createUniqueKey(WorkflowViewCount.WORKFLOW_VIEW_COUNT, "KEY_workflow_view_count_PRIMARY", WorkflowViewCount.WORKFLOW_VIEW_COUNT.WID); } private static class ForeignKeys0 { @@ -154,8 +177,15 @@ private static class ForeignKeys0 { public static final ForeignKey WORKFLOW_OF_PROJECT_IBFK_2 = Internal.createForeignKey(edu.uci.ics.texera.dao.jooq.generated.Keys.KEY_PROJECT_PRIMARY, WorkflowOfProject.WORKFLOW_OF_PROJECT, "workflow_of_project_ibfk_2", WorkflowOfProject.WORKFLOW_OF_PROJECT.PID); public static final ForeignKey WORKFLOW_OF_USER_IBFK_1 = Internal.createForeignKey(edu.uci.ics.texera.dao.jooq.generated.Keys.KEY_USER_PRIMARY, WorkflowOfUser.WORKFLOW_OF_USER, "workflow_of_user_ibfk_1", WorkflowOfUser.WORKFLOW_OF_USER.UID); public static final ForeignKey WORKFLOW_OF_USER_IBFK_2 = Internal.createForeignKey(edu.uci.ics.texera.dao.jooq.generated.Keys.KEY_WORKFLOW_PRIMARY, WorkflowOfUser.WORKFLOW_OF_USER, "workflow_of_user_ibfk_2", WorkflowOfUser.WORKFLOW_OF_USER.WID); + public static final ForeignKey WORKFLOW_RUNTIME_STATISTICS_IBFK_1 = Internal.createForeignKey(edu.uci.ics.texera.dao.jooq.generated.Keys.KEY_WORKFLOW_PRIMARY, WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS, "workflow_runtime_statistics_ibfk_1", WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.WORKFLOW_ID); + public static final ForeignKey WORKFLOW_RUNTIME_STATISTICS_IBFK_2 = Internal.createForeignKey(edu.uci.ics.texera.dao.jooq.generated.Keys.KEY_WORKFLOW_EXECUTIONS_PRIMARY, WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS, "workflow_runtime_statistics_ibfk_2", WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.EXECUTION_ID); public static final ForeignKey WORKFLOW_USER_ACCESS_IBFK_1 = Internal.createForeignKey(edu.uci.ics.texera.dao.jooq.generated.Keys.KEY_USER_PRIMARY, WorkflowUserAccess.WORKFLOW_USER_ACCESS, "workflow_user_access_ibfk_1", WorkflowUserAccess.WORKFLOW_USER_ACCESS.UID); public static final ForeignKey WORKFLOW_USER_ACCESS_IBFK_2 = Internal.createForeignKey(edu.uci.ics.texera.dao.jooq.generated.Keys.KEY_WORKFLOW_PRIMARY, WorkflowUserAccess.WORKFLOW_USER_ACCESS, "workflow_user_access_ibfk_2", WorkflowUserAccess.WORKFLOW_USER_ACCESS.WID); + public static final ForeignKey WORKFLOW_USER_CLONES_IBFK_1 = Internal.createForeignKey(edu.uci.ics.texera.dao.jooq.generated.Keys.KEY_USER_PRIMARY, WorkflowUserClones.WORKFLOW_USER_CLONES, "workflow_user_clones_ibfk_1", WorkflowUserClones.WORKFLOW_USER_CLONES.UID); + public static final ForeignKey WORKFLOW_USER_CLONES_IBFK_2 = Internal.createForeignKey(edu.uci.ics.texera.dao.jooq.generated.Keys.KEY_WORKFLOW_PRIMARY, WorkflowUserClones.WORKFLOW_USER_CLONES, "workflow_user_clones_ibfk_2", WorkflowUserClones.WORKFLOW_USER_CLONES.WID); + public static final ForeignKey WORKFLOW_USER_LIKES_IBFK_1 = Internal.createForeignKey(edu.uci.ics.texera.dao.jooq.generated.Keys.KEY_USER_PRIMARY, WorkflowUserLikes.WORKFLOW_USER_LIKES, "workflow_user_likes_ibfk_1", WorkflowUserLikes.WORKFLOW_USER_LIKES.UID); + public static final ForeignKey WORKFLOW_USER_LIKES_IBFK_2 = Internal.createForeignKey(edu.uci.ics.texera.dao.jooq.generated.Keys.KEY_WORKFLOW_PRIMARY, WorkflowUserLikes.WORKFLOW_USER_LIKES, "workflow_user_likes_ibfk_2", WorkflowUserLikes.WORKFLOW_USER_LIKES.WID); public static final ForeignKey WORKFLOW_VERSION_IBFK_1 = Internal.createForeignKey(edu.uci.ics.texera.dao.jooq.generated.Keys.KEY_WORKFLOW_PRIMARY, WorkflowVersion.WORKFLOW_VERSION, "workflow_version_ibfk_1", WorkflowVersion.WORKFLOW_VERSION.WID); + public static final ForeignKey WORKFLOW_VIEW_COUNT_IBFK_1 = Internal.createForeignKey(edu.uci.ics.texera.dao.jooq.generated.Keys.KEY_WORKFLOW_PRIMARY, WorkflowViewCount.WORKFLOW_VIEW_COUNT, "workflow_view_count_ibfk_1", WorkflowViewCount.WORKFLOW_VIEW_COUNT.WID); } } diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/Tables.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/Tables.java index fc23e569437..33f52316ad9 100644 --- a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/Tables.java +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/Tables.java @@ -16,8 +16,13 @@ import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowExecutions; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowOfProject; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowOfUser; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowRuntimeStatistics; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserAccess; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserActivity; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserClones; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserLikes; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowVersion; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowViewCount; /** @@ -86,13 +91,38 @@ public class Tables { */ public static final WorkflowOfUser WORKFLOW_OF_USER = WorkflowOfUser.WORKFLOW_OF_USER; + /** + * The table texera_db.workflow_runtime_statistics. + */ + public static final WorkflowRuntimeStatistics WORKFLOW_RUNTIME_STATISTICS = WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS; + /** * The table texera_db.workflow_user_access. */ public static final WorkflowUserAccess WORKFLOW_USER_ACCESS = WorkflowUserAccess.WORKFLOW_USER_ACCESS; + /** + * The table texera_db.workflow_user_activity. + */ + public static final WorkflowUserActivity WORKFLOW_USER_ACTIVITY = WorkflowUserActivity.WORKFLOW_USER_ACTIVITY; + + /** + * The table texera_db.workflow_user_clones. + */ + public static final WorkflowUserClones WORKFLOW_USER_CLONES = WorkflowUserClones.WORKFLOW_USER_CLONES; + + /** + * The table texera_db.workflow_user_likes. + */ + public static final WorkflowUserLikes WORKFLOW_USER_LIKES = WorkflowUserLikes.WORKFLOW_USER_LIKES; + /** * The table texera_db.workflow_version. */ public static final WorkflowVersion WORKFLOW_VERSION = WorkflowVersion.WORKFLOW_VERSION; + + /** + * The table texera_db.workflow_view_count. + */ + public static final WorkflowViewCount WORKFLOW_VIEW_COUNT = WorkflowViewCount.WORKFLOW_VIEW_COUNT; } diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/TexeraDb.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/TexeraDb.java index 2a24775599e..84e9f00a718 100644 --- a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/TexeraDb.java +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/TexeraDb.java @@ -16,8 +16,13 @@ import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowExecutions; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowOfProject; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowOfUser; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowRuntimeStatistics; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserAccess; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserActivity; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserClones; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserLikes; import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowVersion; +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowViewCount; import java.util.ArrayList; import java.util.Arrays; @@ -34,7 +39,7 @@ @SuppressWarnings({ "all", "unchecked", "rawtypes" }) public class TexeraDb extends SchemaImpl { - private static final long serialVersionUID = -979994400; + private static final long serialVersionUID = 1224383013; /** * The reference instance of texera_db @@ -101,16 +106,41 @@ public class TexeraDb extends SchemaImpl { */ public final WorkflowOfUser WORKFLOW_OF_USER = edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowOfUser.WORKFLOW_OF_USER; + /** + * The table texera_db.workflow_runtime_statistics. + */ + public final WorkflowRuntimeStatistics WORKFLOW_RUNTIME_STATISTICS = edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS; + /** * The table texera_db.workflow_user_access. */ public final WorkflowUserAccess WORKFLOW_USER_ACCESS = edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserAccess.WORKFLOW_USER_ACCESS; + /** + * The table texera_db.workflow_user_activity. + */ + public final WorkflowUserActivity WORKFLOW_USER_ACTIVITY = edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserActivity.WORKFLOW_USER_ACTIVITY; + + /** + * The table texera_db.workflow_user_clones. + */ + public final WorkflowUserClones WORKFLOW_USER_CLONES = edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserClones.WORKFLOW_USER_CLONES; + + /** + * The table texera_db.workflow_user_likes. + */ + public final WorkflowUserLikes WORKFLOW_USER_LIKES = edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserLikes.WORKFLOW_USER_LIKES; + /** * The table texera_db.workflow_version. */ public final WorkflowVersion WORKFLOW_VERSION = edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowVersion.WORKFLOW_VERSION; + /** + * The table texera_db.workflow_view_count. + */ + public final WorkflowViewCount WORKFLOW_VIEW_COUNT = edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowViewCount.WORKFLOW_VIEW_COUNT; + /** * No further instances allowed */ @@ -145,7 +175,12 @@ private final List> getTables0() { WorkflowExecutions.WORKFLOW_EXECUTIONS, WorkflowOfProject.WORKFLOW_OF_PROJECT, WorkflowOfUser.WORKFLOW_OF_USER, + WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS, WorkflowUserAccess.WORKFLOW_USER_ACCESS, - WorkflowVersion.WORKFLOW_VERSION); + WorkflowUserActivity.WORKFLOW_USER_ACTIVITY, + WorkflowUserClones.WORKFLOW_USER_CLONES, + WorkflowUserLikes.WORKFLOW_USER_LIKES, + WorkflowVersion.WORKFLOW_VERSION, + WorkflowViewCount.WORKFLOW_VIEW_COUNT); } } diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowRuntimeStatistics.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowRuntimeStatistics.java new file mode 100644 index 00000000000..c9435def77b --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowRuntimeStatistics.java @@ -0,0 +1,208 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables; + + +import edu.uci.ics.texera.dao.jooq.generated.Indexes; +import edu.uci.ics.texera.dao.jooq.generated.Keys; +import edu.uci.ics.texera.dao.jooq.generated.TexeraDb; +import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowRuntimeStatisticsRecord; + +import java.sql.Timestamp; +import java.util.Arrays; +import java.util.List; + +import org.jooq.Field; +import org.jooq.ForeignKey; +import org.jooq.Index; +import org.jooq.Name; +import org.jooq.Record; +import org.jooq.Row11; +import org.jooq.Schema; +import org.jooq.Table; +import org.jooq.TableField; +import org.jooq.UniqueKey; +import org.jooq.impl.DSL; +import org.jooq.impl.TableImpl; +import org.jooq.types.UInteger; +import org.jooq.types.ULong; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowRuntimeStatistics extends TableImpl { + + private static final long serialVersionUID = -327153807; + + /** + * The reference instance of texera_db.workflow_runtime_statistics + */ + public static final WorkflowRuntimeStatistics WORKFLOW_RUNTIME_STATISTICS = new WorkflowRuntimeStatistics(); + + /** + * The class holding records for this type + */ + @Override + public Class getRecordType() { + return WorkflowRuntimeStatisticsRecord.class; + } + + /** + * The column texera_db.workflow_runtime_statistics.workflow_id. + */ + public final TableField WORKFLOW_ID = createField(DSL.name("workflow_id"), org.jooq.impl.SQLDataType.INTEGERUNSIGNED.nullable(false), this, ""); + + /** + * The column texera_db.workflow_runtime_statistics.execution_id. + */ + public final TableField EXECUTION_ID = createField(DSL.name("execution_id"), org.jooq.impl.SQLDataType.INTEGERUNSIGNED.nullable(false), this, ""); + + /** + * The column texera_db.workflow_runtime_statistics.operator_id. + */ + public final TableField OPERATOR_ID = createField(DSL.name("operator_id"), org.jooq.impl.SQLDataType.VARCHAR(100).nullable(false), this, ""); + + /** + * The column texera_db.workflow_runtime_statistics.time. + */ + public final TableField TIME = createField(DSL.name("time"), org.jooq.impl.SQLDataType.TIMESTAMP.nullable(false).defaultValue(org.jooq.impl.DSL.field("CURRENT_TIMESTAMP(6)", org.jooq.impl.SQLDataType.TIMESTAMP)), this, ""); + + /** + * The column texera_db.workflow_runtime_statistics.input_tuple_cnt. + */ + public final TableField INPUT_TUPLE_CNT = createField(DSL.name("input_tuple_cnt"), org.jooq.impl.SQLDataType.INTEGERUNSIGNED.nullable(false).defaultValue(org.jooq.impl.DSL.inline("0", org.jooq.impl.SQLDataType.INTEGERUNSIGNED)), this, ""); + + /** + * The column texera_db.workflow_runtime_statistics.output_tuple_cnt. + */ + public final TableField OUTPUT_TUPLE_CNT = createField(DSL.name("output_tuple_cnt"), org.jooq.impl.SQLDataType.INTEGERUNSIGNED.nullable(false).defaultValue(org.jooq.impl.DSL.inline("0", org.jooq.impl.SQLDataType.INTEGERUNSIGNED)), this, ""); + + /** + * The column texera_db.workflow_runtime_statistics.status. + */ + public final TableField STATUS = createField(DSL.name("status"), org.jooq.impl.SQLDataType.TINYINT.nullable(false).defaultValue(org.jooq.impl.DSL.inline("1", org.jooq.impl.SQLDataType.TINYINT)), this, ""); + + /** + * The column texera_db.workflow_runtime_statistics.data_processing_time. + */ + public final TableField DATA_PROCESSING_TIME = createField(DSL.name("data_processing_time"), org.jooq.impl.SQLDataType.BIGINTUNSIGNED.nullable(false).defaultValue(org.jooq.impl.DSL.inline("0", org.jooq.impl.SQLDataType.BIGINTUNSIGNED)), this, ""); + + /** + * The column texera_db.workflow_runtime_statistics.control_processing_time. + */ + public final TableField CONTROL_PROCESSING_TIME = createField(DSL.name("control_processing_time"), org.jooq.impl.SQLDataType.BIGINTUNSIGNED.nullable(false).defaultValue(org.jooq.impl.DSL.inline("0", org.jooq.impl.SQLDataType.BIGINTUNSIGNED)), this, ""); + + /** + * The column texera_db.workflow_runtime_statistics.idle_time. + */ + public final TableField IDLE_TIME = createField(DSL.name("idle_time"), org.jooq.impl.SQLDataType.BIGINTUNSIGNED.nullable(false).defaultValue(org.jooq.impl.DSL.inline("0", org.jooq.impl.SQLDataType.BIGINTUNSIGNED)), this, ""); + + /** + * The column texera_db.workflow_runtime_statistics.num_workers. + */ + public final TableField NUM_WORKERS = createField(DSL.name("num_workers"), org.jooq.impl.SQLDataType.INTEGERUNSIGNED.nullable(false).defaultValue(org.jooq.impl.DSL.inline("0", org.jooq.impl.SQLDataType.INTEGERUNSIGNED)), this, ""); + + /** + * Create a texera_db.workflow_runtime_statistics table reference + */ + public WorkflowRuntimeStatistics() { + this(DSL.name("workflow_runtime_statistics"), null); + } + + /** + * Create an aliased texera_db.workflow_runtime_statistics table reference + */ + public WorkflowRuntimeStatistics(String alias) { + this(DSL.name(alias), WORKFLOW_RUNTIME_STATISTICS); + } + + /** + * Create an aliased texera_db.workflow_runtime_statistics table reference + */ + public WorkflowRuntimeStatistics(Name alias) { + this(alias, WORKFLOW_RUNTIME_STATISTICS); + } + + private WorkflowRuntimeStatistics(Name alias, Table aliased) { + this(alias, aliased, null); + } + + private WorkflowRuntimeStatistics(Name alias, Table aliased, Field[] parameters) { + super(alias, null, aliased, parameters, DSL.comment("")); + } + + public WorkflowRuntimeStatistics(Table child, ForeignKey key) { + super(child, key, WORKFLOW_RUNTIME_STATISTICS); + } + + @Override + public Schema getSchema() { + return TexeraDb.TEXERA_DB; + } + + @Override + public List getIndexes() { + return Arrays.asList(Indexes.WORKFLOW_RUNTIME_STATISTICS_EXECUTION_ID, Indexes.WORKFLOW_RUNTIME_STATISTICS_PRIMARY); + } + + @Override + public UniqueKey getPrimaryKey() { + return Keys.KEY_WORKFLOW_RUNTIME_STATISTICS_PRIMARY; + } + + @Override + public List> getKeys() { + return Arrays.>asList(Keys.KEY_WORKFLOW_RUNTIME_STATISTICS_PRIMARY); + } + + @Override + public List> getReferences() { + return Arrays.>asList(Keys.WORKFLOW_RUNTIME_STATISTICS_IBFK_1, Keys.WORKFLOW_RUNTIME_STATISTICS_IBFK_2); + } + + public Workflow workflow() { + return new Workflow(this, Keys.WORKFLOW_RUNTIME_STATISTICS_IBFK_1); + } + + public WorkflowExecutions workflowExecutions() { + return new WorkflowExecutions(this, Keys.WORKFLOW_RUNTIME_STATISTICS_IBFK_2); + } + + @Override + public WorkflowRuntimeStatistics as(String alias) { + return new WorkflowRuntimeStatistics(DSL.name(alias), this); + } + + @Override + public WorkflowRuntimeStatistics as(Name alias) { + return new WorkflowRuntimeStatistics(alias, this); + } + + /** + * Rename this table + */ + @Override + public WorkflowRuntimeStatistics rename(String name) { + return new WorkflowRuntimeStatistics(DSL.name(name), null); + } + + /** + * Rename this table + */ + @Override + public WorkflowRuntimeStatistics rename(Name name) { + return new WorkflowRuntimeStatistics(name, null); + } + + // ------------------------------------------------------------------------- + // Row11 type methods + // ------------------------------------------------------------------------- + + @Override + public Row11 fieldsRow() { + return (Row11) super.fieldsRow(); + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowUserActivity.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowUserActivity.java new file mode 100644 index 00000000000..bde732fa870 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowUserActivity.java @@ -0,0 +1,143 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables; + + +import edu.uci.ics.texera.dao.jooq.generated.TexeraDb; +import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowUserActivityRecord; + +import java.sql.Timestamp; + +import org.jooq.Field; +import org.jooq.ForeignKey; +import org.jooq.Name; +import org.jooq.Record; +import org.jooq.Row5; +import org.jooq.Schema; +import org.jooq.Table; +import org.jooq.TableField; +import org.jooq.impl.DSL; +import org.jooq.impl.TableImpl; +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowUserActivity extends TableImpl { + + private static final long serialVersionUID = -1146513069; + + /** + * The reference instance of texera_db.workflow_user_activity + */ + public static final WorkflowUserActivity WORKFLOW_USER_ACTIVITY = new WorkflowUserActivity(); + + /** + * The class holding records for this type + */ + @Override + public Class getRecordType() { + return WorkflowUserActivityRecord.class; + } + + /** + * The column texera_db.workflow_user_activity.uid. + */ + public final TableField UID = createField(DSL.name("uid"), org.jooq.impl.SQLDataType.INTEGERUNSIGNED.nullable(false).defaultValue(org.jooq.impl.DSL.inline("0", org.jooq.impl.SQLDataType.INTEGERUNSIGNED)), this, ""); + + /** + * The column texera_db.workflow_user_activity.wid. + */ + public final TableField WID = createField(DSL.name("wid"), org.jooq.impl.SQLDataType.INTEGERUNSIGNED.nullable(false), this, ""); + + /** + * The column texera_db.workflow_user_activity.ip. + */ + public final TableField IP = createField(DSL.name("ip"), org.jooq.impl.SQLDataType.VARCHAR(15), this, ""); + + /** + * The column texera_db.workflow_user_activity.activate. + */ + public final TableField ACTIVATE = createField(DSL.name("activate"), org.jooq.impl.SQLDataType.VARCHAR(10).nullable(false), this, ""); + + /** + * The column texera_db.workflow_user_activity.activity_time. + */ + public final TableField ACTIVITY_TIME = createField(DSL.name("activity_time"), org.jooq.impl.SQLDataType.TIMESTAMP.defaultValue(org.jooq.impl.DSL.field("CURRENT_TIMESTAMP", org.jooq.impl.SQLDataType.TIMESTAMP)), this, ""); + + /** + * Create a texera_db.workflow_user_activity table reference + */ + public WorkflowUserActivity() { + this(DSL.name("workflow_user_activity"), null); + } + + /** + * Create an aliased texera_db.workflow_user_activity table reference + */ + public WorkflowUserActivity(String alias) { + this(DSL.name(alias), WORKFLOW_USER_ACTIVITY); + } + + /** + * Create an aliased texera_db.workflow_user_activity table reference + */ + public WorkflowUserActivity(Name alias) { + this(alias, WORKFLOW_USER_ACTIVITY); + } + + private WorkflowUserActivity(Name alias, Table aliased) { + this(alias, aliased, null); + } + + private WorkflowUserActivity(Name alias, Table aliased, Field[] parameters) { + super(alias, null, aliased, parameters, DSL.comment("")); + } + + public WorkflowUserActivity(Table child, ForeignKey key) { + super(child, key, WORKFLOW_USER_ACTIVITY); + } + + @Override + public Schema getSchema() { + return TexeraDb.TEXERA_DB; + } + + @Override + public WorkflowUserActivity as(String alias) { + return new WorkflowUserActivity(DSL.name(alias), this); + } + + @Override + public WorkflowUserActivity as(Name alias) { + return new WorkflowUserActivity(alias, this); + } + + /** + * Rename this table + */ + @Override + public WorkflowUserActivity rename(String name) { + return new WorkflowUserActivity(DSL.name(name), null); + } + + /** + * Rename this table + */ + @Override + public WorkflowUserActivity rename(Name name) { + return new WorkflowUserActivity(name, null); + } + + // ------------------------------------------------------------------------- + // Row5 type methods + // ------------------------------------------------------------------------- + + @Override + public Row5 fieldsRow() { + return (Row5) super.fieldsRow(); + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowUserClones.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowUserClones.java new file mode 100644 index 00000000000..116c6e22db4 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowUserClones.java @@ -0,0 +1,161 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables; + + +import edu.uci.ics.texera.dao.jooq.generated.Indexes; +import edu.uci.ics.texera.dao.jooq.generated.Keys; +import edu.uci.ics.texera.dao.jooq.generated.TexeraDb; +import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowUserClonesRecord; + +import java.util.Arrays; +import java.util.List; + +import org.jooq.Field; +import org.jooq.ForeignKey; +import org.jooq.Index; +import org.jooq.Name; +import org.jooq.Record; +import org.jooq.Row2; +import org.jooq.Schema; +import org.jooq.Table; +import org.jooq.TableField; +import org.jooq.UniqueKey; +import org.jooq.impl.DSL; +import org.jooq.impl.TableImpl; +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowUserClones extends TableImpl { + + private static final long serialVersionUID = 2096098879; + + /** + * The reference instance of texera_db.workflow_user_clones + */ + public static final WorkflowUserClones WORKFLOW_USER_CLONES = new WorkflowUserClones(); + + /** + * The class holding records for this type + */ + @Override + public Class getRecordType() { + return WorkflowUserClonesRecord.class; + } + + /** + * The column texera_db.workflow_user_clones.uid. + */ + public final TableField UID = createField(DSL.name("uid"), org.jooq.impl.SQLDataType.INTEGERUNSIGNED.nullable(false), this, ""); + + /** + * The column texera_db.workflow_user_clones.wid. + */ + public final TableField WID = createField(DSL.name("wid"), org.jooq.impl.SQLDataType.INTEGERUNSIGNED.nullable(false), this, ""); + + /** + * Create a texera_db.workflow_user_clones table reference + */ + public WorkflowUserClones() { + this(DSL.name("workflow_user_clones"), null); + } + + /** + * Create an aliased texera_db.workflow_user_clones table reference + */ + public WorkflowUserClones(String alias) { + this(DSL.name(alias), WORKFLOW_USER_CLONES); + } + + /** + * Create an aliased texera_db.workflow_user_clones table reference + */ + public WorkflowUserClones(Name alias) { + this(alias, WORKFLOW_USER_CLONES); + } + + private WorkflowUserClones(Name alias, Table aliased) { + this(alias, aliased, null); + } + + private WorkflowUserClones(Name alias, Table aliased, Field[] parameters) { + super(alias, null, aliased, parameters, DSL.comment("")); + } + + public WorkflowUserClones(Table child, ForeignKey key) { + super(child, key, WORKFLOW_USER_CLONES); + } + + @Override + public Schema getSchema() { + return TexeraDb.TEXERA_DB; + } + + @Override + public List getIndexes() { + return Arrays.asList(Indexes.WORKFLOW_USER_CLONES_PRIMARY, Indexes.WORKFLOW_USER_CLONES_WID); + } + + @Override + public UniqueKey getPrimaryKey() { + return Keys.KEY_WORKFLOW_USER_CLONES_PRIMARY; + } + + @Override + public List> getKeys() { + return Arrays.>asList(Keys.KEY_WORKFLOW_USER_CLONES_PRIMARY); + } + + @Override + public List> getReferences() { + return Arrays.>asList(Keys.WORKFLOW_USER_CLONES_IBFK_1, Keys.WORKFLOW_USER_CLONES_IBFK_2); + } + + public User user() { + return new User(this, Keys.WORKFLOW_USER_CLONES_IBFK_1); + } + + public Workflow workflow() { + return new Workflow(this, Keys.WORKFLOW_USER_CLONES_IBFK_2); + } + + @Override + public WorkflowUserClones as(String alias) { + return new WorkflowUserClones(DSL.name(alias), this); + } + + @Override + public WorkflowUserClones as(Name alias) { + return new WorkflowUserClones(alias, this); + } + + /** + * Rename this table + */ + @Override + public WorkflowUserClones rename(String name) { + return new WorkflowUserClones(DSL.name(name), null); + } + + /** + * Rename this table + */ + @Override + public WorkflowUserClones rename(Name name) { + return new WorkflowUserClones(name, null); + } + + // ------------------------------------------------------------------------- + // Row2 type methods + // ------------------------------------------------------------------------- + + @Override + public Row2 fieldsRow() { + return (Row2) super.fieldsRow(); + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowUserLikes.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowUserLikes.java new file mode 100644 index 00000000000..38fd8010ca3 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowUserLikes.java @@ -0,0 +1,161 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables; + + +import edu.uci.ics.texera.dao.jooq.generated.Indexes; +import edu.uci.ics.texera.dao.jooq.generated.Keys; +import edu.uci.ics.texera.dao.jooq.generated.TexeraDb; +import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowUserLikesRecord; + +import java.util.Arrays; +import java.util.List; + +import org.jooq.Field; +import org.jooq.ForeignKey; +import org.jooq.Index; +import org.jooq.Name; +import org.jooq.Record; +import org.jooq.Row2; +import org.jooq.Schema; +import org.jooq.Table; +import org.jooq.TableField; +import org.jooq.UniqueKey; +import org.jooq.impl.DSL; +import org.jooq.impl.TableImpl; +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowUserLikes extends TableImpl { + + private static final long serialVersionUID = -1712382581; + + /** + * The reference instance of texera_db.workflow_user_likes + */ + public static final WorkflowUserLikes WORKFLOW_USER_LIKES = new WorkflowUserLikes(); + + /** + * The class holding records for this type + */ + @Override + public Class getRecordType() { + return WorkflowUserLikesRecord.class; + } + + /** + * The column texera_db.workflow_user_likes.uid. + */ + public final TableField UID = createField(DSL.name("uid"), org.jooq.impl.SQLDataType.INTEGERUNSIGNED.nullable(false), this, ""); + + /** + * The column texera_db.workflow_user_likes.wid. + */ + public final TableField WID = createField(DSL.name("wid"), org.jooq.impl.SQLDataType.INTEGERUNSIGNED.nullable(false), this, ""); + + /** + * Create a texera_db.workflow_user_likes table reference + */ + public WorkflowUserLikes() { + this(DSL.name("workflow_user_likes"), null); + } + + /** + * Create an aliased texera_db.workflow_user_likes table reference + */ + public WorkflowUserLikes(String alias) { + this(DSL.name(alias), WORKFLOW_USER_LIKES); + } + + /** + * Create an aliased texera_db.workflow_user_likes table reference + */ + public WorkflowUserLikes(Name alias) { + this(alias, WORKFLOW_USER_LIKES); + } + + private WorkflowUserLikes(Name alias, Table aliased) { + this(alias, aliased, null); + } + + private WorkflowUserLikes(Name alias, Table aliased, Field[] parameters) { + super(alias, null, aliased, parameters, DSL.comment("")); + } + + public WorkflowUserLikes(Table child, ForeignKey key) { + super(child, key, WORKFLOW_USER_LIKES); + } + + @Override + public Schema getSchema() { + return TexeraDb.TEXERA_DB; + } + + @Override + public List getIndexes() { + return Arrays.asList(Indexes.WORKFLOW_USER_LIKES_PRIMARY, Indexes.WORKFLOW_USER_LIKES_WID); + } + + @Override + public UniqueKey getPrimaryKey() { + return Keys.KEY_WORKFLOW_USER_LIKES_PRIMARY; + } + + @Override + public List> getKeys() { + return Arrays.>asList(Keys.KEY_WORKFLOW_USER_LIKES_PRIMARY); + } + + @Override + public List> getReferences() { + return Arrays.>asList(Keys.WORKFLOW_USER_LIKES_IBFK_1, Keys.WORKFLOW_USER_LIKES_IBFK_2); + } + + public User user() { + return new User(this, Keys.WORKFLOW_USER_LIKES_IBFK_1); + } + + public Workflow workflow() { + return new Workflow(this, Keys.WORKFLOW_USER_LIKES_IBFK_2); + } + + @Override + public WorkflowUserLikes as(String alias) { + return new WorkflowUserLikes(DSL.name(alias), this); + } + + @Override + public WorkflowUserLikes as(Name alias) { + return new WorkflowUserLikes(alias, this); + } + + /** + * Rename this table + */ + @Override + public WorkflowUserLikes rename(String name) { + return new WorkflowUserLikes(DSL.name(name), null); + } + + /** + * Rename this table + */ + @Override + public WorkflowUserLikes rename(Name name) { + return new WorkflowUserLikes(name, null); + } + + // ------------------------------------------------------------------------- + // Row2 type methods + // ------------------------------------------------------------------------- + + @Override + public Row2 fieldsRow() { + return (Row2) super.fieldsRow(); + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowViewCount.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowViewCount.java new file mode 100644 index 00000000000..4e920b53b45 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/WorkflowViewCount.java @@ -0,0 +1,157 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables; + + +import edu.uci.ics.texera.dao.jooq.generated.Indexes; +import edu.uci.ics.texera.dao.jooq.generated.Keys; +import edu.uci.ics.texera.dao.jooq.generated.TexeraDb; +import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowViewCountRecord; + +import java.util.Arrays; +import java.util.List; + +import org.jooq.Field; +import org.jooq.ForeignKey; +import org.jooq.Index; +import org.jooq.Name; +import org.jooq.Record; +import org.jooq.Row2; +import org.jooq.Schema; +import org.jooq.Table; +import org.jooq.TableField; +import org.jooq.UniqueKey; +import org.jooq.impl.DSL; +import org.jooq.impl.TableImpl; +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowViewCount extends TableImpl { + + private static final long serialVersionUID = -1514441832; + + /** + * The reference instance of texera_db.workflow_view_count + */ + public static final WorkflowViewCount WORKFLOW_VIEW_COUNT = new WorkflowViewCount(); + + /** + * The class holding records for this type + */ + @Override + public Class getRecordType() { + return WorkflowViewCountRecord.class; + } + + /** + * The column texera_db.workflow_view_count.wid. + */ + public final TableField WID = createField(DSL.name("wid"), org.jooq.impl.SQLDataType.INTEGERUNSIGNED.nullable(false), this, ""); + + /** + * The column texera_db.workflow_view_count.view_count. + */ + public final TableField VIEW_COUNT = createField(DSL.name("view_count"), org.jooq.impl.SQLDataType.INTEGERUNSIGNED.nullable(false).defaultValue(org.jooq.impl.DSL.inline("0", org.jooq.impl.SQLDataType.INTEGERUNSIGNED)), this, ""); + + /** + * Create a texera_db.workflow_view_count table reference + */ + public WorkflowViewCount() { + this(DSL.name("workflow_view_count"), null); + } + + /** + * Create an aliased texera_db.workflow_view_count table reference + */ + public WorkflowViewCount(String alias) { + this(DSL.name(alias), WORKFLOW_VIEW_COUNT); + } + + /** + * Create an aliased texera_db.workflow_view_count table reference + */ + public WorkflowViewCount(Name alias) { + this(alias, WORKFLOW_VIEW_COUNT); + } + + private WorkflowViewCount(Name alias, Table aliased) { + this(alias, aliased, null); + } + + private WorkflowViewCount(Name alias, Table aliased, Field[] parameters) { + super(alias, null, aliased, parameters, DSL.comment("")); + } + + public WorkflowViewCount(Table child, ForeignKey key) { + super(child, key, WORKFLOW_VIEW_COUNT); + } + + @Override + public Schema getSchema() { + return TexeraDb.TEXERA_DB; + } + + @Override + public List getIndexes() { + return Arrays.asList(Indexes.WORKFLOW_VIEW_COUNT_PRIMARY); + } + + @Override + public UniqueKey getPrimaryKey() { + return Keys.KEY_WORKFLOW_VIEW_COUNT_PRIMARY; + } + + @Override + public List> getKeys() { + return Arrays.>asList(Keys.KEY_WORKFLOW_VIEW_COUNT_PRIMARY); + } + + @Override + public List> getReferences() { + return Arrays.>asList(Keys.WORKFLOW_VIEW_COUNT_IBFK_1); + } + + public Workflow workflow() { + return new Workflow(this, Keys.WORKFLOW_VIEW_COUNT_IBFK_1); + } + + @Override + public WorkflowViewCount as(String alias) { + return new WorkflowViewCount(DSL.name(alias), this); + } + + @Override + public WorkflowViewCount as(Name alias) { + return new WorkflowViewCount(alias, this); + } + + /** + * Rename this table + */ + @Override + public WorkflowViewCount rename(String name) { + return new WorkflowViewCount(DSL.name(name), null); + } + + /** + * Rename this table + */ + @Override + public WorkflowViewCount rename(Name name) { + return new WorkflowViewCount(name, null); + } + + // ------------------------------------------------------------------------- + // Row2 type methods + // ------------------------------------------------------------------------- + + @Override + public Row2 fieldsRow() { + return (Row2) super.fieldsRow(); + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowRuntimeStatisticsDao.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowRuntimeStatisticsDao.java new file mode 100644 index 00000000000..7db23db91cb --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowRuntimeStatisticsDao.java @@ -0,0 +1,198 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.daos; + + +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowRuntimeStatistics; +import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowRuntimeStatisticsRecord; + +import java.sql.Timestamp; +import java.util.List; + +import org.jooq.Configuration; +import org.jooq.Record4; +import org.jooq.impl.DAOImpl; +import org.jooq.types.UInteger; +import org.jooq.types.ULong; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowRuntimeStatisticsDao extends DAOImpl> { + + /** + * Create a new WorkflowRuntimeStatisticsDao without any configuration + */ + public WorkflowRuntimeStatisticsDao() { + super(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS, edu.uci.ics.texera.dao.jooq.generated.tables.pojos.WorkflowRuntimeStatistics.class); + } + + /** + * Create a new WorkflowRuntimeStatisticsDao with an attached configuration + */ + public WorkflowRuntimeStatisticsDao(Configuration configuration) { + super(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS, edu.uci.ics.texera.dao.jooq.generated.tables.pojos.WorkflowRuntimeStatistics.class, configuration); + } + + @Override + public Record4 getId(edu.uci.ics.texera.dao.jooq.generated.tables.pojos.WorkflowRuntimeStatistics object) { + return compositeKeyRecord(object.getWorkflowId(), object.getExecutionId(), object.getOperatorId(), object.getTime()); + } + + /** + * Fetch records that have workflow_id BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfWorkflowId(UInteger lowerInclusive, UInteger upperInclusive) { + return fetchRange(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.WORKFLOW_ID, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have workflow_id IN (values) + */ + public List fetchByWorkflowId(UInteger... values) { + return fetch(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.WORKFLOW_ID, values); + } + + /** + * Fetch records that have execution_id BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfExecutionId(UInteger lowerInclusive, UInteger upperInclusive) { + return fetchRange(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.EXECUTION_ID, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have execution_id IN (values) + */ + public List fetchByExecutionId(UInteger... values) { + return fetch(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.EXECUTION_ID, values); + } + + /** + * Fetch records that have operator_id BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfOperatorId(String lowerInclusive, String upperInclusive) { + return fetchRange(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.OPERATOR_ID, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have operator_id IN (values) + */ + public List fetchByOperatorId(String... values) { + return fetch(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.OPERATOR_ID, values); + } + + /** + * Fetch records that have time BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfTime(Timestamp lowerInclusive, Timestamp upperInclusive) { + return fetchRange(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.TIME, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have time IN (values) + */ + public List fetchByTime(Timestamp... values) { + return fetch(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.TIME, values); + } + + /** + * Fetch records that have input_tuple_cnt BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfInputTupleCnt(UInteger lowerInclusive, UInteger upperInclusive) { + return fetchRange(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.INPUT_TUPLE_CNT, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have input_tuple_cnt IN (values) + */ + public List fetchByInputTupleCnt(UInteger... values) { + return fetch(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.INPUT_TUPLE_CNT, values); + } + + /** + * Fetch records that have output_tuple_cnt BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfOutputTupleCnt(UInteger lowerInclusive, UInteger upperInclusive) { + return fetchRange(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.OUTPUT_TUPLE_CNT, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have output_tuple_cnt IN (values) + */ + public List fetchByOutputTupleCnt(UInteger... values) { + return fetch(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.OUTPUT_TUPLE_CNT, values); + } + + /** + * Fetch records that have status BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfStatus(Byte lowerInclusive, Byte upperInclusive) { + return fetchRange(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.STATUS, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have status IN (values) + */ + public List fetchByStatus(Byte... values) { + return fetch(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.STATUS, values); + } + + /** + * Fetch records that have data_processing_time BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfDataProcessingTime(ULong lowerInclusive, ULong upperInclusive) { + return fetchRange(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.DATA_PROCESSING_TIME, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have data_processing_time IN (values) + */ + public List fetchByDataProcessingTime(ULong... values) { + return fetch(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.DATA_PROCESSING_TIME, values); + } + + /** + * Fetch records that have control_processing_time BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfControlProcessingTime(ULong lowerInclusive, ULong upperInclusive) { + return fetchRange(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.CONTROL_PROCESSING_TIME, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have control_processing_time IN (values) + */ + public List fetchByControlProcessingTime(ULong... values) { + return fetch(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.CONTROL_PROCESSING_TIME, values); + } + + /** + * Fetch records that have idle_time BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfIdleTime(ULong lowerInclusive, ULong upperInclusive) { + return fetchRange(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.IDLE_TIME, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have idle_time IN (values) + */ + public List fetchByIdleTime(ULong... values) { + return fetch(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.IDLE_TIME, values); + } + + /** + * Fetch records that have num_workers BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfNumWorkers(UInteger lowerInclusive, UInteger upperInclusive) { + return fetchRange(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.NUM_WORKERS, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have num_workers IN (values) + */ + public List fetchByNumWorkers(UInteger... values) { + return fetch(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.NUM_WORKERS, values); + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowUserClonesDao.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowUserClonesDao.java new file mode 100644 index 00000000000..ce65b197454 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowUserClonesDao.java @@ -0,0 +1,70 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.daos; + + +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserClones; +import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowUserClonesRecord; + +import java.util.List; + +import org.jooq.Configuration; +import org.jooq.Record2; +import org.jooq.impl.DAOImpl; +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowUserClonesDao extends DAOImpl> { + + /** + * Create a new WorkflowUserClonesDao without any configuration + */ + public WorkflowUserClonesDao() { + super(WorkflowUserClones.WORKFLOW_USER_CLONES, edu.uci.ics.texera.dao.jooq.generated.tables.pojos.WorkflowUserClones.class); + } + + /** + * Create a new WorkflowUserClonesDao with an attached configuration + */ + public WorkflowUserClonesDao(Configuration configuration) { + super(WorkflowUserClones.WORKFLOW_USER_CLONES, edu.uci.ics.texera.dao.jooq.generated.tables.pojos.WorkflowUserClones.class, configuration); + } + + @Override + public Record2 getId(edu.uci.ics.texera.dao.jooq.generated.tables.pojos.WorkflowUserClones object) { + return compositeKeyRecord(object.getUid(), object.getWid()); + } + + /** + * Fetch records that have uid BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfUid(UInteger lowerInclusive, UInteger upperInclusive) { + return fetchRange(WorkflowUserClones.WORKFLOW_USER_CLONES.UID, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have uid IN (values) + */ + public List fetchByUid(UInteger... values) { + return fetch(WorkflowUserClones.WORKFLOW_USER_CLONES.UID, values); + } + + /** + * Fetch records that have wid BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfWid(UInteger lowerInclusive, UInteger upperInclusive) { + return fetchRange(WorkflowUserClones.WORKFLOW_USER_CLONES.WID, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have wid IN (values) + */ + public List fetchByWid(UInteger... values) { + return fetch(WorkflowUserClones.WORKFLOW_USER_CLONES.WID, values); + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowUserLikesDao.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowUserLikesDao.java new file mode 100644 index 00000000000..318dfa55c79 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowUserLikesDao.java @@ -0,0 +1,70 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.daos; + + +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserLikes; +import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowUserLikesRecord; + +import java.util.List; + +import org.jooq.Configuration; +import org.jooq.Record2; +import org.jooq.impl.DAOImpl; +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowUserLikesDao extends DAOImpl> { + + /** + * Create a new WorkflowUserLikesDao without any configuration + */ + public WorkflowUserLikesDao() { + super(WorkflowUserLikes.WORKFLOW_USER_LIKES, edu.uci.ics.texera.dao.jooq.generated.tables.pojos.WorkflowUserLikes.class); + } + + /** + * Create a new WorkflowUserLikesDao with an attached configuration + */ + public WorkflowUserLikesDao(Configuration configuration) { + super(WorkflowUserLikes.WORKFLOW_USER_LIKES, edu.uci.ics.texera.dao.jooq.generated.tables.pojos.WorkflowUserLikes.class, configuration); + } + + @Override + public Record2 getId(edu.uci.ics.texera.dao.jooq.generated.tables.pojos.WorkflowUserLikes object) { + return compositeKeyRecord(object.getUid(), object.getWid()); + } + + /** + * Fetch records that have uid BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfUid(UInteger lowerInclusive, UInteger upperInclusive) { + return fetchRange(WorkflowUserLikes.WORKFLOW_USER_LIKES.UID, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have uid IN (values) + */ + public List fetchByUid(UInteger... values) { + return fetch(WorkflowUserLikes.WORKFLOW_USER_LIKES.UID, values); + } + + /** + * Fetch records that have wid BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfWid(UInteger lowerInclusive, UInteger upperInclusive) { + return fetchRange(WorkflowUserLikes.WORKFLOW_USER_LIKES.WID, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have wid IN (values) + */ + public List fetchByWid(UInteger... values) { + return fetch(WorkflowUserLikes.WORKFLOW_USER_LIKES.WID, values); + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowViewCountDao.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowViewCountDao.java new file mode 100644 index 00000000000..d6a4a681967 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/daos/WorkflowViewCountDao.java @@ -0,0 +1,76 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.daos; + + +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowViewCount; +import edu.uci.ics.texera.dao.jooq.generated.tables.records.WorkflowViewCountRecord; + +import java.util.List; + +import org.jooq.Configuration; +import org.jooq.impl.DAOImpl; +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowViewCountDao extends DAOImpl { + + /** + * Create a new WorkflowViewCountDao without any configuration + */ + public WorkflowViewCountDao() { + super(WorkflowViewCount.WORKFLOW_VIEW_COUNT, edu.uci.ics.texera.dao.jooq.generated.tables.pojos.WorkflowViewCount.class); + } + + /** + * Create a new WorkflowViewCountDao with an attached configuration + */ + public WorkflowViewCountDao(Configuration configuration) { + super(WorkflowViewCount.WORKFLOW_VIEW_COUNT, edu.uci.ics.texera.dao.jooq.generated.tables.pojos.WorkflowViewCount.class, configuration); + } + + @Override + public UInteger getId(edu.uci.ics.texera.dao.jooq.generated.tables.pojos.WorkflowViewCount object) { + return object.getWid(); + } + + /** + * Fetch records that have wid BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfWid(UInteger lowerInclusive, UInteger upperInclusive) { + return fetchRange(WorkflowViewCount.WORKFLOW_VIEW_COUNT.WID, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have wid IN (values) + */ + public List fetchByWid(UInteger... values) { + return fetch(WorkflowViewCount.WORKFLOW_VIEW_COUNT.WID, values); + } + + /** + * Fetch a unique record that has wid = value + */ + public edu.uci.ics.texera.dao.jooq.generated.tables.pojos.WorkflowViewCount fetchOneByWid(UInteger value) { + return fetchOne(WorkflowViewCount.WORKFLOW_VIEW_COUNT.WID, value); + } + + /** + * Fetch records that have view_count BETWEEN lowerInclusive AND upperInclusive + */ + public List fetchRangeOfViewCount(UInteger lowerInclusive, UInteger upperInclusive) { + return fetchRange(WorkflowViewCount.WORKFLOW_VIEW_COUNT.VIEW_COUNT, lowerInclusive, upperInclusive); + } + + /** + * Fetch records that have view_count IN (values) + */ + public List fetchByViewCount(UInteger... values) { + return fetch(WorkflowViewCount.WORKFLOW_VIEW_COUNT.VIEW_COUNT, values); + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowRuntimeStatistics.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowRuntimeStatistics.java new file mode 100644 index 00000000000..17c34923196 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowRuntimeStatistics.java @@ -0,0 +1,143 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.interfaces; + + +import java.io.Serializable; +import java.sql.Timestamp; + +import org.jooq.types.UInteger; +import org.jooq.types.ULong; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public interface IWorkflowRuntimeStatistics extends Serializable { + + /** + * Setter for texera_db.workflow_runtime_statistics.workflow_id. + */ + public void setWorkflowId(UInteger value); + + /** + * Getter for texera_db.workflow_runtime_statistics.workflow_id. + */ + public UInteger getWorkflowId(); + + /** + * Setter for texera_db.workflow_runtime_statistics.execution_id. + */ + public void setExecutionId(UInteger value); + + /** + * Getter for texera_db.workflow_runtime_statistics.execution_id. + */ + public UInteger getExecutionId(); + + /** + * Setter for texera_db.workflow_runtime_statistics.operator_id. + */ + public void setOperatorId(String value); + + /** + * Getter for texera_db.workflow_runtime_statistics.operator_id. + */ + public String getOperatorId(); + + /** + * Setter for texera_db.workflow_runtime_statistics.time. + */ + public void setTime(Timestamp value); + + /** + * Getter for texera_db.workflow_runtime_statistics.time. + */ + public Timestamp getTime(); + + /** + * Setter for texera_db.workflow_runtime_statistics.input_tuple_cnt. + */ + public void setInputTupleCnt(UInteger value); + + /** + * Getter for texera_db.workflow_runtime_statistics.input_tuple_cnt. + */ + public UInteger getInputTupleCnt(); + + /** + * Setter for texera_db.workflow_runtime_statistics.output_tuple_cnt. + */ + public void setOutputTupleCnt(UInteger value); + + /** + * Getter for texera_db.workflow_runtime_statistics.output_tuple_cnt. + */ + public UInteger getOutputTupleCnt(); + + /** + * Setter for texera_db.workflow_runtime_statistics.status. + */ + public void setStatus(Byte value); + + /** + * Getter for texera_db.workflow_runtime_statistics.status. + */ + public Byte getStatus(); + + /** + * Setter for texera_db.workflow_runtime_statistics.data_processing_time. + */ + public void setDataProcessingTime(ULong value); + + /** + * Getter for texera_db.workflow_runtime_statistics.data_processing_time. + */ + public ULong getDataProcessingTime(); + + /** + * Setter for texera_db.workflow_runtime_statistics.control_processing_time. + */ + public void setControlProcessingTime(ULong value); + + /** + * Getter for texera_db.workflow_runtime_statistics.control_processing_time. + */ + public ULong getControlProcessingTime(); + + /** + * Setter for texera_db.workflow_runtime_statistics.idle_time. + */ + public void setIdleTime(ULong value); + + /** + * Getter for texera_db.workflow_runtime_statistics.idle_time. + */ + public ULong getIdleTime(); + + /** + * Setter for texera_db.workflow_runtime_statistics.num_workers. + */ + public void setNumWorkers(UInteger value); + + /** + * Getter for texera_db.workflow_runtime_statistics.num_workers. + */ + public UInteger getNumWorkers(); + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + /** + * Load data from another generated Record/POJO implementing the common interface IWorkflowRuntimeStatistics + */ + public void from(edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowRuntimeStatistics from); + + /** + * Copy data into another generated Record/POJO implementing the common interface IWorkflowRuntimeStatistics + */ + public E into(E into); +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowUserActivity.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowUserActivity.java new file mode 100644 index 00000000000..d077e27e199 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowUserActivity.java @@ -0,0 +1,82 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.interfaces; + + +import java.io.Serializable; +import java.sql.Timestamp; + +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public interface IWorkflowUserActivity extends Serializable { + + /** + * Setter for texera_db.workflow_user_activity.uid. + */ + public void setUid(UInteger value); + + /** + * Getter for texera_db.workflow_user_activity.uid. + */ + public UInteger getUid(); + + /** + * Setter for texera_db.workflow_user_activity.wid. + */ + public void setWid(UInteger value); + + /** + * Getter for texera_db.workflow_user_activity.wid. + */ + public UInteger getWid(); + + /** + * Setter for texera_db.workflow_user_activity.ip. + */ + public void setIp(String value); + + /** + * Getter for texera_db.workflow_user_activity.ip. + */ + public String getIp(); + + /** + * Setter for texera_db.workflow_user_activity.activate. + */ + public void setActivate(String value); + + /** + * Getter for texera_db.workflow_user_activity.activate. + */ + public String getActivate(); + + /** + * Setter for texera_db.workflow_user_activity.activity_time. + */ + public void setActivityTime(Timestamp value); + + /** + * Getter for texera_db.workflow_user_activity.activity_time. + */ + public Timestamp getActivityTime(); + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + /** + * Load data from another generated Record/POJO implementing the common interface IWorkflowUserActivity + */ + public void from(edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowUserActivity from); + + /** + * Copy data into another generated Record/POJO implementing the common interface IWorkflowUserActivity + */ + public E into(E into); +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowUserClones.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowUserClones.java new file mode 100644 index 00000000000..28340c850b4 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowUserClones.java @@ -0,0 +1,51 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.interfaces; + + +import java.io.Serializable; + +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public interface IWorkflowUserClones extends Serializable { + + /** + * Setter for texera_db.workflow_user_clones.uid. + */ + public void setUid(UInteger value); + + /** + * Getter for texera_db.workflow_user_clones.uid. + */ + public UInteger getUid(); + + /** + * Setter for texera_db.workflow_user_clones.wid. + */ + public void setWid(UInteger value); + + /** + * Getter for texera_db.workflow_user_clones.wid. + */ + public UInteger getWid(); + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + /** + * Load data from another generated Record/POJO implementing the common interface IWorkflowUserClones + */ + public void from(edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowUserClones from); + + /** + * Copy data into another generated Record/POJO implementing the common interface IWorkflowUserClones + */ + public E into(E into); +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowUserLikes.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowUserLikes.java new file mode 100644 index 00000000000..d796b913e1b --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowUserLikes.java @@ -0,0 +1,51 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.interfaces; + + +import java.io.Serializable; + +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public interface IWorkflowUserLikes extends Serializable { + + /** + * Setter for texera_db.workflow_user_likes.uid. + */ + public void setUid(UInteger value); + + /** + * Getter for texera_db.workflow_user_likes.uid. + */ + public UInteger getUid(); + + /** + * Setter for texera_db.workflow_user_likes.wid. + */ + public void setWid(UInteger value); + + /** + * Getter for texera_db.workflow_user_likes.wid. + */ + public UInteger getWid(); + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + /** + * Load data from another generated Record/POJO implementing the common interface IWorkflowUserLikes + */ + public void from(edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowUserLikes from); + + /** + * Copy data into another generated Record/POJO implementing the common interface IWorkflowUserLikes + */ + public E into(E into); +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowViewCount.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowViewCount.java new file mode 100644 index 00000000000..6471013ec41 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/interfaces/IWorkflowViewCount.java @@ -0,0 +1,51 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.interfaces; + + +import java.io.Serializable; + +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public interface IWorkflowViewCount extends Serializable { + + /** + * Setter for texera_db.workflow_view_count.wid. + */ + public void setWid(UInteger value); + + /** + * Getter for texera_db.workflow_view_count.wid. + */ + public UInteger getWid(); + + /** + * Setter for texera_db.workflow_view_count.view_count. + */ + public void setViewCount(UInteger value); + + /** + * Getter for texera_db.workflow_view_count.view_count. + */ + public UInteger getViewCount(); + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + /** + * Load data from another generated Record/POJO implementing the common interface IWorkflowViewCount + */ + public void from(edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowViewCount from); + + /** + * Copy data into another generated Record/POJO implementing the common interface IWorkflowViewCount + */ + public E into(E into); +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowRuntimeStatistics.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowRuntimeStatistics.java new file mode 100644 index 00000000000..f72f5a10179 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowRuntimeStatistics.java @@ -0,0 +1,231 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.pojos; + + +import edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowRuntimeStatistics; + +import java.sql.Timestamp; + +import org.jooq.types.UInteger; +import org.jooq.types.ULong; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowRuntimeStatistics implements IWorkflowRuntimeStatistics { + + private static final long serialVersionUID = 511530419; + + private UInteger workflowId; + private UInteger executionId; + private String operatorId; + private Timestamp time; + private UInteger inputTupleCnt; + private UInteger outputTupleCnt; + private Byte status; + private ULong dataProcessingTime; + private ULong controlProcessingTime; + private ULong idleTime; + private UInteger numWorkers; + + public WorkflowRuntimeStatistics() {} + + public WorkflowRuntimeStatistics(IWorkflowRuntimeStatistics value) { + this.workflowId = value.getWorkflowId(); + this.executionId = value.getExecutionId(); + this.operatorId = value.getOperatorId(); + this.time = value.getTime(); + this.inputTupleCnt = value.getInputTupleCnt(); + this.outputTupleCnt = value.getOutputTupleCnt(); + this.status = value.getStatus(); + this.dataProcessingTime = value.getDataProcessingTime(); + this.controlProcessingTime = value.getControlProcessingTime(); + this.idleTime = value.getIdleTime(); + this.numWorkers = value.getNumWorkers(); + } + + public WorkflowRuntimeStatistics( + UInteger workflowId, + UInteger executionId, + String operatorId, + Timestamp time, + UInteger inputTupleCnt, + UInteger outputTupleCnt, + Byte status, + ULong dataProcessingTime, + ULong controlProcessingTime, + ULong idleTime, + UInteger numWorkers + ) { + this.workflowId = workflowId; + this.executionId = executionId; + this.operatorId = operatorId; + this.time = time; + this.inputTupleCnt = inputTupleCnt; + this.outputTupleCnt = outputTupleCnt; + this.status = status; + this.dataProcessingTime = dataProcessingTime; + this.controlProcessingTime = controlProcessingTime; + this.idleTime = idleTime; + this.numWorkers = numWorkers; + } + + @Override + public UInteger getWorkflowId() { + return this.workflowId; + } + + @Override + public void setWorkflowId(UInteger workflowId) { + this.workflowId = workflowId; + } + + @Override + public UInteger getExecutionId() { + return this.executionId; + } + + @Override + public void setExecutionId(UInteger executionId) { + this.executionId = executionId; + } + + @Override + public String getOperatorId() { + return this.operatorId; + } + + @Override + public void setOperatorId(String operatorId) { + this.operatorId = operatorId; + } + + @Override + public Timestamp getTime() { + return this.time; + } + + @Override + public void setTime(Timestamp time) { + this.time = time; + } + + @Override + public UInteger getInputTupleCnt() { + return this.inputTupleCnt; + } + + @Override + public void setInputTupleCnt(UInteger inputTupleCnt) { + this.inputTupleCnt = inputTupleCnt; + } + + @Override + public UInteger getOutputTupleCnt() { + return this.outputTupleCnt; + } + + @Override + public void setOutputTupleCnt(UInteger outputTupleCnt) { + this.outputTupleCnt = outputTupleCnt; + } + + @Override + public Byte getStatus() { + return this.status; + } + + @Override + public void setStatus(Byte status) { + this.status = status; + } + + @Override + public ULong getDataProcessingTime() { + return this.dataProcessingTime; + } + + @Override + public void setDataProcessingTime(ULong dataProcessingTime) { + this.dataProcessingTime = dataProcessingTime; + } + + @Override + public ULong getControlProcessingTime() { + return this.controlProcessingTime; + } + + @Override + public void setControlProcessingTime(ULong controlProcessingTime) { + this.controlProcessingTime = controlProcessingTime; + } + + @Override + public ULong getIdleTime() { + return this.idleTime; + } + + @Override + public void setIdleTime(ULong idleTime) { + this.idleTime = idleTime; + } + + @Override + public UInteger getNumWorkers() { + return this.numWorkers; + } + + @Override + public void setNumWorkers(UInteger numWorkers) { + this.numWorkers = numWorkers; + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("WorkflowRuntimeStatistics ("); + + sb.append(workflowId); + sb.append(", ").append(executionId); + sb.append(", ").append(operatorId); + sb.append(", ").append(time); + sb.append(", ").append(inputTupleCnt); + sb.append(", ").append(outputTupleCnt); + sb.append(", ").append(status); + sb.append(", ").append(dataProcessingTime); + sb.append(", ").append(controlProcessingTime); + sb.append(", ").append(idleTime); + sb.append(", ").append(numWorkers); + + sb.append(")"); + return sb.toString(); + } + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + @Override + public void from(IWorkflowRuntimeStatistics from) { + setWorkflowId(from.getWorkflowId()); + setExecutionId(from.getExecutionId()); + setOperatorId(from.getOperatorId()); + setTime(from.getTime()); + setInputTupleCnt(from.getInputTupleCnt()); + setOutputTupleCnt(from.getOutputTupleCnt()); + setStatus(from.getStatus()); + setDataProcessingTime(from.getDataProcessingTime()); + setControlProcessingTime(from.getControlProcessingTime()); + setIdleTime(from.getIdleTime()); + setNumWorkers(from.getNumWorkers()); + } + + @Override + public E into(E into) { + into.from(this); + return into; + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowUserActivity.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowUserActivity.java new file mode 100644 index 00000000000..0ed85f0a807 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowUserActivity.java @@ -0,0 +1,134 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.pojos; + + +import edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowUserActivity; + +import java.sql.Timestamp; + +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowUserActivity implements IWorkflowUserActivity { + + private static final long serialVersionUID = -724085757; + + private UInteger uid; + private UInteger wid; + private String ip; + private String activate; + private Timestamp activityTime; + + public WorkflowUserActivity() {} + + public WorkflowUserActivity(IWorkflowUserActivity value) { + this.uid = value.getUid(); + this.wid = value.getWid(); + this.ip = value.getIp(); + this.activate = value.getActivate(); + this.activityTime = value.getActivityTime(); + } + + public WorkflowUserActivity( + UInteger uid, + UInteger wid, + String ip, + String activate, + Timestamp activityTime + ) { + this.uid = uid; + this.wid = wid; + this.ip = ip; + this.activate = activate; + this.activityTime = activityTime; + } + + @Override + public UInteger getUid() { + return this.uid; + } + + @Override + public void setUid(UInteger uid) { + this.uid = uid; + } + + @Override + public UInteger getWid() { + return this.wid; + } + + @Override + public void setWid(UInteger wid) { + this.wid = wid; + } + + @Override + public String getIp() { + return this.ip; + } + + @Override + public void setIp(String ip) { + this.ip = ip; + } + + @Override + public String getActivate() { + return this.activate; + } + + @Override + public void setActivate(String activate) { + this.activate = activate; + } + + @Override + public Timestamp getActivityTime() { + return this.activityTime; + } + + @Override + public void setActivityTime(Timestamp activityTime) { + this.activityTime = activityTime; + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("WorkflowUserActivity ("); + + sb.append(uid); + sb.append(", ").append(wid); + sb.append(", ").append(ip); + sb.append(", ").append(activate); + sb.append(", ").append(activityTime); + + sb.append(")"); + return sb.toString(); + } + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + @Override + public void from(IWorkflowUserActivity from) { + setUid(from.getUid()); + setWid(from.getWid()); + setIp(from.getIp()); + setActivate(from.getActivate()); + setActivityTime(from.getActivityTime()); + } + + @Override + public E into(E into) { + into.from(this); + return into; + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowUserClones.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowUserClones.java new file mode 100644 index 00000000000..9a75d18c508 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowUserClones.java @@ -0,0 +1,84 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.pojos; + + +import edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowUserClones; + +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowUserClones implements IWorkflowUserClones { + + private static final long serialVersionUID = -1977537463; + + private UInteger uid; + private UInteger wid; + + public WorkflowUserClones() {} + + public WorkflowUserClones(IWorkflowUserClones value) { + this.uid = value.getUid(); + this.wid = value.getWid(); + } + + public WorkflowUserClones( + UInteger uid, + UInteger wid + ) { + this.uid = uid; + this.wid = wid; + } + + @Override + public UInteger getUid() { + return this.uid; + } + + @Override + public void setUid(UInteger uid) { + this.uid = uid; + } + + @Override + public UInteger getWid() { + return this.wid; + } + + @Override + public void setWid(UInteger wid) { + this.wid = wid; + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("WorkflowUserClones ("); + + sb.append(uid); + sb.append(", ").append(wid); + + sb.append(")"); + return sb.toString(); + } + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + @Override + public void from(IWorkflowUserClones from) { + setUid(from.getUid()); + setWid(from.getWid()); + } + + @Override + public E into(E into) { + into.from(this); + return into; + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowUserLikes.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowUserLikes.java new file mode 100644 index 00000000000..9ba51016d1c --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowUserLikes.java @@ -0,0 +1,84 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.pojos; + + +import edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowUserLikes; + +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowUserLikes implements IWorkflowUserLikes { + + private static final long serialVersionUID = 150648739; + + private UInteger uid; + private UInteger wid; + + public WorkflowUserLikes() {} + + public WorkflowUserLikes(IWorkflowUserLikes value) { + this.uid = value.getUid(); + this.wid = value.getWid(); + } + + public WorkflowUserLikes( + UInteger uid, + UInteger wid + ) { + this.uid = uid; + this.wid = wid; + } + + @Override + public UInteger getUid() { + return this.uid; + } + + @Override + public void setUid(UInteger uid) { + this.uid = uid; + } + + @Override + public UInteger getWid() { + return this.wid; + } + + @Override + public void setWid(UInteger wid) { + this.wid = wid; + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("WorkflowUserLikes ("); + + sb.append(uid); + sb.append(", ").append(wid); + + sb.append(")"); + return sb.toString(); + } + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + @Override + public void from(IWorkflowUserLikes from) { + setUid(from.getUid()); + setWid(from.getWid()); + } + + @Override + public E into(E into) { + into.from(this); + return into; + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowViewCount.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowViewCount.java new file mode 100644 index 00000000000..1d127edb1c1 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/pojos/WorkflowViewCount.java @@ -0,0 +1,84 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.pojos; + + +import edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowViewCount; + +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowViewCount implements IWorkflowViewCount { + + private static final long serialVersionUID = -762830743; + + private UInteger wid; + private UInteger viewCount; + + public WorkflowViewCount() {} + + public WorkflowViewCount(IWorkflowViewCount value) { + this.wid = value.getWid(); + this.viewCount = value.getViewCount(); + } + + public WorkflowViewCount( + UInteger wid, + UInteger viewCount + ) { + this.wid = wid; + this.viewCount = viewCount; + } + + @Override + public UInteger getWid() { + return this.wid; + } + + @Override + public void setWid(UInteger wid) { + this.wid = wid; + } + + @Override + public UInteger getViewCount() { + return this.viewCount; + } + + @Override + public void setViewCount(UInteger viewCount) { + this.viewCount = viewCount; + } + + @Override + public String toString() { + StringBuilder sb = new StringBuilder("WorkflowViewCount ("); + + sb.append(wid); + sb.append(", ").append(viewCount); + + sb.append(")"); + return sb.toString(); + } + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + @Override + public void from(IWorkflowViewCount from) { + setWid(from.getWid()); + setViewCount(from.getViewCount()); + } + + @Override + public E into(E into) { + into.from(this); + return into; + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowRuntimeStatisticsRecord.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowRuntimeStatisticsRecord.java new file mode 100644 index 00000000000..34d16261444 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowRuntimeStatisticsRecord.java @@ -0,0 +1,529 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.records; + + +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowRuntimeStatistics; +import edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowRuntimeStatistics; + +import java.sql.Timestamp; + +import org.jooq.Field; +import org.jooq.Record11; +import org.jooq.Record4; +import org.jooq.Row11; +import org.jooq.impl.UpdatableRecordImpl; +import org.jooq.types.UInteger; +import org.jooq.types.ULong; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowRuntimeStatisticsRecord extends UpdatableRecordImpl implements Record11, IWorkflowRuntimeStatistics { + + private static final long serialVersionUID = 101870722; + + /** + * Setter for texera_db.workflow_runtime_statistics.workflow_id. + */ + @Override + public void setWorkflowId(UInteger value) { + set(0, value); + } + + /** + * Getter for texera_db.workflow_runtime_statistics.workflow_id. + */ + @Override + public UInteger getWorkflowId() { + return (UInteger) get(0); + } + + /** + * Setter for texera_db.workflow_runtime_statistics.execution_id. + */ + @Override + public void setExecutionId(UInteger value) { + set(1, value); + } + + /** + * Getter for texera_db.workflow_runtime_statistics.execution_id. + */ + @Override + public UInteger getExecutionId() { + return (UInteger) get(1); + } + + /** + * Setter for texera_db.workflow_runtime_statistics.operator_id. + */ + @Override + public void setOperatorId(String value) { + set(2, value); + } + + /** + * Getter for texera_db.workflow_runtime_statistics.operator_id. + */ + @Override + public String getOperatorId() { + return (String) get(2); + } + + /** + * Setter for texera_db.workflow_runtime_statistics.time. + */ + @Override + public void setTime(Timestamp value) { + set(3, value); + } + + /** + * Getter for texera_db.workflow_runtime_statistics.time. + */ + @Override + public Timestamp getTime() { + return (Timestamp) get(3); + } + + /** + * Setter for texera_db.workflow_runtime_statistics.input_tuple_cnt. + */ + @Override + public void setInputTupleCnt(UInteger value) { + set(4, value); + } + + /** + * Getter for texera_db.workflow_runtime_statistics.input_tuple_cnt. + */ + @Override + public UInteger getInputTupleCnt() { + return (UInteger) get(4); + } + + /** + * Setter for texera_db.workflow_runtime_statistics.output_tuple_cnt. + */ + @Override + public void setOutputTupleCnt(UInteger value) { + set(5, value); + } + + /** + * Getter for texera_db.workflow_runtime_statistics.output_tuple_cnt. + */ + @Override + public UInteger getOutputTupleCnt() { + return (UInteger) get(5); + } + + /** + * Setter for texera_db.workflow_runtime_statistics.status. + */ + @Override + public void setStatus(Byte value) { + set(6, value); + } + + /** + * Getter for texera_db.workflow_runtime_statistics.status. + */ + @Override + public Byte getStatus() { + return (Byte) get(6); + } + + /** + * Setter for texera_db.workflow_runtime_statistics.data_processing_time. + */ + @Override + public void setDataProcessingTime(ULong value) { + set(7, value); + } + + /** + * Getter for texera_db.workflow_runtime_statistics.data_processing_time. + */ + @Override + public ULong getDataProcessingTime() { + return (ULong) get(7); + } + + /** + * Setter for texera_db.workflow_runtime_statistics.control_processing_time. + */ + @Override + public void setControlProcessingTime(ULong value) { + set(8, value); + } + + /** + * Getter for texera_db.workflow_runtime_statistics.control_processing_time. + */ + @Override + public ULong getControlProcessingTime() { + return (ULong) get(8); + } + + /** + * Setter for texera_db.workflow_runtime_statistics.idle_time. + */ + @Override + public void setIdleTime(ULong value) { + set(9, value); + } + + /** + * Getter for texera_db.workflow_runtime_statistics.idle_time. + */ + @Override + public ULong getIdleTime() { + return (ULong) get(9); + } + + /** + * Setter for texera_db.workflow_runtime_statistics.num_workers. + */ + @Override + public void setNumWorkers(UInteger value) { + set(10, value); + } + + /** + * Getter for texera_db.workflow_runtime_statistics.num_workers. + */ + @Override + public UInteger getNumWorkers() { + return (UInteger) get(10); + } + + // ------------------------------------------------------------------------- + // Primary key information + // ------------------------------------------------------------------------- + + @Override + public Record4 key() { + return (Record4) super.key(); + } + + // ------------------------------------------------------------------------- + // Record11 type implementation + // ------------------------------------------------------------------------- + + @Override + public Row11 fieldsRow() { + return (Row11) super.fieldsRow(); + } + + @Override + public Row11 valuesRow() { + return (Row11) super.valuesRow(); + } + + @Override + public Field field1() { + return WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.WORKFLOW_ID; + } + + @Override + public Field field2() { + return WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.EXECUTION_ID; + } + + @Override + public Field field3() { + return WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.OPERATOR_ID; + } + + @Override + public Field field4() { + return WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.TIME; + } + + @Override + public Field field5() { + return WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.INPUT_TUPLE_CNT; + } + + @Override + public Field field6() { + return WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.OUTPUT_TUPLE_CNT; + } + + @Override + public Field field7() { + return WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.STATUS; + } + + @Override + public Field field8() { + return WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.DATA_PROCESSING_TIME; + } + + @Override + public Field field9() { + return WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.CONTROL_PROCESSING_TIME; + } + + @Override + public Field field10() { + return WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.IDLE_TIME; + } + + @Override + public Field field11() { + return WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS.NUM_WORKERS; + } + + @Override + public UInteger component1() { + return getWorkflowId(); + } + + @Override + public UInteger component2() { + return getExecutionId(); + } + + @Override + public String component3() { + return getOperatorId(); + } + + @Override + public Timestamp component4() { + return getTime(); + } + + @Override + public UInteger component5() { + return getInputTupleCnt(); + } + + @Override + public UInteger component6() { + return getOutputTupleCnt(); + } + + @Override + public Byte component7() { + return getStatus(); + } + + @Override + public ULong component8() { + return getDataProcessingTime(); + } + + @Override + public ULong component9() { + return getControlProcessingTime(); + } + + @Override + public ULong component10() { + return getIdleTime(); + } + + @Override + public UInteger component11() { + return getNumWorkers(); + } + + @Override + public UInteger value1() { + return getWorkflowId(); + } + + @Override + public UInteger value2() { + return getExecutionId(); + } + + @Override + public String value3() { + return getOperatorId(); + } + + @Override + public Timestamp value4() { + return getTime(); + } + + @Override + public UInteger value5() { + return getInputTupleCnt(); + } + + @Override + public UInteger value6() { + return getOutputTupleCnt(); + } + + @Override + public Byte value7() { + return getStatus(); + } + + @Override + public ULong value8() { + return getDataProcessingTime(); + } + + @Override + public ULong value9() { + return getControlProcessingTime(); + } + + @Override + public ULong value10() { + return getIdleTime(); + } + + @Override + public UInteger value11() { + return getNumWorkers(); + } + + @Override + public WorkflowRuntimeStatisticsRecord value1(UInteger value) { + setWorkflowId(value); + return this; + } + + @Override + public WorkflowRuntimeStatisticsRecord value2(UInteger value) { + setExecutionId(value); + return this; + } + + @Override + public WorkflowRuntimeStatisticsRecord value3(String value) { + setOperatorId(value); + return this; + } + + @Override + public WorkflowRuntimeStatisticsRecord value4(Timestamp value) { + setTime(value); + return this; + } + + @Override + public WorkflowRuntimeStatisticsRecord value5(UInteger value) { + setInputTupleCnt(value); + return this; + } + + @Override + public WorkflowRuntimeStatisticsRecord value6(UInteger value) { + setOutputTupleCnt(value); + return this; + } + + @Override + public WorkflowRuntimeStatisticsRecord value7(Byte value) { + setStatus(value); + return this; + } + + @Override + public WorkflowRuntimeStatisticsRecord value8(ULong value) { + setDataProcessingTime(value); + return this; + } + + @Override + public WorkflowRuntimeStatisticsRecord value9(ULong value) { + setControlProcessingTime(value); + return this; + } + + @Override + public WorkflowRuntimeStatisticsRecord value10(ULong value) { + setIdleTime(value); + return this; + } + + @Override + public WorkflowRuntimeStatisticsRecord value11(UInteger value) { + setNumWorkers(value); + return this; + } + + @Override + public WorkflowRuntimeStatisticsRecord values(UInteger value1, UInteger value2, String value3, Timestamp value4, UInteger value5, UInteger value6, Byte value7, ULong value8, ULong value9, ULong value10, UInteger value11) { + value1(value1); + value2(value2); + value3(value3); + value4(value4); + value5(value5); + value6(value6); + value7(value7); + value8(value8); + value9(value9); + value10(value10); + value11(value11); + return this; + } + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + @Override + public void from(IWorkflowRuntimeStatistics from) { + setWorkflowId(from.getWorkflowId()); + setExecutionId(from.getExecutionId()); + setOperatorId(from.getOperatorId()); + setTime(from.getTime()); + setInputTupleCnt(from.getInputTupleCnt()); + setOutputTupleCnt(from.getOutputTupleCnt()); + setStatus(from.getStatus()); + setDataProcessingTime(from.getDataProcessingTime()); + setControlProcessingTime(from.getControlProcessingTime()); + setIdleTime(from.getIdleTime()); + setNumWorkers(from.getNumWorkers()); + } + + @Override + public E into(E into) { + into.from(this); + return into; + } + + // ------------------------------------------------------------------------- + // Constructors + // ------------------------------------------------------------------------- + + /** + * Create a detached WorkflowRuntimeStatisticsRecord + */ + public WorkflowRuntimeStatisticsRecord() { + super(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS); + } + + /** + * Create a detached, initialised WorkflowRuntimeStatisticsRecord + */ + public WorkflowRuntimeStatisticsRecord(UInteger workflowId, UInteger executionId, String operatorId, Timestamp time, UInteger inputTupleCnt, UInteger outputTupleCnt, Byte status, ULong dataProcessingTime, ULong controlProcessingTime, ULong idleTime, UInteger numWorkers) { + super(WorkflowRuntimeStatistics.WORKFLOW_RUNTIME_STATISTICS); + + set(0, workflowId); + set(1, executionId); + set(2, operatorId); + set(3, time); + set(4, inputTupleCnt); + set(5, outputTupleCnt); + set(6, status); + set(7, dataProcessingTime); + set(8, controlProcessingTime); + set(9, idleTime); + set(10, numWorkers); + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowUserActivityRecord.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowUserActivityRecord.java new file mode 100644 index 00000000000..228ee95b06b --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowUserActivityRecord.java @@ -0,0 +1,278 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.records; + + +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserActivity; +import edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowUserActivity; + +import java.sql.Timestamp; + +import org.jooq.Field; +import org.jooq.Record5; +import org.jooq.Row5; +import org.jooq.impl.TableRecordImpl; +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowUserActivityRecord extends TableRecordImpl implements Record5, IWorkflowUserActivity { + + private static final long serialVersionUID = 2014169707; + + /** + * Setter for texera_db.workflow_user_activity.uid. + */ + @Override + public void setUid(UInteger value) { + set(0, value); + } + + /** + * Getter for texera_db.workflow_user_activity.uid. + */ + @Override + public UInteger getUid() { + return (UInteger) get(0); + } + + /** + * Setter for texera_db.workflow_user_activity.wid. + */ + @Override + public void setWid(UInteger value) { + set(1, value); + } + + /** + * Getter for texera_db.workflow_user_activity.wid. + */ + @Override + public UInteger getWid() { + return (UInteger) get(1); + } + + /** + * Setter for texera_db.workflow_user_activity.ip. + */ + @Override + public void setIp(String value) { + set(2, value); + } + + /** + * Getter for texera_db.workflow_user_activity.ip. + */ + @Override + public String getIp() { + return (String) get(2); + } + + /** + * Setter for texera_db.workflow_user_activity.activate. + */ + @Override + public void setActivate(String value) { + set(3, value); + } + + /** + * Getter for texera_db.workflow_user_activity.activate. + */ + @Override + public String getActivate() { + return (String) get(3); + } + + /** + * Setter for texera_db.workflow_user_activity.activity_time. + */ + @Override + public void setActivityTime(Timestamp value) { + set(4, value); + } + + /** + * Getter for texera_db.workflow_user_activity.activity_time. + */ + @Override + public Timestamp getActivityTime() { + return (Timestamp) get(4); + } + + // ------------------------------------------------------------------------- + // Record5 type implementation + // ------------------------------------------------------------------------- + + @Override + public Row5 fieldsRow() { + return (Row5) super.fieldsRow(); + } + + @Override + public Row5 valuesRow() { + return (Row5) super.valuesRow(); + } + + @Override + public Field field1() { + return WorkflowUserActivity.WORKFLOW_USER_ACTIVITY.UID; + } + + @Override + public Field field2() { + return WorkflowUserActivity.WORKFLOW_USER_ACTIVITY.WID; + } + + @Override + public Field field3() { + return WorkflowUserActivity.WORKFLOW_USER_ACTIVITY.IP; + } + + @Override + public Field field4() { + return WorkflowUserActivity.WORKFLOW_USER_ACTIVITY.ACTIVATE; + } + + @Override + public Field field5() { + return WorkflowUserActivity.WORKFLOW_USER_ACTIVITY.ACTIVITY_TIME; + } + + @Override + public UInteger component1() { + return getUid(); + } + + @Override + public UInteger component2() { + return getWid(); + } + + @Override + public String component3() { + return getIp(); + } + + @Override + public String component4() { + return getActivate(); + } + + @Override + public Timestamp component5() { + return getActivityTime(); + } + + @Override + public UInteger value1() { + return getUid(); + } + + @Override + public UInteger value2() { + return getWid(); + } + + @Override + public String value3() { + return getIp(); + } + + @Override + public String value4() { + return getActivate(); + } + + @Override + public Timestamp value5() { + return getActivityTime(); + } + + @Override + public WorkflowUserActivityRecord value1(UInteger value) { + setUid(value); + return this; + } + + @Override + public WorkflowUserActivityRecord value2(UInteger value) { + setWid(value); + return this; + } + + @Override + public WorkflowUserActivityRecord value3(String value) { + setIp(value); + return this; + } + + @Override + public WorkflowUserActivityRecord value4(String value) { + setActivate(value); + return this; + } + + @Override + public WorkflowUserActivityRecord value5(Timestamp value) { + setActivityTime(value); + return this; + } + + @Override + public WorkflowUserActivityRecord values(UInteger value1, UInteger value2, String value3, String value4, Timestamp value5) { + value1(value1); + value2(value2); + value3(value3); + value4(value4); + value5(value5); + return this; + } + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + @Override + public void from(IWorkflowUserActivity from) { + setUid(from.getUid()); + setWid(from.getWid()); + setIp(from.getIp()); + setActivate(from.getActivate()); + setActivityTime(from.getActivityTime()); + } + + @Override + public E into(E into) { + into.from(this); + return into; + } + + // ------------------------------------------------------------------------- + // Constructors + // ------------------------------------------------------------------------- + + /** + * Create a detached WorkflowUserActivityRecord + */ + public WorkflowUserActivityRecord() { + super(WorkflowUserActivity.WORKFLOW_USER_ACTIVITY); + } + + /** + * Create a detached, initialised WorkflowUserActivityRecord + */ + public WorkflowUserActivityRecord(UInteger uid, UInteger wid, String ip, String activate, Timestamp activityTime) { + super(WorkflowUserActivity.WORKFLOW_USER_ACTIVITY); + + set(0, uid); + set(1, wid); + set(2, ip); + set(3, activate); + set(4, activityTime); + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowUserClonesRecord.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowUserClonesRecord.java new file mode 100644 index 00000000000..1d331602c14 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowUserClonesRecord.java @@ -0,0 +1,165 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.records; + + +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserClones; +import edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowUserClones; + +import org.jooq.Field; +import org.jooq.Record2; +import org.jooq.Row2; +import org.jooq.impl.UpdatableRecordImpl; +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowUserClonesRecord extends UpdatableRecordImpl implements Record2, IWorkflowUserClones { + + private static final long serialVersionUID = 695281574; + + /** + * Setter for texera_db.workflow_user_clones.uid. + */ + @Override + public void setUid(UInteger value) { + set(0, value); + } + + /** + * Getter for texera_db.workflow_user_clones.uid. + */ + @Override + public UInteger getUid() { + return (UInteger) get(0); + } + + /** + * Setter for texera_db.workflow_user_clones.wid. + */ + @Override + public void setWid(UInteger value) { + set(1, value); + } + + /** + * Getter for texera_db.workflow_user_clones.wid. + */ + @Override + public UInteger getWid() { + return (UInteger) get(1); + } + + // ------------------------------------------------------------------------- + // Primary key information + // ------------------------------------------------------------------------- + + @Override + public Record2 key() { + return (Record2) super.key(); + } + + // ------------------------------------------------------------------------- + // Record2 type implementation + // ------------------------------------------------------------------------- + + @Override + public Row2 fieldsRow() { + return (Row2) super.fieldsRow(); + } + + @Override + public Row2 valuesRow() { + return (Row2) super.valuesRow(); + } + + @Override + public Field field1() { + return WorkflowUserClones.WORKFLOW_USER_CLONES.UID; + } + + @Override + public Field field2() { + return WorkflowUserClones.WORKFLOW_USER_CLONES.WID; + } + + @Override + public UInteger component1() { + return getUid(); + } + + @Override + public UInteger component2() { + return getWid(); + } + + @Override + public UInteger value1() { + return getUid(); + } + + @Override + public UInteger value2() { + return getWid(); + } + + @Override + public WorkflowUserClonesRecord value1(UInteger value) { + setUid(value); + return this; + } + + @Override + public WorkflowUserClonesRecord value2(UInteger value) { + setWid(value); + return this; + } + + @Override + public WorkflowUserClonesRecord values(UInteger value1, UInteger value2) { + value1(value1); + value2(value2); + return this; + } + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + @Override + public void from(IWorkflowUserClones from) { + setUid(from.getUid()); + setWid(from.getWid()); + } + + @Override + public E into(E into) { + into.from(this); + return into; + } + + // ------------------------------------------------------------------------- + // Constructors + // ------------------------------------------------------------------------- + + /** + * Create a detached WorkflowUserClonesRecord + */ + public WorkflowUserClonesRecord() { + super(WorkflowUserClones.WORKFLOW_USER_CLONES); + } + + /** + * Create a detached, initialised WorkflowUserClonesRecord + */ + public WorkflowUserClonesRecord(UInteger uid, UInteger wid) { + super(WorkflowUserClones.WORKFLOW_USER_CLONES); + + set(0, uid); + set(1, wid); + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowUserLikesRecord.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowUserLikesRecord.java new file mode 100644 index 00000000000..fce1877f349 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowUserLikesRecord.java @@ -0,0 +1,165 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.records; + + +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowUserLikes; +import edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowUserLikes; + +import org.jooq.Field; +import org.jooq.Record2; +import org.jooq.Row2; +import org.jooq.impl.UpdatableRecordImpl; +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowUserLikesRecord extends UpdatableRecordImpl implements Record2, IWorkflowUserLikes { + + private static final long serialVersionUID = -1808144318; + + /** + * Setter for texera_db.workflow_user_likes.uid. + */ + @Override + public void setUid(UInteger value) { + set(0, value); + } + + /** + * Getter for texera_db.workflow_user_likes.uid. + */ + @Override + public UInteger getUid() { + return (UInteger) get(0); + } + + /** + * Setter for texera_db.workflow_user_likes.wid. + */ + @Override + public void setWid(UInteger value) { + set(1, value); + } + + /** + * Getter for texera_db.workflow_user_likes.wid. + */ + @Override + public UInteger getWid() { + return (UInteger) get(1); + } + + // ------------------------------------------------------------------------- + // Primary key information + // ------------------------------------------------------------------------- + + @Override + public Record2 key() { + return (Record2) super.key(); + } + + // ------------------------------------------------------------------------- + // Record2 type implementation + // ------------------------------------------------------------------------- + + @Override + public Row2 fieldsRow() { + return (Row2) super.fieldsRow(); + } + + @Override + public Row2 valuesRow() { + return (Row2) super.valuesRow(); + } + + @Override + public Field field1() { + return WorkflowUserLikes.WORKFLOW_USER_LIKES.UID; + } + + @Override + public Field field2() { + return WorkflowUserLikes.WORKFLOW_USER_LIKES.WID; + } + + @Override + public UInteger component1() { + return getUid(); + } + + @Override + public UInteger component2() { + return getWid(); + } + + @Override + public UInteger value1() { + return getUid(); + } + + @Override + public UInteger value2() { + return getWid(); + } + + @Override + public WorkflowUserLikesRecord value1(UInteger value) { + setUid(value); + return this; + } + + @Override + public WorkflowUserLikesRecord value2(UInteger value) { + setWid(value); + return this; + } + + @Override + public WorkflowUserLikesRecord values(UInteger value1, UInteger value2) { + value1(value1); + value2(value2); + return this; + } + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + @Override + public void from(IWorkflowUserLikes from) { + setUid(from.getUid()); + setWid(from.getWid()); + } + + @Override + public E into(E into) { + into.from(this); + return into; + } + + // ------------------------------------------------------------------------- + // Constructors + // ------------------------------------------------------------------------- + + /** + * Create a detached WorkflowUserLikesRecord + */ + public WorkflowUserLikesRecord() { + super(WorkflowUserLikes.WORKFLOW_USER_LIKES); + } + + /** + * Create a detached, initialised WorkflowUserLikesRecord + */ + public WorkflowUserLikesRecord(UInteger uid, UInteger wid) { + super(WorkflowUserLikes.WORKFLOW_USER_LIKES); + + set(0, uid); + set(1, wid); + } +} diff --git a/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowViewCountRecord.java b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowViewCountRecord.java new file mode 100644 index 00000000000..b6621839bb1 --- /dev/null +++ b/core/micro-services/dao/src/main/scala/edu/uci/ics/texera/dao/jooq/generated/tables/records/WorkflowViewCountRecord.java @@ -0,0 +1,166 @@ +/* + * This file is generated by jOOQ. + */ +package edu.uci.ics.texera.dao.jooq.generated.tables.records; + + +import edu.uci.ics.texera.dao.jooq.generated.tables.WorkflowViewCount; +import edu.uci.ics.texera.dao.jooq.generated.tables.interfaces.IWorkflowViewCount; + +import org.jooq.Field; +import org.jooq.Record1; +import org.jooq.Record2; +import org.jooq.Row2; +import org.jooq.impl.UpdatableRecordImpl; +import org.jooq.types.UInteger; + + +/** + * This class is generated by jOOQ. + */ +@SuppressWarnings({ "all", "unchecked", "rawtypes" }) +public class WorkflowViewCountRecord extends UpdatableRecordImpl implements Record2, IWorkflowViewCount { + + private static final long serialVersionUID = 1060055745; + + /** + * Setter for texera_db.workflow_view_count.wid. + */ + @Override + public void setWid(UInteger value) { + set(0, value); + } + + /** + * Getter for texera_db.workflow_view_count.wid. + */ + @Override + public UInteger getWid() { + return (UInteger) get(0); + } + + /** + * Setter for texera_db.workflow_view_count.view_count. + */ + @Override + public void setViewCount(UInteger value) { + set(1, value); + } + + /** + * Getter for texera_db.workflow_view_count.view_count. + */ + @Override + public UInteger getViewCount() { + return (UInteger) get(1); + } + + // ------------------------------------------------------------------------- + // Primary key information + // ------------------------------------------------------------------------- + + @Override + public Record1 key() { + return (Record1) super.key(); + } + + // ------------------------------------------------------------------------- + // Record2 type implementation + // ------------------------------------------------------------------------- + + @Override + public Row2 fieldsRow() { + return (Row2) super.fieldsRow(); + } + + @Override + public Row2 valuesRow() { + return (Row2) super.valuesRow(); + } + + @Override + public Field field1() { + return WorkflowViewCount.WORKFLOW_VIEW_COUNT.WID; + } + + @Override + public Field field2() { + return WorkflowViewCount.WORKFLOW_VIEW_COUNT.VIEW_COUNT; + } + + @Override + public UInteger component1() { + return getWid(); + } + + @Override + public UInteger component2() { + return getViewCount(); + } + + @Override + public UInteger value1() { + return getWid(); + } + + @Override + public UInteger value2() { + return getViewCount(); + } + + @Override + public WorkflowViewCountRecord value1(UInteger value) { + setWid(value); + return this; + } + + @Override + public WorkflowViewCountRecord value2(UInteger value) { + setViewCount(value); + return this; + } + + @Override + public WorkflowViewCountRecord values(UInteger value1, UInteger value2) { + value1(value1); + value2(value2); + return this; + } + + // ------------------------------------------------------------------------- + // FROM and INTO + // ------------------------------------------------------------------------- + + @Override + public void from(IWorkflowViewCount from) { + setWid(from.getWid()); + setViewCount(from.getViewCount()); + } + + @Override + public E into(E into) { + into.from(this); + return into; + } + + // ------------------------------------------------------------------------- + // Constructors + // ------------------------------------------------------------------------- + + /** + * Create a detached WorkflowViewCountRecord + */ + public WorkflowViewCountRecord() { + super(WorkflowViewCount.WORKFLOW_VIEW_COUNT); + } + + /** + * Create a detached, initialised WorkflowViewCountRecord + */ + public WorkflowViewCountRecord(UInteger wid, UInteger viewCount) { + super(WorkflowViewCount.WORKFLOW_VIEW_COUNT); + + set(0, wid); + set(1, viewCount); + } +}