This is an automated email from the ASF dual-hosted git repository. loogn pushed a commit to branch cp_release_v7 in repository https://gitbox.apache.org/repos/asf/geaflow.git
commit 0d120c3fa6f503003e052674e85ecec797e9c4e6 Author: loogn zhou <[email protected]> AuthorDate: Tue Nov 4 17:29:03 2025 +0800 fix(incubator): Fix LICENSE/NOTICE and add proper headers to derived files --- LICENSE | 81 ++++++++++++++++++---- NOTICE | 34 +++------ .../core/status/GeaflowStatusRecorder.java | 6 +- .../analytics/service/client/HttpResponse.java | 4 ++ .../service/client/jdbc/AnalyticsDriver.java | 4 ++ .../jdbc/property/AbstractConnectProperty.java | 4 ++ .../client/jdbc/property/ConnectProperties.java | 4 ++ .../client/jdbc/property/ConnectProperty.java | 4 ++ .../analytics/service/query/IQueryStatus.java | 4 ++ .../analytics/service/query/QueryIdGenerator.java | 4 ++ .../analytics/service/query/QueryResults.java | 4 ++ .../apache/geaflow/common/binary/BinaryString.java | 4 ++ .../geaflow/shuffle/network/netty/NettyClient.java | 4 ++ .../shuffle/network/netty/NettyFrameDecoder.java | 4 ++ .../geaflow/shuffle/network/netty/NettyServer.java | 4 ++ .../network/netty/SliceRequestClientHandler.java | 4 ++ .../network/protocol/AbstractFileRegion.java | 4 ++ .../network/protocol/CompositeFileRegion.java | 4 ++ .../network/protocol/MemoryBytesFileRegion.java | 4 ++ .../shuffle/network/protocol/NettyMessage.java | 4 ++ .../pipeline/channel/AbstractInputChannel.java | 4 ++ .../shuffle/pipeline/channel/ChannelId.java | 4 ++ .../pipeline/channel/LocalInputChannel.java | 4 ++ .../pipeline/fetcher/MultiShardFetcher.java | 4 ++ .../shuffle/pipeline/fetcher/OneShardFetcher.java | 4 ++ .../shuffle/pipeline/fetcher/ShardFetcher.java | 4 ++ .../geaflow/shuffle/util/TransportException.java | 4 ++ .../cluster/k8s/config/KubernetesConfigKeys.java | 4 ++ .../k8s/entrypoint/KubernetesContainerRunner.java | 4 ++ .../k8s/entrypoint/KubernetesDriverRunner.java | 4 ++ .../k8s/entrypoint/KubernetesMasterRunner.java | 4 ++ .../apache/geaflow/dsl/udf/table/string/Like.java | 4 ++ .../main/java/org/apache/geaflow/memory/Chunk.java | 4 ++ .../org/apache/geaflow/memory/DirectMemory.java | 4 ++ .../main/java/org/apache/geaflow/memory/Page.java | 4 ++ .../apache/geaflow/memory/PlatformDependent.java | 4 ++ .../org/apache/geaflow/memory/cleaner/Cleaner.java | 3 + .../geaflow/memory/cleaner/CleanerJava6.java | 4 ++ .../geaflow/memory/cleaner/CleanerJava9.java | 4 ++ .../geaflow/state/iterator/MultiIterator.java | 4 ++ .../geaflow/utils/keygroup/KeyGroupAssignment.java | 4 ++ 41 files changed, 235 insertions(+), 37 deletions(-) diff --git a/LICENSE b/LICENSE index f116cb4d4..53993da3d 100644 --- a/LICENSE +++ b/LICENSE @@ -201,8 +201,19 @@ See the License for the specific language governing permissions and limitations under the License. -Apache Software Foundation License 2.0 --------------------------------------- + +------------------------------------------------------------------------------------ +This product includes derivative works from the following third-party projects: + + +------------------------------------------------------------------------------------ +Apache Flink (https://github.com/apache/flink, version 1.18) +Licensed under the Apache License, Version 2.0. + +Original copyright notice: + Copyright 2014-2025 The Apache Software Foundation + +The following files are derived from Apache Flink: geaflow/geaflow-utils/src/main/java/org/apache/geaflow/utils/KeyGroupAssignment.java geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyClient.java geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyServer.java @@ -219,22 +230,42 @@ geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesDriverRunner.java geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesContainerRunner.java geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/config/KubernetesConfigKeys.java -from https://github.com/apache/flink version 1.18 + +------------------------------------------------------------------------------------ +Apache Flink Kubernetes Operator (https://github.com/apache/flink-kubernetes-operator, version 1.1) +Licensed under the Apache License, Version 2.0. + +Original copyright notice: + Copyright 2014-2025 The Apache Software Foundation + +The following file is derived from Apache Flink Kubernetes Operator: geaflow-kubernetes-operator/geaflow-kubernetes-operator-core/src/main/java/org/apache/geaflow/kubernetes/operator/core/status/GeaflowStatusRecorder.java -from https://github.com/apache/flink-kubernetes-operator version 1.1 + +------------------------------------------------------------------------------------ +Apache Spark (https://github.com/apache/spark, version 3.0) +Licensed under the Apache License, Version 2.0. + +Original copyright notice: + Copyright 2014 and onwards The Apache Software Foundation + +The following files are derived from Apache Spark: geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/AbstractFileRegion.java geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/CompositeFileRegion.java geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/MemoryBytesFileRegion.java geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyFrameDecoder.java geaflow/geaflow-common/src/main/java/org/apache/geaflow/common/binary/BinaryString.java -from https://github.com/apache/spark version 3.0 -geaflow/geaflow-dsl/geaflow-dsl-parser/* -geaflow/geaflow-dsl/geaflow-dsl-plan/* -from https://github.com/apache/calcite version 1.18.0 +------------------------------------------------------------------------------------ +Netty (https://github.com/netty/netty, version 4.1) +Licensed under the Apache License, Version 2.0. + +Original copyright notice: + Copyright 2012-2024 The Netty Project + +The following files are derived from Netty: geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Chunk.java geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/DirectMemory.java geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Page.java @@ -242,8 +273,16 @@ geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/PlatformDependent geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/Cleaner.java geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava6.java geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava9.java -from https://github.com/netty/netty/ version 4.1 + +------------------------------------------------------------------------------------ +Presto (https://github.com/prestodb/presto, version 0.276) +Licensed under the Apache License, Version 2.0. + +Original copyright notice: + Copyright (c) 2012-2024 Meta Platforms, Inc. and affiliates. + +The following files are derived from Presto: geaflow/geaflow-analytics-service/geaflow-analytics-service-client/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperty.java geaflow/geaflow-analytics-service/geaflow-analytics-service-client/org/apache/geaflow/analytics/service/client/jdbc/property/AbstractConnectProperty.java geaflow/geaflow-analytics-service/geaflow-analytics-service-client/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperties.java @@ -252,10 +291,28 @@ geaflow/geaflow-analytics-service/geaflow-analytics-service-client/org/apache/ge geaflow/geaflow-analytics-service/geaflow-analytics-service-common/org/apache/geaflow/analytics/service/query/IQueryStatus.java geaflow/geaflow-analytics-service/geaflow-analytics-service-common/org/apache/geaflow/analytics/service/query/QueryIdGenerator.java geaflow/geaflow-analytics-service/geaflow-analytics-service-common/org/apache/geaflow/analytics/service/query/QueryResults.java -from https://github.com/prestodb/presto version 0.276 + +------------------------------------------------------------------------------------ +Apache Hive (https://github.com/apache/hive, version 3.0) +Licensed under the Apache License, Version 2.0. + +Original copyright notice: + Copyright 2008-2025 The Apache Software Foundation + +The following file is derived from Apache Hive: geaflow/geaflow-dsl/geaflow-dsl-plan/org/apache/geaflow/dsl/udf/table/string/Like.java -from https://github.com/apache/hive version 3.0 + +------------------------------------------------------------------------------------ +Guava (https://github.com/google/guava, version 22.0) +Licensed under the Apache License, Version 2.0. + +Original copyright notice: + Copyright (C) 2006-2024 Google LLC + +The following file is derived from Guava: geaflow/geaflow-state/geaflow-state-common/org/apache/geaflow/state/iterator/MultiIterator.java -from https://github.com/google/guava version 22.0 \ No newline at end of file + + +------------------------------------------------------------------------------------ \ No newline at end of file diff --git a/NOTICE b/NOTICE index 8348c8306..14ad26d92 100644 --- a/NOTICE +++ b/NOTICE @@ -13,37 +13,23 @@ Copyright 2014-2025 The Apache Software Foundation Apache Spark Copyright 2014 and onwards The Apache Software Foundation -Apache Calcite -Copyright 2012-2025 The Apache Software Foundation - Apache Hive -Copyright 2008-2018 The Apache Software Foundation - -Netty -Copyright 2012-2024 The Netty Project +Copyright 2008-2025 The Apache Software Foundation ---------------------------------------------------------- -Prosto -Copyright 2012-2022 The Presto Foundation -Licensed 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 +Netty +Copyright 2012-2024 The Netty Project -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. +This product includes software developed at +The Netty Project (http://netty.io/). ---------------------------------------------------------- -Guava -Copyright 2006-2022 Google LLC -Licensed 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 +Presto +Copyright (c) 2012-2024 Meta Platforms, Inc. and affiliates. -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. +This product includes software developed at +Presto (https://prestodb.github.io/). ----------------------------------------------------------- \ No newline at end of file +---------------------------------------------------------- diff --git a/geaflow-kubernetes-operator/geaflow-kubernetes-operator-core/src/main/java/org/apache/geaflow/kubernetes/operator/core/status/GeaflowStatusRecorder.java b/geaflow-kubernetes-operator/geaflow-kubernetes-operator-core/src/main/java/org/apache/geaflow/kubernetes/operator/core/status/GeaflowStatusRecorder.java index 4328c1752..f1035daf6 100644 --- a/geaflow-kubernetes-operator/geaflow-kubernetes-operator-core/src/main/java/org/apache/geaflow/kubernetes/operator/core/status/GeaflowStatusRecorder.java +++ b/geaflow-kubernetes-operator/geaflow-kubernetes-operator-core/src/main/java/org/apache/geaflow/kubernetes/operator/core/status/GeaflowStatusRecorder.java @@ -29,8 +29,12 @@ import org.apache.geaflow.kubernetes.operator.core.model.customresource.Abstract import org.apache.geaflow.kubernetes.operator.core.model.exception.StatusConflictException; import org.apache.geaflow.kubernetes.operator.core.util.KubernetesUtil; +/* This file is based on source code from the Flink Kubernetes Operator Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** - * This class is an adaptation of Flink's org.apache.flink.kubernetes.operator.utils.StatusRecorder. + * This class is an adaptation of Flink Kubernetes Operator's org.apache.flink.kubernetes.operator.utils.StatusRecorder. */ @Slf4j public class GeaflowStatusRecorder<CR extends AbstractGeaflowResource<?, STAT>, diff --git a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/HttpResponse.java b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/HttpResponse.java index 9c5c62dd1..5c40de822 100644 --- a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/HttpResponse.java +++ b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/HttpResponse.java @@ -39,6 +39,10 @@ import org.apache.http.impl.client.CloseableHttpClient; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/* This file is based on source code from the Presto Project (https://prestodb.github.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Presto's com.facebook.presto.client.JsonResponse. */ diff --git a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/AnalyticsDriver.java b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/AnalyticsDriver.java index e36abe0a9..d6d7bd364 100644 --- a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/AnalyticsDriver.java +++ b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/AnalyticsDriver.java @@ -37,6 +37,10 @@ import java.util.stream.Collectors; import org.apache.geaflow.analytics.service.client.utils.JDBCUtils; import org.apache.geaflow.common.exception.GeaflowRuntimeException; +/* This file is based on source code from the Presto Project (https://prestodb.github.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Presto's com.facebook.presto.jdbc.PrestoDriver. */ diff --git a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/AbstractConnectProperty.java b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/AbstractConnectProperty.java index da79ef320..47670af7c 100644 --- a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/AbstractConnectProperty.java +++ b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/AbstractConnectProperty.java @@ -36,6 +36,10 @@ import org.apache.geaflow.common.exception.GeaflowRuntimeException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/* This file is based on source code from the Presto Project (https://prestodb.github.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Presto's com.facebook.presto.jdbc.AbstractConnectionProperty. */ diff --git a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperties.java b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperties.java index 2900f822a..5467fe837 100644 --- a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperties.java +++ b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperties.java @@ -32,6 +32,10 @@ import java.util.Properties; import java.util.Set; import java.util.function.Predicate; +/* This file is based on source code from the Presto Project (https://prestodb.github.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Presto's com.facebook.presto.jdbc.ConnectionProperties. */ diff --git a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperty.java b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperty.java index b43412dcc..abe2761f9 100644 --- a/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperty.java +++ b/geaflow/geaflow-analytics-service/geaflow-analytics-service-client/src/main/java/org/apache/geaflow/analytics/service/client/jdbc/property/ConnectProperty.java @@ -25,6 +25,10 @@ import java.util.Optional; import java.util.Properties; import org.apache.geaflow.common.exception.GeaflowRuntimeException; +/* This file is based on source code from the Presto Project (https://prestodb.github.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Presto's com.facebook.presto.jdbc.ConnectionProperty. */ diff --git a/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/IQueryStatus.java b/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/IQueryStatus.java index 347274d2e..aa8e64b3f 100644 --- a/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/IQueryStatus.java +++ b/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/IQueryStatus.java @@ -19,6 +19,10 @@ package org.apache.geaflow.analytics.service.query; +/* This file is based on source code from the Presto Project (https://prestodb.github.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Presto's com.facebook.presto.client.QueryStatusInfo. */ diff --git a/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryIdGenerator.java b/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryIdGenerator.java index 5b01c8ef5..92b41e7fd 100644 --- a/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryIdGenerator.java +++ b/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryIdGenerator.java @@ -31,6 +31,10 @@ import java.util.concurrent.TimeUnit; import org.joda.time.format.DateTimeFormat; import org.joda.time.format.DateTimeFormatter; +/* This file is based on source code from the Presto Project (https://prestodb.github.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Presto's com.facebook.presto.execution.QueryIdGenerator. */ diff --git a/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryResults.java b/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryResults.java index 072b767a1..558e0b56b 100644 --- a/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryResults.java +++ b/geaflow/geaflow-analytics-service/geaflow-analytics-service-common/src/main/java/org/apache/geaflow/analytics/service/query/QueryResults.java @@ -31,6 +31,10 @@ import org.apache.calcite.rel.type.RelDataType; import org.apache.geaflow.cluster.response.ResponseResult; import org.apache.geaflow.dsl.common.data.impl.ObjectRow; +/* This file is based on source code from the Presto Project (https://prestodb.github.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Presto's com.facebook.presto.client.QueryResults. */ diff --git a/geaflow/geaflow-common/src/main/java/org/apache/geaflow/common/binary/BinaryString.java b/geaflow/geaflow-common/src/main/java/org/apache/geaflow/common/binary/BinaryString.java index ba90ea7f0..d8a5c8362 100644 --- a/geaflow/geaflow-common/src/main/java/org/apache/geaflow/common/binary/BinaryString.java +++ b/geaflow/geaflow-common/src/main/java/org/apache/geaflow/common/binary/BinaryString.java @@ -48,6 +48,10 @@ import java.nio.ByteOrder; import java.nio.charset.StandardCharsets; import java.util.Objects; +/* This file is based on source code from the Spark Project (http://spark.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Spark's org.apache.spark.unsafe.types.UTF8String. */ diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyClient.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyClient.java index e2b8d798b..c7bd011f7 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyClient.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyClient.java @@ -41,6 +41,10 @@ import org.apache.geaflow.shuffle.network.NettyUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's org.apache.flink.runtime.io.network.netty.NettyClient. */ diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyFrameDecoder.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyFrameDecoder.java index 1b772ca6b..301a1fa1e 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyFrameDecoder.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyFrameDecoder.java @@ -28,6 +28,10 @@ import io.netty.channel.ChannelHandlerContext; import io.netty.channel.ChannelInboundHandlerAdapter; import java.util.LinkedList; +/* This file is based on source code from the Spark Project (http://spark.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Spark's org.apache.spark.network.util.TransportFrameDecoder. */ diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyServer.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyServer.java index 5cb6d48bd..628e329da 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyServer.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/NettyServer.java @@ -42,6 +42,10 @@ import org.apache.geaflow.shuffle.network.NettyUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's org.apache.flink.runtime.io.network.netty.NettyServer. */ diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/SliceRequestClientHandler.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/SliceRequestClientHandler.java index adedfeda1..6e461b6f7 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/SliceRequestClientHandler.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/netty/SliceRequestClientHandler.java @@ -38,6 +38,10 @@ import org.apache.geaflow.shuffle.util.TransportException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's org.apache.flink.runtime.io.network.netty.CreditBasedPartitionRequestClientHandler. */ diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/AbstractFileRegion.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/AbstractFileRegion.java index 7c3d39aeb..48be9c9e5 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/AbstractFileRegion.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/AbstractFileRegion.java @@ -22,6 +22,10 @@ package org.apache.geaflow.shuffle.network.protocol; import io.netty.channel.FileRegion; import io.netty.util.AbstractReferenceCounted; +/* This file is based on source code from the Spark Project (http://spark.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Spark's org.apache.spark.network.util.AbstractFileRegion. */ diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/CompositeFileRegion.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/CompositeFileRegion.java index cec53db49..6bb223d05 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/CompositeFileRegion.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/CompositeFileRegion.java @@ -27,6 +27,10 @@ import java.io.IOException; import java.nio.ByteBuffer; import java.nio.channels.WritableByteChannel; +/* This file is based on source code from the Spark Project (http://spark.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Spark's org.apache.spark.network.protocol.MessageWithHeader. */ diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/MemoryBytesFileRegion.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/MemoryBytesFileRegion.java index 6abc95d93..7b0d4e0be 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/MemoryBytesFileRegion.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/MemoryBytesFileRegion.java @@ -23,6 +23,10 @@ import java.io.IOException; import java.nio.ByteBuffer; import java.nio.channels.WritableByteChannel; +/* This file is based on source code from the Spark Project (http://spark.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Spark's org.apache.spark.util.io.ChunkedByteBufferFileRegion. */ diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/NettyMessage.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/NettyMessage.java index 99c9f21f7..c5bfeca95 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/NettyMessage.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/network/protocol/NettyMessage.java @@ -24,6 +24,10 @@ import io.netty.buffer.ByteBuf; import io.netty.buffer.ByteBufAllocator; import java.io.Serializable; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's org.apache.flink.runtime.io.network.netty.NettyMessage. */ diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/AbstractInputChannel.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/AbstractInputChannel.java index 3a8073c33..f7945ab96 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/AbstractInputChannel.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/AbstractInputChannel.java @@ -26,6 +26,10 @@ import org.apache.geaflow.shuffle.message.SliceId; import org.apache.geaflow.shuffle.pipeline.buffer.PipeChannelBuffer; import org.apache.geaflow.shuffle.pipeline.fetcher.OneShardFetcher; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's org.apache.flink.runtime.io.network.partition.consumer.InputChannel. */ diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/ChannelId.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/ChannelId.java index 8b9fd16b1..48a46acad 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/ChannelId.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/ChannelId.java @@ -24,6 +24,10 @@ import java.io.Serializable; import java.util.Objects; import java.util.UUID; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's org.apache.flink.util.AbstractID. */ diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/LocalInputChannel.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/LocalInputChannel.java index 0a33bfc10..f98853d52 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/LocalInputChannel.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/channel/LocalInputChannel.java @@ -35,6 +35,10 @@ import org.apache.geaflow.shuffle.util.SliceNotFoundException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's org.apache.flink.runtime.io.network.partition.consumer.LocalInputChannel. */ diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/MultiShardFetcher.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/MultiShardFetcher.java index 7f3638de7..098a4a962 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/MultiShardFetcher.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/MultiShardFetcher.java @@ -36,6 +36,10 @@ import java.util.stream.Collectors; import org.apache.geaflow.common.tuple.Tuple; import org.apache.geaflow.shuffle.pipeline.buffer.PipeFetcherBuffer; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * Interface to fetch data from multiple {@link OneShardFetcher}. * This class is an adaptation of Flink's org.apache.flink.runtime.io.network.partition.consumer.UnionInputGate. diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/OneShardFetcher.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/OneShardFetcher.java index b04a42f47..1cfdadfc6 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/OneShardFetcher.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/OneShardFetcher.java @@ -49,6 +49,10 @@ import org.apache.geaflow.shuffle.pipeline.channel.RemoteInputChannel; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's org.apache.flink.runtime.io.network.partition.consumer.SingleInputGate. */ diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/ShardFetcher.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/ShardFetcher.java index 972bc28d6..0ab58f18b 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/ShardFetcher.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/pipeline/fetcher/ShardFetcher.java @@ -24,6 +24,10 @@ import java.io.IOException; import java.util.Optional; import org.apache.geaflow.shuffle.pipeline.buffer.PipeFetcherBuffer; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's org.apache.flink.runtime.io.network.partition.consumer.InputGate. */ diff --git a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/util/TransportException.java b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/util/TransportException.java index dfb5002c4..3a9301042 100644 --- a/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/util/TransportException.java +++ b/geaflow/geaflow-core/geaflow-engine/geaflow-shuffle/src/main/java/org/apache/geaflow/shuffle/util/TransportException.java @@ -22,6 +22,10 @@ package org.apache.geaflow.shuffle.util; import java.io.IOException; import java.net.SocketAddress; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's org.apache.flink.runtime.io.network.netty.exception.TransportException. */ diff --git a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/config/KubernetesConfigKeys.java b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/config/KubernetesConfigKeys.java index 2b6dac7dc..ff57a4aa6 100644 --- a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/config/KubernetesConfigKeys.java +++ b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/config/KubernetesConfigKeys.java @@ -23,6 +23,10 @@ import org.apache.geaflow.cluster.k8s.config.KubernetesConfig.ServiceExposedType import org.apache.geaflow.common.config.ConfigKey; import org.apache.geaflow.common.config.ConfigKeys; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's org.apache.flink.kubernetes.configuration.KubernetesConfigOptions. */ diff --git a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesContainerRunner.java b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesContainerRunner.java index c9e992046..f7658658f 100644 --- a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesContainerRunner.java +++ b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesContainerRunner.java @@ -32,6 +32,10 @@ import org.apache.geaflow.common.config.Configuration; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's org.apache.flink.kubernetes.taskmanager.KubernetesTaskExecutorRunner. */ diff --git a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesDriverRunner.java b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesDriverRunner.java index afa5276ac..40861d6e5 100644 --- a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesDriverRunner.java +++ b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesDriverRunner.java @@ -32,6 +32,10 @@ import org.apache.geaflow.common.config.Configuration; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's org.apache.flink.kubernetes.taskmanager.KubernetesTaskExecutorRunner. */ diff --git a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesMasterRunner.java b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesMasterRunner.java index b53cee498..8f78594dd 100644 --- a/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesMasterRunner.java +++ b/geaflow/geaflow-deploy/geaflow-on-k8s/src/main/java/org/apache/geaflow/cluster/k8s/entrypoint/KubernetesMasterRunner.java @@ -46,6 +46,10 @@ import org.apache.geaflow.ha.leaderelection.LeaderContenderType; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's * org.apache.flink.kubernetes.taskmanager.KubernetesTaskExecutorRunner. diff --git a/geaflow/geaflow-dsl/geaflow-dsl-plan/src/main/java/org/apache/geaflow/dsl/udf/table/string/Like.java b/geaflow/geaflow-dsl/geaflow-dsl-plan/src/main/java/org/apache/geaflow/dsl/udf/table/string/Like.java index 8b350fb36..826301572 100644 --- a/geaflow/geaflow-dsl/geaflow-dsl-plan/src/main/java/org/apache/geaflow/dsl/udf/table/string/Like.java +++ b/geaflow/geaflow-dsl/geaflow-dsl-plan/src/main/java/org/apache/geaflow/dsl/udf/table/string/Like.java @@ -24,6 +24,10 @@ import java.util.regex.Pattern; import org.apache.geaflow.dsl.common.function.Description; import org.apache.geaflow.dsl.common.function.UDF; +/* This file is based on source code from the Hive Project (http://hive.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Hive's org.apache.hadoop.hive.ql.udf.UDFLike. */ diff --git a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Chunk.java b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Chunk.java index 43da7b838..764607472 100644 --- a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Chunk.java +++ b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Chunk.java @@ -21,6 +21,10 @@ package org.apache.geaflow.memory; import org.apache.geaflow.memory.metric.ChunkMetric; +/* This file is based on source code from the Netty Project (http://netty.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Netty's io.netty.buffer.PoolChunk. */ diff --git a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/DirectMemory.java b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/DirectMemory.java index f99235de2..ec6bb99db 100644 --- a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/DirectMemory.java +++ b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/DirectMemory.java @@ -34,6 +34,10 @@ import org.apache.geaflow.memory.exception.GeaflowOutOfMemoryException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/* This file is based on source code from the Netty Project (http://netty.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Netty's io.netty.util.internal.DirectMemory. */ diff --git a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Page.java b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Page.java index 28dab9902..4dc6bbd82 100644 --- a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Page.java +++ b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/Page.java @@ -21,6 +21,10 @@ package org.apache.geaflow.memory; import org.apache.geaflow.memory.metric.PageMetric; +/* This file is based on source code from the Netty Project (http://netty.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Netty's io.netty.buffer.PoolSubpage. */ diff --git a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/PlatformDependent.java b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/PlatformDependent.java index 1b6f37181..0a2248cd7 100644 --- a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/PlatformDependent.java +++ b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/PlatformDependent.java @@ -34,6 +34,10 @@ import org.apache.geaflow.common.utils.ReflectionUtil; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/* This file is based on source code from the Netty Project (http://netty.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Netty's io.netty.util.internal.PlatformDependent. */ diff --git a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/Cleaner.java b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/Cleaner.java index 5c902603d..7f16880ef 100644 --- a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/Cleaner.java +++ b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/Cleaner.java @@ -21,6 +21,9 @@ package org.apache.geaflow.memory.cleaner; import java.nio.ByteBuffer; +/* This file is based on source code from the Netty Project (http://netty.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ /** * This class is an adaptation of Netty's io.netty.util.internal.Cleaner. diff --git a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava6.java b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava6.java index 5bd8275cb..27b973ea1 100644 --- a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava6.java +++ b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava6.java @@ -45,6 +45,10 @@ import org.apache.geaflow.memory.PlatformDependent; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/* This file is based on source code from the Netty Project (http://netty.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Netty's io.netty.util.internal.CleanerJava6. * Allows to free direct {@link ByteBuffer} by using Cleaner for Java version less than 9. diff --git a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava9.java b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava9.java index f307a4d45..04a017de4 100644 --- a/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava9.java +++ b/geaflow/geaflow-memory/src/main/java/org/apache/geaflow/memory/cleaner/CleanerJava9.java @@ -44,6 +44,10 @@ import org.apache.geaflow.memory.PlatformDependent; import org.slf4j.Logger; import org.slf4j.LoggerFactory; +/* This file is based on source code from the Netty Project (http://netty.io/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Netty's io.netty.util.internal.CleanerJava9. * Allows to free direct {@link ByteBuffer} by using Cleaner for Java version equal or greater than 9. diff --git a/geaflow/geaflow-state/geaflow-state-common/src/main/java/org/apache/geaflow/state/iterator/MultiIterator.java b/geaflow/geaflow-state/geaflow-state-common/src/main/java/org/apache/geaflow/state/iterator/MultiIterator.java index a4497bd2e..9b8cb59f0 100644 --- a/geaflow/geaflow-state/geaflow-state-common/src/main/java/org/apache/geaflow/state/iterator/MultiIterator.java +++ b/geaflow/geaflow-state/geaflow-state-common/src/main/java/org/apache/geaflow/state/iterator/MultiIterator.java @@ -23,6 +23,10 @@ import java.util.Arrays; import java.util.Iterator; import org.apache.geaflow.common.iterator.CloseableIterator; +/* This file is based on source code from the Guava Project (https://guava.dev/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Guava's Iterators.concat * by fixing the issue https://github.com/google/guava/issues/3178. diff --git a/geaflow/geaflow-utils/src/main/java/org/apache/geaflow/utils/keygroup/KeyGroupAssignment.java b/geaflow/geaflow-utils/src/main/java/org/apache/geaflow/utils/keygroup/KeyGroupAssignment.java index cdfb5721a..6d59ec0b2 100644 --- a/geaflow/geaflow-utils/src/main/java/org/apache/geaflow/utils/keygroup/KeyGroupAssignment.java +++ b/geaflow/geaflow-utils/src/main/java/org/apache/geaflow/utils/keygroup/KeyGroupAssignment.java @@ -27,6 +27,10 @@ import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import org.apache.geaflow.utils.math.MathUtil; +/* This file is based on source code from the Flink Project (http://flink.apache.org/), licensed by the Apache + * Software Foundation (ASF) under the Apache License, Version 2.0. See the NOTICE file distributed with this work for + * additional information regarding copyright ownership. */ + /** * This class is an adaptation of Flink's org.apache.flink.runtime.state.KeyGroupRangeAssignment. */ --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
