CassandraSourceRelation

Value Members

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

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

4. val AdditionalCassandraPushDownRulesParam: ConfigParameter[List[CassandraPredicateRules]]

   

5. val DirectJoinSettingParam: ConfigParameter[String]

   

6. val DirectJoinSizeRatioParam: ConfigParameter[Double]

   

7. val DseReferenceSection: String

   

8. val IgnoreMissingMetaColumns: ConfigParameter[Boolean]

   

9. val InClauseToFullTableScanConversionThreshold: ConfigParameter[Long]

   

10. val InClauseToJoinWithTableConversionThreshold: ConfigParameter[Long]

    

11. val ReferenceSection: String

    

12. val SearchPredicateOptimizationParam: ConfigParameter[String]

    

13. val SearchPredicateOptimizationRatioParam: ConfigParameter[Double]

    

14. val SolrPredciateOptimizationParam: DeprecatedConfigParameter[String]

    

15. val TTLParam: ConfigParameter[Option[String]]

    

16. val TableSizeInBytesParam: ConfigParameter[Option[Long]]

    

17. val WriteTimeParam: ConfigParameter[Option[String]]

    

18. def apply(tableRef: TableRef, sqlContext: SQLContext, options: CassandraSourceOptions, schema: Option[StructType]): CassandraSourceRelation

    

19. final def asInstanceOf[T0]: T0

    

    Definition Classes

    Any

20. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

21. def consolidateConfs(sparkConf: SparkConf, sqlConf: Map[String, String], tableRef: TableRef, tableConf: Map[String, String]): SparkConf

    

    Consolidate Cassandra conf settings in the order of table level -> keyspace level -> cluster level -> default.

    Consolidate Cassandra conf settings in the order of table level -> keyspace level -> cluster level -> default. Use the first available setting. Default settings are stored in SparkConf.

22. val defaultClusterName: String

    

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

    

    Definition Classes

    AnyRef

24. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

25. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

27. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

28. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

29. def isTraceEnabled(): Boolean

    

    Attributes

    protected

    Definition Classes

    Logging

30. def log: Logger

    

    Attributes

    protected

    Definition Classes

    Logging

31. def logDebug(msg: ⇒ String, throwable: Throwable): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

32. def logDebug(msg: ⇒ String): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

33. def logError(msg: ⇒ String, throwable: Throwable): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

34. def logError(msg: ⇒ String): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

35. def logInfo(msg: ⇒ String, throwable: Throwable): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

36. def logInfo(msg: ⇒ String): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

37. def logName: String

    

    Attributes

    protected

    Definition Classes

    Logging

38. def logTrace(msg: ⇒ String, throwable: Throwable): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

39. def logTrace(msg: ⇒ String): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

40. def logWarning(msg: ⇒ String, throwable: Throwable): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

41. def logWarning(msg: ⇒ String): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

43. final def notify(): Unit

    

    Definition Classes

    AnyRef

44. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

45. def setDirectJoin[K](ds: Dataset[K], directJoinSetting: DirectJoinSetting = AlwaysOn)(implicit arg0: Encoder[K]): Dataset[K]

    

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

    

    Definition Classes

    AnyRef

47. def toString(): String

    

    Definition Classes

    AnyRef → Any

48. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )