beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From j...@apache.org
Subject [3/3] beam git commit: This closes #3730: Cleans up PTransform validation across Beam
Date Mon, 11 Sep 2017 22:38:19 GMT
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 <ekirpichov@gmail.com>
Authored: Mon Sep 11 15:37:27 2017 -0700
Committer: Eugene Kirpichov <ekirpichov@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(-)
----------------------------------------------------------------------



Mime
View raw message