You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by bc...@apache.org on 2023/10/19 02:25:38 UTC
[beam-swift] 12/17: Merge pull request #1 from byronellis/main
This is an automated email from the ASF dual-hosted git repository.
bce pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/beam-swift.git
commit 48d0a7958a228a164b36c45fd6c24cc89ccc10bd
Merge: d2c23f2 210420a
Author: Byron Ellis <by...@gmail.com>
AuthorDate: Tue Oct 17 18:31:12 2023 -0700
Merge pull request #1 from byronellis/main
Initial import of code from original repository
.gitignore | 8 +
Package.resolved | 167 +
Package.swift | 70 +
README.md | 32 +
Sources/ApacheBeam/ApacheBeam.swift | 21 +
.../ApacheBeam/Client/ApiServiceDescriptor.swift | 90 +
Sources/ApacheBeam/Client/ExpansionClient.swift | 37 +
Sources/ApacheBeam/Coders/BeamValue.swift | 74 +
Sources/ApacheBeam/Coders/Beamable.swift | 40 +
Sources/ApacheBeam/Coders/Coder+Decoding.swift | 82 +
Sources/ApacheBeam/Coders/Coder+Encoding.swift | 122 +
Sources/ApacheBeam/Coders/Coder.swift | 214 +
Sources/ApacheBeam/Core/ArtifactInfo.swift | 29 +
Sources/ApacheBeam/Core/DynamicProperties.swift | 37 +
Sources/ApacheBeam/Core/Environment.swift | 90 +
Sources/ApacheBeam/Core/Fn/ClosureFn.swift | 60 +
Sources/ApacheBeam/Core/Fn/DoFn.swift | 58 +
Sources/ApacheBeam/Core/Fn/ObjectFn.swift | 33 +
.../Core/Fn/ParameterizedClosureFn.swift | 74 +
Sources/ApacheBeam/Core/Fn/SerializableFn.swift | 41 +
.../Core/Fn/SerializableFnRegistry.swift | 26 +
Sources/ApacheBeam/Core/KeyValue.swift | 62 +
.../Core/PCollection/AnyPCollection.swift | 100 +
.../Core/PCollection/AnyPCollectionStream.swift | 97 +
.../ApacheBeam/Core/PCollection/PCollection.swift | 98 +
.../Core/PCollection/PCollectionGroup.swift | 27 +
.../Core/PCollection/PCollectionStream.swift | 114 +
.../ApacheBeam/Core/PTransform/AnyPTransform.swift | 47 +
Sources/ApacheBeam/Core/PTransform/Group.swift | 38 +
.../ApacheBeam/Core/PTransform/PTransform.swift | 65 +
.../Core/PTransform/PTransformBuilder.swift | 68 +
.../Core/PTransform/PTransformVisitor.swift | 65 +
Sources/ApacheBeam/Core/PTransform/PValue.swift | 89 +
Sources/ApacheBeam/Core/PTransform/Tag.swift | 39 +
Sources/ApacheBeam/Core/PTransform/Transform.swift | 25 +
.../Core/PTransform/TuplePTransform.swift | 37 +
Sources/ApacheBeam/Core/Pipeline/Pipeline.swift | 290 +
.../ApacheBeam/Core/Pipeline/PipelineContext.swift | 33 +
.../ApacheBeam/Core/Pipeline/PipelineRunner.swift | 21 +
.../Core/Pipeline/PipelineTransform.swift | 52 +
Sources/ApacheBeam/Core/Windowing.swift | 55 +
.../model/fn_execution/v1/beam_fn_api.grpc.swift | 2061 +++++
.../fn_execution/v1/beam_provision_api.grpc.swift | 332 +
.../job_management/v1/beam_artifact_api.grpc.swift | 1579 ++++
.../v1/beam_expansion_api.grpc.swift | 425 +
.../job_management/v1/beam_job_api.grpc.swift | 1237 +++
.../model/pipeline/v1/beam_runner_api.grpc.swift | 322 +
.../model/fn_execution/v1/beam_fn_api.pb.swift | 5317 ++++++++++++
.../fn_execution/v1/beam_provision_api.pb.swift | 383 +
.../job_management/v1/beam_artifact_api.pb.swift | 1372 +++
.../job_management/v1/beam_expansion_api.pb.swift | 413 +
.../model/job_management/v1/beam_job_api.pb.swift | 1708 ++++
.../model/pipeline/v1/beam_runner_api.pb.swift | 9135 ++++++++++++++++++++
.../beam/model/pipeline/v1/endpoints.pb.swift | 178 +
.../model/pipeline/v1/external_transforms.pb.swift | 482 ++
.../apache/beam/model/pipeline/v1/metrics.pb.swift | 1029 +++
.../apache/beam/model/pipeline/v1/schema.pb.swift | 2273 +++++
.../model/pipeline/v1/standard_window_fns.pb.swift | 515 ++
Sources/ApacheBeam/Internal/Array+Helpers.swift | 23 +
Sources/ApacheBeam/Internal/Data+Decoding.swift | 101 +
Sources/ApacheBeam/Internal/Data+Encoding.swift | 51 +
Sources/ApacheBeam/Internal/Date+Timestamp.swift | 29 +
.../ApacheBeam/Internal/Dictionary+Helpers.swift | 24 +
Sources/ApacheBeam/Internal/Model+Typealias.swift | 33 +
.../ApacheBeam/Internal/PipelineProto+Coder.swift | 45 +
.../Internal/PipelineProto+Environment.swift | 27 +
.../Internal/PipelineProto+Initializers.swift | 90 +
Sources/ApacheBeam/Internal/ProtoConversion.swift | 23 +
Sources/ApacheBeam/Internal/Server+Endpoint.swift | 34 +
Sources/ApacheBeam/Internal/String+Urns.swift | 39 +
Sources/ApacheBeam/Runners/PortableRunner.swift | 75 +
.../Runtime/Bundle/BundleProcessor.swift | 138 +
Sources/ApacheBeam/Runtime/Bundle/Sink.swift | 44 +
Sources/ApacheBeam/Runtime/Bundle/Source.swift | 69 +
.../Runtime/Commands/PipelineCommand.swift | 38 +
.../Commands/Tools/PortableRunnerTool.swift | 27 +
Sources/ApacheBeam/Runtime/DataplaneClient.swift | 232 +
.../Runtime/Metrics/MetricReporter.swift | 20 +
Sources/ApacheBeam/Runtime/Worker/Worker.swift | 94 +
.../ApacheBeam/Runtime/Worker/WorkerProvider.swift | 79 +
Sources/ApacheBeam/Schema/FieldType+Proto.swift | 162 +
Sources/ApacheBeam/Schema/FieldType.swift | 46 +
.../ApacheBeam/Schema/FieldValue+Decoding.swift | 90 +
.../ApacheBeam/Schema/FieldValue+Encoding.swift | 91 +
Sources/ApacheBeam/Schema/FieldValue+Proto.swift | 55 +
Sources/ApacheBeam/Schema/FieldValue.swift | 169 +
Sources/ApacheBeam/Schema/RowElement.swift | 21 +
Sources/ApacheBeam/Schema/RowProtocol.swift | 19 +
Sources/ApacheBeam/Schema/Schema+Proto.swift | 53 +
Sources/ApacheBeam/Schema/Schema.swift | 129 +
.../ApacheBeam/Testing/PCollection+Testing.swift | 35 +
Sources/ApacheBeam/Testing/PCollectionTest.swift | 58 +
Sources/ApacheBeam/Transforms/Basic.swift | 109 +
.../ApacheBeam/Transforms/BuiltIn+Elements.swift | 51 +
.../ApacheBeam/Transforms/BuiltIn+Windows.swift | 25 +
Sources/ApacheBeam/Transforms/BuiltIn.swift | 213 +
Sources/ApacheBeam/Transforms/Combining.swift | 42 +
Sources/ApacheBeam/Transforms/Composite.swift | 26 +
Sources/ApacheBeam/Transforms/Grouping.swift | 26 +
Sources/ApacheBeam/Transforms/IO/FileIO.swift | 35 +
.../Transforms/IO/GoogleCloud/GoogleStorage.swift | 113 +
.../Transforms/IO/Local/LocalStorage.swift | 53 +
Tests/ApacheBeamTests/ApacheBeamTests.swift | 31 +
Tests/ApacheBeamTests/Coders/CoderTests.swift | 68 +
.../CrossLanguage/ExpansionServiceTests.swift | 34 +
.../Pipeline/CompositeIntegrationTests.swift | 83 +
Tests/ApacheBeamTests/Pipeline/FileIOTests.swift | 97 +
Tests/ApacheBeamTests/Pipeline/Fixtures/file1.txt | 4 +
Tests/ApacheBeamTests/Pipeline/Fixtures/file2.txt | 3 +
.../Pipeline/IntegrationTests.swift | 83 +
Tests/ApacheBeamTests/Schema/SchemaTests.swift | 35 +
111 files changed, 34982 insertions(+)