Add copyright header to all the files

Signed-off-by: Amanda Xiang <[email protected]>
opensearch-project · Jan 7, 2025 · 82c6461 · 82c6461
1 parent e90bf5b
commit 82c6461
Show file tree

Hide file tree

Showing 49 changed files with 117 additions and 59 deletions.
diff --git a/data-prepper-plugins/neptune-source/build.gradle b/data-prepper-plugins/neptune-source/build.gradle
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 dependencies {
     implementation project(path: ':data-prepper-api')
 

diff --git a/...ource/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/NeptuneService.java b/...ource/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/NeptuneService.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune;
 
 import com.amazonaws.neptune.auth.NeptuneSigV4SignerException;

diff --git a/...source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/NeptuneSource.java b/...source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/NeptuneSource.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune;
 
 import com.amazonaws.neptune.auth.NeptuneSigV4SignerException;

diff --git a/...ain/java/org/opensearch/dataprepper/plugins/source/neptune/buffer/RecordBufferWriter.java b/...ain/java/org/opensearch/dataprepper/plugins/source/neptune/buffer/RecordBufferWriter.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.buffer;
 
 import io.micrometer.core.instrument.Counter;

diff --git a/...va/org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneDataClientWrapper.java b/...va/org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneDataClientWrapper.java
@@ -1,12 +1,6 @@
 /*
- *
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
- *
- * The OpenSearch Contributors require contributions made to
- * this file be licensed under the Apache-2.0 license or a
- * compatible open source license.
- *
  */
 package org.opensearch.dataprepper.plugins.source.neptune.client;
 

diff --git a/...in/java/org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneStreamClient.java b/...in/java/org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneStreamClient.java
@@ -1,13 +1,7 @@
 /*
- *
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
- *
- * The OpenSearch Contributors require contributions made to
- * this file be licensed under the Apache-2.0 license or a
- * compatible open source license.
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.client;
 
 import lombok.Getter;

diff --git a/.../org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneStreamEventListener.java b/.../org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneStreamEventListener.java
@@ -1,13 +1,7 @@
 /*
- *
  * Copyright OpenSearch Contributors
- *  SPDX-License-Identifier: Apache-2.0
- *
- *  The OpenSearch Contributors require contributions made to
- *  this file be licensed under the Apache-2.0 license or a
- *  compatible open source license.
+ * SPDX-License-Identifier: Apache-2.0
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.client;
 
 import org.opensearch.dataprepper.plugins.source.neptune.stream.model.NeptuneStreamRecord;

diff --git a/.../main/java/org/opensearch/dataprepper/plugins/source/neptune/configuration/AwsConfig.java b/.../main/java/org/opensearch/dataprepper/plugins/source/neptune/configuration/AwsConfig.java
@@ -2,7 +2,6 @@
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.configuration;
 
 import com.fasterxml.jackson.annotation.JsonProperty;

diff --git a/.../org/opensearch/dataprepper/plugins/source/neptune/configuration/NeptuneSourceConfig.java b/.../org/opensearch/dataprepper/plugins/source/neptune/configuration/NeptuneSourceConfig.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.configuration;
 
 import com.fasterxml.jackson.annotation.JsonProperty;

diff --git a/...va/org/opensearch/dataprepper/plugins/source/neptune/converter/MetadataKeyAttributes.java b/...va/org/opensearch/dataprepper/plugins/source/neptune/converter/MetadataKeyAttributes.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.converter;
 
 public class MetadataKeyAttributes {

diff --git a/...ain/java/org/opensearch/dataprepper/plugins/source/neptune/converter/NeptuneS3Record.java b/...ain/java/org/opensearch/dataprepper/plugins/source/neptune/converter/NeptuneS3Record.java
@@ -1,14 +1,7 @@
 /*
- *
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
- *
- * The OpenSearch Contributors require contributions made to
- * this file be licensed under the Apache-2.0 license or a
- * compatible open source license.
- *
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.converter;
 
 import com.fasterxml.jackson.annotation.JsonProperty;

diff --git a/...org/opensearch/dataprepper/plugins/source/neptune/converter/NeptuneS3RecordPredicate.java b/...org/opensearch/dataprepper/plugins/source/neptune/converter/NeptuneS3RecordPredicate.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.converter;
 
 import com.fasterxml.jackson.annotation.JsonProperty;

diff --git a/...opensearch/dataprepper/plugins/source/neptune/converter/NeptuneStreamRecordValidator.java b/...opensearch/dataprepper/plugins/source/neptune/converter/NeptuneStreamRecordValidator.java
@@ -1,14 +1,7 @@
 /*
- *
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
- *
- * The OpenSearch Contributors require contributions made to
- * this file be licensed under the Apache-2.0 license or a
- * compatible open source license.
- *
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.converter;
 
 import org.eclipse.rdf4j.model.IRI;

diff --git a/...va/org/opensearch/dataprepper/plugins/source/neptune/converter/StreamRecordConverter.java b/...va/org/opensearch/dataprepper/plugins/source/neptune/converter/StreamRecordConverter.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.converter;
 
 import lombok.Setter;

diff --git a/...java/org/opensearch/dataprepper/plugins/source/neptune/coordination/PartitionFactory.java b/...java/org/opensearch/dataprepper/plugins/source/neptune/coordination/PartitionFactory.java
@@ -2,7 +2,6 @@
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.coordination;
 
 import org.opensearch.dataprepper.model.source.coordinator.SourcePartitionStoreItem;

diff --git a/...nsearch/dataprepper/plugins/source/neptune/coordination/partition/DataQueryPartition.java b/...nsearch/dataprepper/plugins/source/neptune/coordination/partition/DataQueryPartition.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.coordination.partition;
 
 import org.opensearch.dataprepper.model.source.coordinator.SourcePartitionStoreItem;

diff --git a/...org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/GlobalState.java b/...org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/GlobalState.java
@@ -2,7 +2,6 @@
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.coordination.partition;
 
 import org.opensearch.dataprepper.model.source.coordinator.SourcePartitionStoreItem;

diff --git a/...opensearch/dataprepper/plugins/source/neptune/coordination/partition/LeaderPartition.java b/...opensearch/dataprepper/plugins/source/neptune/coordination/partition/LeaderPartition.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.coordination.partition;
 
 import org.opensearch.dataprepper.model.source.coordinator.SourcePartitionStoreItem;

diff --git a/...ensearch/dataprepper/plugins/source/neptune/coordination/partition/S3FolderPartition.java b/...ensearch/dataprepper/plugins/source/neptune/coordination/partition/S3FolderPartition.java
@@ -2,7 +2,6 @@
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.coordination.partition;
 
 import org.opensearch.dataprepper.model.source.coordinator.SourcePartitionStoreItem;

diff --git a/...opensearch/dataprepper/plugins/source/neptune/coordination/partition/StreamPartition.java b/...opensearch/dataprepper/plugins/source/neptune/coordination/partition/StreamPartition.java
@@ -2,7 +2,6 @@
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.coordination.partition;
 
 import org.opensearch.dataprepper.model.source.coordinator.SourcePartitionStoreItem;

diff --git a/...nsearch/dataprepper/plugins/source/neptune/coordination/state/DataQueryProgressState.java b/...nsearch/dataprepper/plugins/source/neptune/coordination/state/DataQueryProgressState.java
@@ -2,7 +2,6 @@
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.coordination.state;
 
 import com.fasterxml.jackson.annotation.JsonProperty;

diff --git a/...opensearch/dataprepper/plugins/source/neptune/coordination/state/LeaderProgressState.java b/...opensearch/dataprepper/plugins/source/neptune/coordination/state/LeaderProgressState.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.coordination.state;
 
 import com.fasterxml.jackson.annotation.JsonProperty;

diff --git a/...opensearch/dataprepper/plugins/source/neptune/coordination/state/StreamProgressState.java b/...opensearch/dataprepper/plugins/source/neptune/coordination/state/StreamProgressState.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.coordination.state;
 
 import com.fasterxml.jackson.annotation.JsonProperty;

diff --git a/...c/main/java/org/opensearch/dataprepper/plugins/source/neptune/leader/LeaderScheduler.java b/...c/main/java/org/opensearch/dataprepper/plugins/source/neptune/leader/LeaderScheduler.java
@@ -2,7 +2,6 @@
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.leader;
 
 import org.opensearch.dataprepper.model.source.coordinator.enhanced.EnhancedSourceCoordinator;

diff --git a/...c/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/ExportLoadStatus.java b/...c/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/ExportLoadStatus.java
@@ -2,7 +2,6 @@
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.model;
 
 import java.util.Map;

diff --git a/...ava/org/opensearch/dataprepper/plugins/source/neptune/model/PartitionIdentifierBatch.java b/...ava/org/opensearch/dataprepper/plugins/source/neptune/model/PartitionIdentifierBatch.java
@@ -2,7 +2,6 @@
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.model;
 
 import org.opensearch.dataprepper.model.source.coordinator.PartitionIdentifier;

diff --git a/.../main/java/org/opensearch/dataprepper/plugins/source/neptune/model/S3PartitionStatus.java b/.../main/java/org/opensearch/dataprepper/plugins/source/neptune/model/S3PartitionStatus.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.model;
 
 import java.util.List;

diff --git a/...c/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/StreamLoadStatus.java b/...c/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/StreamLoadStatus.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.model;
 
 import java.util.Map;

diff --git a/...ensearch/dataprepper/plugins/source/neptune/s3partition/S3FolderPartitionCoordinator.java b/...ensearch/dataprepper/plugins/source/neptune/s3partition/S3FolderPartitionCoordinator.java
@@ -2,7 +2,6 @@
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.s3partition;
 
 import org.opensearch.dataprepper.model.source.coordinator.enhanced.EnhancedSourceCoordinator;

diff --git a/...ava/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreator.java b/...ava/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreator.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.s3partition;
 
 import org.slf4j.Logger;

diff --git a/...pensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreatorScheduler.java b/...pensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreatorScheduler.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.s3partition;
 
 import org.opensearch.dataprepper.model.source.coordinator.enhanced.EnhancedSourceCoordinator;

diff --git a/.../main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/CheckpointStatus.java b/.../main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/CheckpointStatus.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.stream;
 
 import lombok.Getter;

diff --git a/...g/opensearch/dataprepper/plugins/source/neptune/stream/DataStreamPartitionCheckpoint.java b/...g/opensearch/dataprepper/plugins/source/neptune/stream/DataStreamPartitionCheckpoint.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.stream;
 
 import org.opensearch.dataprepper.model.source.coordinator.enhanced.EnhancedSourceCoordinator;

diff --git a/...rg/opensearch/dataprepper/plugins/source/neptune/stream/StreamAcknowledgementManager.java b/...rg/opensearch/dataprepper/plugins/source/neptune/stream/StreamAcknowledgementManager.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.stream;
 
 import com.google.common.annotations.VisibleForTesting;

diff --git a/...c/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamScheduler.java b/...c/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamScheduler.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.stream;
 
 import org.opensearch.dataprepper.buffer.common.BufferAccumulator;

diff --git a/...a/org/opensearch/dataprepper/plugins/source/neptune/stream/model/NeptuneStreamRecord.java b/...a/org/opensearch/dataprepper/plugins/source/neptune/stream/model/NeptuneStreamRecord.java
@@ -1,12 +1,6 @@
 /*
- *
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
- *
- * The OpenSearch Contributors require contributions made to
- * this file be licensed under the Apache-2.0 license or a
- * compatible open source license.
- *
  */
 package org.opensearch.dataprepper.plugins.source.neptune.stream.model;
 

diff --git a/...java/org/opensearch/dataprepper/plugins/source/neptune/stream/model/StreamCheckpoint.java b/...java/org/opensearch/dataprepper/plugins/source/neptune/stream/model/StreamCheckpoint.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.stream.model;
 
 import lombok.AllArgsConstructor;

diff --git a/...n/java/org/opensearch/dataprepper/plugins/source/neptune/stream/model/StreamPosition.java b/...n/java/org/opensearch/dataprepper/plugins/source/neptune/stream/model/StreamPosition.java
@@ -1,13 +1,7 @@
 /*
- *
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
- *
- * The OpenSearch Contributors require contributions made to
- * this file be licensed under the Apache-2.0 license or a
- * compatible open source license.
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.stream.model;
 
 import lombok.AllArgsConstructor;

diff --git a/...java/org/opensearch/dataprepper/plugins/source/neptune/buffer/RecordBufferWriterTest.java b/...java/org/opensearch/dataprepper/plugins/source/neptune/buffer/RecordBufferWriterTest.java
@@ -2,7 +2,6 @@
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.buffer;
 
 import io.micrometer.core.instrument.Counter;

diff --git a/...rg/opensearch/dataprepper/plugins/source/neptune/converter/StreamRecordConverterTest.java b/...rg/opensearch/dataprepper/plugins/source/neptune/converter/StreamRecordConverterTest.java
@@ -2,7 +2,6 @@
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
  */
-
 package org.opensearch.dataprepper.plugins.source.neptune.converter;
 
 import org.junit.jupiter.api.BeforeEach;

diff --git a/.../org/opensearch/dataprepper/plugins/source/neptune/coordination/PartitionFactoryTest.java b/.../org/opensearch/dataprepper/plugins/source/neptune/coordination/PartitionFactoryTest.java
@@ -2,8 +2,6 @@
  * Copyright OpenSearch Contributors
  * SPDX-License-Identifier: Apache-2.0
  */
-
-
 package org.opensearch.dataprepper.plugins.source.neptune.coordination;
 
 import org.junit.jupiter.api.Test;

diff --git a/...st/java/org/opensearch/dataprepper/plugins/source/neptune/leader/LeaderSchedulerTest.java b/...st/java/org/opensearch/dataprepper/plugins/source/neptune/leader/LeaderSchedulerTest.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.leader;
 
 import org.junit.jupiter.api.Test;

diff --git a/...arch/dataprepper/plugins/source/neptune/s3partition/S3FolderPartitionCoordinatorTest.java b/...arch/dataprepper/plugins/source/neptune/s3partition/S3FolderPartitionCoordinatorTest.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.s3partition;
 
 import org.junit.jupiter.api.Test;

diff --git a/...earch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreatorSchedulerTest.java b/...earch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreatorSchedulerTest.java
@@ -1,3 +1,7 @@
+/*
+ * Copyright OpenSearch Contributors
+ * SPDX-License-Identifier: Apache-2.0
+ */
 package org.opensearch.dataprepper.plugins.source.neptune.s3partition;
 
 import org.junit.jupiter.api.BeforeEach;