SnappyContextFunctions

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. def aqpTablePopulator(session: SnappySession): Unit

   

5. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

6. def clear(): Unit

   

7. def clearStatic(): () ⇒ Unit

   

8. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

9. def collectSamples(session: SnappySession, rows: RDD[Row], aqpTables: Seq[String], time: Long): Unit

   

   Attributes

   protected[org.apache.spark.sql]

10. def convertToStratifiedSample(options: Map[String, Any], session: SnappySession, logicalPlan: LogicalPlan): LogicalPlan

    

11. def createSampleDataFrameContract(session: SnappySession, df: DataFrame, logicalPlan: LogicalPlan): SampleDataFrameContract

    

12. def createTopK(session: SnappySession, tableName: String, keyColumnName: String, schema: StructType, topkOptions: Map[String, String], ifExists: Boolean): Boolean

    

13. def dropTopK(session: SnappySession, topKName: String): Unit

    

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

    

    Definition Classes

    AnyRef

15. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

16. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

18. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

19. def insertIntoTopK(session: SnappySession, rows: RDD[Row], topKName: String, time: Long): Unit

    

20. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

21. def isStratifiedSample(logicalPlan: LogicalPlan): Boolean

    

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

    

    Definition Classes

    AnyRef

23. def newSQLParser(snappySession: SnappySession): SnappySqlParser

    

24. final def notify(): Unit

    

    Definition Classes

    AnyRef

25. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

26. def postRelationCreation(relation: Option[BaseRelation], session: SnappySession): Unit

    

27. def queryTopK(session: SnappySession, topK: String, startTime: Long, endTime: Long, k: Int): DataFrame

    

28. def queryTopK(session: SnappySession, topKName: String, startTime: String, endTime: String, k: Int): DataFrame

    

29. def queryTopKRDD(session: SnappySession, topK: String, startTime: String, endTime: String, schema: StructType): RDD[InternalRow]

    

30. def registerSnappyFunctions(session: SnappySession): Unit

    

31. def sql[T](fn: ⇒ T): T

    

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

    

    Definition Classes

    AnyRef

33. def toString(): String

    

    Definition Classes

    AnyRef → Any

34. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

37. def withErrorDataFrame(df: DataFrame, error: Double, confidence: Double, behavior: String): DataFrame