'delete operation on hive delta lake table
I Have created delta table on hive
CREATE EXTERNAL TABLE delta_hive_test(col1 string, col2 int, col3 string)
STORED BY 'io.delta.hive.DeltaStorageHandler'
LOCATION 'maprfs://path/to/delta_hive_test';
and I am able to fetch the record from select query in hive. is there any way to delete record from hive using delete query? when i checked getting exception
hive> delete from delta_hive_test where col1 = 'A' and col2 =1;
FAILED: SemanticException [Error 17980]: Operation is not supported. Table is nor ACID neither MapRDbJSON
same delete operation is working fine in spark
import io.delta.tables._
val deltaTable = DeltaTable.forPath(spark, "maprfs://path/to/delta_hive_test")
deltaTable.delete("col1 ='A' and col2 = 1")
So my question is if delete is supported on delta table using hive query ? currently I am using hive 2.3 and spark 2.4 version
Sources
This article follows the attribution requirements of Stack Overflow and is licensed under CC BY-SA 3.0.
Source: Stack Overflow
| Solution | Source |
|---|
