You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by ra...@apache.org on 2014/10/07 08:28:32 UTC
git commit: PHOENIX-1315-Test Load from Index table.
Repository: phoenix
Updated Branches:
refs/heads/master 7dbd3503b -> e35503374
PHOENIX-1315-Test Load from Index table.
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/e3550337
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/e3550337
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/e3550337
Branch: refs/heads/master
Commit: e35503374393b0428f4e6603c8e05d87a073e3c3
Parents: 7dbd350
Author: ravimagham <ra...@apache.org>
Authored: Mon Oct 6 20:25:20 2014 -0700
Committer: ravimagham <ra...@apache.org>
Committed: Mon Oct 6 20:25:20 2014 -0700
----------------------------------------------------------------------
.../phoenix/pig/PhoenixHBaseLoaderIT.java | 39 +++++++++++++++++++-
1 file changed, 38 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/e3550337/phoenix-pig/src/it/java/org/apache/phoenix/pig/PhoenixHBaseLoaderIT.java
----------------------------------------------------------------------
diff --git a/phoenix-pig/src/it/java/org/apache/phoenix/pig/PhoenixHBaseLoaderIT.java b/phoenix-pig/src/it/java/org/apache/phoenix/pig/PhoenixHBaseLoaderIT.java
index 4801d63..82a35d9 100644
--- a/phoenix-pig/src/it/java/org/apache/phoenix/pig/PhoenixHBaseLoaderIT.java
+++ b/phoenix-pig/src/it/java/org/apache/phoenix/pig/PhoenixHBaseLoaderIT.java
@@ -72,6 +72,7 @@ public class PhoenixHBaseLoaderIT {
private static final Log LOG = LogFactory.getLog(PhoenixHBaseLoaderIT.class);
private static final String SCHEMA_NAME = "T";
private static final String TABLE_NAME = "A";
+ private static final String INDEX_NAME = "I";
private static final String TABLE_FULL_NAME = SchemaUtil.getTableName(SCHEMA_NAME, TABLE_NAME);
private static HBaseTestingUtility hbaseTestUtil;
private static String zkQuorum;
@@ -563,6 +564,42 @@ public class PhoenixHBaseLoaderIT {
}
}
+ @Test
+ public void testDataFromIndexTable() throws Exception {
+ try {
+ //create the table
+ String ddl = "CREATE TABLE " + TABLE_NAME
+ + " (ID INTEGER NOT NULL, NAME VARCHAR NOT NULL, EMPLID INTEGER CONSTRAINT pk PRIMARY KEY (ID, NAME)) IMMUTABLE_ROWS=true";
+
+ conn.createStatement().execute(ddl);
+
+ //create a index table
+ String indexDdl = " CREATE INDEX " + INDEX_NAME + " ON " + TABLE_NAME + " (EMPLID) INCLUDE (NAME) ";
+ conn.createStatement().execute(indexDdl);
+
+ //upsert the data.
+ final String dml = "UPSERT INTO " + TABLE_NAME + " VALUES(?,?,?)";
+ PreparedStatement stmt = conn.prepareStatement(dml);
+ int rows = 20;
+ for(int i = 0 ; i < rows; i++) {
+ stmt.setInt(1, i);
+ stmt.setString(2, "a"+i);
+ stmt.setInt(3, i * 5);
+ stmt.execute();
+ }
+ conn.commit();
+ pigServer.registerQuery("A = load 'hbase://query/SELECT NAME , EMPLID FROM A WHERE EMPLID = 25 ' using " + PhoenixHBaseLoader.class.getName() + "('"+zkQuorum + "') ;");
+ Iterator<Tuple> iterator = pigServer.openIterator("A");
+ while (iterator.hasNext()) {
+ Tuple tuple = iterator.next();
+ assertEquals("a5", tuple.get(0));
+ assertEquals(25, tuple.get(1));
+ }
+ } finally {
+ dropTable(TABLE_NAME);
+ dropTable(INDEX_NAME);
+ }
+ }
@After
public void tearDown() throws Exception {
@@ -573,7 +610,7 @@ public class PhoenixHBaseLoaderIT {
private void dropTable(String tableFullName) throws SQLException {
Preconditions.checkNotNull(conn);
- conn.createStatement().execute(String.format("DROP TABLE %s",tableFullName));
+ conn.createStatement().execute(String.format("DROP TABLE IF EXISTS %s",tableFullName));
}
@AfterClass