Skip to content

Commit a9ab48e

Browse files
hfutatzhanghbzhanghaobo@kanzhun.com
andauthored
chore: fix wrong com.lancedb package in Hive2 and Hive3 Namespace (#11)
chore: fix wrong com.lancedb package in Hive2 and Hive3 Namespace. Co-authored-by: zhanghaobo@kanzhun.com <zhanghaobo@kanzhun.com>
1 parent 48b547a commit a9ab48e

2 files changed

Lines changed: 5 additions & 5 deletions

File tree

java/lance-namespace-hive2/src/main/java/org/lance/namespace/hive2/Hive2Namespace.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -467,11 +467,11 @@ protected void doCreateTable(
467467
StorageDescriptor sd = new StorageDescriptor();
468468
sd.setLocation(location);
469469
sd.setCols(Lists.newArrayList());
470-
sd.setInputFormat("com.lancedb.lance.mapred.LanceInputFormat");
471-
sd.setOutputFormat("com.lancedb.lance.mapred.LanceOutputFormat");
470+
sd.setInputFormat("org.lance.mapred.LanceInputFormat");
471+
sd.setOutputFormat("org.lance.mapred.LanceOutputFormat");
472472
org.apache.hadoop.hive.metastore.api.SerDeInfo serdeInfo =
473473
new org.apache.hadoop.hive.metastore.api.SerDeInfo();
474-
serdeInfo.setSerializationLib("com.lancedb.lance.mapred.LanceSerDe");
474+
serdeInfo.setSerializationLib("org.lance.mapred.LanceSerDe");
475475
sd.setSerdeInfo(serdeInfo);
476476
table.setSd(sd);
477477

java/lance-namespace-hive3/src/main/java/org/lance/namespace/hive3/Hive3Namespace.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -512,8 +512,8 @@ protected void doCreateTable(
512512
StorageDescriptor sd = new StorageDescriptor();
513513
sd.setLocation(location);
514514
sd.setCols(Lists.newArrayList());
515-
sd.setInputFormat("com.lancedb.lance.mapred.LanceInputFormat");
516-
sd.setOutputFormat("com.lancedb.lance.mapred.LanceOutputFormat");
515+
sd.setInputFormat("org.lance.mapred.LanceInputFormat");
516+
sd.setOutputFormat("org.lance.mapred.LanceOutputFormat");
517517
sd.setSerdeInfo(new org.apache.hadoop.hive.metastore.api.SerDeInfo());
518518
table.setSd(sd);
519519

0 commit comments

Comments
 (0)