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 DseInClauseToFullTableScanConversionThreshold: DeprecatedConfigParameter[Long]

   

8. val DseInClauseToJoinWithTableConversionThreshold: DeprecatedConfigParameter[Long]

   

9. val IgnoreMissingMetaColumns: ConfigParameter[Boolean]

   

10. val InClauseToFullTableScanConversionThreshold: ConfigParameter[Long]

    

11. val InClauseToJoinWithTableConversionThreshold: ConfigParameter[Long]

    

12. val ReferenceSection: String

    

13. val SearchPredicateOptimizationParam: ConfigParameter[String]

    

14. val SearchPredicateOptimizationRatioParam: ConfigParameter[Double]

    

15. val SolrPredciateOptimizationParam: DeprecatedConfigParameter[String]

    

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

    

17. val TableOptions: String

    

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

    

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

    

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

    

21. final def asInstanceOf[T0]: T0

    

    Definition Classes

    Any

22. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

23. 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.

24. val defaultClusterName: String

    

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

    

    Definition Classes

    AnyRef

26. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

27. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

29. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

30. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

31. def isTraceEnabled(): Boolean

    

    Attributes

    protected

    Definition Classes

    Logging

32. def log: Logger

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging

39. def logName: String

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

45. final def notify(): Unit

    

    Definition Classes

    AnyRef

46. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

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

    

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

    

    Definition Classes

    AnyRef

49. def toString(): String

    

    Definition Classes

    AnyRef → Any

50. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )