This is an automated email from the ASF dual-hosted git repository.
bce pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/beam-swift.git
from d2c23f2 Create LICENSE
new 63de428 Initial Package Creation
new 385eb27 Copying existing implementation from old Beam branch
new 597f7d5 Remove unused dependencies and fix platforms for macOS builds
new dd1254c Add a README and Package.resolved
new 1c32ef7 Added README
new 6e9491e Fix license header
new af3d4e5 Fix typo
new 210420a Improve README wording
new 48d0a79 Merge pull request #1 from byronellis/main
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.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(+)
create mode 100644 .gitignore
create mode 100644 Package.resolved
create mode 100644 Package.swift
create mode 100644 README.md
create mode 100644 Sources/ApacheBeam/ApacheBeam.swift
create mode 100644 Sources/ApacheBeam/Client/ApiServiceDescriptor.swift
create mode 100644 Sources/ApacheBeam/Client/ExpansionClient.swift
create mode 100644 Sources/ApacheBeam/Coders/BeamValue.swift
create mode 100644 Sources/ApacheBeam/Coders/Beamable.swift
create mode 100644 Sources/ApacheBeam/Coders/Coder+Decoding.swift
create mode 100644 Sources/ApacheBeam/Coders/Coder+Encoding.swift
create mode 100644 Sources/ApacheBeam/Coders/Coder.swift
create mode 100644 Sources/ApacheBeam/Core/ArtifactInfo.swift
create mode 100644 Sources/ApacheBeam/Core/DynamicProperties.swift
create mode 100644 Sources/ApacheBeam/Core/Environment.swift
create mode 100644 Sources/ApacheBeam/Core/Fn/ClosureFn.swift
create mode 100644 Sources/ApacheBeam/Core/Fn/DoFn.swift
create mode 100644 Sources/ApacheBeam/Core/Fn/ObjectFn.swift
create mode 100644 Sources/ApacheBeam/Core/Fn/ParameterizedClosureFn.swift
create mode 100644 Sources/ApacheBeam/Core/Fn/SerializableFn.swift
create mode 100644 Sources/ApacheBeam/Core/Fn/SerializableFnRegistry.swift
create mode 100644 Sources/ApacheBeam/Core/KeyValue.swift
create mode 100644 Sources/ApacheBeam/Core/PCollection/AnyPCollection.swift
create mode 100644
Sources/ApacheBeam/Core/PCollection/AnyPCollectionStream.swift
create mode 100644 Sources/ApacheBeam/Core/PCollection/PCollection.swift
create mode 100644 Sources/ApacheBeam/Core/PCollection/PCollectionGroup.swift
create mode 100644 Sources/ApacheBeam/Core/PCollection/PCollectionStream.swift
create mode 100644 Sources/ApacheBeam/Core/PTransform/AnyPTransform.swift
create mode 100644 Sources/ApacheBeam/Core/PTransform/Group.swift
create mode 100644 Sources/ApacheBeam/Core/PTransform/PTransform.swift
create mode 100644 Sources/ApacheBeam/Core/PTransform/PTransformBuilder.swift
create mode 100644 Sources/ApacheBeam/Core/PTransform/PTransformVisitor.swift
create mode 100644 Sources/ApacheBeam/Core/PTransform/PValue.swift
create mode 100644 Sources/ApacheBeam/Core/PTransform/Tag.swift
create mode 100644 Sources/ApacheBeam/Core/PTransform/Transform.swift
create mode 100644 Sources/ApacheBeam/Core/PTransform/TuplePTransform.swift
create mode 100644 Sources/ApacheBeam/Core/Pipeline/Pipeline.swift
create mode 100644 Sources/ApacheBeam/Core/Pipeline/PipelineContext.swift
create mode 100644 Sources/ApacheBeam/Core/Pipeline/PipelineRunner.swift
create mode 100644 Sources/ApacheBeam/Core/Pipeline/PipelineTransform.swift
create mode 100644 Sources/ApacheBeam/Core/Windowing.swift
create mode 100644
Sources/ApacheBeam/Generated/GRPC/org/apache/beam/model/fn_execution/v1/beam_fn_api.grpc.swift
create mode 100644
Sources/ApacheBeam/Generated/GRPC/org/apache/beam/model/fn_execution/v1/beam_provision_api.grpc.swift
create mode 100644
Sources/ApacheBeam/Generated/GRPC/org/apache/beam/model/job_management/v1/beam_artifact_api.grpc.swift
create mode 100644
Sources/ApacheBeam/Generated/GRPC/org/apache/beam/model/job_management/v1/beam_expansion_api.grpc.swift
create mode 100644
Sources/ApacheBeam/Generated/GRPC/org/apache/beam/model/job_management/v1/beam_job_api.grpc.swift
create mode 100644
Sources/ApacheBeam/Generated/GRPC/org/apache/beam/model/pipeline/v1/beam_runner_api.grpc.swift
create mode 100644
Sources/ApacheBeam/Generated/Model/org/apache/beam/model/fn_execution/v1/beam_fn_api.pb.swift
create mode 100644
Sources/ApacheBeam/Generated/Model/org/apache/beam/model/fn_execution/v1/beam_provision_api.pb.swift
create mode 100644
Sources/ApacheBeam/Generated/Model/org/apache/beam/model/job_management/v1/beam_artifact_api.pb.swift
create mode 100644
Sources/ApacheBeam/Generated/Model/org/apache/beam/model/job_management/v1/beam_expansion_api.pb.swift
create mode 100644
Sources/ApacheBeam/Generated/Model/org/apache/beam/model/job_management/v1/beam_job_api.pb.swift
create mode 100644
Sources/ApacheBeam/Generated/Model/org/apache/beam/model/pipeline/v1/beam_runner_api.pb.swift
create mode 100644
Sources/ApacheBeam/Generated/Model/org/apache/beam/model/pipeline/v1/endpoints.pb.swift
create mode 100644
Sources/ApacheBeam/Generated/Model/org/apache/beam/model/pipeline/v1/external_transforms.pb.swift
create mode 100644
Sources/ApacheBeam/Generated/Model/org/apache/beam/model/pipeline/v1/metrics.pb.swift
create mode 100644
Sources/ApacheBeam/Generated/Model/org/apache/beam/model/pipeline/v1/schema.pb.swift
create mode 100644
Sources/ApacheBeam/Generated/Model/org/apache/beam/model/pipeline/v1/standard_window_fns.pb.swift
create mode 100644 Sources/ApacheBeam/Internal/Array+Helpers.swift
create mode 100644 Sources/ApacheBeam/Internal/Data+Decoding.swift
create mode 100644 Sources/ApacheBeam/Internal/Data+Encoding.swift
create mode 100644 Sources/ApacheBeam/Internal/Date+Timestamp.swift
create mode 100644 Sources/ApacheBeam/Internal/Dictionary+Helpers.swift
create mode 100644 Sources/ApacheBeam/Internal/Model+Typealias.swift
create mode 100644 Sources/ApacheBeam/Internal/PipelineProto+Coder.swift
create mode 100644 Sources/ApacheBeam/Internal/PipelineProto+Environment.swift
create mode 100644 Sources/ApacheBeam/Internal/PipelineProto+Initializers.swift
create mode 100644 Sources/ApacheBeam/Internal/ProtoConversion.swift
create mode 100644 Sources/ApacheBeam/Internal/Server+Endpoint.swift
create mode 100644 Sources/ApacheBeam/Internal/String+Urns.swift
create mode 100644 Sources/ApacheBeam/Runners/PortableRunner.swift
create mode 100644 Sources/ApacheBeam/Runtime/Bundle/BundleProcessor.swift
create mode 100644 Sources/ApacheBeam/Runtime/Bundle/Sink.swift
create mode 100644 Sources/ApacheBeam/Runtime/Bundle/Source.swift
create mode 100644 Sources/ApacheBeam/Runtime/Commands/PipelineCommand.swift
create mode 100644
Sources/ApacheBeam/Runtime/Commands/Tools/PortableRunnerTool.swift
create mode 100644 Sources/ApacheBeam/Runtime/DataplaneClient.swift
create mode 100644 Sources/ApacheBeam/Runtime/Metrics/MetricReporter.swift
create mode 100644 Sources/ApacheBeam/Runtime/Worker/Worker.swift
create mode 100644 Sources/ApacheBeam/Runtime/Worker/WorkerProvider.swift
create mode 100644 Sources/ApacheBeam/Schema/FieldType+Proto.swift
create mode 100644 Sources/ApacheBeam/Schema/FieldType.swift
create mode 100644 Sources/ApacheBeam/Schema/FieldValue+Decoding.swift
create mode 100644 Sources/ApacheBeam/Schema/FieldValue+Encoding.swift
create mode 100644 Sources/ApacheBeam/Schema/FieldValue+Proto.swift
create mode 100644 Sources/ApacheBeam/Schema/FieldValue.swift
create mode 100644 Sources/ApacheBeam/Schema/RowElement.swift
create mode 100644 Sources/ApacheBeam/Schema/RowProtocol.swift
create mode 100644 Sources/ApacheBeam/Schema/Schema+Proto.swift
create mode 100644 Sources/ApacheBeam/Schema/Schema.swift
create mode 100644 Sources/ApacheBeam/Testing/PCollection+Testing.swift
create mode 100644 Sources/ApacheBeam/Testing/PCollectionTest.swift
create mode 100644 Sources/ApacheBeam/Transforms/Basic.swift
create mode 100644 Sources/ApacheBeam/Transforms/BuiltIn+Elements.swift
create mode 100644 Sources/ApacheBeam/Transforms/BuiltIn+Windows.swift
create mode 100644 Sources/ApacheBeam/Transforms/BuiltIn.swift
create mode 100644 Sources/ApacheBeam/Transforms/Combining.swift
create mode 100644 Sources/ApacheBeam/Transforms/Composite.swift
create mode 100644 Sources/ApacheBeam/Transforms/Grouping.swift
create mode 100644 Sources/ApacheBeam/Transforms/IO/FileIO.swift
create mode 100644
Sources/ApacheBeam/Transforms/IO/GoogleCloud/GoogleStorage.swift
create mode 100644 Sources/ApacheBeam/Transforms/IO/Local/LocalStorage.swift
create mode 100644 Tests/ApacheBeamTests/ApacheBeamTests.swift
create mode 100644 Tests/ApacheBeamTests/Coders/CoderTests.swift
create mode 100644
Tests/ApacheBeamTests/CrossLanguage/ExpansionServiceTests.swift
create mode 100644
Tests/ApacheBeamTests/Pipeline/CompositeIntegrationTests.swift
create mode 100644 Tests/ApacheBeamTests/Pipeline/FileIOTests.swift
create mode 100644 Tests/ApacheBeamTests/Pipeline/Fixtures/file1.txt
create mode 100644 Tests/ApacheBeamTests/Pipeline/Fixtures/file2.txt
create mode 100644 Tests/ApacheBeamTests/Pipeline/IntegrationTests.swift
create mode 100644 Tests/ApacheBeamTests/Schema/SchemaTests.swift
