Package

com.qubole.spark

hiveacid

Permalink

package hiveacid

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. hiveacid
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Type Members

  1. trait AcidOperationDelegate extends AnyRef

    Permalink

    Delegate to perform ACID operations: UPDATE/DELETE/INSERT/READ These APIs are not protected under Transactions, however most of them may need transactions to be already open.

  2. class AnalysisException extends Exception with Serializable

    Permalink
  3. case class HiveAcidAutoConvert(spark: SparkSession) extends Rule[LogicalPlan] with Product with Serializable

    Permalink

    Analyzer rule to convert a transactional HiveRelation into LogicalRelation backed by HiveAcidRelation

    Analyzer rule to convert a transactional HiveRelation into LogicalRelation backed by HiveAcidRelation

    spark

    - spark session

  4. class HiveAcidAutoConvertExtension extends (SparkSessionExtensions) ⇒ Unit

    Permalink
  5. implicit class HiveAcidDataFrameReader extends AnyRef

    Permalink
  6. implicit class HiveAcidDataFrameWriter[T] extends AnyRef

    Permalink
  7. class HiveAcidDataSourceV2Reader extends DataSourceV2 with DataSourceReader with SupportsScanColumnarBatch with SupportsPushDownRequiredColumns with SupportsPushDownFilters with SupportsReportStatistics with Logging

    Permalink

    Data source V2 implementation for HiveACID

  8. class HiveAcidOperationDelegate extends AcidOperationDelegate with Logging

    Permalink

    HiveAcidTable uses Delegate pattern to delegate it's API to this object

  9. class HiveAcidTable extends Logging with Closeable

    Permalink

    Represents a hive acid table and exposes API to perform operations on top of it

    Represents a hive acid table and exposes API to perform operations on top of it

    Annotations
    @Evolving()
  10. class HiveTableStatisticsForV2 extends Statistics

    Permalink
  11. class HiveTxnWrapper extends Logging

    Permalink

    Wrapper over HiveAcidTxn which ensures running operations within transaction boundary

    Wrapper over HiveAcidTxn which ensures running operations within transaction boundary

    This wrapper can be used just once for running an operation. That operation is not allowed to recursively call this again

  12. case class SparkAcidConf(sparkSession: SparkSession, parameters: Map[String, String]) extends Product with Serializable

    Permalink
  13. case class SparkAcidConfigBuilder[T](configName: String) extends Product with Serializable

    Permalink
  14. case class SparkAcidConfigEntry[T](configName: String, defaultValue: String, description: String, converter: Option[(String, String) ⇒ T]) extends Product with Serializable

    Permalink

    Spark specific configuration container to be used by Hive Acid module

  15. class TransactionInvalidException extends Exception

    Permalink

Value Members

  1. object HiveAcidErrors

    Permalink
  2. object HiveAcidTable

    Permalink
  3. object SparkAcidConf extends Serializable

    Permalink
  4. package datasource

    Permalink
  5. package hive

    Permalink
  6. package merge

    Permalink
  7. package rdd

    Permalink
  8. package reader

    Permalink
  9. package streaming

    Permalink
  10. package transaction

    Permalink
  11. package util

    Permalink

Inherited from AnyRef

Inherited from Any

Ungrouped