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 <[email protected]> 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(+)
