ExternalStoreUtils

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. final val BUCKETS: String("buckets")

   

5. final val COLUMN_BATCH_SIZE: String("column_batch_size")

   

6. final val COLUMN_BATCH_SIZE_TRANSIENT: String("column_batch_size_transient")

   

7. final val COLUMN_MAX_DELTA_ROWS: String("column_max_delta_rows")

   

8. final val COLUMN_MAX_DELTA_ROWS_TRANSIENT: String("column_max_delta_rows_transient")

   

9. final val COMPRESSION_CODEC: String("compression")

   

10. final val INDEX_NAME: String("index_name")

    

11. final val INDEX_TYPE: String("index_type")

    

12. final val KEY_COLUMNS: String("key_columns")

    

13. final val PARTITION_BY: String("partition_by")

    

14. final val RELATION_FOR_SAMPLE: String("relation_for_sample")

    

15. final val REPLICATE: String("replicate")

    

16. final def asInstanceOf[T0]: T0

    

    Definition Classes

    Any

17. def checkPositiveNum(n: Int, propertyName: String): Int

    

18. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

19. def codeGenOnExecutor(plan: CodegenSupport, child: CodegenSupportOnExecutor): (CodegenContext, CodeAndComment)

    

    Generates code for this subtree.

    Generates code for this subtree.

    Adapted from WholeStageCodegenExec to allow running on executors.

    returns

    the tuple of the codegen context and the actual generated source.

20. val ddlOptions: Seq[String]

    

21. def defaultColumnBatchSize(session: SparkSession): Int

    

22. def defaultColumnMaxDeltaRows(session: SparkSession): Int

    

23. def defaultStoreURL(clusterMode: ClusterMode): String

    

24. def defaultStoreURL(sparkContext: Option[SparkContext]): String

    

25. val emptyCIMutableMap: CaseInsensitiveMutableHashMap[String]

    

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

    

    Definition Classes

    AnyRef

27. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

28. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

29. def getAllPoolProperties(url: String, driver: String, poolProps: Map[String, String], hikariCP: Boolean, isEmbedded: Boolean): Map[String, String]

    

30. def getAndSetTotalPartitions(session: SnappySession, parameters: Map[String, String], forManagedTable: Boolean, forColumnTable: Boolean = true, forSampleTable: Boolean = false): Int

    

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

    

    Definition Classes

    AnyRef → Any

32. def getColumnMetadata(schema: StructType): List[com.gemstone.gemfire.internal.cache.ExternalTableMetaData.Column]

    

33. def getConnection(id: String, connProperties: ConnectionProperties, forExecutor: Boolean, resetIsolationLevel: Boolean): Connection

    

34. def getConnectionProperties(session: Option[SparkSession], url: String, driver: String, dialect: JdbcDialect, poolProps: Map[String, String], connProps: Properties, executorConnProps: Properties, hikariCP: Boolean): ConnectionProperties

    

35. def getConnectionType(dialect: JdbcDialect): ConnectionType.Value

    

36. def getCredentials(session: SparkSession, prefix: String = ""): (String, String)

    

37. def getDriver(url: String, dialect: JdbcDialect): String

    

38. def getExpandedGranteesIterator(grantees: Seq[String]): Iterator[String]

    

39. def getExternalStoreOnExecutor(parameters: CaseInsensitiveMutableHashMap[String], partitions: Int, tableName: String, schema: StructType): ExternalStore

    

40. def getExternalTableMetaData(qualifiedTable: String, container: GemFireContainer, checkColumnStore: Boolean): ExternalTableMetaData

    

41. def getExternalTableMetaData(qualifiedTable: String): ExternalTableMetaData

    

42. def getLdapGroupsForUser(userId: String): Array[String]

    

43. def getSQLListener: AtomicReference[SQLListener]

    

44. def getTableSchema(props: Map[String, String], forView: Boolean): Option[StructType]

    

    Get the table schema from CatalogTable.properties if present.

45. def getTableSchema(schemaAsJson: String): StructType

    

46. def handleRollback(rollback: () ⇒ Unit, finallyCode: () ⇒ Unit = null): Unit

    

47. def handledFilter(f: Expression, indexedCols: Set[String]): Option[Expression]

    

48. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

49. def init(): Unit

    

50. def initializeLogIfNecessary(): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

51. final def isDebugEnabled: Boolean

    

    Definition Classes

    Logging

52. def isExternalSchemaRelationProvider(provider: String): Boolean

    

    check if the DataSource implements ExternalSchemaRelationProvider

53. final def isInfoEnabled: Boolean

    

    Definition Classes

    Logging

54. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

55. def isLocalMode(sparkContext: SparkContext): Boolean

    

56. final def isTraceEnabled: Boolean

    

    Definition Classes

    Logging

57. final var levelFlags: Int

    

    Attributes

    protected

    Definition Classes

    Logging

58. def log: Logger

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

65. def logName: String

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

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

    

    Definition Classes

    Logging

70. final var log_: Logger

    

    Attributes

    protected

    Definition Classes

    Logging

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

    

    Definition Classes

    AnyRef

72. final def notify(): Unit

    

    Definition Classes

    AnyRef

73. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

74. def pruneSchema(fieldMap: Map[String, StructField], columns: Seq[String], columnType: String): StructType

    

    Prune all but the specified columns from the specified Catalyst schema.

    Prune all but the specified columns from the specified Catalyst schema.

    fieldMap

    - The Catalyst column name to metadata of the master table

    columns

    - The list of desired columns

    returns

    A Catalyst schema corresponding to columns in the given order.

75. def registerBuiltinDrivers(): Unit

    

76. def removeCachedObjects(table: String): Unit

    

77. def removeCachedObjects(sqlContext: SQLContext, table: String): Unit

    

78. def removeInternalPropsAndGetTable(parameters: Map[String, String], tableAsUpper: Boolean = true): String

    

79. def removeSamplingOptions(parameters: Map[String, String]): Map[String, String]

    

80. def resetLogger(): Unit

    

    Attributes

    protected

    Definition Classes

    Logging

81. def setStatementParameters(stmt: PreparedStatement, row: ArrayBuffer[Any]): Unit

    

82. def sizeAsBytes(str: String, propertyName: String, minSize: Long, maxSize: Long): Long

    

83. def sizeAsBytes(str: String, propertyName: String): Int

    

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

    

    Definition Classes

    AnyRef

85. def toString(): String

    

    Definition Classes

    AnyRef → Any

86. def unhandledFilter(f: Expression, indexedCols: Set[String]): Boolean

    

87. def unhandledFilter(f: Expression): Boolean

    

88. def validateAndGetAllProps(session: Option[SparkSession], parameters: CaseInsensitiveMutableHashMap[String]): ConnectionProperties

    

89. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )