Commits

Branch selector

 master

User selector

jkff

Datepicker

All time

Commit History

Commits on Oct 27, 2017

• This closes apache#4013: [BEAM-1542] A transform for reading the Spanner schema

  jkff

  committed
  e686286

  Copy full SHA for e686286

Commits on Oct 26, 2017

• This closes apache#3835: [BEAM-2994] Many improvements to TikaIO

  jkff

  committed
  0c22113

  Copy full SHA for 0c22113

• Adds ParseResult.failure()

  Show description for c76c518
  jkff

  committed
  c76c518

  Copy full SHA for c76c518

Commits on Oct 20, 2017

• This closes apache#3999: [BEAM-2682] Deletes AvroIOTransformTest

  jkff

  committed
  f7aa41a

  Copy full SHA for f7aa41a

• [BEAM-2682] Deletes AvroIOTransformTest

  Show description for 8242abd
  jkff

  committed
  8242abd

  Copy full SHA for 8242abd

Commits on Oct 16, 2017

• This closes apache#3995: Add custom gcs temp location support to BigQueryIO

  jkff

  committed
  a5cbd76

  Copy full SHA for a5cbd76

Commits on Oct 14, 2017

• This closes apache#3921: [BEAM-3009] Introduces Contextful machinery and uses it to add side input support to Watch

  jkff

  committed
  014614b

  Copy full SHA for 014614b

• Supports side inputs in MapElements and FlatMapElements

  jkff

  committed
  e2ad925

  Copy full SHA for e2ad925

• Introduces Contextful

  jkff

  committed
  4b908c2

  Copy full SHA for 4b908c2

Commits on Oct 9, 2017

• This closes apache#3934: Add @FunctionalInterface annotation to several JdbcIO interfaces

  jkff

  committed
  63de41a

  Copy full SHA for 63de41a

• This closes apache#3957: Fixes TextIO and AvroIO tests of watchForNewFiles

  jkff

  committed
  5130cab

  Copy full SHA for 5130cab

• Fixes TextIO and AvroIO tests of watchForNewFiles

  Show description for 35183c7
  jkff

  committed
  35183c7

  Copy full SHA for 35183c7

Commits on Sep 29, 2017

• This closes apache#3551: [BEAM-2455] Backlog size retrieval for Kinesis source

  jkff

  committed
  7db0f13

  Copy full SHA for 7db0f13

• This closes apache#3910: Fix "Writing data to multiple destinations" part of AvroIO javadoc

  jkff

  committed
  294f633

  Copy full SHA for 294f633

Commits on Sep 28, 2017

• This closes apache#3894: [BEAM-2986] Support for reading avro GenericRecords from BigQuery

  jkff

  committed
  6be9e0b

  Copy full SHA for 6be9e0b

Commits on Sep 27, 2017

• This closes apache#3890: Introduces Reshuffle.viaRandomKey()

  jkff

  committed
  393e563

  Copy full SHA for 393e563

• Adds ReadableFile.toString() for debugging

  jkff

  committed
  a6e2001

  Copy full SHA for a6e2001

• Introduces Reshuffle.viaRandomKey()

  Show description for b74644a
  jkff

  committed
  b74644a

  Copy full SHA for b74644a

• PAssert improvements.

  Show description for 30e7d15
  jkff

  committed
  30e7d15

  Copy full SHA for 30e7d15

• This closes apache#3891: [BEAM-2992] Removes codepaths for reading unsplit BigQuery sources

  jkff

  committed
  7e3f591

  Copy full SHA for 7e3f591

• Removes codepaths for reading unsplit BigQuery sources

  jkff

  committed
  18d7c29

  Copy full SHA for 18d7c29

• This closes apache#3883: [BEAM-2991] Sets a TTL on BigQueryIO.read().fromQuery() temp dataset

  jkff

  committed
  41239d8

  Copy full SHA for 41239d8

• Sets a TTL on BigQueryIO.read().fromQuery() temp dataset

  Show description for f54477c
  jkff

  committed
  f54477c

  Copy full SHA for f54477c

Commits on Sep 25, 2017

• This closes apache#3851: [BEAM-2467] Kinesis source watermark based on approximateArrivalTimestamp

  jkff

  committed
  3bf65dc

  Copy full SHA for 3bf65dc

Commits on Sep 20, 2017

• Marks TikaIO as experimental to allow backward-incompatible changes

  jkff

  committed
  7d7baf7

  Copy full SHA for 7d7baf7

• This closes apache#3862: [BEAM-2837] Updated grpc-google-pubsub-v1 dependency

  jkff

  committed
  e8a5282

  Copy full SHA for e8a5282

Commits on Sep 19, 2017

• This closes apache#3827: [BEAM-407] fixes inconsistent synchronization in OffsetRangeTracker.copy

  jkff

  committed
  e7eefdd

  Copy full SHA for e7eefdd

Commits on Sep 18, 2017

• This closes apache#3854: Speeds up CompressedSourceTest

  jkff

  committed
  fdd9965

  Copy full SHA for fdd9965

• Speeds up CompressedSourceTest

  jkff

  committed
  fecfbc1

  Copy full SHA for fecfbc1

Commits on Sep 15, 2017

• This closes apache#3703: [BEAM-1637] Create Elasticsearch IO compatible with ES 5.x

  jkff

  committed
  307b036

  Copy full SHA for 307b036

• Piggyback: deflakes MongoDBGridFSIOTest which failed during merge

  jkff

  committed
  6c21cab

  Copy full SHA for 6c21cab

Commits on Sep 11, 2017

• This closes apache#3730: Cleans up PTransform validation across Beam

  jkff

  committed
  e8bf045

  Copy full SHA for e8bf045

• Cleans up PTransform validation across Beam

  Show description for 1a38de1
  jkff

  committed
  1a38de1

  Copy full SHA for 1a38de1

Commits on Sep 6, 2017

• This closes apache#3800: [BEAM-2803, BEAM-2706] JdbcIO improvements

  jkff

  committed
  7fe5b75

  Copy full SHA for 7fe5b75

• Implements JdbcIO.readAll() and improves validation messages

  jkff

  committed
  c4c6d93

  Copy full SHA for c4c6d93

Pagination

Previous

Next