File tree 1 file changed +0
-18
lines changed
cloud_gcp/src/main/scala/ai/chronon/integrations/cloud_gcp
1 file changed +0
-18
lines changed Original file line number Diff line number Diff line change @@ -32,24 +32,6 @@ case class GcpFormatProvider(sparkSession: SparkSession) extends FormatProvider
32
32
case None => Hive
33
33
}
34
34
35
- /**
36
- Using federation
37
- val tableIdentifier = sparkSession.sessionState.sqlParser.parseTableIdentifier(tableName)
38
- val tableMeta = sparkSession.sessionState.catalog.getTableRawMetadata(tableIdentifier)
39
-
40
-
41
- val tableOpt = Option(bigQueryClient.getTable(unshadedTI))
42
-
43
- tableOpt match {
44
- case Some(table) => {
45
- table.getDefinition match {
46
- case ExternalTableDefinition => BQuery(unshadedTI.getProject)
47
- case StandardTableDefinition => GCS(unshadedTI.getProject)
48
- }
49
- }
50
- case None => Hive
51
- }
52
-
53
35
/**
54
36
Using federation
55
37
val tableIdentifier = sparkSession.sessionState.sqlParser.parseTableIdentifier(tableName)
You can’t perform that action at this time.
0 commit comments