Skip to content

Commit

Permalink
Bump Scio to 0.5.0 (#47)
Browse files Browse the repository at this point in the history
* Bump Scio to 0.5.0

* Undo Arbitrary import
  • Loading branch information
idreeskhan authored Mar 15, 2018
1 parent d804309 commit c2a78b2
Show file tree
Hide file tree
Showing 2 changed files with 6 additions and 6 deletions.
4 changes: 2 additions & 2 deletions build.sbt
Original file line number Diff line number Diff line change
Expand Up @@ -27,11 +27,11 @@ val parquetVersion = "1.9.0"
val protoBufVersion = "3.3.1"
val scalaCheckVersion = "1.13.5"
val scalaTestVersion = "3.0.4"
val scioVersion = "0.4.3"
val scioVersion = "0.5.0"
val scoptVersion = "3.5.0"
val slf4jVersion = "1.7.25"
val bigqueryVersion = "v2-rev372-1.23.0"
val beamVersion = "2.1.0"
val beamVersion = "2.2.0"

val commonSettings = Sonatype.sonatypeSettings ++ assemblySettings ++ releaseSettings ++ Seq(
organization := "com.spotify",
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -837,22 +837,22 @@ public Table patchTableDescription(TableReference tableReference,
}

private static class BigQueryJsonReaderImpl implements BigQueryJsonReader {
private BigQueryTableRowIterator iterator;
private PatchedBigQueryTableRowIterator iterator;

private BigQueryJsonReaderImpl(BigQueryTableRowIterator iterator) {
private BigQueryJsonReaderImpl(PatchedBigQueryTableRowIterator iterator) {
this.iterator = iterator;
}

private static BigQueryJsonReader fromQuery(
BigQueryOptions bqOptions, String projectId, JobConfigurationQuery queryConfig) {
return new BigQueryJsonReaderImpl(
BigQueryTableRowIterator.fromQuery(
PatchedBigQueryTableRowIterator.fromQuery(
queryConfig, projectId, newBigQueryClient(bqOptions).build()));
}

private static BigQueryJsonReader fromTable(
BigQueryOptions bqOptions, TableReference tableRef) {
return new BigQueryJsonReaderImpl(BigQueryTableRowIterator.fromTable(
return new BigQueryJsonReaderImpl(PatchedBigQueryTableRowIterator.fromTable(
tableRef, newBigQueryClient(bqOptions).build()));
}

Expand Down

0 comments on commit c2a78b2

Please sign in to comment.