Updated the package name to org.opensearch for data-prepper-core.

data-prepper-core/build.gradle

@@ -56,7 +56,7 @@ jar {
     manifest {
         attributes('Implementation-Title': project.name,
                 'Implementation-Version': project.version,
-                'Main-Class': 'com.amazon.dataprepper.DataPrepperExecute')
+                'Main-Class': 'org.opensearch.dataprepper.DataPrepperExecute')
     }
     from {
         configurations.runtimeClasspath.collect { it.isDirectory() ? it : zipTree(it) }

data-prepper-core/src/main/java/com/amazon/dataprepper/ContextManager.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/ContextManager.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper;
+package org.opensearch.dataprepper;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

data-prepper-core/src/main/java/com/amazon/dataprepper/DataPrepper.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/DataPrepper.java

@@ -3,12 +3,12 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper;
+package org.opensearch.dataprepper;
 
 import com.amazon.dataprepper.model.plugin.PluginFactory;
-import com.amazon.dataprepper.parser.PipelineParser;
-import com.amazon.dataprepper.pipeline.Pipeline;
-import com.amazon.dataprepper.pipeline.server.DataPrepperServer;
+import org.opensearch.dataprepper.parser.PipelineParser;
+import org.opensearch.dataprepper.pipeline.Pipeline;
+import org.opensearch.dataprepper.pipeline.server.DataPrepperServer;
 import io.micrometer.core.instrument.util.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

data-prepper-core/src/main/java/com/amazon/dataprepper/DataPrepperExecute.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/DataPrepperExecute.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper;
+package org.opensearch.dataprepper;
 
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

data-prepper-core/src/main/java/com/amazon/dataprepper/meter/EMFLoggingMeterRegistry.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/meter/EMFLoggingMeterRegistry.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.meter;
+package org.opensearch.dataprepper.meter;
 
 import io.micrometer.cloudwatch2.CloudWatchNamingConvention;
 import io.micrometer.core.instrument.Clock;

data-prepper-core/src/main/java/com/amazon/dataprepper/meter/EMFLoggingRegistryConfig.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/meter/EMFLoggingRegistryConfig.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.meter;
+package org.opensearch.dataprepper.meter;
 
 import io.micrometer.core.instrument.step.StepRegistryConfig;
 

data-prepper-core/src/main/java/com/amazon/dataprepper/meter/EMFMetricUtils.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/meter/EMFMetricUtils.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.meter;
+package org.opensearch.dataprepper.meter;
 
 class EMFMetricUtils {
 

data-prepper-core/src/main/java/com/amazon/dataprepper/parser/ParseException.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/parser/ParseException.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.parser;
+package org.opensearch.dataprepper.parser;
 
 public class ParseException extends RuntimeException {
     public ParseException(final Throwable cause) {

data-prepper-core/src/main/java/com/amazon/dataprepper/parser/PipelineConfigurationValidator.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/parser/PipelineConfigurationValidator.java

@@ -3,10 +3,10 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.parser;
+package org.opensearch.dataprepper.parser;
 
 import com.amazon.dataprepper.model.configuration.PluginSetting;
-import com.amazon.dataprepper.parser.model.PipelineConfiguration;
+import org.opensearch.dataprepper.parser.model.PipelineConfiguration;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

data-prepper-core/src/main/java/com/amazon/dataprepper/parser/PipelineParser.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/parser/PipelineParser.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.parser;
+package org.opensearch.dataprepper.parser;
 
 import com.amazon.dataprepper.model.annotations.SingleThread;
 import com.amazon.dataprepper.model.buffer.Buffer;
@@ -15,10 +15,10 @@
 import com.amazon.dataprepper.model.processor.Processor;
 import com.amazon.dataprepper.model.sink.Sink;
 import com.amazon.dataprepper.model.source.Source;
-import com.amazon.dataprepper.parser.model.PipelineConfiguration;
-import com.amazon.dataprepper.peerforwarder.PeerForwardingProcessorDecorator;
-import com.amazon.dataprepper.pipeline.Pipeline;
-import com.amazon.dataprepper.pipeline.PipelineConnector;
+import org.opensearch.dataprepper.parser.model.PipelineConfiguration;
+import org.opensearch.dataprepper.peerforwarder.PeerForwardingProcessorDecorator;
+import org.opensearch.dataprepper.pipeline.Pipeline;
+import org.opensearch.dataprepper.pipeline.PipelineConnector;
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.DeserializationFeature;
 import com.fasterxml.jackson.databind.ObjectMapper;

data-prepper-core/src/main/java/com/amazon/dataprepper/parser/config/DataPrepperAppConfiguration.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/parser/config/DataPrepperAppConfiguration.java

@@ -3,10 +3,10 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.parser.config;
+package org.opensearch.dataprepper.parser.config;
 
 import com.amazon.dataprepper.model.configuration.PluginModel;
-import com.amazon.dataprepper.parser.model.DataPrepperConfiguration;
+import org.opensearch.dataprepper.parser.model.DataPrepperConfiguration;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;

data-prepper-core/src/main/java/com/amazon/dataprepper/parser/config/DataPrepperArgs.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/parser/config/DataPrepperArgs.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.parser.config;
+package org.opensearch.dataprepper.parser.config;
 
 import org.opensearch.dataprepper.logstash.LogstashConfigConverter;
 import org.slf4j.Logger;

data-prepper-core/src/main/java/com/amazon/dataprepper/parser/config/MetricsConfig.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/parser/config/MetricsConfig.java

@@ -3,12 +3,12 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.parser.config;
+package org.opensearch.dataprepper.parser.config;
 
-import com.amazon.dataprepper.meter.EMFLoggingMeterRegistry;
-import com.amazon.dataprepper.parser.model.DataPrepperConfiguration;
-import com.amazon.dataprepper.parser.model.MetricRegistryType;
-import com.amazon.dataprepper.pipeline.server.CloudWatchMeterRegistryProvider;
+import org.opensearch.dataprepper.meter.EMFLoggingMeterRegistry;
+import org.opensearch.dataprepper.parser.model.DataPrepperConfiguration;
+import org.opensearch.dataprepper.parser.model.MetricRegistryType;
+import org.opensearch.dataprepper.pipeline.server.CloudWatchMeterRegistryProvider;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.fasterxml.jackson.dataformat.yaml.YAMLFactory;
 import io.micrometer.cloudwatch2.CloudWatchMeterRegistry;
@@ -37,7 +37,7 @@
 import java.util.Map;
 import java.util.stream.Collectors;
 
-import static com.amazon.dataprepper.DataPrepper.getServiceNameForMetrics;
+import static org.opensearch.dataprepper.DataPrepper.getServiceNameForMetrics;
 import static com.amazon.dataprepper.metrics.MetricNames.SERVICE_NAME;
 
 @Configuration

data-prepper-core/src/main/java/com/amazon/dataprepper/parser/config/PipelineParserConfiguration.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/parser/config/PipelineParserConfiguration.java

@@ -3,10 +3,10 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.parser.config;
+package org.opensearch.dataprepper.parser.config;
 
 import com.amazon.dataprepper.model.plugin.PluginFactory;
-import com.amazon.dataprepper.parser.PipelineParser;
+import org.opensearch.dataprepper.parser.PipelineParser;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 

data-prepper-core/src/main/java/com/amazon/dataprepper/parser/model/DataPrepperConfiguration.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/parser/model/DataPrepperConfiguration.java

@@ -3,10 +3,10 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.parser.model;
+package org.opensearch.dataprepper.parser.model;
 
 import com.amazon.dataprepper.model.configuration.PluginModel;
-import com.amazon.dataprepper.peerforwarder.PeerForwarderConfiguration;
+import org.opensearch.dataprepper.peerforwarder.PeerForwarderConfiguration;
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.databind.ObjectMapper;

data-prepper-core/src/main/java/com/amazon/dataprepper/parser/model/MetricRegistryType.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/parser/model/MetricRegistryType.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.parser.model;
+package org.opensearch.dataprepper.parser.model;
 
 public enum MetricRegistryType {
     // TODO: capitalize enum values

data-prepper-core/src/main/java/com/amazon/dataprepper/parser/model/PipelineConfiguration.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/parser/model/PipelineConfiguration.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.parser.model;
+package org.opensearch.dataprepper.parser.model;
 
 import com.amazon.dataprepper.model.configuration.PluginSetting;
 import com.amazon.dataprepper.plugins.buffer.blockingbuffer.BlockingBuffer;

data-prepper-core/src/main/java/com/amazon/dataprepper/peerforwarder/HashRing.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/peerforwarder/HashRing.java

@@ -3,10 +3,10 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.peerforwarder;
+package org.opensearch.dataprepper.peerforwarder;
 
-import com.amazon.dataprepper.peerforwarder.discovery.PeerListProvider;
 import com.linecorp.armeria.client.Endpoint;
+import org.opensearch.dataprepper.peerforwarder.discovery.PeerListProvider;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 

data-prepper-core/src/main/java/com/amazon/dataprepper/peerforwarder/PeerClientPool.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/peerforwarder/PeerClientPool.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.peerforwarder;
+package org.opensearch.dataprepper.peerforwarder;
 
 import com.amazon.dataprepper.plugins.certificate.model.Certificate;
 import com.linecorp.armeria.client.ClientBuilder;

data-prepper-core/src/main/java/com/amazon/dataprepper/peerforwarder/PeerForwarderAppConfig.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/peerforwarder/PeerForwarderAppConfig.java

@@ -3,9 +3,9 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.peerforwarder;
+package org.opensearch.dataprepper.peerforwarder;
 
-import com.amazon.dataprepper.parser.model.DataPrepperConfiguration;
+import org.opensearch.dataprepper.parser.model.DataPrepperConfiguration;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;

data-prepper-core/src/main/java/com/amazon/dataprepper/peerforwarder/PeerForwarderClientFactory.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/peerforwarder/PeerForwarderClientFactory.java

@@ -3,11 +3,12 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.peerforwarder;
+package org.opensearch.dataprepper.peerforwarder;
 
-import com.amazon.dataprepper.peerforwarder.certificate.CertificateProviderFactory;
-import com.amazon.dataprepper.peerforwarder.discovery.DiscoveryMode;
-import com.amazon.dataprepper.peerforwarder.discovery.PeerListProvider;
+
+import org.opensearch.dataprepper.peerforwarder.certificate.CertificateProviderFactory;
+import org.opensearch.dataprepper.peerforwarder.discovery.DiscoveryMode;
+import org.opensearch.dataprepper.peerforwarder.discovery.PeerListProvider;
 
 import javax.inject.Inject;
 import javax.inject.Named;

data-prepper-core/src/main/java/com/amazon/dataprepper/peerforwarder/PeerForwarderConfiguration.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/peerforwarder/PeerForwarderConfiguration.java

@@ -3,20 +3,20 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.peerforwarder;
+package org.opensearch.dataprepper.peerforwarder;
 
-import com.amazon.dataprepper.peerforwarder.discovery.DiscoveryMode;
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import org.apache.commons.lang3.StringUtils;
+import org.opensearch.dataprepper.peerforwarder.discovery.DiscoveryMode;
 
 import java.util.ArrayList;
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
 
 /**
- * Class to hold configuration for Core Peer Forwarder in {@link com.amazon.dataprepper.parser.model.DataPrepperConfiguration},
+ * Class to hold configuration for Core Peer Forwarder in {@link org.opensearch.dataprepper.parser.model.DataPrepperConfiguration},
  * including port, ssl, buffer, peer forwarder client and server configuration.
  * @since 2.0
  */

data-prepper-core/src/main/java/com/amazon/dataprepper/peerforwarder/PeerForwarderReceiveBuffer.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/peerforwarder/PeerForwarderReceiveBuffer.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.peerforwarder;
+package org.opensearch.dataprepper.peerforwarder;
 
 import com.amazon.dataprepper.model.CheckpointState;
 import com.amazon.dataprepper.model.buffer.Buffer;

data-prepper-core/src/main/java/com/amazon/dataprepper/peerforwarder/PeerForwardingProcessorDecorator.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/peerforwarder/PeerForwardingProcessorDecorator.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.peerforwarder;
+package org.opensearch.dataprepper.peerforwarder;
 
 import com.amazon.dataprepper.model.event.Event;
 import com.amazon.dataprepper.model.processor.Processor;

data-prepper-core/src/main/java/com/amazon/dataprepper/peerforwarder/certificate/CertificateProviderFactory.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/peerforwarder/certificate/CertificateProviderFactory.java

@@ -3,13 +3,13 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.peerforwarder.certificate;
+package org.opensearch.dataprepper.peerforwarder.certificate;
 
-import com.amazon.dataprepper.peerforwarder.PeerForwarderConfiguration;
 import com.amazon.dataprepper.plugins.certificate.CertificateProvider;
 import com.amazon.dataprepper.plugins.certificate.acm.ACMCertificateProvider;
 import com.amazon.dataprepper.plugins.certificate.file.FileCertificateProvider;
 import com.amazon.dataprepper.plugins.certificate.s3.S3CertificateProvider;
+import org.opensearch.dataprepper.peerforwarder.PeerForwarderConfiguration;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import software.amazon.awssdk.auth.credentials.AwsCredentialsProvider;

data-prepper-core/src/main/java/com/amazon/dataprepper/peerforwarder/discovery/AwsCloudMapPeerListProvider.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/peerforwarder/discovery/AwsCloudMapPeerListProvider.java

@@ -3,9 +3,9 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.peerforwarder.discovery;
+package org.opensearch.dataprepper.peerforwarder.discovery;
 
-import com.amazon.dataprepper.peerforwarder.PeerForwarderConfiguration;
+import org.opensearch.dataprepper.peerforwarder.PeerForwarderConfiguration;
 import com.linecorp.armeria.client.Endpoint;
 import com.linecorp.armeria.client.endpoint.DynamicEndpointGroup;
 import com.linecorp.armeria.client.retry.Backoff;

data-prepper-core/src/main/java/com/amazon/dataprepper/peerforwarder/discovery/DiscoveryMode.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/peerforwarder/discovery/DiscoveryMode.java

@@ -3,9 +3,9 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.peerforwarder.discovery;
+package org.opensearch.dataprepper.peerforwarder.discovery;
 
-import com.amazon.dataprepper.peerforwarder.PeerForwarderConfiguration;
+import org.opensearch.dataprepper.peerforwarder.PeerForwarderConfiguration;
 
 import java.util.Objects;
 import java.util.function.Function;

data-prepper-core/src/main/java/com/amazon/dataprepper/peerforwarder/discovery/DiscoveryUtils.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/peerforwarder/discovery/DiscoveryUtils.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.peerforwarder.discovery;
+package org.opensearch.dataprepper.peerforwarder.discovery;
 
 import com.google.common.net.InternetDomainName;
 import org.apache.commons.validator.routines.InetAddressValidator;

data-prepper-core/src/main/java/com/amazon/dataprepper/peerforwarder/discovery/DnsPeerListProvider.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/peerforwarder/discovery/DnsPeerListProvider.java

@@ -3,9 +3,9 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.peerforwarder.discovery;
+package org.opensearch.dataprepper.peerforwarder.discovery;
 
-import com.amazon.dataprepper.peerforwarder.PeerForwarderConfiguration;
+import org.opensearch.dataprepper.peerforwarder.PeerForwarderConfiguration;
 import com.google.common.base.Preconditions;
 import com.linecorp.armeria.client.Endpoint;
 import com.linecorp.armeria.client.endpoint.dns.DnsAddressEndpointGroup;

data-prepper-core/src/main/java/com/amazon/dataprepper/peerforwarder/discovery/PeerListProvider.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/peerforwarder/discovery/PeerListProvider.java

@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.peerforwarder.discovery;
+package org.opensearch.dataprepper.peerforwarder.discovery;
 
 import com.linecorp.armeria.client.Endpoint;
 import com.linecorp.armeria.common.util.Listenable;

data-prepper-core/src/main/java/com/amazon/dataprepper/peerforwarder/discovery/StaticPeerListProvider.java → data-prepper-core/src/main/java/org/opensearch/dataprepper/peerforwarder/discovery/StaticPeerListProvider.java

@@ -3,9 +3,9 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.peerforwarder.discovery;
+package org.opensearch.dataprepper.peerforwarder.discovery;
 
-import com.amazon.dataprepper.peerforwarder.PeerForwarderConfiguration;
+import org.opensearch.dataprepper.peerforwarder.PeerForwarderConfiguration;
 import com.google.common.base.Preconditions;
 import com.linecorp.armeria.client.Endpoint;
 import org.slf4j.Logger;