This is an automated email from the ASF dual-hosted git repository.
yanxinyi pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/phoenix.git
The following commit(s) were added to refs/heads/master by this push:
new 260520d PHOENIX-5592 Addendum for removing local test file
260520d is described below
commit 260520d5c1d2d38d27808fed59c1e4792b2c6942
Author: Xinyi Yan <yanxi...@apache.org>
AuthorDate: Tue Dec 29 23:25:45 2020 -0800
PHOENIX-5592 Addendum for removing local test file
Signed-off-by: Xinyi Yan <yanxi...@apache.org>
---
.../it/java/org/apache/phoenix/end2end/Dummy.java | 70 ----------------------
1 file changed, 70 deletions(-)
diff --git a/phoenix-core/src/it/java/org/apache/phoenix/end2end/Dummy.java
b/phoenix-core/src/it/java/org/apache/phoenix/end2end/Dummy.java
deleted file mode 100644
index 4f833bf..0000000
--- a/phoenix-core/src/it/java/org/apache/phoenix/end2end/Dummy.java
+++ /dev/null
@@ -1,70 +0,0 @@
-package org.apache.phoenix.end2end;
-
-import org.apache.hadoop.hbase.HTableDescriptor;
-import org.apache.hadoop.hbase.TableName;
-import org.apache.hadoop.hbase.client.HBaseAdmin;
-//import org.apache.phoenix.coprocessor.SyscatRegionObserver;
-import org.apache.phoenix.jdbc.PhoenixConnection;
-import org.apache.phoenix.jdbc.PhoenixDatabaseMetaData;
-import org.apache.phoenix.query.QueryServices;
-import org.apache.phoenix.query.QueryServicesOptions;
-import org.apache.phoenix.util.ReadOnlyProps;
-import org.apache.phoenix.util.SchemaUtil;
-import org.junit.Test;
-
-import java.sql.Connection;
-import java.sql.DriverManager;
-import java.sql.ResultSet;
-
-public class Dummy {
- @Test
- public void test() throws Exception {
- try (Connection conn =
DriverManager.getConnection("jdbc:phoenix:localhost")) {
-//
-// try (HBaseAdmin admin = conn.unwrap(PhoenixConnection.class)
-// .getQueryServices().getAdmin()) {
-// HTableDescriptor htd;
-// TableName syscatPhysicalTableName =
SchemaUtil.getPhysicalTableName(
-// PhoenixDatabaseMetaData.SYSTEM_CATALOG_NAME,
ReadOnlyProps.EMPTY_PROPS);
-// htd = admin.getTableDescriptor(syscatPhysicalTableName);
-//
-// if
(!htd.hasCoprocessor(SyscatRegionObserver.class.getName())) {
-//// admin.disableTable(syscatPhysicalTableName);
-////
admin.getTableRegions(syscatPhysicalTableName).get(0).setOffline(true);
-// int priority =
ReadOnlyProps.EMPTY_PROPS.getInt(QueryServices.COPROCESSOR_PRIORITY_ATTRIB,
-//
QueryServicesOptions.DEFAULT_COPROCESSOR_PRIORITY);
-// htd.addCoprocessor(SyscatRegionObserver.class.getName(),
null, priority-2, null);
-// admin.modifyTable(syscatPhysicalTableName, htd);
-//// pollForUpdatedTableDescriptor(admin, htd,
syscatPhysicalTableName.getName());
-//// admin.enableTable(syscatPhysicalTableName);
-////
admin.getTableRegions(syscatPhysicalTableName).get(0).setOffline(false);
-// }
-// }
-
-// ResultSet rs = conn.createStatement().executeQuery("SELECT *
FROM SYSTEM.CATALOG WHERE TABLE_NAME=''");
-// while (rs.next()) {
-//
-// }
-//
-//
-// String ddl =
-// "SELECT TABLE_NAME,VIEW_INDEX_ID,VIEW_INDEX_ID_DATA_TYPE
" +
-// "FROM SYSTEM.CATALOG WHERE COLUMN_COUNT IS NOT
NULL";
-// rs = conn.createStatement().executeQuery(ddl);
-// while (rs.next()) {
-// String tablename = rs.getString(1);
-// int viewType = rs.getInt(3);
-// long viewId;
-// String type;
-// try {
-// viewId = rs.getShort(2);
-// type = "short";
-// } catch (Exception e) {
-// viewId = rs.getLong(2);
-// type = "long";
-// }
-// System.out.println(tablename + "," + viewId + "," + viewType
+","+ type);
-// }
- }
- }
-}
