Merge pull request #1607 from data-integrations/fix-plugin-1948

[PLUGIN-1948] Fix ClassCastException in BigQuery source plugin for table definition

Author: adrikagupta

src/main/java/io/cdap/plugin/gcp/bigquery/source/PartitionedBigQueryInputFormat.java

@@ -24,6 +24,7 @@
 import com.google.api.services.bigquery.model.TableReference;
 import com.google.cloud.bigquery.RangePartitioning;
 import com.google.cloud.bigquery.StandardTableDefinition;
+import com.google.cloud.bigquery.TableDefinition;
 import com.google.cloud.bigquery.TableDefinition.Type;
 import com.google.cloud.bigquery.TimePartitioning;
 import com.google.cloud.hadoop.io.bigquery.AbstractBigQueryInputFormat;
@@ -146,7 +147,7 @@ private void processQuery(JobContext context) throws IOException, InterruptedExc
         readTimeout);
     Type type = Objects.requireNonNull(bigQueryTable).getDefinition().getType();
     Boolean isPartitionFilterRequired = bigQueryTable.getRequirePartitionFilter();
-    StandardTableDefinition tableDefinition = Objects.requireNonNull(bigQueryTable).getDefinition();
+    TableDefinition tableDefinition = Objects.requireNonNull(bigQueryTable).getDefinition();
 
     String query;
     if (type == Type.VIEW || type == Type.MATERIALIZED_VIEW || type == Type.EXTERNAL) {
@@ -156,7 +157,7 @@ private void processQuery(JobContext context) throws IOException, InterruptedExc
       query = generateQuery(partitionFromDate, partitionToDate, filter, datasetProjectId,
           datasetId,
           tableName, limit, orderBy,
-          isPartitionFilterRequired, tableDefinition);
+          isPartitionFilterRequired, (StandardTableDefinition) tableDefinition);
     }
 
     if (query != null) {