This is an automated email from the ASF dual-hosted git repository. lostluck pushed a commit to branch swift-sdk in repository https://gitbox.apache.org/repos/asf/beam.git
commit 24d960835ad94ec10e8b7d609f66749493feff02 Author: Byron Ellis <[email protected]> AuthorDate: Wed Aug 16 18:28:08 2023 -0700 Add licenses everywhere --- .../swift/Sources/ApacheBeam/Coders/Beamable.swift | 17 ++++++++++++++++ .../ApacheBeam/Core/DynamicProperties.swift | 18 +++++++++++++++++ sdks/swift/Sources/ApacheBeam/Core/Fn/DoFn.swift | 17 ++++++++++++++++ .../Core/PCollection/AnyPCollection.swift | 18 +++++++++++++++++ .../ApacheBeam/Core/PCollection/PCollection.swift | 18 +++++++++++++++++ .../ApacheBeam/Core/PTransform/AnyPTransform.swift | 18 +++++++++++++++++ .../ApacheBeam/Core/PTransform/PTransform.swift | 18 +++++++++++++++++ .../ApacheBeam/Core/Pipeline/Pipeline.swift | 18 +++++++++++++++++ .../ApacheBeam/Core/Pipeline/PipelineContext.swift | 18 +++++++++++++++++ .../ApacheBeam/Core/Pipeline/PipelineRunner.swift | 20 ++++++++++++++++++- .../Core/Pipeline/PipelineTransform.swift | 17 ++++++++++++++++ .../ApacheBeam/Internal/Array+Helpers.swift | 18 +++++++++++++++++ .../ApacheBeam/Internal/Dictionary+Helpers.swift | 20 ++++++++++++++++++- .../ApacheBeam/Internal/PipelineProto+Coder.swift | 18 +++++++++++++++++ .../Internal/PipelineProto+Environment.swift | 18 +++++++++++++++++ .../Internal/PipelineProto+Initializers.swift | 18 +++++++++++++++++ .../ApacheBeam/Internal/Server+Endpoint.swift | 23 ++++++++++++++++------ .../ApacheBeam/Runners/PortableRunner.swift | 18 +++++++++++++++++ .../Runtime/Bundle/BundleProcessor.swift | 18 +++++++++++++++++ .../Sources/ApacheBeam/Runtime/Bundle/Sink.swift | 18 +++++++++++++++++ .../Sources/ApacheBeam/Runtime/Bundle/Source.swift | 18 +++++++++++++++++ .../ApacheBeam/Runtime/DataplaneClient.swift | 18 +++++++++++++++++ .../Sources/ApacheBeam/Runtime/Worker/Worker.swift | 18 +++++++++++++++++ .../Sources/ApacheBeam/Transforms/Basic.swift | 17 ++++++++++++++++ .../Sources/ApacheBeam/Transforms/BuiltIn.swift | 17 ++++++++++++++++ .../Sources/ApacheBeam/Transforms/Combining.swift | 18 +++++++++++++++++ .../Sources/ApacheBeam/Transforms/Grouping.swift | 18 +++++++++++++++++ .../Tests/ApacheBeamTests/ApacheBeamTests.swift | 18 +++++++++++++++++ .../Pipeline/IntegrationTests.swift | 23 ++++++++++++++++------ 29 files changed, 517 insertions(+), 14 deletions(-) diff --git a/sdks/swift/Sources/ApacheBeam/Coders/Beamable.swift b/sdks/swift/Sources/ApacheBeam/Coders/Beamable.swift index 239c248104c..30a92b1a4f4 100644 --- a/sdks/swift/Sources/ApacheBeam/Coders/Beamable.swift +++ b/sdks/swift/Sources/ApacheBeam/Coders/Beamable.swift @@ -1,3 +1,20 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ import Foundation diff --git a/sdks/swift/Sources/ApacheBeam/Core/DynamicProperties.swift b/sdks/swift/Sources/ApacheBeam/Core/DynamicProperties.swift index ee3c61a65c5..c084e371182 100644 --- a/sdks/swift/Sources/ApacheBeam/Core/DynamicProperties.swift +++ b/sdks/swift/Sources/ApacheBeam/Core/DynamicProperties.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + import Logging public protocol DynamicProperty { } diff --git a/sdks/swift/Sources/ApacheBeam/Core/Fn/DoFn.swift b/sdks/swift/Sources/ApacheBeam/Core/Fn/DoFn.swift index 58d1c211c81..713b1de6796 100644 --- a/sdks/swift/Sources/ApacheBeam/Core/Fn/DoFn.swift +++ b/sdks/swift/Sources/ApacheBeam/Core/Fn/DoFn.swift @@ -1,3 +1,20 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ import Logging diff --git a/sdks/swift/Sources/ApacheBeam/Core/PCollection/AnyPCollection.swift b/sdks/swift/Sources/ApacheBeam/Core/PCollection/AnyPCollection.swift index 9d2aa8e8c9f..3e6af55f2a9 100644 --- a/sdks/swift/Sources/ApacheBeam/Core/PCollection/AnyPCollection.swift +++ b/sdks/swift/Sources/ApacheBeam/Core/PCollection/AnyPCollection.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + public struct AnyPCollection : PCollectionProtocol { diff --git a/sdks/swift/Sources/ApacheBeam/Core/PCollection/PCollection.swift b/sdks/swift/Sources/ApacheBeam/Core/PCollection/PCollection.swift index 5fb52f7e7ea..eec4c78c4eb 100644 --- a/sdks/swift/Sources/ApacheBeam/Core/PCollection/PCollection.swift +++ b/sdks/swift/Sources/ApacheBeam/Core/PCollection/PCollection.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + public protocol PCollectionProtocol { associatedtype Of diff --git a/sdks/swift/Sources/ApacheBeam/Core/PTransform/AnyPTransform.swift b/sdks/swift/Sources/ApacheBeam/Core/PTransform/AnyPTransform.swift index 0be179c8cdf..ad9328dad92 100644 --- a/sdks/swift/Sources/ApacheBeam/Core/PTransform/AnyPTransform.swift +++ b/sdks/swift/Sources/ApacheBeam/Core/PTransform/AnyPTransform.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + public struct AnyPTransform : _PrimitivePTransform { let type: Any.Type var transform: Any diff --git a/sdks/swift/Sources/ApacheBeam/Core/PTransform/PTransform.swift b/sdks/swift/Sources/ApacheBeam/Core/PTransform/PTransform.swift index 483a784c420..db7b87a5a73 100644 --- a/sdks/swift/Sources/ApacheBeam/Core/PTransform/PTransform.swift +++ b/sdks/swift/Sources/ApacheBeam/Core/PTransform/PTransform.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + /// Represents a composite transform public protocol PTransform { associatedtype Expansion: PTransform diff --git a/sdks/swift/Sources/ApacheBeam/Core/Pipeline/Pipeline.swift b/sdks/swift/Sources/ApacheBeam/Core/Pipeline/Pipeline.swift index 116da114b67..b89025b7ec1 100644 --- a/sdks/swift/Sources/ApacheBeam/Core/Pipeline/Pipeline.swift +++ b/sdks/swift/Sources/ApacheBeam/Core/Pipeline/Pipeline.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + import GRPC import Logging diff --git a/sdks/swift/Sources/ApacheBeam/Core/Pipeline/PipelineContext.swift b/sdks/swift/Sources/ApacheBeam/Core/Pipeline/PipelineContext.swift index a173d1850ff..733397fff52 100644 --- a/sdks/swift/Sources/ApacheBeam/Core/Pipeline/PipelineContext.swift +++ b/sdks/swift/Sources/ApacheBeam/Core/Pipeline/PipelineContext.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + public final class PipelineContext { var proto : PipelineProto diff --git a/sdks/swift/Sources/ApacheBeam/Core/Pipeline/PipelineRunner.swift b/sdks/swift/Sources/ApacheBeam/Core/Pipeline/PipelineRunner.swift index 4e5e4f55d73..358dc4d3d5c 100644 --- a/sdks/swift/Sources/ApacheBeam/Core/Pipeline/PipelineRunner.swift +++ b/sdks/swift/Sources/ApacheBeam/Core/Pipeline/PipelineRunner.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + public protocol PipelineRunner { - func run(_ context: PipelineContext) async throws + func run(_ context: PipelineContext) async throws } diff --git a/sdks/swift/Sources/ApacheBeam/Core/Pipeline/PipelineTransform.swift b/sdks/swift/Sources/ApacheBeam/Core/Pipeline/PipelineTransform.swift index 7a54ecbc685..550df2fb860 100644 --- a/sdks/swift/Sources/ApacheBeam/Core/Pipeline/PipelineTransform.swift +++ b/sdks/swift/Sources/ApacheBeam/Core/Pipeline/PipelineTransform.swift @@ -1,3 +1,20 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ import Foundation diff --git a/sdks/swift/Sources/ApacheBeam/Internal/Array+Helpers.swift b/sdks/swift/Sources/ApacheBeam/Internal/Array+Helpers.swift index 61c788c0387..6941b04b1df 100644 --- a/sdks/swift/Sources/ApacheBeam/Internal/Array+Helpers.swift +++ b/sdks/swift/Sources/ApacheBeam/Internal/Array+Helpers.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + extension Array where Element == (String,String) { func dict() -> [String:String] { reduce(into:[:],{ $0[$1.0] = $1.1} ) diff --git a/sdks/swift/Sources/ApacheBeam/Internal/Dictionary+Helpers.swift b/sdks/swift/Sources/ApacheBeam/Internal/Dictionary+Helpers.swift index a129508e85f..5a192a1d859 100644 --- a/sdks/swift/Sources/ApacheBeam/Internal/Dictionary+Helpers.swift +++ b/sdks/swift/Sources/ApacheBeam/Internal/Dictionary+Helpers.swift @@ -1,5 +1,23 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + public extension Dictionary where Key:Comparable { - /// Return key-value pairs sorted by key. + /// Return key-value pairs sorted by key. func sorted() -> [(Key,Value)] { self.map({ ($0,$1)}).sorted(by: { $0.0 < $1.0 }) } diff --git a/sdks/swift/Sources/ApacheBeam/Internal/PipelineProto+Coder.swift b/sdks/swift/Sources/ApacheBeam/Internal/PipelineProto+Coder.swift index 2ad5c73cfdb..c63e6f83989 100644 --- a/sdks/swift/Sources/ApacheBeam/Internal/PipelineProto+Coder.swift +++ b/sdks/swift/Sources/ApacheBeam/Internal/PipelineProto+Coder.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + extension PipelineProto { mutating func coder(from: Coder) -> PipelineComponent { diff --git a/sdks/swift/Sources/ApacheBeam/Internal/PipelineProto+Environment.swift b/sdks/swift/Sources/ApacheBeam/Internal/PipelineProto+Environment.swift index 8e9d85d2a7a..761b589f210 100644 --- a/sdks/swift/Sources/ApacheBeam/Internal/PipelineProto+Environment.swift +++ b/sdks/swift/Sources/ApacheBeam/Internal/PipelineProto+Environment.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + extension PipelineProto { mutating func environment(from: Environment) throws -> PipelineComponent { diff --git a/sdks/swift/Sources/ApacheBeam/Internal/PipelineProto+Initializers.swift b/sdks/swift/Sources/ApacheBeam/Internal/PipelineProto+Initializers.swift index eebfec33168..97de0720f8a 100644 --- a/sdks/swift/Sources/ApacheBeam/Internal/PipelineProto+Initializers.swift +++ b/sdks/swift/Sources/ApacheBeam/Internal/PipelineProto+Initializers.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + enum PipelineComponent { case none case transform(String,PTransformProto) diff --git a/sdks/swift/Sources/ApacheBeam/Internal/Server+Endpoint.swift b/sdks/swift/Sources/ApacheBeam/Internal/Server+Endpoint.swift index f32da24fbe1..263a514a347 100644 --- a/sdks/swift/Sources/ApacheBeam/Internal/Server+Endpoint.swift +++ b/sdks/swift/Sources/ApacheBeam/Internal/Server+Endpoint.swift @@ -1,9 +1,20 @@ -// -// File.swift -// -// -// Created by Byron Ellis on 8/9/23. -// +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ import GRPC diff --git a/sdks/swift/Sources/ApacheBeam/Runners/PortableRunner.swift b/sdks/swift/Sources/ApacheBeam/Runners/PortableRunner.swift index 67737e0bf1a..2053726667f 100644 --- a/sdks/swift/Sources/ApacheBeam/Runners/PortableRunner.swift +++ b/sdks/swift/Sources/ApacheBeam/Runners/PortableRunner.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + import Logging import GRPC import NIOCore diff --git a/sdks/swift/Sources/ApacheBeam/Runtime/Bundle/BundleProcessor.swift b/sdks/swift/Sources/ApacheBeam/Runtime/Bundle/BundleProcessor.swift index 3863b8748f7..8f1b2cac9de 100644 --- a/sdks/swift/Sources/ApacheBeam/Runtime/Bundle/BundleProcessor.swift +++ b/sdks/swift/Sources/ApacheBeam/Runtime/Bundle/BundleProcessor.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + import Logging import Foundation diff --git a/sdks/swift/Sources/ApacheBeam/Runtime/Bundle/Sink.swift b/sdks/swift/Sources/ApacheBeam/Runtime/Bundle/Sink.swift index b399c13f1f6..19ad99c7d99 100644 --- a/sdks/swift/Sources/ApacheBeam/Runtime/Bundle/Sink.swift +++ b/sdks/swift/Sources/ApacheBeam/Runtime/Bundle/Sink.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + import Foundation final class Sink : SerializableFn { diff --git a/sdks/swift/Sources/ApacheBeam/Runtime/Bundle/Source.swift b/sdks/swift/Sources/ApacheBeam/Runtime/Bundle/Source.swift index b53ed8794fa..fd2888ad027 100644 --- a/sdks/swift/Sources/ApacheBeam/Runtime/Bundle/Source.swift +++ b/sdks/swift/Sources/ApacheBeam/Runtime/Bundle/Source.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + import Foundation /// Custom SerializableFn that reads/writes from an external data stream using a defined coder. It assumes that a given diff --git a/sdks/swift/Sources/ApacheBeam/Runtime/DataplaneClient.swift b/sdks/swift/Sources/ApacheBeam/Runtime/DataplaneClient.swift index ac959d3235d..da820e0675b 100644 --- a/sdks/swift/Sources/ApacheBeam/Runtime/DataplaneClient.swift +++ b/sdks/swift/Sources/ApacheBeam/Runtime/DataplaneClient.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + import Foundation import GRPC import Logging diff --git a/sdks/swift/Sources/ApacheBeam/Runtime/Worker/Worker.swift b/sdks/swift/Sources/ApacheBeam/Runtime/Worker/Worker.swift index a9c2effee6b..08204a11184 100644 --- a/sdks/swift/Sources/ApacheBeam/Runtime/Worker/Worker.swift +++ b/sdks/swift/Sources/ApacheBeam/Runtime/Worker/Worker.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + import GRPC import NIOCore import Logging diff --git a/sdks/swift/Sources/ApacheBeam/Transforms/Basic.swift b/sdks/swift/Sources/ApacheBeam/Transforms/Basic.swift index b0e4d21edcb..0b97a084ccf 100644 --- a/sdks/swift/Sources/ApacheBeam/Transforms/Basic.swift +++ b/sdks/swift/Sources/ApacheBeam/Transforms/Basic.swift @@ -1,3 +1,20 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ /// Creating Static Values public extension PCollection { diff --git a/sdks/swift/Sources/ApacheBeam/Transforms/BuiltIn.swift b/sdks/swift/Sources/ApacheBeam/Transforms/BuiltIn.swift index 265fdbd58f1..3684b239050 100644 --- a/sdks/swift/Sources/ApacheBeam/Transforms/BuiltIn.swift +++ b/sdks/swift/Sources/ApacheBeam/Transforms/BuiltIn.swift @@ -1,3 +1,20 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ import Foundation diff --git a/sdks/swift/Sources/ApacheBeam/Transforms/Combining.swift b/sdks/swift/Sources/ApacheBeam/Transforms/Combining.swift index 1b60f2a49cb..642e76548ad 100644 --- a/sdks/swift/Sources/ApacheBeam/Transforms/Combining.swift +++ b/sdks/swift/Sources/ApacheBeam/Transforms/Combining.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + /// Basic reducers public extension PCollection { func reduce<Result:Codable,K,V>(name:String = "\(#file):\(#line)",into:Result,_ accumulator: @Sendable @escaping (V,inout Result) -> Void) -> PCollection<KV<K,Result>> where Of == KV<K,V> { diff --git a/sdks/swift/Sources/ApacheBeam/Transforms/Grouping.swift b/sdks/swift/Sources/ApacheBeam/Transforms/Grouping.swift index e2025394471..ed98a8577e6 100644 --- a/sdks/swift/Sources/ApacheBeam/Transforms/Grouping.swift +++ b/sdks/swift/Sources/ApacheBeam/Transforms/Grouping.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + /// Basic grouping functionality /// public extension PCollection { diff --git a/sdks/swift/Tests/ApacheBeamTests/ApacheBeamTests.swift b/sdks/swift/Tests/ApacheBeamTests/ApacheBeamTests.swift index 23f85941311..15e5a54dca7 100644 --- a/sdks/swift/Tests/ApacheBeamTests/ApacheBeamTests.swift +++ b/sdks/swift/Tests/ApacheBeamTests/ApacheBeamTests.swift @@ -1,3 +1,21 @@ +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + import XCTest @testable import ApacheBeam diff --git a/sdks/swift/Tests/ApacheBeamTests/Pipeline/IntegrationTests.swift b/sdks/swift/Tests/ApacheBeamTests/Pipeline/IntegrationTests.swift index d3743cfbc56..58c2baa479c 100644 --- a/sdks/swift/Tests/ApacheBeamTests/Pipeline/IntegrationTests.swift +++ b/sdks/swift/Tests/ApacheBeamTests/Pipeline/IntegrationTests.swift @@ -1,9 +1,20 @@ -// -// IntegrationTests.swift -// -// -// Created by Byron Ellis on 8/11/23. -// +/* + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ import XCTest import ApacheBeam
