feat: add support for Hive partitioning options when creating external tables (#235)

Author: ekanth

google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/ExternalTableDefinition.java

@@ -135,6 +135,9 @@ public Builder setFormatOptions(FormatOptions formatOptions) {
  /** Sets the table schema. */
  public abstract Builder setSchema(Schema schema);
 
+ /** Sets the table Hive partitioning options. */
+ public abstract Builder setHivePartitioningOptions(HivePartitioningOptions hivePartitioningOptions);
+
  /** Creates an {@code ExternalTableDefinition} object. */
  @Override
  public abstract ExternalTableDefinition build();
@@ -212,6 +215,13 @@ public <F extends FormatOptions> F getFormatOptions() {
  @Nullable
  public abstract Boolean getAutodetect();
 
+ /**
+ * [Experimental] Returns the HivePartitioningOptions when the data layout follows Hive partitioning convention
+ */
+ @SuppressWarnings("unchecked")
+ @Nullable
+ public abstract HivePartitioningOptions getHivePartitioningOptions();
+
  /** Returns a builder for the {@code ExternalTableDefinition} object. */
  public abstract Builder toBuilder();
 
@@ -257,6 +267,9 @@ com.google.api.services.bigquery.model.ExternalDataConfiguration toExternalDataC
  if (getAutodetect() != null) {
  externalConfigurationPb.setAutodetect(getAutodetect());
  }
+ if (getHivePartitioningOptions() != null) {
+ externalConfigurationPb.setHivePartitioningOptions(getHivePartitioningOptions().toPb());
+ }
  return externalConfigurationPb;
  }
 
@@ -405,6 +418,10 @@ static ExternalTableDefinition fromPb(Table tablePb) {
  }
  builder.setMaxBadRecords(externalDataConfiguration.getMaxBadRecords());
  builder.setAutodetect(externalDataConfiguration.getAutodetect());
+ if (externalDataConfiguration.getHivePartitioningOptions() != null) {
+ builder.setHivePartitioningOptions(
+ HivePartitioningOptions.fromPb(externalDataConfiguration.getHivePartitioningOptions()));
+ }
  }
  return builder.build();
  }
@@ -444,6 +461,10 @@ static ExternalTableDefinition fromExternalDataConfiguration(
  if (externalDataConfiguration.getAutodetect() != null) {
  builder.setAutodetect(externalDataConfiguration.getAutodetect());
  }
+ if (externalDataConfiguration.getHivePartitioningOptions() != null) {
+ builder.setHivePartitioningOptions(
+ HivePartitioningOptions.fromPb(externalDataConfiguration.getHivePartitioningOptions()));
+ }
  return builder.build();
  }
 }

google-cloud-bigquery/src/main/java/com/google/cloud/bigquery/HivePartitioningOptions.java

@@ -103,6 +103,15 @@ public String toString() {
  .toString();
  }
 
+ @Override
+ public boolean equals(Object obj) {
+ return obj == this
+ || obj != null
+ && obj.getClass().equals(HivePartitioningOptions.class)
+ && Objects.equals(mode, ((HivePartitioningOptions) obj).getMode())
+ && Objects.equals(sourceUriPrefix, ((HivePartitioningOptions) obj).getSourceUriPrefix());
+ }
+
  @Override
  public int hashCode() {
  return Objects.hash(mode, sourceUriPrefix);

google-cloud-bigquery/src/test/java/com/google/cloud/bigquery/ExternalTableDefinitionTest.java

@@ -46,12 +46,18 @@ public class ExternalTableDefinitionTest {
  private static final String COMPRESSION = "GZIP";
  private static final Boolean AUTODETECT = true;
  private static final CsvOptions CSV_OPTIONS = CsvOptions.newBuilder().build();
+ private static final HivePartitioningOptions HIVE_PARTITIONING_OPTIONS =
+ HivePartitioningOptions.newBuilder()
+ .setMode("AUTO")
+ .setSourceUriPrefix(SOURCE_URIS.get(0))
+ .build();
  private static final ExternalTableDefinition EXTERNAL_TABLE_DEFINITION =
  ExternalTableDefinition.newBuilder(SOURCE_URIS, TABLE_SCHEMA, CSV_OPTIONS)
  .setCompression(COMPRESSION)
  .setIgnoreUnknownValues(IGNORE_UNKNOWN_VALUES)
  .setMaxBadRecords(MAX_BAD_RECORDS)
  .setAutodetect(AUTODETECT)
+ .setHivePartitioningOptions(HIVE_PARTITIONING_OPTIONS)
  .build();
 
  @Test
@@ -83,6 +89,7 @@ public void testBuilder() {
  assertEquals(TABLE_SCHEMA, EXTERNAL_TABLE_DEFINITION.getSchema());
  assertEquals(SOURCE_URIS, EXTERNAL_TABLE_DEFINITION.getSourceUris());
  assertEquals(AUTODETECT, EXTERNAL_TABLE_DEFINITION.getAutodetect());
+ assertEquals(HIVE_PARTITIONING_OPTIONS, EXTERNAL_TABLE_DEFINITION.getHivePartitioningOptions());
  }
 
  @Test
@@ -107,5 +114,6 @@ private void compareExternalTableDefinition(
  assertEquals(expected.getSourceUris(), value.getSourceUris());
  assertEquals(expected.hashCode(), value.hashCode());
  assertEquals(expected.getAutodetect(), value.getAutodetect());
+ assertEquals(expected.getHivePartitioningOptions(), value.getHivePartitioningOptions());
  }
 }