@@ -50,7 +50,7 @@ class DefaultSource extends RelationProvider
|
|||||||
optParams: Map[String, String],
|
optParams: Map[String, String],
|
||||||
schema: StructType): BaseRelation = {
|
schema: StructType): BaseRelation = {
|
||||||
// Add default options for unspecified read options keys.
|
// Add default options for unspecified read options keys.
|
||||||
val parameters = Map(VIEW_TYPE_OPT_KEY -> DEFAULT_VIEW_TYPE_OPT_VAL) ++: optParams
|
val parameters = Map(VIEW_TYPE_OPT_KEY -> DEFAULT_VIEW_TYPE_OPT_VAL) ++ optParams
|
||||||
|
|
||||||
val path = parameters.get("path")
|
val path = parameters.get("path")
|
||||||
if (path.isEmpty) {
|
if (path.isEmpty) {
|
||||||
|
|||||||
@@ -305,7 +305,7 @@ private[hudi] object HoodieSparkSqlWriter {
|
|||||||
HIVE_PARTITION_EXTRACTOR_CLASS_OPT_KEY -> DEFAULT_HIVE_PARTITION_EXTRACTOR_CLASS_OPT_VAL,
|
HIVE_PARTITION_EXTRACTOR_CLASS_OPT_KEY -> DEFAULT_HIVE_PARTITION_EXTRACTOR_CLASS_OPT_VAL,
|
||||||
HIVE_ASSUME_DATE_PARTITION_OPT_KEY -> DEFAULT_HIVE_ASSUME_DATE_PARTITION_OPT_VAL,
|
HIVE_ASSUME_DATE_PARTITION_OPT_KEY -> DEFAULT_HIVE_ASSUME_DATE_PARTITION_OPT_VAL,
|
||||||
HIVE_STYLE_PARTITIONING_OPT_KEY -> DEFAULT_HIVE_STYLE_PARTITIONING_OPT_VAL
|
HIVE_STYLE_PARTITIONING_OPT_KEY -> DEFAULT_HIVE_STYLE_PARTITIONING_OPT_VAL
|
||||||
) ++: parameters
|
) ++ parameters
|
||||||
}
|
}
|
||||||
|
|
||||||
def toProperties(params: Map[String, String]): TypedProperties = {
|
def toProperties(params: Map[String, String]): TypedProperties = {
|
||||||
|
|||||||
Reference in New Issue
Block a user