File tree Expand file tree Collapse file tree 1 file changed +4
-1
lines changed
cloud_gcp/src/main/scala/ai/chronon/integrations/cloud_gcp Expand file tree Collapse file tree 1 file changed +4
-1
lines changed Original file line number Diff line number Diff line change @@ -45,7 +45,10 @@ case class GcpFormatProvider(sparkSession: SparkSession) extends FormatProvider
45
45
assert(scala.Option (tableId.getDataset).isDefined, s " dataset required for ${table}" )
46
46
47
47
val sparkOptions : Map [String , String ] = Map (
48
- " writeMethod" -> " direct" ,
48
+ " temporaryGcsBucket" -> sparkSession.conf.get(" spark.chronon.table.gcs.temporary_gcs_bucket" ),
49
+ " writeMethod" -> " indirect" , // writeMethod direct does not output partitioned tables. keep as indirect.
50
+ " materializationProject" -> tableId.getProject,
51
+ " materializationDataset" -> tableId.getDataset,
49
52
" createDisposition" -> JobInfo .CreateDisposition .CREATE_NEVER .name
50
53
)
51
54
You can’t perform that action at this time.
0 commit comments