DefaultSourceStaticUtils

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. final def asInstanceOf[T0]: T0

   Definition Classes

   Any

7. val byteRange: ThreadLocal[PositionedByteRange]

8. def clone(): AnyRef

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

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

   Definition Classes

   AnyRef

10. def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

11. def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

12. def getByteValue(field: Field, value: String): Array[Byte]

    This will convert the value from SparkSQL to be stored into HBase using the right byte Type

    This will convert the value from SparkSQL to be stored into HBase using the right byte Type

    value

    String value from SparkSQL

    returns

    Returns the byte array to go into HBase

13. final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

14. def getFreshByteRange(bytes: Array[Byte], offset: Int = 0, length: Int): PositionedByteRange

15. def getFreshByteRange(bytes: Array[Byte]): PositionedByteRange

16. def getValue(field: Field, r: Result): Any

    This method will convert the result content from HBase into the SQL value type that is requested by the Spark SQL schema definition

    This method will convert the result content from HBase into the SQL value type that is requested by the Spark SQL schema definition

    field

    The structure of the SparkSQL Column

    r

    The result object from HBase

    returns

    The converted object type

17. def hashCode(): Int

    Definition Classes

    AnyRef → Any

18. final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

19. val lastFiveExecutionRules: ConcurrentLinkedQueue[ExecutionRuleForUnitTesting]

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

    Definition Classes

    AnyRef

21. final def notify(): Unit

    Definition Classes

    AnyRef

22. final def notifyAll(): Unit

    Definition Classes

    AnyRef

23. def populateLatestExecutionRules(rowKeyFilter: RowKeyFilter, dynamicLogicExpression: DynamicLogicExpression): Unit

    This method is to populate the lastFiveExecutionRules for unit test perposes This method is not thread safe.

    This method is to populate the lastFiveExecutionRules for unit test perposes This method is not thread safe.

    rowKeyFilter

    The rowKey Filter logic used in the last query

    dynamicLogicExpression

    The dynamicLogicExpression used in the last query

24. val rawDouble: RawDouble

25. val rawFloat: RawFloat

26. val rawInteger: RawInteger

27. val rawLong: RawLong

28. val rawString: RawString

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

    Definition Classes

    AnyRef

30. def toString(): String

    Definition Classes

    AnyRef → Any

31. final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

32. final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

33. final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )