This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from 1eaa869 (commit)
to 8463a05 (commit)
from 1eaa869 [BEAM-7372][BEAM-9372] Cleanup py2 and py35 codepath from
runners worker (#14730)
add 5b99d4a [BEAM-12158] Update session and pubsub protos. (#14831)
add 5bb1bbf [BEAM-12017] initial implementation of combine and
combine_first (#14656)
add 2c796cb [BEAM-12358] Add Nullable annotation to key field in TimerKey
(#14835)
add 345af33 [BEAM-10099] Add FhirIO and HL7v2IO to I/O matrix
add 974056d Merge pull request #14841 from [BEAM-10099] Add FhirIO and
HL7v2IO to I/O matrix
add 4b449f2 [BEAM-9547] Add support for drop_duplicates and duplicated
(#14786)
add f25b42e Don't compile with 8 if flag is set (#14838)
add aaaf0fb [BEAM-11644] Remove pack_all_combiners optimizer phase
(#14647)
add 88dd2c9 [BEAM-12341] Enable Portable job submission for Dataflow
(#14822)
add 660fe11 [BEAM-9615] Enable Schemas for struct coding. (#14826)
add 99b1a92 [BEAM-10670] Use non-SDF based translation for Read by
default on all runners except Dataflow
add 2d37477 Merge pull request #14801 from[BEAM-10670] Use non-SDF based
translation for Read by default on all runners except Dataflow
add e959d62 Fixes a case where BigQuery sink swallows HttpErrors
preventing retries.
add d221125 Merge pull request #14837 from chamikaramj/bq_empty_error
add 159a9d3 [BEAM-7372] cleanup py2 codepath from combiners.py (#14634)
add 8926c43 [BEAM-7372] cleanup py2 and py35 codepath from
apache_beam/typehints (#14752)
add 8463a05 [BEAM-11227] Upgrade vendored gRPC to 1.36.0 with test fix
(#14833)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 1 +
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 12 +-
.../apache/beam/gradle/GrpcVendoring_1_26_0.groovy | 222 ------
examples/java/build.gradle | 2 +-
.../transforms/DataProtectors.java | 6 +-
.../kafkatopubsub/kafka/consumer/Utils.java | 4 +-
.../get-started/try-apache-beam-java.ipynb | 12 +-
runners/core-construction-java/build.gradle | 2 +-
.../beam/runners/core/construction/BeamUrns.java | 2 +-
.../core/construction/CoderTranslation.java | 2 +-
.../core/construction/CoderTranslators.java | 2 +-
.../core/construction/CombineTranslation.java | 2 +-
.../CreatePCollectionViewTranslation.java | 2 +-
.../DefaultExpansionServiceClientFactory.java | 2 +-
.../core/construction/DisplayDataTranslation.java | 2 +-
.../runners/core/construction/Environments.java | 4 +-
.../beam/runners/core/construction/External.java | 6 +-
.../runners/core/construction/ModelCoders.java | 2 +-
.../construction/PCollectionViewTranslation.java | 2 +-
.../core/construction/ParDoTranslation.java | 4 +-
.../construction/PipelineOptionsTranslation.java | 6 +-
.../runners/core/construction/ReadTranslation.java | 4 +-
.../runners/core/construction/SdkComponents.java | 2 +-
.../runners/core/construction/SplittableParDo.java | 4 +-
.../core/construction/TestStreamTranslation.java | 2 +-
.../core/construction/WindowIntoTranslation.java | 2 +-
.../construction/WindowingStrategyTranslation.java | 8 +-
.../core/construction/WriteFilesTranslation.java | 2 +-
.../graph/GreedyPCollectionFusers.java | 2 +-
.../core/construction/graph/QueryablePipeline.java | 2 +-
.../runners/core/construction/CommonCoderTest.java | 2 +-
.../PipelineOptionsTranslationTest.java | 6 +-
.../core/construction/PipelineTranslationTest.java | 2 +-
.../core/construction/ValidateRunnerXlangTest.java | 8 +-
.../construction/WindowIntoTranslationTest.java | 2 +-
.../construction/graph/ProtoOverridesTest.java | 2 +-
runners/core-java/build.gradle | 2 +-
.../runners/core/metrics/MetricsContainerImpl.java | 2 +-
.../core/metrics/MetricsContainerStepMap.java | 6 +-
.../core/metrics/MonitoringInfoEncodings.java | 2 +-
.../runners/core/metrics/SimpleExecutionState.java | 2 +-
.../runners/core/metrics/SimpleStateRegistry.java | 2 +-
.../core/metrics/MonitoringInfoEncodingsTest.java | 2 +-
runners/direct-java/build.gradle | 4 +-
.../apache/beam/runners/direct/DirectRunner.java | 11 +
runners/flink/flink_runner.gradle | 2 +-
.../FlinkBatchPortablePipelineTranslator.java | 2 +-
.../apache/beam/runners/flink/FlinkJobInvoker.java | 2 +-
.../beam/runners/flink/FlinkPipelineRunner.java | 2 +-
.../org/apache/beam/runners/flink/FlinkRunner.java | 15 +-
.../FlinkStreamingPortablePipelineTranslator.java | 2 +-
.../utils/FlinkPortableRunnerUtils.java | 2 +-
.../streaming/ExecutableStageDoFnOperator.java | 4 +-
.../wrappers/streaming/FlinkKeyUtils.java | 2 +-
.../FlinkExecutableStageFunctionTest.java | 2 +-
.../streaming/ExecutableStageDoFnOperatorTest.java | 4 +-
.../wrappers/streaming/FlinkKeyUtilsTest.java | 2 +-
runners/google-cloud-dataflow-java/build.gradle | 2 +-
.../dataflow/DataflowPipelineTranslator.java | 2 +-
.../beam/runners/dataflow/DataflowRunner.java | 4 +-
.../util/RowCoderCloudObjectTranslator.java | 2 +-
.../util/SchemaCoderCloudObjectTranslator.java | 2 +-
.../dataflow/DataflowPipelineTranslatorTest.java | 2 +-
.../beam/runners/dataflow/DataflowRunnerTest.java | 2 +-
.../google-cloud-dataflow-java/worker/build.gradle | 2 +-
.../worker/legacy-worker/build.gradle | 4 +-
.../runners/dataflow/worker/ByteStringCoder.java | 2 +-
.../dataflow/worker/DataflowRunnerHarness.java | 2 +-
.../worker/DataflowWorkerHarnessHelper.java | 2 +-
.../worker/GroupAlsoByWindowParDoFnFactory.java | 2 +-
.../beam/runners/dataflow/worker/PubsubSink.java | 2 +-
.../beam/runners/dataflow/worker/StateFetcher.java | 2 +-
.../dataflow/worker/StreamingDataflowWorker.java | 4 +-
.../worker/StreamingModeExecutionContext.java | 2 +-
.../dataflow/worker/StreamingSideInputFetcher.java | 4 +-
.../dataflow/worker/WindmillComputationKey.java | 4 +-
.../dataflow/worker/WindmillNamespacePrefix.java | 2 +-
.../beam/runners/dataflow/worker/WindmillSink.java | 2 +-
.../dataflow/worker/WindmillStateCache.java | 2 +-
.../dataflow/worker/WindmillStateInternals.java | 2 +-
.../dataflow/worker/WindmillStateReader.java | 2 +-
.../dataflow/worker/WindmillTimerInternals.java | 2 +-
.../dataflow/worker/WorkerCustomSources.java | 2 +-
.../dataflow/worker/fn/BeamFnControlService.java | 6 +-
.../control/RegisterAndProcessBundleOperation.java | 4 +-
.../worker/fn/data/BeamFnDataGrpcService.java | 4 +-
.../worker/fn/logging/BeamFnLoggingService.java | 4 +-
.../fn/stream/ServerStreamObserverFactory.java | 6 +-
.../graph/CreateExecutableStageNodeFunction.java | 4 +-
...nsertFetchAndFilterStreamingSideInputNodes.java | 2 +-
.../worker/graph/RegisterNodeFunction.java | 4 +-
.../worker/windmill/DirectStreamObserver.java | 4 +-
.../windmill/ForwardingClientResponseObserver.java | 6 +-
.../worker/windmill/GrpcWindmillServer.java | 30 +-
.../worker/windmill/StreamObserverFactory.java | 4 +-
.../runners/dataflow/harness/test/TestStreams.java | 4 +-
.../runners/dataflow/worker/DataflowMatchers.java | 2 +-
.../worker/DataflowWorkerHarnessHelperTest.java | 2 +-
.../runners/dataflow/worker/PubsubReaderTest.java | 2 +-
.../runners/dataflow/worker/PubsubSinkTest.java | 2 +-
.../runners/dataflow/worker/ReaderCacheTest.java | 2 +-
.../runners/dataflow/worker/StateFetcherTest.java | 2 +-
.../worker/StreamingDataflowWorkerTest.java | 6 +-
.../worker/StreamingGroupAlsoByWindowFnsTest.java | 2 +-
...reamingGroupAlsoByWindowsReshuffleDoFnTest.java | 2 +-
.../worker/StreamingModeExecutionContextTest.java | 2 +-
.../worker/StreamingSideInputDoFnRunnerTest.java | 2 +-
.../worker/StreamingSideInputFetcherTest.java | 2 +-
.../dataflow/worker/WindmillKeyedWorkItemTest.java | 2 +-
.../worker/WindmillReaderIteratorBaseTest.java | 2 +-
.../dataflow/worker/WindmillStateCacheTest.java | 2 +-
.../worker/WindmillStateInternalsTest.java | 2 +-
.../dataflow/worker/WindmillStateReaderTest.java | 4 +-
.../dataflow/worker/WorkerCustomSourcesTest.java | 2 +-
.../worker/fn/BeamFnControlServiceTest.java | 6 +-
.../RegisterAndProcessBundleOperationTest.java | 2 +-
.../worker/fn/data/BeamFnDataGrpcServiceTest.java | 32 +-
.../fn/logging/BeamFnLoggingServiceTest.java | 24 +-
.../fn/stream/ServerStreamObserverFactoryTest.java | 4 +-
...tFetchAndFilterStreamingSideInputNodesTest.java | 2 +-
.../logging/DataflowWorkerLoggingHandlerTest.java | 2 +-
.../worker/windmill/GrpcWindmillServerTest.java | 14 +-
runners/java-fn-execution/build.gradle | 2 +-
.../apache/beam/runners/fnexecution/FnService.java | 6 +-
.../GrpcContextHeaderAccessorProvider.java | 16 +-
.../beam/runners/fnexecution/GrpcFnServer.java | 2 +-
.../fnexecution/InProcessServerFactory.java | 8 +-
.../beam/runners/fnexecution/ServerFactory.java | 20 +-
.../artifact/ArtifactRetrievalService.java | 8 +-
.../artifact/ArtifactStagingService.java | 10 +-
.../control/BundleCheckpointHandlers.java | 2 +-
.../fnexecution/control/FnApiControlClient.java | 6 +-
.../control/FnApiControlClientPoolService.java | 6 +-
.../control/ProcessBundleDescriptors.java | 2 +-
.../runners/fnexecution/data/GrpcDataService.java | 2 +-
.../environment/ExternalEnvironmentFactory.java | 2 +-
.../fnexecution/logging/GrpcLoggingService.java | 2 +-
.../runners/fnexecution/provisioning/JobInfo.java | 2 +-
.../provisioning/StaticGrpcProvisionService.java | 2 +-
.../fnexecution/state/GrpcStateService.java | 4 +-
.../fnexecution/state/StateRequestHandlers.java | 2 +-
.../status/BeamWorkerStatusGrpcService.java | 2 +-
.../fnexecution/status/WorkerStatusClient.java | 2 +-
.../translation/PipelineTranslatorUtils.java | 2 +-
.../runners/fnexecution/wire/ByteStringCoder.java | 2 +-
.../GrpcContextHeaderAccessorProviderTest.java | 20 +-
.../runners/fnexecution/ServerFactoryTest.java | 12 +-
.../artifact/ArtifactRetrievalServiceTest.java | 10 +-
.../artifact/ArtifactStagingServiceTest.java | 12 +-
.../control/DefaultJobBundleFactoryTest.java | 4 +-
.../control/FnApiControlClientPoolServiceTest.java | 8 +-
.../control/FnApiControlClientTest.java | 2 +-
.../fnexecution/control/RemoteExecutionTest.java | 2 +-
.../fnexecution/control/SdkHarnessClientTest.java | 2 +-
.../fnexecution/data/GrpcDataServiceTest.java | 8 +-
.../logging/GrpcLoggingServiceTest.java | 19 +-
.../StaticGrpcProvisionServiceTest.java | 10 +-
.../fnexecution/state/GrpcStateServiceTest.java | 4 +-
.../state/StateRequestHandlersTest.java | 2 +-
.../status/BeamWorkerStatusGrpcServiceTest.java | 8 +-
.../fnexecution/status/WorkerStatusClientTest.java | 2 +-
.../fnexecution/wire/ByteStringCoderTest.java | 2 +-
runners/java-job-service/build.gradle | 2 +-
.../runners/jobsubmission/InMemoryJobService.java | 10 +-
.../beam/runners/jobsubmission/JobInvocation.java | 2 +-
.../beam/runners/jobsubmission/JobInvoker.java | 2 +-
.../beam/runners/jobsubmission/JobPreparation.java | 2 +-
.../jobsubmission/PortablePipelineJarCreator.java | 4 +-
.../jobsubmission/PortablePipelineJarUtils.java | 6 +-
.../jobsubmission/InMemoryJobServiceTest.java | 6 +-
.../runners/jobsubmission/JobInvocationTest.java | 2 +-
.../PortablePipelineJarCreatorTest.java | 2 +-
runners/portability/java/build.gradle | 2 +-
.../runners/portability/ExternalWorkerService.java | 2 +-
.../portability/JobServicePipelineResult.java | 2 +-
.../beam/runners/portability/PortableRunner.java | 4 +-
.../portability/testing/TestJobService.java | 2 +-
.../portability/ExternalWorkerServiceTest.java | 2 +-
.../runners/portability/PortableRunnerTest.java | 8 +-
runners/samza/build.gradle | 2 +-
.../apache/beam/runners/samza/SamzaJobInvoker.java | 2 +-
.../org/apache/beam/runners/samza/SamzaRunner.java | 10 +
.../samza/runtime/SamzaTimerInternalsFactory.java | 2 +-
.../samza/translation/WindowAssignTranslator.java | 2 +-
.../samza/util/SamzaPipelineTranslatorUtils.java | 2 +-
.../SparkStructuredStreamingRunner.java | 12 +-
runners/spark/spark_runner.gradle | 3 +-
.../apache/beam/runners/spark/SparkJobInvoker.java | 2 +-
.../beam/runners/spark/SparkPipelineRunner.java | 2 +-
.../org/apache/beam/runners/spark/SparkRunner.java | 11 +-
.../beam/runners/spark/SparkRunnerDebugger.java | 11 +-
runners/twister2/build.gradle | 2 +-
.../beam/runners/twister2/Twister2Runner.java | 20 +
.../functions/AssignWindowsFunction.java | 2 +-
.../translators/functions/DoFnFunction.java | 2 +-
.../functions/GroupByWindowFunction.java | 2 +-
sdks/go/pkg/beam/beam.shims.go | 4 +
sdks/go/pkg/beam/coder.go | 12 +-
.../pkg/beam/core/runtime/coderx/coderx.shims.go | 2 +
sdks/go/pkg/beam/core/runtime/harness/gen.go | 2 +-
.../go/pkg/beam/core/runtime/harness/session.proto | 4 +-
.../core/runtime/harness/session/session.pb.go | 814 +++++++++++++--------
sdks/go/pkg/beam/core/runtime/pipelinex/replace.go | 155 +++-
.../beam/core/runtime/pipelinex/replace_test.go | 116 ++-
sdks/go/pkg/beam/io/pubsubio/v1/gen.go | 2 +-
sdks/go/pkg/beam/io/pubsubio/v1/v1.pb.go | 320 +++++---
sdks/go/pkg/beam/io/pubsubio/v1/v1.proto | 4 +-
sdks/go/pkg/beam/io/synthetic/source.go | 1 +
sdks/go/pkg/beam/runners/dataflow/dataflow.go | 10 +-
.../runners/vet/testpipeline/testpipeline.shims.go | 2 +
sdks/go/pkg/beam/testing/passert/passert.shims.go | 9 +
sdks/go/pkg/beam/transforms/filter/filter.shims.go | 2 +
sdks/go/pkg/beam/transforms/stats/stats.shims.go | 154 ++--
sdks/go/pkg/beam/transforms/top/top.shims.go | 3 +
sdks/go/pkg/beam/util/shimx/generate.go | 2 +-
sdks/go/pkg/beam/x/debug/debug.shims.go | 7 +
sdks/java/core/build.gradle | 2 +-
.../java/org/apache/beam/sdk/io/TextSource.java | 2 +-
.../java/org/apache/beam/sdk/io/range/ByteKey.java | 4 +-
.../apache/beam/sdk/schemas/SchemaTranslation.java | 2 +-
.../transforms/resourcehints/ResourceHints.java | 2 +-
.../test/java/org/apache/beam/sdk/io/ReadTest.java | 4 +
.../beam/sdk/transforms/GroupIntoBatchesTest.java | 5 +-
sdks/java/expansion-service/build.gradle | 2 +-
.../sdk/expansion/service/ExpansionServer.java | 4 +-
.../sdk/expansion/service/ExpansionService.java | 6 +-
.../expansion/service/ExpansionServiceTest.java | 2 +-
.../beam/sdk/expansion/service/ExternalTest.java | 4 +-
.../schemaio-expansion-service/build.gradle | 2 +-
.../ExternalSchemaIOTransformRegistrar.java | 2 +-
sdks/java/fn-execution/build.gradle | 2 +-
.../beam/sdk/fn/channel/ManagedChannelFactory.java | 18 +-
.../beam/sdk/fn/channel/SocketAddressFactory.java | 2 +-
.../data/BeamFnDataBufferingOutboundObserver.java | 2 +-
.../sdk/fn/data/BeamFnDataGrpcMultiplexer.java | 6 +-
.../sdk/fn/data/BeamFnDataInboundObserver.java | 2 +-
...amFnDataSizeBasedBufferingOutboundObserver.java | 4 +-
...amFnDataTimeBasedBufferingOutboundObserver.java | 2 +-
.../beam/sdk/fn/data/DecodingFnDataReceiver.java | 2 +-
.../beam/sdk/fn/data/RemoteGrpcPortRead.java | 2 +-
.../beam/sdk/fn/data/RemoteGrpcPortWrite.java | 2 +-
.../sdk/fn/stream/BufferingStreamObserver.java | 4 +-
.../org/apache/beam/sdk/fn/stream/DataStreams.java | 2 +-
.../beam/sdk/fn/stream/DirectStreamObserver.java | 4 +-
.../stream/ForwardingClientResponseObserver.java | 6 +-
.../sdk/fn/stream/OutboundObserverFactory.java | 4 +-
.../sdk/fn/stream/SynchronizedStreamObserver.java | 2 +-
.../fn/test/InProcessManagedChannelFactory.java | 4 +-
.../org/apache/beam/sdk/fn/test/TestStreams.java | 4 +-
.../sdk/fn/windowing/EncodedBoundedWindow.java | 2 +-
.../sdk/fn/channel/ManagedChannelFactoryTest.java | 6 +-
.../sdk/fn/channel/SocketAddressFactoryTest.java | 2 +-
.../sdk/fn/data/BeamFnDataGrpcMultiplexerTest.java | 2 +-
...DataSizeBasedBufferingOutboundObserverTest.java | 2 +-
...DataTimeBasedBufferingOutboundObserverTest.java | 2 +-
.../beam/sdk/fn/data/RemoteGrpcPortReadTest.java | 2 +-
.../beam/sdk/fn/data/RemoteGrpcPortWriteTest.java | 2 +-
.../apache/beam/sdk/fn/stream/DataStreamsTest.java | 2 +-
.../ForwardingClientResponseObserverTest.java | 6 +-
.../sdk/fn/stream/OutboundObserverFactoryTest.java | 4 +-
.../sdk/fn/windowing/EncodedBoundedWindowTest.java | 2 +-
sdks/java/harness/build.gradle | 2 +-
.../apache/beam/fn/harness/FnApiDoFnRunner.java | 16 +-
.../java/org/apache/beam/fn/harness/FnHarness.java | 4 +-
.../harness/control/AddHarnessIdInterceptor.java | 8 +-
.../fn/harness/control/BeamFnControlClient.java | 4 +-
.../fn/harness/control/ProcessBundleHandler.java | 6 +-
.../beam/fn/harness/data/BeamFnDataClient.java | 2 +-
.../beam/fn/harness/data/BeamFnDataGrpcClient.java | 4 +-
.../harness/data/PCollectionConsumerRegistry.java | 2 +-
.../harness/data/PTransformFunctionRegistry.java | 2 +-
.../fn/harness/data/QueueingBeamFnDataClient.java | 2 +-
.../fn/harness/logging/BeamFnLoggingClient.java | 12 +-
.../apache/beam/fn/harness/state/BagUserState.java | 2 +-
.../harness/state/BeamFnStateGrpcClientCache.java | 4 +-
.../beam/fn/harness/state/FnApiStateAccessor.java | 2 +-
.../beam/fn/harness/state/IterableSideInput.java | 2 +-
.../beam/fn/harness/state/MultimapSideInput.java | 2 +-
.../beam/fn/harness/state/StateBackedIterable.java | 2 +-
.../fn/harness/state/StateFetchingIterators.java | 2 +-
.../beam/fn/harness/status/BeamFnStatusClient.java | 4 +-
.../stream/HarnessStreamObserverFactories.java | 2 +-
.../beam/fn/harness/FnApiDoFnRunnerTest.java | 38 +-
.../org/apache/beam/fn/harness/FnHarnessTest.java | 8 +-
.../harness/control/BeamFnControlClientTest.java | 8 +-
.../harness/control/ProcessBundleHandlerTest.java | 4 +-
.../fn/harness/data/BeamFnDataGrpcClientTest.java | 14 +-
.../data/BeamFnDataInboundObserverTest.java | 2 +-
.../harness/data/QueueingBeamFnDataClientTest.java | 14 +-
.../harness/logging/BeamFnLoggingClientTest.java | 16 +-
.../beam/fn/harness/state/BagUserStateTest.java | 2 +-
.../state/BeamFnStateGrpcClientCacheTest.java | 16 +-
.../fn/harness/state/FakeBeamFnStateClient.java | 2 +-
.../fn/harness/state/MultimapSideInputTest.java | 2 +-
.../fn/harness/state/StateBackedIterableTest.java | 2 +-
.../harness/state/StateFetchingIteratorsTest.java | 2 +-
.../fn/harness/status/BeamFnStatusClientTest.java | 6 +-
.../stream/HarnessStreamObserverFactoriesTest.java | 4 +-
sdks/java/io/contextualtextio/build.gradle | 2 +-
.../contextualtextio/ContextualTextIOSource.java | 2 +-
sdks/java/io/debezium/build.gradle | 2 +-
.../apache/beam/io/debezium/SourceRecordJson.java | 4 +-
sdks/java/io/google-cloud-platform/build.gradle | 2 +-
.../io/gcp/spanner/SpannerTransformRegistrar.java | 2 +-
.../sdk/io/gcp/pubsub/PubsubIOExternalTest.java | 4 +-
.../beam/sdk/io/kafka/KafkaIOExternalTest.java | 4 +-
sdks/java/testing/nexmark/build.gradle | 8 +-
sdks/python/apache_beam/dataframe/frames.py | 161 +++-
sdks/python/apache_beam/dataframe/frames_test.py | 226 ++++++
.../apache_beam/dataframe/pandas_doctests_test.py | 25 +-
.../examples/complete/top_wikipedia_sessions.py | 4 +-
sdks/python/apache_beam/io/gcp/bigquery_tools.py | 3 +
.../portability/fn_api_runner/translations.py | 4 -
.../portability/fn_api_runner/translations_test.py | 43 +-
sdks/python/apache_beam/transforms/combiners.py | 212 ++----
sdks/python/apache_beam/typehints/__init__.py | 2 -
sdks/python/apache_beam/typehints/decorators.py | 135 +---
.../apache_beam/typehints/decorators_test.py | 189 ++++-
.../apache_beam/typehints/decorators_test_py3.py | 215 ------
.../typehints/native_type_compatibility.py | 9 -
.../typehints/native_type_compatibility_test.py | 3 -
sdks/python/apache_beam/typehints/opcodes.py | 6 +-
sdks/python/apache_beam/typehints/row_type.py | 2 -
sdks/python/apache_beam/typehints/schemas.py | 13 +-
sdks/python/apache_beam/typehints/schemas_test.py | 18 +-
.../apache_beam/typehints/sharded_key_type.py | 8 +-
.../apache_beam/typehints/sharded_key_type_test.py | 2 -
.../apache_beam/typehints/trivial_inference.py | 13 +-
.../typehints/trivial_inference_test.py | 41 +-
.../typehints/trivial_inference_test_py3.py | 54 --
sdks/python/apache_beam/typehints/typecheck.py | 23 +-
.../{typecheck_test_py3.py => typecheck_test.py} | 2 -
.../apache_beam/typehints/typed_pipeline_test.py | 496 ++++++++++++-
.../typehints/typed_pipeline_test_py3.py | 535 --------------
sdks/python/apache_beam/typehints/typehints.py | 9 +-
.../python/apache_beam/typehints/typehints_test.py | 248 ++++++-
.../apache_beam/typehints/typehints_test_py3.py | 274 -------
settings.gradle.kts | 1 -
vendor/grpc-1_26_0/build.gradle | 37 -
website/www/site/data/io_matrix.yaml | 12 +
340 files changed, 3209 insertions(+), 2931 deletions(-)
delete mode 100644
buildSrc/src/main/groovy/org/apache/beam/gradle/GrpcVendoring_1_26_0.groovy
delete mode 100644 sdks/python/apache_beam/typehints/decorators_test_py3.py
delete mode 100644
sdks/python/apache_beam/typehints/trivial_inference_test_py3.py
rename sdks/python/apache_beam/typehints/{typecheck_test_py3.py =>
typecheck_test.py} (99%)
delete mode 100644 sdks/python/apache_beam/typehints/typed_pipeline_test_py3.py
delete mode 100644 sdks/python/apache_beam/typehints/typehints_test_py3.py
delete mode 100644 vendor/grpc-1_26_0/build.gradle
