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/08/04 01:02:31 UTC
[6/6] beam git commit: This closes #3649: [BEAM-2686] Towards
deprecating PCollection.setCoder()
This closes #3649: [BEAM-2686] Towards deprecating PCollection.setCoder()
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/9e6530ad
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/9e6530ad
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/9e6530ad
Branch: refs/heads/master
Commit: 9e6530adb00669b7cf0f01cb8b128be0a21fd721
Parents: 38f1890 48690bc
Author: Eugene Kirpichov <ki...@google.com>
Authored: Thu Aug 3 17:45:41 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Thu Aug 3 17:45:41 2017 -0700
----------------------------------------------------------------------
.../apache/beam/examples/complete/TfIdf.java | 14 +-
.../apache/beam/runners/apex/ApexRunner.java | 10 +-
.../FlattenPCollectionTranslator.java | 15 +-
.../apex/translation/ParDoTranslator.java | 7 +-
.../apex/translation/utils/ValuesSource.java | 2 +-
.../apex/examples/UnboundedTextSource.java | 2 +-
.../translation/ApexGroupByKeyOperatorTest.java | 6 +-
.../translation/GroupByKeyTranslatorTest.java | 2 +-
.../translation/utils/CollectionSource.java | 2 +-
.../core/construction/ForwardingPTransform.java | 18 ++-
.../construction/PCollectionTranslation.java | 8 +-
.../construction/PTransformReplacements.java | 6 +
.../core/construction/PrimitiveCreate.java | 14 +-
.../core/construction/SplittableParDo.java | 62 ++++----
.../UnboundedReadFromBoundedSource.java | 11 +-
.../construction/ForwardingPTransformTest.java | 17 ++-
.../construction/PTransformMatchersTest.java | 79 +++++-----
.../core/construction/ReadTranslationTest.java | 4 +-
.../construction/ReplacementOutputsTest.java | 14 +-
.../core/construction/SplittableParDoTest.java | 33 +++--
.../UnboundedReadFromBoundedSourceTest.java | 2 +-
.../core/GroupByKeyViaGroupByKeyOnly.java | 15 +-
.../core/SplittableParDoViaKeyedWorkItems.java | 10 +-
.../beam/runners/direct/DirectGroupByKey.java | 31 ++--
.../beam/runners/direct/MultiStepCombine.java | 10 +-
.../direct/ParDoMultiOverrideFactory.java | 5 +-
.../direct/TestStreamEvaluatorFactory.java | 8 +-
.../runners/direct/ViewOverrideFactory.java | 5 +-
.../direct/BoundedReadEvaluatorFactoryTest.java | 2 +-
.../runners/direct/CommittedResultTest.java | 26 +++-
.../beam/runners/direct/DirectRunnerTest.java | 4 +-
.../runners/direct/EvaluationContextTest.java | 8 +-
.../UnboundedReadEvaluatorFactoryTest.java | 2 +-
.../runners/flink/CreateStreamingFlinkView.java | 5 +-
.../streaming/io/UnboundedSocketSource.java | 2 +-
.../flink/streaming/TestCountingSource.java | 2 +-
.../beam/runners/dataflow/AssignWindows.java | 12 +-
.../runners/dataflow/BatchViewOverrides.java | 19 +--
.../runners/dataflow/CreateDataflowView.java | 5 +-
.../beam/runners/dataflow/DataflowRunner.java | 147 ++++++++++---------
.../dataflow/PrimitiveParDoSingleFactory.java | 12 +-
.../dataflow/SplittableParDoOverrides.java | 2 +-
.../DataflowPipelineTranslatorTest.java | 21 +--
.../runners/dataflow/DataflowRunnerTest.java | 11 +-
.../transforms/DataflowGroupByKeyTest.java | 12 +-
.../dataflow/transforms/DataflowViewTest.java | 14 +-
.../beam/runners/spark/io/CreateStream.java | 11 +-
.../beam/runners/spark/io/MicrobatchSource.java | 4 +-
.../runners/spark/io/SparkUnboundedSource.java | 2 +-
.../spark/stateful/StateSpecFunctions.java | 2 +-
.../translation/StorageLevelPTransform.java | 10 +-
.../util/SinglePrimitiveOutputPTransform.java | 51 -------
.../java/org/apache/beam/sdk/io/AvroIO.java | 6 -
.../java/org/apache/beam/sdk/io/AvroSource.java | 2 +-
.../sdk/io/BoundedReadFromUnboundedSource.java | 12 +-
.../apache/beam/sdk/io/CompressedSource.java | 6 +-
.../org/apache/beam/sdk/io/CountingSource.java | 4 +-
.../main/java/org/apache/beam/sdk/io/Read.java | 27 ++--
.../java/org/apache/beam/sdk/io/Source.java | 14 +-
.../java/org/apache/beam/sdk/io/TFRecordIO.java | 20 +--
.../java/org/apache/beam/sdk/io/TextIO.java | 12 --
.../java/org/apache/beam/sdk/io/TextSource.java | 2 +-
.../beam/sdk/testing/SourceTestUtils.java | 12 +-
.../org/apache/beam/sdk/testing/TestStream.java | 5 +-
.../org/apache/beam/sdk/transforms/Combine.java | 22 +--
.../org/apache/beam/sdk/transforms/Create.java | 72 ++++-----
.../org/apache/beam/sdk/transforms/Filter.java | 26 ++--
.../org/apache/beam/sdk/transforms/Flatten.java | 22 +--
.../apache/beam/sdk/transforms/GroupByKey.java | 12 +-
.../apache/beam/sdk/transforms/PTransform.java | 13 +-
.../org/apache/beam/sdk/transforms/ParDo.java | 61 ++++----
.../org/apache/beam/sdk/transforms/View.java | 5 +-
.../beam/sdk/transforms/windowing/Window.java | 8 +-
.../org/apache/beam/sdk/values/PCollection.java | 9 +-
.../beam/sdk/values/PCollectionTuple.java | 10 +-
.../beam/sdk/io/CompressedSourceTest.java | 2 +-
.../apache/beam/sdk/io/FileBasedSourceTest.java | 2 +-
.../beam/sdk/io/OffsetBasedSourceTest.java | 2 +-
.../java/org/apache/beam/sdk/io/ReadTest.java | 4 +-
.../sdk/runners/TransformHierarchyTest.java | 41 +++---
.../beam/sdk/runners/TransformTreeTest.java | 19 +--
.../runners/dataflow/TestCountingSource.java | 2 +-
.../apache/beam/sdk/transforms/CreateTest.java | 31 ++--
.../apache/beam/sdk/transforms/FlattenTest.java | 2 +-
.../beam/sdk/transforms/GroupByKeyTest.java | 11 +-
.../apache/beam/sdk/transforms/ViewTest.java | 11 +-
.../beam/sdk/values/PCollectionTupleTest.java | 7 +-
.../beam/sdk/extensions/sorter/SortValues.java | 20 +--
.../org/apache/beam/sdk/io/amqp/AmqpIO.java | 2 +-
.../beam/sdk/io/cassandra/CassandraIO.java | 2 +-
.../sdk/io/elasticsearch/ElasticsearchIO.java | 2 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 18 +--
.../sdk/io/gcp/bigquery/BigQuerySourceBase.java | 4 +-
.../io/gcp/bigquery/PassThroughThenCleanup.java | 2 +-
.../sdk/io/gcp/bigquery/StreamingInserts.java | 8 -
.../beam/sdk/io/gcp/bigtable/BigtableIO.java | 2 +-
.../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java | 13 +-
.../io/gcp/pubsub/PubsubUnboundedSource.java | 2 +-
.../hadoop/inputformat/HadoopInputFormatIO.java | 2 +-
.../org/apache/beam/sdk/io/hbase/HBaseIO.java | 2 +-
.../apache/beam/sdk/io/hcatalog/HCatalogIO.java | 2 +-
.../java/org/apache/beam/sdk/io/jms/JmsIO.java | 2 +-
.../org/apache/beam/sdk/io/kafka/KafkaIO.java | 2 +-
.../beam/sdk/io/kinesis/KinesisSource.java | 2 +-
.../beam/sdk/io/mongodb/MongoDbGridFSIO.java | 2 +-
.../apache/beam/sdk/io/mongodb/MongoDbIO.java | 2 +-
.../org/apache/beam/sdk/io/mqtt/MqttIO.java | 2 +-
.../org/apache/beam/sdk/io/xml/XmlSource.java | 2 +-
108 files changed, 631 insertions(+), 778 deletions(-)
----------------------------------------------------------------------