Updated internal lpackage name to implementation

sdk/cosmos/azure-cosmos-benchmark/src/main/java/com/azure/cosmos/benchmark/AsyncBenchmark.java

@@ -3,12 +3,12 @@
 
 package com.azure.cosmos.benchmark;
 
-import com.azure.cosmos.internal.AsyncDocumentClient;
+import com.azure.cosmos.implementation.AsyncDocumentClient;
 import com.azure.cosmos.BridgeInternal;
-import com.azure.cosmos.internal.Database;
-import com.azure.cosmos.internal.Document;
-import com.azure.cosmos.internal.DocumentCollection;
-import com.azure.cosmos.internal.ResourceResponse;
+import com.azure.cosmos.implementation.Database;
+import com.azure.cosmos.implementation.Document;
+import com.azure.cosmos.implementation.DocumentCollection;
+import com.azure.cosmos.implementation.ResourceResponse;
 import com.codahale.metrics.ConsoleReporter;
 import com.codahale.metrics.Meter;
 import com.codahale.metrics.MetricFilter;

sdk/cosmos/azure-cosmos-benchmark/src/main/java/com/azure/cosmos/benchmark/AsyncMixedBenchmark.java

@@ -4,11 +4,11 @@
 package com.azure.cosmos.benchmark;
 
 import com.azure.cosmos.BridgeInternal;
-import com.azure.cosmos.internal.Document;
+import com.azure.cosmos.implementation.Document;
 import com.azure.cosmos.FeedOptions;
 import com.azure.cosmos.PartitionKey;
-import com.azure.cosmos.internal.RequestOptions;
-import com.azure.cosmos.internal.ResourceResponse;
+import com.azure.cosmos.implementation.RequestOptions;
+import com.azure.cosmos.implementation.ResourceResponse;
 import org.apache.commons.lang3.RandomStringUtils;
 import reactor.core.publisher.BaseSubscriber;
 import reactor.core.publisher.Flux;

sdk/cosmos/azure-cosmos-benchmark/src/main/java/com/azure/cosmos/benchmark/AsyncQueryBenchmark.java

@@ -3,7 +3,7 @@
 
 package com.azure.cosmos.benchmark;
 
-import com.azure.cosmos.internal.Document;
+import com.azure.cosmos.implementation.Document;
 import com.azure.cosmos.FeedOptions;
 import com.azure.cosmos.FeedResponse;
 import com.azure.cosmos.PartitionKey;

sdk/cosmos/azure-cosmos-benchmark/src/main/java/com/azure/cosmos/benchmark/AsyncQuerySinglePartitionMultiple.java

@@ -3,7 +3,7 @@
 
 package com.azure.cosmos.benchmark;
 
-import com.azure.cosmos.internal.Document;
+import com.azure.cosmos.implementation.Document;
 import com.azure.cosmos.FeedOptions;
 import com.azure.cosmos.FeedResponse;
 import com.azure.cosmos.PartitionKey;

sdk/cosmos/azure-cosmos-benchmark/src/main/java/com/azure/cosmos/benchmark/AsyncReadBenchmark.java

@@ -3,10 +3,10 @@
 
 package com.azure.cosmos.benchmark;
 
-import com.azure.cosmos.internal.Document;
+import com.azure.cosmos.implementation.Document;
 import com.azure.cosmos.PartitionKey;
-import com.azure.cosmos.internal.RequestOptions;
-import com.azure.cosmos.internal.ResourceResponse;
+import com.azure.cosmos.implementation.RequestOptions;
+import com.azure.cosmos.implementation.ResourceResponse;
 import com.codahale.metrics.Timer;
 import org.reactivestreams.Subscription;
 import reactor.core.publisher.BaseSubscriber;

sdk/cosmos/azure-cosmos-benchmark/src/main/java/com/azure/cosmos/benchmark/AsyncWriteBenchmark.java

@@ -4,8 +4,8 @@
 package com.azure.cosmos.benchmark;
 
 import com.azure.cosmos.BridgeInternal;
-import com.azure.cosmos.internal.Document;
-import com.azure.cosmos.internal.ResourceResponse;
+import com.azure.cosmos.implementation.Document;
+import com.azure.cosmos.implementation.ResourceResponse;
 import com.codahale.metrics.Timer;
 import org.apache.commons.lang3.RandomStringUtils;
 import org.reactivestreams.Subscription;

sdk/cosmos/azure-cosmos-benchmark/src/main/java/com/azure/cosmos/benchmark/DocDBUtils.java

@@ -3,9 +3,9 @@
 
 package com.azure.cosmos.benchmark;
 
-import com.azure.cosmos.internal.AsyncDocumentClient;
-import com.azure.cosmos.internal.Database;
-import com.azure.cosmos.internal.DocumentCollection;
+import com.azure.cosmos.implementation.AsyncDocumentClient;
+import com.azure.cosmos.implementation.Database;
+import com.azure.cosmos.implementation.DocumentCollection;
 import com.azure.cosmos.FeedResponse;
 import com.azure.cosmos.SqlParameter;
 import com.azure.cosmos.SqlParameterList;

sdk/cosmos/azure-cosmos-benchmark/src/main/java/com/azure/cosmos/benchmark/ReadMyWriteWorkflow.java

@@ -4,16 +4,16 @@
 package com.azure.cosmos.benchmark;
 
 import com.azure.cosmos.BridgeInternal;
-import com.azure.cosmos.internal.Document;
+import com.azure.cosmos.implementation.Document;
 import com.azure.cosmos.FeedOptions;
 import com.azure.cosmos.NotFoundException;
 import com.azure.cosmos.PartitionKey;
 import com.azure.cosmos.SqlParameter;
 import com.azure.cosmos.SqlParameterList;
 import com.azure.cosmos.SqlQuerySpec;
-import com.azure.cosmos.internal.RequestOptions;
-import com.azure.cosmos.internal.ResourceResponse;
-import com.azure.cosmos.internal.Utils;
+import com.azure.cosmos.implementation.RequestOptions;
+import com.azure.cosmos.implementation.ResourceResponse;
+import com.azure.cosmos.implementation.Utils;
 import org.apache.commons.lang3.RandomUtils;
 import reactor.core.publisher.BaseSubscriber;
 import reactor.core.publisher.Flux;

sdk/cosmos/azure-cosmos-benchmark/src/main/resources/log4j.properties

@@ -4,20 +4,20 @@ log4j.rootLogger=INFO, Console
 
 log4j.category.com.azure.cosmos=INFO
 log4j.category.com.azure.cosmos.benchmark=INFO
-log4j.category.com.azure.cosmos.internal=INFO
-log4j.category.com.aure.cosmos.internal.caches=INFO
-log4j.category.com.aure.cosmos.internal.changefeed=INFO
-log4j.category.com.azure.cosmos.internal.directconnectivity=INFO
-log4j.category.com.azure.cosmos.internal.directconnectivity.rntbd=INFO
-log4j.category.com.azure.cosmos.internal.http=INFO
-log4j.category.com.azure.cosmos.internal.query=INFO
-log4j.category.com.azure.cosmos.internal.query.aggregation=INFO
-log4j.category.com.azure.cosmos.internal.query.metrics=INFO
-log4j.category.com.azure.cosmos.internal.query.orderbyquery=INFO
-log4j.category.com.azure.cosmos.internal.routing=INFO
+log4j.category.com.azure.cosmos.implementation=INFO
+log4j.category.com.azure.cosmos.implementation.caches=INFO
+log4j.category.com.azure.cosmos.implementation.changefeed=INFO
+log4j.category.com.azure.cosmos.implementation.directconnectivity=INFO
+log4j.category.com.azure.cosmos.implementation.directconnectivity.rntbd=INFO
+log4j.category.com.azure.cosmos.implementation.http=INFO
+log4j.category.com.azure.cosmos.implementation.query=INFO
+log4j.category.com.azure.cosmos.implementation.query.aggregation=INFO
+log4j.category.com.azure.cosmos.implementation.query.metrics=INFO
+log4j.category.com.azure.cosmos.implementation.query.orderbyquery=INFO
+log4j.category.com.azure.cosmos.implementation.routing=INFO
 
-log4j.category.com.azure.cosmos.internal.directconnectivity.RntbdTransportClient=INFO
-log4j.category.com.azure.cosmos.internal.directconnectivity.rntbd.RntbdRequestManager=INFO
+log4j.category.com.azure.cosmos.implementation.directconnectivity.RntbdTransportClient=INFO
+log4j.category.com.azure.cosmos.implementation.directconnectivity.rntbd.RntbdRequestManager=INFO
 
 log4j.appender.Console=org.apache.log4j.ConsoleAppender
 log4j.appender.Console.layout=org.apache.log4j.PatternLayout

sdk/cosmos/azure-cosmos-benchmark/src/test/java/com/azure/cosmos/benchmark/ReadMyWritesConsistencyTest.java

@@ -9,11 +9,11 @@
 import com.azure.cosmos.Index;
 import com.azure.cosmos.IndexingPolicy;
 import com.azure.cosmos.PartitionKeyDefinition;
-import com.azure.cosmos.internal.AsyncDocumentClient;
-import com.azure.cosmos.internal.Database;
-import com.azure.cosmos.internal.DocumentCollection;
-import com.azure.cosmos.internal.RequestOptions;
-import com.azure.cosmos.internal.TestConfigurations;
+import com.azure.cosmos.implementation.AsyncDocumentClient;
+import com.azure.cosmos.implementation.Database;
+import com.azure.cosmos.implementation.DocumentCollection;
+import com.azure.cosmos.implementation.RequestOptions;
+import com.azure.cosmos.implementation.TestConfigurations;
 import com.beust.jcommander.JCommander;
 import com.google.common.base.CaseFormat;
 import com.google.common.base.Strings;

sdk/cosmos/azure-cosmos-benchmark/src/test/java/com/azure/cosmos/benchmark/Utils.java

@@ -3,16 +3,16 @@
 
 package com.azure.cosmos.benchmark;
 
-import com.azure.cosmos.internal.AsyncDocumentClient;
+import com.azure.cosmos.implementation.AsyncDocumentClient;
 import com.azure.cosmos.ConnectionPolicy;
-import com.azure.cosmos.internal.Database;
-import com.azure.cosmos.internal.DatabaseForTest;
-import com.azure.cosmos.internal.DocumentCollection;
+import com.azure.cosmos.implementation.Database;
+import com.azure.cosmos.implementation.DatabaseForTest;
+import com.azure.cosmos.implementation.DocumentCollection;
 import com.azure.cosmos.FeedResponse;
-import com.azure.cosmos.internal.ResourceResponse;
+import com.azure.cosmos.implementation.ResourceResponse;
 import com.azure.cosmos.RetryOptions;
 import com.azure.cosmos.SqlQuerySpec;
-import com.azure.cosmos.internal.TestConfigurations;
+import com.azure.cosmos.implementation.TestConfigurations;
 import reactor.core.publisher.Flux;
 
 public class Utils {

sdk/cosmos/azure-cosmos-benchmark/src/test/java/com/azure/cosmos/benchmark/WorkflowTest.java

@@ -3,17 +3,17 @@
 
 package com.azure.cosmos.benchmark;
 
-import com.azure.cosmos.internal.AsyncDocumentClient;
+import com.azure.cosmos.implementation.AsyncDocumentClient;
 import com.azure.cosmos.BridgeInternal;
 import com.azure.cosmos.DataType;
-import com.azure.cosmos.internal.Database;
-import com.azure.cosmos.internal.DocumentCollection;
+import com.azure.cosmos.implementation.Database;
+import com.azure.cosmos.implementation.DocumentCollection;
 import com.azure.cosmos.IncludedPath;
 import com.azure.cosmos.Index;
 import com.azure.cosmos.IndexingPolicy;
 import com.azure.cosmos.PartitionKeyDefinition;
-import com.azure.cosmos.internal.RequestOptions;
-import com.azure.cosmos.internal.TestConfigurations;
+import com.azure.cosmos.implementation.RequestOptions;
+import com.azure.cosmos.implementation.TestConfigurations;
 import com.beust.jcommander.JCommander;
 import org.apache.commons.lang3.StringUtils;
 import org.testng.annotations.AfterClass;

sdk/cosmos/azure-cosmos-examples/src/main/java/com/azure/cosmos/rx/examples/multimaster/Helpers.java

@@ -3,11 +3,11 @@
 
 package com.azure.cosmos.rx.examples.multimaster;
 
-import com.azure.cosmos.internal.AsyncDocumentClient;
+import com.azure.cosmos.implementation.AsyncDocumentClient;
 import com.azure.cosmos.CosmosClientException;
-import com.azure.cosmos.internal.Database;
-import com.azure.cosmos.internal.DocumentCollection;
-import com.azure.cosmos.internal.ResourceResponse;
+import com.azure.cosmos.implementation.Database;
+import com.azure.cosmos.implementation.DocumentCollection;
+import com.azure.cosmos.implementation.ResourceResponse;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 

sdk/cosmos/azure-cosmos-examples/src/main/java/com/azure/cosmos/rx/examples/multimaster/samples/ConflictWorker.java

@@ -5,18 +5,18 @@
 
 import com.azure.cosmos.AccessCondition;
 import com.azure.cosmos.AccessConditionType;
-import com.azure.cosmos.internal.AsyncDocumentClient;
+import com.azure.cosmos.implementation.AsyncDocumentClient;
 import com.azure.cosmos.BridgeInternal;
-import com.azure.cosmos.internal.Conflict;
+import com.azure.cosmos.implementation.Conflict;
 import com.azure.cosmos.ConflictResolutionPolicy;
 import com.azure.cosmos.CosmosClientException;
-import com.azure.cosmos.internal.Document;
-import com.azure.cosmos.internal.DocumentCollection;
+import com.azure.cosmos.implementation.Document;
+import com.azure.cosmos.implementation.DocumentCollection;
 import com.azure.cosmos.FeedResponse;
 import com.azure.cosmos.Resource;
-import com.azure.cosmos.internal.RequestOptions;
-import com.azure.cosmos.internal.ResourceResponse;
-import com.azure.cosmos.internal.StoredProcedure;
+import com.azure.cosmos.implementation.RequestOptions;
+import com.azure.cosmos.implementation.ResourceResponse;
+import com.azure.cosmos.implementation.StoredProcedure;
 import com.azure.cosmos.rx.examples.multimaster.Helpers;
 import org.apache.commons.io.IOUtils;
 import org.apache.commons.lang3.StringUtils;

sdk/cosmos/azure-cosmos-examples/src/main/java/com/azure/cosmos/rx/examples/multimaster/samples/MultiMasterScenario.java

@@ -3,7 +3,7 @@
 
 package com.azure.cosmos.rx.examples.multimaster.samples;
 
-import com.azure.cosmos.internal.AsyncDocumentClient;
+import com.azure.cosmos.implementation.AsyncDocumentClient;
 import com.azure.cosmos.ConnectionPolicy;
 import com.azure.cosmos.ConsistencyLevel;
 import com.azure.cosmos.rx.examples.multimaster.ConfigurationManager;

sdk/cosmos/azure-cosmos-examples/src/main/java/com/azure/cosmos/rx/examples/multimaster/samples/Worker.java

@@ -4,9 +4,9 @@
 package com.azure.cosmos.rx.examples.multimaster.samples;
 
 
-import com.azure.cosmos.internal.AsyncDocumentClient;
+import com.azure.cosmos.implementation.AsyncDocumentClient;
 import com.azure.cosmos.CosmosClientException;
-import com.azure.cosmos.internal.Document;
+import com.azure.cosmos.implementation.Document;
 import com.azure.cosmos.FeedOptions;
 import com.azure.cosmos.FeedResponse;
 import org.slf4j.Logger;

sdk/cosmos/azure-cosmos-examples/src/test/java/com/azure/cosmos/DocumentClientTest.java

@@ -3,7 +3,7 @@
 
 package com.azure.cosmos;
 
-import com.azure.cosmos.internal.AsyncDocumentClient;
+import com.azure.cosmos.implementation.AsyncDocumentClient;
 import com.google.common.base.Strings;
 import org.testng.ITest;
 import org.testng.annotations.AfterMethod;

sdk/cosmos/azure-cosmos-examples/src/test/java/com/azure/cosmos/rx/examples/CollectionCRUDAsyncAPITest.java

@@ -2,23 +2,23 @@
 // Licensed under the MIT License.
 package com.azure.cosmos.rx.examples;
 
-import com.azure.cosmos.internal.AsyncDocumentClient;
+import com.azure.cosmos.implementation.AsyncDocumentClient;
 import com.azure.cosmos.BridgeInternal;
 import com.azure.cosmos.ConnectionMode;
 import com.azure.cosmos.ConnectionPolicy;
 import com.azure.cosmos.ConsistencyLevel;
 import com.azure.cosmos.CosmosClientException;
 import com.azure.cosmos.DataType;
-import com.azure.cosmos.internal.Database;
+import com.azure.cosmos.implementation.Database;
 import com.azure.cosmos.DocumentClientTest;
-import com.azure.cosmos.internal.DocumentCollection;
+import com.azure.cosmos.implementation.DocumentCollection;
 import com.azure.cosmos.FeedResponse;
 import com.azure.cosmos.IncludedPath;
 import com.azure.cosmos.Index;
 import com.azure.cosmos.IndexingPolicy;
 import com.azure.cosmos.PartitionKeyDefinition;
-import com.azure.cosmos.internal.RequestOptions;
-import com.azure.cosmos.internal.ResourceResponse;
+import com.azure.cosmos.implementation.RequestOptions;
+import com.azure.cosmos.implementation.ResourceResponse;
 import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.BeforeMethod;

sdk/cosmos/azure-cosmos-examples/src/test/java/com/azure/cosmos/rx/examples/ConflictAPITest.java

@@ -2,19 +2,19 @@
 // Licensed under the MIT License.
 package com.azure.cosmos.rx.examples;
 
-import com.azure.cosmos.internal.AsyncDocumentClient;
-import com.azure.cosmos.internal.Conflict;
+import com.azure.cosmos.implementation.AsyncDocumentClient;
+import com.azure.cosmos.implementation.Conflict;
 import com.azure.cosmos.ConnectionMode;
 import com.azure.cosmos.ConnectionPolicy;
 import com.azure.cosmos.ConsistencyLevel;
-import com.azure.cosmos.internal.Database;
-import com.azure.cosmos.internal.Document;
+import com.azure.cosmos.implementation.Database;
+import com.azure.cosmos.implementation.Document;
 import com.azure.cosmos.DocumentClientTest;
-import com.azure.cosmos.internal.DocumentCollection;
+import com.azure.cosmos.implementation.DocumentCollection;
 import com.azure.cosmos.FeedOptions;
 import com.azure.cosmos.FeedResponse;
 import com.azure.cosmos.PartitionKeyDefinition;
-import com.azure.cosmos.internal.HttpConstants;
+import com.azure.cosmos.implementation.HttpConstants;
 import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Ignore;

sdk/cosmos/azure-cosmos-examples/src/test/java/com/azure/cosmos/rx/examples/DatabaseCRUDAsyncAPITest.java

@@ -2,15 +2,15 @@
 // Licensed under the MIT License.
 package com.azure.cosmos.rx.examples;
 
-import com.azure.cosmos.internal.AsyncDocumentClient;
+import com.azure.cosmos.implementation.AsyncDocumentClient;
 import com.azure.cosmos.ConnectionMode;
 import com.azure.cosmos.ConnectionPolicy;
 import com.azure.cosmos.ConsistencyLevel;
 import com.azure.cosmos.CosmosClientException;
-import com.azure.cosmos.internal.Database;
+import com.azure.cosmos.implementation.Database;
 import com.azure.cosmos.DocumentClientTest;
 import com.azure.cosmos.FeedResponse;
-import com.azure.cosmos.internal.ResourceResponse;
+import com.azure.cosmos.implementation.ResourceResponse;
 import org.testng.annotations.AfterClass;
 import org.testng.annotations.BeforeClass;
 import org.testng.annotations.Test;

sdk/cosmos/azure-cosmos-examples/src/test/java/com/azure/cosmos/rx/examples/DocumentCRUDAsyncAPITest.java

@@ -3,22 +3,21 @@
 package com.azure.cosmos.rx.examples;
 
 import com.azure.cosmos.DocumentClientTest;
-import com.azure.cosmos.internal.AsyncDocumentClient;
+import com.azure.cosmos.implementation.AsyncDocumentClient;
 import com.azure.cosmos.BridgeInternal;
 import com.azure.cosmos.ConnectionMode;
 import com.azure.cosmos.ConnectionPolicy;
 import com.azure.cosmos.ConsistencyLevel;
 import com.azure.cosmos.CosmosClientException;
-import com.azure.cosmos.internal.Database;
-import com.azure.cosmos.internal.Document;
-import com.azure.cosmos.DocumentClientTest;
-import com.azure.cosmos.internal.DocumentCollection;
+import com.azure.cosmos.implementation.Database;
+import com.azure.cosmos.implementation.Document;
+import com.azure.cosmos.implementation.DocumentCollection;
 import com.azure.cosmos.FeedOptions;
 import com.azure.cosmos.FeedResponse;
 import com.azure.cosmos.PartitionKey;
 import com.azure.cosmos.PartitionKeyDefinition;
-import com.azure.cosmos.internal.RequestOptions;
-import com.azure.cosmos.internal.ResourceResponse;
+import com.azure.cosmos.implementation.RequestOptions;
+import com.azure.cosmos.implementation.ResourceResponse;
 import com.fasterxml.jackson.annotation.JsonProperty;
 import com.fasterxml.jackson.core.JsonParser;
 import com.fasterxml.jackson.databind.DeserializationFeature;