From 82c6461d3eac0f60c6bdbf38f3da1005f895fa0e Mon Sep 17 00:00:00 2001 From: Amanda Xiang Date: Tue, 7 Jan 2025 13:59:50 +0100 Subject: [PATCH] Add copyright header to all the files Signed-off-by: Amanda Xiang --- data-prepper-plugins/neptune-source/build.gradle | 4 ++++ .../plugins/source/neptune/NeptuneService.java | 4 ++++ .../dataprepper/plugins/source/neptune/NeptuneSource.java | 4 ++++ .../plugins/source/neptune/buffer/RecordBufferWriter.java | 4 ++++ .../source/neptune/client/NeptuneDataClientWrapper.java | 6 ------ .../source/neptune/client/NeptuneStreamClient.java | 6 ------ .../source/neptune/client/NeptuneStreamEventListener.java | 8 +------- .../plugins/source/neptune/configuration/AwsConfig.java | 1 - .../source/neptune/configuration/NeptuneSourceConfig.java | 4 ++++ .../source/neptune/converter/MetadataKeyAttributes.java | 4 ++++ .../plugins/source/neptune/converter/NeptuneS3Record.java | 7 ------- .../neptune/converter/NeptuneS3RecordPredicate.java | 4 ++++ .../neptune/converter/NeptuneStreamRecordValidator.java | 7 ------- .../source/neptune/converter/StreamRecordConverter.java | 4 ++++ .../source/neptune/coordination/PartitionFactory.java | 1 - .../coordination/partition/DataQueryPartition.java | 4 ++++ .../neptune/coordination/partition/GlobalState.java | 1 - .../neptune/coordination/partition/LeaderPartition.java | 4 ++++ .../neptune/coordination/partition/S3FolderPartition.java | 1 - .../neptune/coordination/partition/StreamPartition.java | 1 - .../coordination/state/DataQueryProgressState.java | 1 - .../neptune/coordination/state/LeaderProgressState.java | 4 ++++ .../neptune/coordination/state/StreamProgressState.java | 4 ++++ .../plugins/source/neptune/leader/LeaderScheduler.java | 1 - .../plugins/source/neptune/model/ExportLoadStatus.java | 1 - .../source/neptune/model/PartitionIdentifierBatch.java | 1 - .../plugins/source/neptune/model/S3PartitionStatus.java | 4 ++++ .../plugins/source/neptune/model/StreamLoadStatus.java | 4 ++++ .../neptune/s3partition/S3FolderPartitionCoordinator.java | 1 - .../source/neptune/s3partition/S3PartitionCreator.java | 4 ++++ .../neptune/s3partition/S3PartitionCreatorScheduler.java | 4 ++++ .../plugins/source/neptune/stream/CheckpointStatus.java | 4 ++++ .../neptune/stream/DataStreamPartitionCheckpoint.java | 4 ++++ .../neptune/stream/StreamAcknowledgementManager.java | 4 ++++ .../plugins/source/neptune/stream/StreamScheduler.java | 4 ++++ .../source/neptune/stream/model/NeptuneStreamRecord.java | 6 ------ .../source/neptune/stream/model/StreamCheckpoint.java | 4 ++++ .../source/neptune/stream/model/StreamPosition.java | 6 ------ .../source/neptune/buffer/RecordBufferWriterTest.java | 1 - .../neptune/converter/StreamRecordConverterTest.java | 1 - .../source/neptune/coordination/PartitionFactoryTest.java | 2 -- .../source/neptune/leader/LeaderSchedulerTest.java | 4 ++++ .../s3partition/S3FolderPartitionCoordinatorTest.java | 4 ++++ .../s3partition/S3PartitionCreatorSchedulerTest.java | 4 ++++ .../neptune/s3partition/S3PartitionCreatorTest.java | 4 ++++ .../neptune/stream/DataStreamPartitionCheckpointTest.java | 4 ++++ .../neptune/stream/StreamAcknowledgementManagerTest.java | 4 ++++ .../source/neptune/stream/StreamSchedulerTest.java | 4 ++++ .../plugins/source/neptune/stream/StreamWorkerTest.java | 4 ++++ 49 files changed, 117 insertions(+), 59 deletions(-) diff --git a/data-prepper-plugins/neptune-source/build.gradle b/data-prepper-plugins/neptune-source/build.gradle index bbc830700e..6961ecf7de 100644 --- 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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/NeptuneService.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/NeptuneService.java index e149e8b40a..79802859fe 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/NeptuneService.java +++ b/data-prepper-plugins/neptune-source/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/NeptuneSource.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/NeptuneSource.java index f1b16ff406..effb25ecdb 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/NeptuneSource.java +++ b/data-prepper-plugins/neptune-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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/buffer/RecordBufferWriter.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/buffer/RecordBufferWriter.java index 88aa1ad219..84e158ebeb 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/buffer/RecordBufferWriter.java +++ b/data-prepper-plugins/neptune-source/src/main/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneDataClientWrapper.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneDataClientWrapper.java index e0543cb1b9..fd2199c921 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneDataClientWrapper.java +++ b/data-prepper-plugins/neptune-source/src/main/java/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneStreamClient.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneStreamClient.java index 622bf8f833..f42608ccbf 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneStreamClient.java +++ b/data-prepper-plugins/neptune-source/src/main/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneStreamEventListener.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneStreamEventListener.java index 6b3deee4b9..9dffc1b396 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/client/NeptuneStreamEventListener.java +++ b/data-prepper-plugins/neptune-source/src/main/java/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/configuration/AwsConfig.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/configuration/AwsConfig.java index ff0e256984..eeebf63518 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/configuration/AwsConfig.java +++ b/data-prepper-plugins/neptune-source/src/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/configuration/NeptuneSourceConfig.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/configuration/NeptuneSourceConfig.java index bcad2f9043..3a75b3455a 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/configuration/NeptuneSourceConfig.java +++ b/data-prepper-plugins/neptune-source/src/main/java/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/MetadataKeyAttributes.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/MetadataKeyAttributes.java index c8bd3a56de..b8fef52688 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/MetadataKeyAttributes.java +++ b/data-prepper-plugins/neptune-source/src/main/java/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/NeptuneS3Record.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/NeptuneS3Record.java index 79982e9303..99e14780cb 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/NeptuneS3Record.java +++ b/data-prepper-plugins/neptune-source/src/main/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/NeptuneS3RecordPredicate.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/NeptuneS3RecordPredicate.java index 7e66a55264..8a104cf022 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/NeptuneS3RecordPredicate.java +++ b/data-prepper-plugins/neptune-source/src/main/java/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/NeptuneStreamRecordValidator.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/NeptuneStreamRecordValidator.java index 955b68e86e..e4947e93ea 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/NeptuneStreamRecordValidator.java +++ b/data-prepper-plugins/neptune-source/src/main/java/org/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/StreamRecordConverter.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/StreamRecordConverter.java index f70f86c690..75ac68f20e 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/converter/StreamRecordConverter.java +++ b/data-prepper-plugins/neptune-source/src/main/java/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/PartitionFactory.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/PartitionFactory.java index 699c1edb85..e7bcaa9309 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/PartitionFactory.java +++ b/data-prepper-plugins/neptune-source/src/main/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/DataQueryPartition.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/DataQueryPartition.java index b1fb5b6805..732c848fba 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/DataQueryPartition.java +++ b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/GlobalState.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/GlobalState.java index 729fd8c151..29af0e9360 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/GlobalState.java +++ b/data-prepper-plugins/neptune-source/src/main/java/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/LeaderPartition.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/LeaderPartition.java index 8a7410d3b0..6fd8f959b7 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/LeaderPartition.java +++ b/data-prepper-plugins/neptune-source/src/main/java/org/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/S3FolderPartition.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/S3FolderPartition.java index a445c27297..10e6b0392b 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/S3FolderPartition.java +++ b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/StreamPartition.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/StreamPartition.java index e52191e610..7699056fd6 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/partition/StreamPartition.java +++ b/data-prepper-plugins/neptune-source/src/main/java/org/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/state/DataQueryProgressState.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/state/DataQueryProgressState.java index 50a9302edb..974b65a59a 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/state/DataQueryProgressState.java +++ b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/state/LeaderProgressState.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/state/LeaderProgressState.java index 31be05cbc9..9197a2e97e 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/state/LeaderProgressState.java +++ b/data-prepper-plugins/neptune-source/src/main/java/org/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/state/StreamProgressState.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/state/StreamProgressState.java index a68d23684a..124fde3c47 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/state/StreamProgressState.java +++ b/data-prepper-plugins/neptune-source/src/main/java/org/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/leader/LeaderScheduler.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/leader/LeaderScheduler.java index faa4367d7a..8b4db4af91 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/leader/LeaderScheduler.java +++ b/data-prepper-plugins/neptune-source/src/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/ExportLoadStatus.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/ExportLoadStatus.java index 6f422f6787..00d07ffb8b 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/ExportLoadStatus.java +++ b/data-prepper-plugins/neptune-source/src/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/PartitionIdentifierBatch.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/PartitionIdentifierBatch.java index 1a56426786..16281665df 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/PartitionIdentifierBatch.java +++ b/data-prepper-plugins/neptune-source/src/main/java/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/S3PartitionStatus.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/S3PartitionStatus.java index 4daf291de9..15ec246296 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/S3PartitionStatus.java +++ b/data-prepper-plugins/neptune-source/src/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/StreamLoadStatus.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/StreamLoadStatus.java index dfd1fb7a90..b3ecaf94c3 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/model/StreamLoadStatus.java +++ b/data-prepper-plugins/neptune-source/src/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3FolderPartitionCoordinator.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3FolderPartitionCoordinator.java index 7379b1f143..9fc896485a 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3FolderPartitionCoordinator.java +++ b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreator.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreator.java index b46a7e3444..bb58f65fd3 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreator.java +++ b/data-prepper-plugins/neptune-source/src/main/java/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreatorScheduler.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreatorScheduler.java index 9108ef14a0..44b36560f5 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreatorScheduler.java +++ b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/CheckpointStatus.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/CheckpointStatus.java index d82b1741cc..0047108e95 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/CheckpointStatus.java +++ b/data-prepper-plugins/neptune-source/src/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/DataStreamPartitionCheckpoint.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/DataStreamPartitionCheckpoint.java index a0ad8f2a2b..fbc3b06ad6 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/DataStreamPartitionCheckpoint.java +++ b/data-prepper-plugins/neptune-source/src/main/java/org/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamAcknowledgementManager.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamAcknowledgementManager.java index 2d1522a3d2..e794dd14c3 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamAcknowledgementManager.java +++ b/data-prepper-plugins/neptune-source/src/main/java/org/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamScheduler.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamScheduler.java index bf30da0288..fff98a9eed 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamScheduler.java +++ b/data-prepper-plugins/neptune-source/src/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/model/NeptuneStreamRecord.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/model/NeptuneStreamRecord.java index 24074f9e4c..9675f401c3 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/model/NeptuneStreamRecord.java +++ b/data-prepper-plugins/neptune-source/src/main/java/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/model/StreamCheckpoint.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/model/StreamCheckpoint.java index a945ae7abb..343fe89097 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/model/StreamCheckpoint.java +++ b/data-prepper-plugins/neptune-source/src/main/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/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/model/StreamPosition.java b/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/model/StreamPosition.java index a21a3c6cfd..54f702f68d 100644 --- a/data-prepper-plugins/neptune-source/src/main/java/org/opensearch/dataprepper/plugins/source/neptune/stream/model/StreamPosition.java +++ b/data-prepper-plugins/neptune-source/src/main/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/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/buffer/RecordBufferWriterTest.java b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/buffer/RecordBufferWriterTest.java index 1e64236eb6..01d092a4b2 100644 --- a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/buffer/RecordBufferWriterTest.java +++ b/data-prepper-plugins/neptune-source/src/test/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/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/converter/StreamRecordConverterTest.java b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/converter/StreamRecordConverterTest.java index 2386bd939e..8779660f84 100644 --- a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/converter/StreamRecordConverterTest.java +++ b/data-prepper-plugins/neptune-source/src/test/java/org/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/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/PartitionFactoryTest.java b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/PartitionFactoryTest.java index bb07ce7505..8317cfc5f6 100644 --- a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/coordination/PartitionFactoryTest.java +++ b/data-prepper-plugins/neptune-source/src/test/java/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/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/leader/LeaderSchedulerTest.java b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/leader/LeaderSchedulerTest.java index ade5c7336d..0bb728c7f5 100644 --- a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/leader/LeaderSchedulerTest.java +++ b/data-prepper-plugins/neptune-source/src/test/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/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3FolderPartitionCoordinatorTest.java b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3FolderPartitionCoordinatorTest.java index 7eea492a18..193cc323a2 100644 --- a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3FolderPartitionCoordinatorTest.java +++ b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/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/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreatorSchedulerTest.java b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreatorSchedulerTest.java index 45cdc00e4f..2d7d32329a 100644 --- a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreatorSchedulerTest.java +++ b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/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; diff --git a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreatorTest.java b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreatorTest.java index 27f7b691a6..ab20b2fc5b 100644 --- a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreatorTest.java +++ b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/s3partition/S3PartitionCreatorTest.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/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/DataStreamPartitionCheckpointTest.java b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/DataStreamPartitionCheckpointTest.java index 3923466dc4..0fcacf6dfc 100644 --- a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/DataStreamPartitionCheckpointTest.java +++ b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/DataStreamPartitionCheckpointTest.java @@ -1,3 +1,7 @@ +/* + * Copyright OpenSearch Contributors + * SPDX-License-Identifier: Apache-2.0 + */ package org.opensearch.dataprepper.plugins.source.neptune.stream; import org.junit.jupiter.api.Test; diff --git a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamAcknowledgementManagerTest.java b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamAcknowledgementManagerTest.java index afd36a7e6f..96b9353b2a 100644 --- a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamAcknowledgementManagerTest.java +++ b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamAcknowledgementManagerTest.java @@ -1,3 +1,7 @@ +/* + * Copyright OpenSearch Contributors + * SPDX-License-Identifier: Apache-2.0 + */ package org.opensearch.dataprepper.plugins.source.neptune.stream; import org.junit.jupiter.api.BeforeEach; diff --git a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamSchedulerTest.java b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamSchedulerTest.java index a273157710..c51d48ccc3 100644 --- a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamSchedulerTest.java +++ b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamSchedulerTest.java @@ -1,3 +1,7 @@ +/* + * Copyright OpenSearch Contributors + * SPDX-License-Identifier: Apache-2.0 + */ package org.opensearch.dataprepper.plugins.source.neptune.stream; import org.junit.jupiter.api.BeforeEach; diff --git a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamWorkerTest.java b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamWorkerTest.java index c11cff8f0b..38f220824e 100644 --- a/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamWorkerTest.java +++ b/data-prepper-plugins/neptune-source/src/test/java/org/opensearch/dataprepper/plugins/source/neptune/stream/StreamWorkerTest.java @@ -1,3 +1,7 @@ +/* + * Copyright OpenSearch Contributors + * SPDX-License-Identifier: Apache-2.0 + */ package org.opensearch.dataprepper.plugins.source.neptune.stream; import io.micrometer.core.instrument.Counter;