Updates data-prepper-api to the org.opensearch.dataprepper package. (#…

…1833) Signed-off-by: David Venable <[email protected]>
opensearch-project · Sep 29, 2022 · 59c48e2 · 59c48e2
1 parent cb65e46
commit 59c48e2
Show file tree

Hide file tree

Showing 393 changed files with 1,122 additions and 1,123 deletions.
diff --git a/...-prepper-api/src/main/java/org/opensearch/dataprepper/expression/ExpressionEvaluator.java b/...-prepper-api/src/main/java/org/opensearch/dataprepper/expression/ExpressionEvaluator.java
@@ -5,7 +5,7 @@
 
 package org.opensearch.dataprepper.expression;
 
-import com.amazon.dataprepper.model.event.Event;
+import org.opensearch.dataprepper.model.event.Event;
 
 /**
  * @since 1.3

diff --git a/...azon/dataprepper/metrics/MetricNames.java → ...arch/dataprepper/metrics/MetricNames.java b/...azon/dataprepper/metrics/MetricNames.java → ...arch/dataprepper/metrics/MetricNames.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.metrics;
+package org.opensearch.dataprepper.metrics;
 
 public class MetricNames {
     private MetricNames() {}

diff --git a/...on/dataprepper/metrics/PluginMetrics.java → ...ch/dataprepper/metrics/PluginMetrics.java b/...on/dataprepper/metrics/PluginMetrics.java → ...ch/dataprepper/metrics/PluginMetrics.java
@@ -3,9 +3,9 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.metrics;
+package org.opensearch.dataprepper.metrics;
 
-import com.amazon.dataprepper.model.configuration.PluginSetting;
+import org.opensearch.dataprepper.model.configuration.PluginSetting;
 import java.util.StringJoiner;
 import java.util.function.ToDoubleFunction;
 

diff --git a/...on/dataprepper/model/CheckpointState.java → ...ch/dataprepper/model/CheckpointState.java b/...on/dataprepper/model/CheckpointState.java → ...ch/dataprepper/model/CheckpointState.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model;
+package org.opensearch.dataprepper.model;
 
 /**
  * CheckpointState keeps track of a summary of records processed by a data-prepper worker thread.

diff --git a/.../model/annotations/DataPrepperPlugin.java → .../model/annotations/DataPrepperPlugin.java b/.../model/annotations/DataPrepperPlugin.java → .../model/annotations/DataPrepperPlugin.java
@@ -3,9 +3,9 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.annotations;
+package org.opensearch.dataprepper.model.annotations;
 
-import com.amazon.dataprepper.model.configuration.PluginSetting;
+import org.opensearch.dataprepper.model.configuration.PluginSetting;
 
 import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;
@@ -15,10 +15,10 @@
 
 /**
  * Annotates a Data Prepper plugin. This can be a pipeline component such
- * as {@link com.amazon.dataprepper.model.source.Source},
- * {@link com.amazon.dataprepper.model.buffer.Buffer},
- * {@link com.amazon.dataprepper.model.processor.Processor}, or
- * {@link com.amazon.dataprepper.model.sink.Sink}. It can also be another
+ * as {@link org.opensearch.dataprepper.model.source.Source},
+ * {@link org.opensearch.dataprepper.model.buffer.Buffer},
+ * {@link org.opensearch.dataprepper.model.processor.Processor}, or
+ * {@link org.opensearch.dataprepper.model.sink.Sink}. It can also be another
  * plugin-supported class.
  * <p>
  * The value provided in the {@link #name()} attribute determines the name of

diff --git a/...tations/DataPrepperPluginConstructor.java → ...tations/DataPrepperPluginConstructor.java b/...tations/DataPrepperPluginConstructor.java → ...tations/DataPrepperPluginConstructor.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.annotations;
+package org.opensearch.dataprepper.model.annotations;
 
 import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;

diff --git a/...epper/model/annotations/SingleThread.java → ...epper/model/annotations/SingleThread.java b/...epper/model/annotations/SingleThread.java → ...epper/model/annotations/SingleThread.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.annotations;
+package org.opensearch.dataprepper.model.annotations;
 
 import java.lang.annotation.Documented;
 import java.lang.annotation.ElementType;

diff --git a/...aprepper/model/buffer/AbstractBuffer.java → ...aprepper/model/buffer/AbstractBuffer.java b/...aprepper/model/buffer/AbstractBuffer.java → ...aprepper/model/buffer/AbstractBuffer.java
@@ -3,15 +3,15 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.buffer;
+package org.opensearch.dataprepper.model.buffer;
 
-import com.amazon.dataprepper.metrics.MetricNames;
-import com.amazon.dataprepper.metrics.PluginMetrics;
-import com.amazon.dataprepper.model.CheckpointState;
-import com.amazon.dataprepper.model.configuration.PluginSetting;
-import com.amazon.dataprepper.model.record.Record;
 import io.micrometer.core.instrument.Counter;
 import io.micrometer.core.instrument.Timer;
+import org.opensearch.dataprepper.metrics.MetricNames;
+import org.opensearch.dataprepper.metrics.PluginMetrics;
+import org.opensearch.dataprepper.model.CheckpointState;
+import org.opensearch.dataprepper.model.configuration.PluginSetting;
+import org.opensearch.dataprepper.model.record.Record;
 
 import java.util.Collection;
 import java.util.Map;

diff --git a/...azon/dataprepper/model/buffer/Buffer.java → ...arch/dataprepper/model/buffer/Buffer.java b/...azon/dataprepper/model/buffer/Buffer.java → ...arch/dataprepper/model/buffer/Buffer.java
@@ -3,10 +3,10 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.buffer;
+package org.opensearch.dataprepper.model.buffer;
 
-import com.amazon.dataprepper.model.record.Record;
-import com.amazon.dataprepper.model.CheckpointState;
+import org.opensearch.dataprepper.model.record.Record;
+import org.opensearch.dataprepper.model.CheckpointState;
 
 import java.util.Collection;
 import java.util.Map;

diff --git a/...r/model/buffer/SizeOverflowException.java → ...r/model/buffer/SizeOverflowException.java b/...r/model/buffer/SizeOverflowException.java → ...r/model/buffer/SizeOverflowException.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.buffer;
+package org.opensearch.dataprepper.model.buffer;
 
 /**
  * Thrown to indicate the size of the data to be written into the {@link Buffer} is

diff --git a/...model/configuration/ConditionalRoute.java → ...model/configuration/ConditionalRoute.java b/...model/configuration/ConditionalRoute.java → ...model/configuration/ConditionalRoute.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.configuration;
+package org.opensearch.dataprepper.model.configuration;
 
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.core.JacksonException;

diff --git a/...el/configuration/PipelineDescription.java → ...el/configuration/PipelineDescription.java b/...el/configuration/PipelineDescription.java → ...el/configuration/PipelineDescription.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.configuration;
+package org.opensearch.dataprepper.model.configuration;
 
 /**
  * Model that should be provided to plugins to provide certain details about the pipeline they belong to

diff --git a/...er/model/configuration/PipelineModel.java → ...er/model/configuration/PipelineModel.java b/...er/model/configuration/PipelineModel.java → ...er/model/configuration/PipelineModel.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.configuration;
+package org.opensearch.dataprepper.model.configuration;
 
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonInclude;

diff --git a/...configuration/PipelinesDataFlowModel.java → ...configuration/PipelinesDataFlowModel.java b/...configuration/PipelinesDataFlowModel.java → ...configuration/PipelinesDataFlowModel.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.configuration;
+package org.opensearch.dataprepper.model.configuration;
 
 import com.fasterxml.jackson.annotation.JsonAnyGetter;
 import com.fasterxml.jackson.annotation.JsonAnySetter;

diff --git a/...pper/model/configuration/PluginModel.java → ...pper/model/configuration/PluginModel.java b/...pper/model/configuration/PluginModel.java → ...pper/model/configuration/PluginModel.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.configuration;
+package org.opensearch.dataprepper.model.configuration;
 
 import com.fasterxml.jackson.annotation.JsonAnyGetter;
 import com.fasterxml.jackson.annotation.JsonAnySetter;

diff --git a/...er/model/configuration/PluginSetting.java → ...er/model/configuration/PluginSetting.java b/...er/model/configuration/PluginSetting.java → ...er/model/configuration/PluginSetting.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.configuration;
+package org.opensearch.dataprepper.model.configuration;
 
 import java.util.Collections;
 import java.util.List;

diff --git a/...repper/model/configuration/SinkModel.java → ...repper/model/configuration/SinkModel.java b/...repper/model/configuration/SinkModel.java → ...repper/model/configuration/SinkModel.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.configuration;
+package org.opensearch.dataprepper.model.configuration;
 
 import com.fasterxml.jackson.annotation.JsonCreator;
 import com.fasterxml.jackson.annotation.JsonInclude;

diff --git a/...per/model/event/DefaultEventMetadata.java → ...per/model/event/DefaultEventMetadata.java b/...per/model/event/DefaultEventMetadata.java → ...per/model/event/DefaultEventMetadata.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.event;
+package org.opensearch.dataprepper.model.event;
 
 import com.google.common.collect.ImmutableMap;
 

diff --git a/...amazon/dataprepper/model/event/Event.java → ...search/dataprepper/model/event/Event.java b/...amazon/dataprepper/model/event/Event.java → ...search/dataprepper/model/event/Event.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.event;
+package org.opensearch.dataprepper.model.event;
 
 import java.util.List;
 import java.util.Map;
@@ -12,10 +12,10 @@
  * All data flowing through Data Prepper will be represented as events. An event is the base representation of data.
  * An event can be defined as a collection of key-value pairs and the following interface represents the contract with this model.
  * <p>
- * Data Prepper will be migrating away from the original use of {@link com.amazon.dataprepper.model.record.Record}s.
- * Internal interfaces for {@link com.amazon.dataprepper.model.processor.Processor}, {@link com.amazon.dataprepper.model.buffer.Buffer},
- * {@link com.amazon.dataprepper.model.sink.Sink} and {@link com.amazon.dataprepper.model.source.Source} will be extended to support
- * the new internal model. The use of {@link com.amazon.dataprepper.model.record.Record}s will be deprecated in 2.0.
+ * Data Prepper will be migrating away from the original use of {@link org.opensearch.dataprepper.model.record.Record}s.
+ * Internal interfaces for {@link org.opensearch.dataprepper.model.processor.Processor}, {@link org.opensearch.dataprepper.model.buffer.Buffer},
+ * {@link org.opensearch.dataprepper.model.sink.Sink} and {@link org.opensearch.dataprepper.model.source.Source} will be extended to support
+ * the new internal model. The use of {@link org.opensearch.dataprepper.model.record.Record}s will be deprecated in 2.0.
  * <p>
  * @since 1.2
  */

diff --git a/...ataprepper/model/event/EventMetadata.java → ...ataprepper/model/event/EventMetadata.java b/...ataprepper/model/event/EventMetadata.java → ...ataprepper/model/event/EventMetadata.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.event;
+package org.opensearch.dataprepper.model.event;
 
 import java.time.Instant;
 import java.util.Map;

diff --git a/...on/dataprepper/model/event/EventType.java → ...ch/dataprepper/model/event/EventType.java b/...on/dataprepper/model/event/EventType.java → ...ch/dataprepper/model/event/EventType.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.event;
+package org.opensearch.dataprepper.model.event;
 
 import java.util.Arrays;
 import java.util.Map;

diff --git a/...dataprepper/model/event/JacksonEvent.java → ...dataprepper/model/event/JacksonEvent.java b/...dataprepper/model/event/JacksonEvent.java → ...dataprepper/model/event/JacksonEvent.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.event;
+package org.opensearch.dataprepper.model.event;
 
 import com.fasterxml.jackson.core.JsonPointer;
 import com.fasterxml.jackson.core.JsonProcessingException;

diff --git a/...zon/dataprepper/model/log/JacksonLog.java → ...rch/dataprepper/model/log/JacksonLog.java b/...zon/dataprepper/model/log/JacksonLog.java → ...rch/dataprepper/model/log/JacksonLog.java
@@ -3,10 +3,10 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.log;
+package org.opensearch.dataprepper.model.log;
 
-import com.amazon.dataprepper.model.event.EventType;
-import com.amazon.dataprepper.model.event.JacksonEvent;
+import org.opensearch.dataprepper.model.event.EventType;
+import org.opensearch.dataprepper.model.event.JacksonEvent;
 
 import static com.google.common.base.Preconditions.checkArgument;
 

diff --git a/...com/amazon/dataprepper/model/log/Log.java → ...opensearch/dataprepper/model/log/Log.java b/...com/amazon/dataprepper/model/log/Log.java → ...opensearch/dataprepper/model/log/Log.java
@@ -3,9 +3,9 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.log;
+package org.opensearch.dataprepper.model.log;
 
-import com.amazon.dataprepper.model.event.Event;
+import org.opensearch.dataprepper.model.event.Event;
 
 /**
  * A log event in Data Prepper represents a single log line. A log event does not require any specific keys allowing this event type to

diff --git a/...azon/dataprepper/model/metric/Bucket.java → ...arch/dataprepper/model/metric/Bucket.java b/...azon/dataprepper/model/metric/Bucket.java → ...arch/dataprepper/model/metric/Bucket.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.metric;
+package org.opensearch.dataprepper.model.metric;
 
 /**
  * Represents a bucket of a {@link Histogram}.

diff --git a/...taprepper/model/metric/DefaultBucket.java → ...taprepper/model/metric/DefaultBucket.java b/...taprepper/model/metric/DefaultBucket.java → ...taprepper/model/metric/DefaultBucket.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.metric;
+package org.opensearch.dataprepper.model.metric;
 
 /**
  * The default implementation of {@link Bucket}, measurement within a {@link Histogram}

diff --git a/...prepper/model/metric/DefaultQuantile.java → ...prepper/model/metric/DefaultQuantile.java b/...prepper/model/metric/DefaultQuantile.java → ...prepper/model/metric/DefaultQuantile.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.metric;
+package org.opensearch.dataprepper.model.metric;
 
 /**
  * The default implementation of {@link Quantile}, measurement within a {@link Summary}

diff --git a/...mazon/dataprepper/model/metric/Gauge.java → ...earch/dataprepper/model/metric/Gauge.java b/...mazon/dataprepper/model/metric/Gauge.java → ...earch/dataprepper/model/metric/Gauge.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.metric;
+package org.opensearch.dataprepper.model.metric;
 
 /**
  * A gauge event in Data Prepper represents a metric event.

diff --git a/...n/dataprepper/model/metric/Histogram.java → ...h/dataprepper/model/metric/Histogram.java b/...n/dataprepper/model/metric/Histogram.java → ...h/dataprepper/model/metric/Histogram.java
@@ -3,7 +3,7 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.metric;
+package org.opensearch.dataprepper.model.metric;
 
 import java.util.List;
 

diff --git a/...ataprepper/model/metric/JacksonGauge.java → ...ataprepper/model/metric/JacksonGauge.java b/...ataprepper/model/metric/JacksonGauge.java → ...ataprepper/model/metric/JacksonGauge.java
@@ -3,9 +3,9 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.metric;
+package org.opensearch.dataprepper.model.metric;
 
-import com.amazon.dataprepper.model.event.EventType;
+import org.opensearch.dataprepper.model.event.EventType;
 
 import java.util.ArrayList;
 import java.util.Arrays;

diff --git a/...repper/model/metric/JacksonHistogram.java → ...repper/model/metric/JacksonHistogram.java b/...repper/model/metric/JacksonHistogram.java → ...repper/model/metric/JacksonHistogram.java
@@ -3,9 +3,9 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.metric;
+package org.opensearch.dataprepper.model.metric;
 
-import com.amazon.dataprepper.model.event.EventType;
+import org.opensearch.dataprepper.model.event.EventType;
 
 import java.util.ArrayList;
 import java.util.Arrays;

diff --git a/...taprepper/model/metric/JacksonMetric.java → ...taprepper/model/metric/JacksonMetric.java b/...taprepper/model/metric/JacksonMetric.java → ...taprepper/model/metric/JacksonMetric.java
@@ -3,9 +3,9 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.metric;
+package org.opensearch.dataprepper.model.metric;
 
-import com.amazon.dataprepper.model.event.JacksonEvent;
+import org.opensearch.dataprepper.model.event.JacksonEvent;
 import com.fasterxml.jackson.databind.JsonNode;
 import com.fasterxml.jackson.databind.node.ObjectNode;
 

diff --git a/.../dataprepper/model/metric/JacksonSum.java → .../dataprepper/model/metric/JacksonSum.java b/.../dataprepper/model/metric/JacksonSum.java → .../dataprepper/model/metric/JacksonSum.java
@@ -3,9 +3,9 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.metric;
+package org.opensearch.dataprepper.model.metric;
 
-import com.amazon.dataprepper.model.event.EventType;
+import org.opensearch.dataprepper.model.event.EventType;
 
 import java.util.ArrayList;
 import java.util.Arrays;

diff --git a/...aprepper/model/metric/JacksonSummary.java → ...aprepper/model/metric/JacksonSummary.java b/...aprepper/model/metric/JacksonSummary.java → ...aprepper/model/metric/JacksonSummary.java
@@ -3,9 +3,9 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.metric;
+package org.opensearch.dataprepper.model.metric;
 
-import com.amazon.dataprepper.model.event.EventType;
+import org.opensearch.dataprepper.model.event.EventType;
 
 import java.util.Arrays;
 import java.util.Collections;

diff --git a/...azon/dataprepper/model/metric/Metric.java → ...arch/dataprepper/model/metric/Metric.java b/...azon/dataprepper/model/metric/Metric.java → ...arch/dataprepper/model/metric/Metric.java
@@ -3,9 +3,9 @@
  * SPDX-License-Identifier: Apache-2.0
  */
 
-package com.amazon.dataprepper.model.metric;
+package org.opensearch.dataprepper.model.metric;
 
-import com.amazon.dataprepper.model.event.Event;
+import org.opensearch.dataprepper.model.event.Event;
 
 import java.util.Map;