org.apache.spark.sql.datasources.hbase

HBaseTableCatalog

object HBaseTableCatalog extends Serializable

Annotations
@Public()
Linear Supertypes
Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By inheritance
Inherited
  1. HBaseTableCatalog
  2. Serializable
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show all
Learn more about member selection
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  2. final def !=(arg0: Any): Boolean

    Definition Classes
    Any
  3. final def ##(): Int

    Definition Classes
    AnyRef → Any
  4. final def ==(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  5. final def ==(arg0: Any): Boolean

    Definition Classes
    Any
  6. val SCHEMA_COLUMNS_MAPPING_KEY: String

  7. val TABLE_KEY: String

  8. def apply(params: Map[String, String]): HBaseTableCatalog

    User provide table schema definition {"tablename":"name", "rowkey":"key1:key2", "columns":{"col1":{"cf":"cf1", "col":"col1", "type":"type1"}, "col2":{"cf":"cf2", "col":"col2", "type":"type2" }}} Note that any col in the rowKey, there has to be one corresponding col defined in columns

  9. final def asInstanceOf[T0]: T0

    Definition Classes
    Any
  10. val avro: String

  11. val cf: String

  12. def clone(): AnyRef

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  13. val col: String

  14. val columns: String

  15. val defaultRegionEnd: String

  16. val defaultRegionStart: String

  17. val delimiter: Byte

  18. final def eq(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  19. def equals(arg0: Any): Boolean

    Definition Classes
    AnyRef → Any
  20. def finalize(): Unit

    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  21. def generateSchemaMappingMap(schemaMappingString: String): HashMap[String, SchemaQualifierDefinition]

    Reads the SCHEMA_COLUMNS_MAPPING_KEY and converts it to a map of SchemaQualifierDefinitions with the original sql column name as the key

    Reads the SCHEMA_COLUMNS_MAPPING_KEY and converts it to a map of SchemaQualifierDefinitions with the original sql column name as the key

    schemaMappingString

    The schema mapping string from the SparkSQL map

    returns

    A map of definitions keyed by the SparkSQL column name

    Annotations
    @Private()
  22. final def getClass(): Class[_]

    Definition Classes
    AnyRef → Any
  23. def hashCode(): Int

    Definition Classes
    AnyRef → Any
  24. final def isInstanceOf[T0]: Boolean

    Definition Classes
    Any
  25. val length: String

  26. val nameSpace: String

  27. final def ne(arg0: AnyRef): Boolean

    Definition Classes
    AnyRef
  28. val newTable: String

  29. final def notify(): Unit

    Definition Classes
    AnyRef
  30. final def notifyAll(): Unit

    Definition Classes
    AnyRef
  31. val regionEnd: String

  32. val regionStart: String

  33. val rowKey: String

  34. val serdes: String

  35. final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes
    AnyRef
  36. val table: String

  37. val tableCatalog: String

  38. val tableName: String

  39. def toString(): String

    Definition Classes
    AnyRef → Any
  40. val type: String

  41. final def wait(): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  42. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  43. final def wait(arg0: Long): Unit

    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Deprecated Value Members

  1. def convert(parameters: Map[String, String]): Map[String, String]

    Annotations
    @deprecated
    Deprecated

    Please use new json format to define HBaseCatalog

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped