@Override
  protected SchemaTransform from(BigQueryExportReadSchemaTransformConfiguration configuration) {
    return new BigQueryExportSchemaTransform(configuration);
  }
@Test
  public void testInvalidInput() {
    BigQueryExportReadSchemaTransformProvider provider =
        new BigQueryExportReadSchemaTransformProvider();
    BigQueryExportReadSchemaTransformConfiguration configuration =
        BigQueryExportReadSchemaTransformConfiguration.builder().setTableSpec(TABLE_SPEC).build();
    BigQueryExportSchemaTransform schemaTransform =
        (BigQueryExportSchemaTransform) provider.from(configuration);

    schemaTransform.setTestBigQueryServices(fakeBigQueryServices);
    PCollectionRowTuple input = PCollectionRowTuple.of("badinput", p.apply(Create.of(ROWS)));
    assertThrows(IllegalArgumentException.class, () -> input.apply(schemaTransform));
  }