Commit 8242de30 by Shwetha GS

fixed multiplicity in hive model

parent f2b81b65
...@@ -452,8 +452,9 @@ public class HiveDataModelGenerator { ...@@ -452,8 +452,9 @@ public class HiveDataModelGenerator {
Multiplicity.REQUIRED, false, null), Multiplicity.REQUIRED, false, null),
new AttributeDefinition("functionType", HiveDataTypes.HIVE_FUNCTION_TYPE.getName(), new AttributeDefinition("functionType", HiveDataTypes.HIVE_FUNCTION_TYPE.getName(),
Multiplicity.REQUIRED, false, null), Multiplicity.REQUIRED, false, null),
new AttributeDefinition("resourceUris", HiveDataTypes.HIVE_RESOURCEURI.getName(), new AttributeDefinition("resourceUris",
Multiplicity.COLLECTION, false, null), DataTypes.arrayTypeName(HiveDataTypes.HIVE_RESOURCEURI.getName()), Multiplicity.OPTIONAL, false,
null),
}; };
HierarchicalTypeDefinition<ClassType> definition = new HierarchicalTypeDefinition<>( HierarchicalTypeDefinition<ClassType> definition = new HierarchicalTypeDefinition<>(
......
...@@ -62,8 +62,8 @@ public class HiveHookIT { ...@@ -62,8 +62,8 @@ public class HiveHookIT {
hiveConf.set("javax.jdo.option.ConnectionURL", "jdbc:derby:./target/metastore_db;create=true"); hiveConf.set("javax.jdo.option.ConnectionURL", "jdbc:derby:./target/metastore_db;create=true");
hiveConf.set("hive.hook.dgi.synchronous", "true"); hiveConf.set("hive.hook.dgi.synchronous", "true");
hiveConf.set(HiveMetaStoreBridge.HIVE_CLUSTER_NAME, CLUSTER_NAME); hiveConf.set(HiveMetaStoreBridge.HIVE_CLUSTER_NAME, CLUSTER_NAME);
//weird, hive prepends test_ to table name hiveConf.setBoolVar(HiveConf.ConfVars.HIVETESTMODE, true); //to not use hdfs
hiveConf.set("hive.test.mode", "true"); hiveConf.setVar(HiveConf.ConfVars.HIVETESTMODEPREFIX, "");
hiveConf.set("fs.pfile.impl", "org.apache.hadoop.fs.ProxyLocalFileSystem"); hiveConf.set("fs.pfile.impl", "org.apache.hadoop.fs.ProxyLocalFileSystem");
return hiveConf; return hiveConf;
} }
...@@ -127,7 +127,7 @@ public class HiveHookIT { ...@@ -127,7 +127,7 @@ public class HiveHookIT {
@Test @Test
public void testLoadData() throws Exception { public void testLoadData() throws Exception {
String tableName = "table" + random(); String tableName = "table" + random();
runCommand("create table test_" + tableName + "(id int, name string)"); runCommand("create table " + tableName + "(id int, name string)");
String loadFile = file("load"); String loadFile = file("load");
String query = "load data local inpath 'file://" + loadFile + "' into table " + tableName; String query = "load data local inpath 'file://" + loadFile + "' into table " + tableName;
...@@ -142,14 +142,14 @@ public class HiveHookIT { ...@@ -142,14 +142,14 @@ public class HiveHookIT {
runCommand("create table " + tableName + "(id int, name string) partitioned by(dt string)"); runCommand("create table " + tableName + "(id int, name string) partitioned by(dt string)");
String insertTableName = "table" + random(); String insertTableName = "table" + random();
runCommand("create table test_" + insertTableName + "(name string) partitioned by(dt string)"); runCommand("create table " + insertTableName + "(name string) partitioned by(dt string)");
String query = "insert into " + insertTableName + " partition(dt = '2015-01-01') select name from " String query = "insert into " + insertTableName + " partition(dt = '2015-01-01') select name from "
+ tableName + " where dt = '2015-01-01'"; + tableName + " where dt = '2015-01-01'";
runCommand(query); runCommand(query);
assertProcessIsRegistered(query); assertProcessIsRegistered(query);
assertPartitionIsRegistered("default", "test_" + insertTableName, "2015-01-01"); assertPartitionIsRegistered("default", insertTableName, "2015-01-01");
} }
private String random() { private String random() {
...@@ -173,7 +173,7 @@ public class HiveHookIT { ...@@ -173,7 +173,7 @@ public class HiveHookIT {
@Test @Test
public void testExportImport() throws Exception { public void testExportImport() throws Exception {
String tableName = "table" + random(); String tableName = "table" + random();
runCommand("create table test_" + tableName + "(name string)"); runCommand("create table " + tableName + "(name string)");
String filename = "pfile://" + mkdir("export"); String filename = "pfile://" + mkdir("export");
String query = "export table " + tableName + " to '" + filename + "'"; String query = "export table " + tableName + " to '" + filename + "'";
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment