@Test
public void testConfigureBigQueryInput() throws IOException {

  BigQueryConfiguration.configureBigQueryInput(
      conf,
      INPUT_PROJECT_ID,
      INPUT_DATASET_ID,
      INPUT_TABLE_ID);
  assertThat(BigQueryConfiguration.INPUT_PROJECT_ID.get(conf, conf::get))
      .isEqualTo(INPUT_PROJECT_ID);
  assertThat(BigQueryConfiguration.INPUT_DATASET_ID.get(conf, conf::get))
      .isEqualTo(INPUT_DATASET_ID);
  assertThat(BigQueryConfiguration.INPUT_TABLE_ID.get(conf, conf::get)).isEqualTo(INPUT_TABLE_ID);
  // By default, the job-level projectId inherits the input projectId if it's not already set.
  assertThat(BigQueryConfiguration.PROJECT_ID.get(conf, conf::get)).isEqualTo(INPUT_PROJECT_ID);
}