Home
last modified time | relevance | path

Searched refs:staticPartitionKeys (Results 1 – 5 of 5) sorted by relevance

/dports/devel/spark/spark-2.1.1/sql/core/src/main/scala/org/apache/spark/sql/execution/datasources/
H A DInsertIntoHadoopFsRelationCommand.scala47 staticPartitionKeys: TablePartitionSpec,
125 val staticPartitionPrefix = if (staticPartitionKeys.nonEmpty) {
127 staticPartitionKeys.get(p.name) match {
146 (staticPartitionKeys.toSet -- spec).isEmpty,
H A DDataSourceStrategy.scala195 val staticPartitionKeys: TablePartitionSpec = if (overwrite.enabled) { constant
196 overwrite.staticPartitionKeys.map { case (k, v) =>
207 l.catalogTable.get.identifier, Some(staticPartitionKeys))
238 staticPartitionKeys,
H A DDataSource.scala474 staticPartitionKeys = Map.empty,
/dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/plans/logical/
H A DbasicLogicalOperators.scala368 staticPartitionKeys: CatalogTypes.TablePartitionSpec = Map.empty) {
369 if (staticPartitionKeys.nonEmpty) {
/dports/devel/spark/spark-2.1.1/sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/parser/
H A DAstBuilder.scala181 val staticPartitionKeys: Map[String, String] = constant
188 OverwriteOptions(overwrite, if (overwrite) staticPartitionKeys else Map.empty),