Package

com.qubole.spark.hiveacid

streaming

Permalink

package streaming

Visibility
  1. Public
  2. All

Type Members

  1. class HiveAcidSink extends Sink with Logging

    Permalink
  2. class HiveAcidSinkLog extends CompactibleFileStreamLog[HiveAcidSinkStatus]

    Permalink
  3. class HiveAcidSinkOptions extends AnyRef

    Permalink
  4. case class HiveAcidSinkStatus(txnId: Long, action: String) extends Product with Serializable

    Permalink
  5. class HiveAcidStreamingCommitProtocol extends Serializable with Logging

    Permalink

Value Members

  1. object HiveAcidSink

    Permalink
  2. object HiveAcidSinkLog

    Permalink
  3. object HiveAcidSinkOptions

    Permalink
  4. object HiveAcidStreamingCommitProtocol extends Serializable

    Permalink

Ungrouped