[04/21] phoenix git commit: PHOENIX-2715 Query Log (Ankit Singhal)
PHOENIX-2715 Query Log (Ankit Singhal) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/b291068b Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/b291068b Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/b291068b Branch: refs/heads/4.x-cdh5.14 Commit: b291068bc9c6e133c7bcb6dfe52dd4f96a76f2a1 Parents: 4d9cc92 Author: Ankit Singhal Authored: Tue Apr 10 07:53:31 2018 +0100 Committer: Pedro Boado Committed: Fri Apr 13 23:26:16 2018 +0100 -- phoenix-core/pom.xml| 5 + .../end2end/QueryDatabaseMetaDataIT.java| 4 + .../apache/phoenix/end2end/QueryLoggerIT.java | 358 +++ .../end2end/TenantSpecificTablesDDLIT.java | 2 + .../phoenix/compile/StatementContext.java | 10 + .../phoenix/coprocessor/MetaDataProtocol.java | 5 +- .../phoenix/iterate/ScanningResultIterator.java | 18 +- .../apache/phoenix/jdbc/PhoenixConnection.java | 17 +- .../phoenix/jdbc/PhoenixDatabaseMetaData.java | 18 + .../phoenix/jdbc/PhoenixPreparedStatement.java | 11 +- .../apache/phoenix/jdbc/PhoenixResultSet.java | 38 ++ .../apache/phoenix/jdbc/PhoenixStatement.java | 67 +++- .../java/org/apache/phoenix/log/LogLevel.java | 22 ++ .../java/org/apache/phoenix/log/LogWriter.java | 51 +++ .../log/QueryLogDetailsEventHandler.java| 63 .../org/apache/phoenix/log/QueryLogInfo.java| 87 + .../org/apache/phoenix/log/QueryLogState.java | 22 ++ .../org/apache/phoenix/log/QueryLogger.java | 145 .../log/QueryLoggerDefaultExceptionHandler.java | 51 +++ .../phoenix/log/QueryLoggerDisruptor.java | 117 ++ .../org/apache/phoenix/log/QueryLoggerUtil.java | 62 .../org/apache/phoenix/log/RingBufferEvent.java | 93 + .../phoenix/log/RingBufferEventTranslator.java | 53 +++ .../org/apache/phoenix/log/TableLogWriter.java | 125 +++ .../phoenix/monitoring/ReadMetricQueue.java | 44 ++- .../phoenix/monitoring/ScanMetricsHolder.java | 48 ++- .../phoenix/query/ConnectionQueryServices.java | 6 + .../query/ConnectionQueryServicesImpl.java | 35 +- .../query/ConnectionlessQueryServicesImpl.java | 18 + .../query/DelegateConnectionQueryServices.java | 14 + .../apache/phoenix/query/QueryConstants.java| 45 +++ .../org/apache/phoenix/query/QueryServices.java | 4 + .../phoenix/query/QueryServicesOptions.java | 9 +- pom.xml | 6 + 34 files changed, 1612 insertions(+), 61 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/b291068b/phoenix-core/pom.xml -- diff --git a/phoenix-core/pom.xml b/phoenix-core/pom.xml index b07cbbb..8fe8a10 100644 --- a/phoenix-core/pom.xml +++ b/phoenix-core/pom.xml @@ -526,5 +526,10 @@ i18n-util ${i18n-util.version} + +com.lmax +disruptor +${disruptor.version} + http://git-wip-us.apache.org/repos/asf/phoenix/blob/b291068b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java index a1bcf40..54cb5da 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java @@ -166,6 +166,10 @@ public class QueryDatabaseMetaDataIT extends ParallelStatsDisabledIT { assertEquals(PTableType.SYSTEM.toString(), rs.getString("TABLE_TYPE")); assertTrue(rs.next()); assertEquals(SYSTEM_CATALOG_SCHEMA, rs.getString("TABLE_SCHEM")); +assertEquals(PhoenixDatabaseMetaData.SYSTEM_LOG_TABLE, rs.getString("TABLE_NAME")); +assertEquals(PTableType.SYSTEM.toString(), rs.getString("TABLE_TYPE")); +assertTrue(rs.next()); +assertEquals(SYSTEM_CATALOG_SCHEMA, rs.getString("TABLE_SCHEM")); assertEquals(TYPE_SEQUENCE, rs.getString("TABLE_NAME")); assertEquals(PTableType.SYSTEM.toString(), rs.getString("TABLE_TYPE")); assertTrue(rs.next()); http://git-wip-us.apache.org/repos/asf/phoenix/blob/b291068b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryLoggerIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryLoggerIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryLoggerIT.java new file mode 100644 index 000..940ba6f ---
[04/21] phoenix git commit: PHOENIX-2715 Query Log (Ankit Singhal)
PHOENIX-2715 Query Log (Ankit Singhal) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/b291068b Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/b291068b Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/b291068b Branch: refs/heads/4.x-cdh5.13 Commit: b291068bc9c6e133c7bcb6dfe52dd4f96a76f2a1 Parents: 4d9cc92 Author: Ankit Singhal Authored: Tue Apr 10 07:53:31 2018 +0100 Committer: Pedro Boado Committed: Fri Apr 13 23:26:16 2018 +0100 -- phoenix-core/pom.xml| 5 + .../end2end/QueryDatabaseMetaDataIT.java| 4 + .../apache/phoenix/end2end/QueryLoggerIT.java | 358 +++ .../end2end/TenantSpecificTablesDDLIT.java | 2 + .../phoenix/compile/StatementContext.java | 10 + .../phoenix/coprocessor/MetaDataProtocol.java | 5 +- .../phoenix/iterate/ScanningResultIterator.java | 18 +- .../apache/phoenix/jdbc/PhoenixConnection.java | 17 +- .../phoenix/jdbc/PhoenixDatabaseMetaData.java | 18 + .../phoenix/jdbc/PhoenixPreparedStatement.java | 11 +- .../apache/phoenix/jdbc/PhoenixResultSet.java | 38 ++ .../apache/phoenix/jdbc/PhoenixStatement.java | 67 +++- .../java/org/apache/phoenix/log/LogLevel.java | 22 ++ .../java/org/apache/phoenix/log/LogWriter.java | 51 +++ .../log/QueryLogDetailsEventHandler.java| 63 .../org/apache/phoenix/log/QueryLogInfo.java| 87 + .../org/apache/phoenix/log/QueryLogState.java | 22 ++ .../org/apache/phoenix/log/QueryLogger.java | 145 .../log/QueryLoggerDefaultExceptionHandler.java | 51 +++ .../phoenix/log/QueryLoggerDisruptor.java | 117 ++ .../org/apache/phoenix/log/QueryLoggerUtil.java | 62 .../org/apache/phoenix/log/RingBufferEvent.java | 93 + .../phoenix/log/RingBufferEventTranslator.java | 53 +++ .../org/apache/phoenix/log/TableLogWriter.java | 125 +++ .../phoenix/monitoring/ReadMetricQueue.java | 44 ++- .../phoenix/monitoring/ScanMetricsHolder.java | 48 ++- .../phoenix/query/ConnectionQueryServices.java | 6 + .../query/ConnectionQueryServicesImpl.java | 35 +- .../query/ConnectionlessQueryServicesImpl.java | 18 + .../query/DelegateConnectionQueryServices.java | 14 + .../apache/phoenix/query/QueryConstants.java| 45 +++ .../org/apache/phoenix/query/QueryServices.java | 4 + .../phoenix/query/QueryServicesOptions.java | 9 +- pom.xml | 6 + 34 files changed, 1612 insertions(+), 61 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/b291068b/phoenix-core/pom.xml -- diff --git a/phoenix-core/pom.xml b/phoenix-core/pom.xml index b07cbbb..8fe8a10 100644 --- a/phoenix-core/pom.xml +++ b/phoenix-core/pom.xml @@ -526,5 +526,10 @@ i18n-util ${i18n-util.version} + +com.lmax +disruptor +${disruptor.version} + http://git-wip-us.apache.org/repos/asf/phoenix/blob/b291068b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java index a1bcf40..54cb5da 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java @@ -166,6 +166,10 @@ public class QueryDatabaseMetaDataIT extends ParallelStatsDisabledIT { assertEquals(PTableType.SYSTEM.toString(), rs.getString("TABLE_TYPE")); assertTrue(rs.next()); assertEquals(SYSTEM_CATALOG_SCHEMA, rs.getString("TABLE_SCHEM")); +assertEquals(PhoenixDatabaseMetaData.SYSTEM_LOG_TABLE, rs.getString("TABLE_NAME")); +assertEquals(PTableType.SYSTEM.toString(), rs.getString("TABLE_TYPE")); +assertTrue(rs.next()); +assertEquals(SYSTEM_CATALOG_SCHEMA, rs.getString("TABLE_SCHEM")); assertEquals(TYPE_SEQUENCE, rs.getString("TABLE_NAME")); assertEquals(PTableType.SYSTEM.toString(), rs.getString("TABLE_TYPE")); assertTrue(rs.next()); http://git-wip-us.apache.org/repos/asf/phoenix/blob/b291068b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryLoggerIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryLoggerIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryLoggerIT.java new file mode 100644 index 000..940ba6f ---
[04/21] phoenix git commit: PHOENIX-2715 Query Log (Ankit Singhal)
PHOENIX-2715 Query Log (Ankit Singhal) Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/b291068b Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/b291068b Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/b291068b Branch: refs/heads/4.x-cdh5.12 Commit: b291068bc9c6e133c7bcb6dfe52dd4f96a76f2a1 Parents: 4d9cc92 Author: Ankit Singhal Authored: Tue Apr 10 07:53:31 2018 +0100 Committer: Pedro Boado Committed: Fri Apr 13 23:26:16 2018 +0100 -- phoenix-core/pom.xml| 5 + .../end2end/QueryDatabaseMetaDataIT.java| 4 + .../apache/phoenix/end2end/QueryLoggerIT.java | 358 +++ .../end2end/TenantSpecificTablesDDLIT.java | 2 + .../phoenix/compile/StatementContext.java | 10 + .../phoenix/coprocessor/MetaDataProtocol.java | 5 +- .../phoenix/iterate/ScanningResultIterator.java | 18 +- .../apache/phoenix/jdbc/PhoenixConnection.java | 17 +- .../phoenix/jdbc/PhoenixDatabaseMetaData.java | 18 + .../phoenix/jdbc/PhoenixPreparedStatement.java | 11 +- .../apache/phoenix/jdbc/PhoenixResultSet.java | 38 ++ .../apache/phoenix/jdbc/PhoenixStatement.java | 67 +++- .../java/org/apache/phoenix/log/LogLevel.java | 22 ++ .../java/org/apache/phoenix/log/LogWriter.java | 51 +++ .../log/QueryLogDetailsEventHandler.java| 63 .../org/apache/phoenix/log/QueryLogInfo.java| 87 + .../org/apache/phoenix/log/QueryLogState.java | 22 ++ .../org/apache/phoenix/log/QueryLogger.java | 145 .../log/QueryLoggerDefaultExceptionHandler.java | 51 +++ .../phoenix/log/QueryLoggerDisruptor.java | 117 ++ .../org/apache/phoenix/log/QueryLoggerUtil.java | 62 .../org/apache/phoenix/log/RingBufferEvent.java | 93 + .../phoenix/log/RingBufferEventTranslator.java | 53 +++ .../org/apache/phoenix/log/TableLogWriter.java | 125 +++ .../phoenix/monitoring/ReadMetricQueue.java | 44 ++- .../phoenix/monitoring/ScanMetricsHolder.java | 48 ++- .../phoenix/query/ConnectionQueryServices.java | 6 + .../query/ConnectionQueryServicesImpl.java | 35 +- .../query/ConnectionlessQueryServicesImpl.java | 18 + .../query/DelegateConnectionQueryServices.java | 14 + .../apache/phoenix/query/QueryConstants.java| 45 +++ .../org/apache/phoenix/query/QueryServices.java | 4 + .../phoenix/query/QueryServicesOptions.java | 9 +- pom.xml | 6 + 34 files changed, 1612 insertions(+), 61 deletions(-) -- http://git-wip-us.apache.org/repos/asf/phoenix/blob/b291068b/phoenix-core/pom.xml -- diff --git a/phoenix-core/pom.xml b/phoenix-core/pom.xml index b07cbbb..8fe8a10 100644 --- a/phoenix-core/pom.xml +++ b/phoenix-core/pom.xml @@ -526,5 +526,10 @@ i18n-util ${i18n-util.version} + +com.lmax +disruptor +${disruptor.version} + http://git-wip-us.apache.org/repos/asf/phoenix/blob/b291068b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java index a1bcf40..54cb5da 100644 --- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java +++ b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryDatabaseMetaDataIT.java @@ -166,6 +166,10 @@ public class QueryDatabaseMetaDataIT extends ParallelStatsDisabledIT { assertEquals(PTableType.SYSTEM.toString(), rs.getString("TABLE_TYPE")); assertTrue(rs.next()); assertEquals(SYSTEM_CATALOG_SCHEMA, rs.getString("TABLE_SCHEM")); +assertEquals(PhoenixDatabaseMetaData.SYSTEM_LOG_TABLE, rs.getString("TABLE_NAME")); +assertEquals(PTableType.SYSTEM.toString(), rs.getString("TABLE_TYPE")); +assertTrue(rs.next()); +assertEquals(SYSTEM_CATALOG_SCHEMA, rs.getString("TABLE_SCHEM")); assertEquals(TYPE_SEQUENCE, rs.getString("TABLE_NAME")); assertEquals(PTableType.SYSTEM.toString(), rs.getString("TABLE_TYPE")); assertTrue(rs.next()); http://git-wip-us.apache.org/repos/asf/phoenix/blob/b291068b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryLoggerIT.java -- diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryLoggerIT.java b/phoenix-core/src/it/java/org/apache/phoenix/end2end/QueryLoggerIT.java new file mode 100644 index 000..940ba6f ---