You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/09/11 22:38:19 UTC
[3/3] beam git commit: This closes #3730: Cleans up PTransform
validation across Beam
This closes #3730: Cleans up PTransform validation across Beam
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/e8bf045f
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/e8bf045f
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/e8bf045f
Branch: refs/heads/master
Commit: e8bf045f6a9ad574780157ca9a1864c0a4f62fea
Parents: 98b0fd2 1a38de1
Author: Eugene Kirpichov <ek...@gmail.com>
Authored: Mon Sep 11 15:37:27 2017 -0700
Committer: Eugene Kirpichov <ek...@gmail.com>
Committed: Mon Sep 11 15:37:27 2017 -0700
----------------------------------------------------------------------
.../apex/translation/utils/ValuesSource.java | 4 -
.../apex/examples/UnboundedTextSource.java | 4 -
.../translation/GroupByKeyTranslatorTest.java | 4 -
.../translation/utils/CollectionSource.java | 4 -
.../core/construction/ReadTranslationTest.java | 6 -
.../direct/BoundedReadEvaluatorFactoryTest.java | 4 -
.../UnboundedReadEvaluatorFactoryTest.java | 3 -
.../flink/streaming/TestCountingSource.java | 3 -
.../gearpump/translators/io/ValuesSource.java | 8 -
.../beam/runners/dataflow/AssignWindows.java | 84 -------
.../java/org/apache/beam/sdk/io/AvroSource.java | 10 +-
.../org/apache/beam/sdk/io/CountingSource.java | 3 -
.../apache/beam/sdk/io/GenerateSequence.java | 3 +-
.../java/org/apache/beam/sdk/io/Source.java | 2 +-
.../java/org/apache/beam/sdk/io/TextIO.java | 4 +-
.../java/org/apache/beam/sdk/io/WriteFiles.java | 6 +-
.../org/apache/beam/sdk/transforms/Create.java | 3 -
.../apache/beam/sdk/io/FileBasedSourceTest.java | 3 -
.../beam/sdk/io/OffsetBasedSourceTest.java | 3 -
.../java/org/apache/beam/sdk/io/ReadTest.java | 6 -
.../runners/dataflow/TestCountingSource.java | 3 -
.../org/apache/beam/sdk/io/amqp/AmqpIO.java | 33 +--
.../beam/sdk/io/cassandra/CassandraIO.java | 64 ++---
.../sdk/io/elasticsearch/ElasticsearchIO.java | 123 +++-------
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 59 +++--
.../beam/sdk/io/gcp/bigtable/BigtableIO.java | 33 +--
.../beam/sdk/io/gcp/datastore/DatastoreV1.java | 81 +++----
.../beam/sdk/io/gcp/spanner/SpannerConfig.java | 3 +-
.../beam/sdk/io/gcp/spanner/SpannerIO.java | 26 +--
.../sdk/io/gcp/bigquery/BigQueryIOTest.java | 6 +-
.../sdk/io/gcp/bigtable/BigtableIOTest.java | 4 +-
.../sdk/io/gcp/datastore/DatastoreV1Test.java | 137 +----------
.../sdk/io/gcp/spanner/SpannerIOReadTest.java | 69 ------
.../sdk/io/gcp/spanner/SpannerIOWriteTest.java | 6 +-
sdks/java/io/hadoop/input-format/pom.xml | 5 -
.../hadoop/inputformat/HadoopInputFormatIO.java | 48 ++--
.../inputformat/HadoopInputFormatIOTest.java | 14 +-
.../org/apache/beam/sdk/io/hbase/HBaseIO.java | 232 +++++++++----------
.../apache/beam/sdk/io/hbase/HBaseIOTest.java | 20 +-
.../apache/beam/sdk/io/hcatalog/HCatalogIO.java | 23 +-
.../beam/sdk/io/hcatalog/HCatalogIOTest.java | 24 +-
.../org/apache/beam/sdk/io/jdbc/JdbcIO.java | 84 ++-----
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 71 +++---
.../org/apache/beam/sdk/io/kafka/KafkaIO.java | 60 +++--
.../apache/beam/sdk/io/kinesis/KinesisIO.java | 18 +-
.../beam/sdk/io/kinesis/KinesisReader.java | 1 -
.../beam/sdk/io/mongodb/MongoDbGridFSIO.java | 4 -
.../apache/beam/sdk/io/mongodb/MongoDbIO.java | 55 ++---
.../org/apache/beam/sdk/io/mqtt/MqttIO.java | 49 +---
.../org/apache/beam/sdk/io/solr/SolrIO.java | 26 +--
.../java/org/apache/beam/sdk/io/xml/XmlIO.java | 32 +--
.../org/apache/beam/sdk/io/xml/XmlSink.java | 10 -
.../org/apache/beam/sdk/io/xml/XmlSinkTest.java | 12 +-
53 files changed, 456 insertions(+), 1146 deletions(-)
----------------------------------------------------------------------