- spark session object
- metadata object
- additional parameters
Delete rows from the table based on condtional expression.
Delete rows from the table based on condtional expression.
- Conditional filter for delete
Return an RDD on top of Hive ACID table
Return an RDD on top of Hive ACID table
- columns needed
- filters that can be pushed down to file format
- read conf
Appends a given dataframe df into the hive acid table
Appends a given dataframe df into the hive acid table
- dataframe to insert
Overwrites a given dataframe df onto the hive acid table
Overwrites a given dataframe df onto the hive acid table
- dataframe to insert
Update rows in the hive acid table based on condition and newValues
Update rows in the hive acid table based on condition and newValues
- condition string to identify rows which needs to be updated
- Map of (column, value) to set
Represents a hive acid table and exposes API to perform operations on top of it