This closes #3632: [BEAM-2677] AvroIO.parseGenericRecords - schemaless AvroIO.read
Project: http://git-wip-us.apache.org/repos/asf/beam/repo Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/a94d680e Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/a94d680e Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/a94d680e Branch: refs/heads/master Commit: a94d680eabd47a69be628028799ac4d41bd110d5 Parents: 7ab8954 c16947e Author: Eugene Kirpichov <[email protected]> Authored: Fri Jul 28 10:25:35 2017 -0700 Committer: Eugene Kirpichov <[email protected]> Committed: Fri Jul 28 10:25:35 2017 -0700 ---------------------------------------------------------------------- .../java/org/apache/beam/sdk/io/AvroIO.java | 199 ++++++++++++++++++- .../java/org/apache/beam/sdk/io/AvroSource.java | 166 ++++++++++++---- .../org/apache/beam/sdk/io/FileBasedSink.java | 24 +-- .../apache/beam/sdk/values/TypeDescriptor.java | 64 ++++-- .../apache/beam/sdk/values/TypeDescriptors.java | 118 ++++++++++- .../java/org/apache/beam/sdk/io/AvroIOTest.java | 89 ++++++--- .../org/apache/beam/sdk/io/AvroSourceTest.java | 30 ++- .../beam/sdk/values/TypeDescriptorsTest.java | 49 +++++ .../sdk/io/gcp/bigquery/BigQuerySourceBase.java | 4 +- .../io/gcp/bigquery/DynamicDestinations.java | 22 +- .../sdk/io/gcp/bigquery/TransformingSource.java | 136 ------------- .../sdk/io/gcp/bigquery/BigQueryIOTest.java | 68 ------- 12 files changed, 641 insertions(+), 328 deletions(-) ----------------------------------------------------------------------
