Merge pull request #726 from zalando/ARUHA-964-reformat-imports-vol2

ARUHA-964: reformated imports;
zalando · Aug 4, 2017 · 58cce1a · 58cce1a
2 parents 35f2545 + 2f795a6
commit 58cce1a
Show file tree

Hide file tree

Showing 45 changed files with 448 additions and 372 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -6,6 +6,9 @@ and this project adheres to [Semantic Versioning](http://semver.org/).
 
 ## [Unreleased]
 
+### Changed
+- Changed imports format to have the same structure
+
 ## [1.1.3] - 2017-08-03
 
 ### Fixed

diff --git a/src/acceptance-test/java/org/zalando/nakadi/repository/db/SchemaRepositoryTest.java b/src/acceptance-test/java/org/zalando/nakadi/repository/db/SchemaRepositoryTest.java
@@ -1,7 +1,6 @@
 package org.zalando.nakadi.repository.db;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
-import java.util.List;
 import org.joda.time.DateTime;
 import org.junit.Assert;
 import org.junit.Before;
@@ -12,6 +11,9 @@
 import org.zalando.nakadi.domain.Version;
 import org.zalando.nakadi.utils.EventTypeTestBuilder;
 import org.zalando.nakadi.utils.TestUtils;
+
+import java.util.List;
+
 import static org.zalando.nakadi.utils.TestUtils.randomUUID;
 
 public class SchemaRepositoryTest extends AbstractDbRepositoryTest {

diff --git a/src/acceptance-test/java/org/zalando/nakadi/repository/db/StorageDbRepositoryTest.java b/src/acceptance-test/java/org/zalando/nakadi/repository/db/StorageDbRepositoryTest.java
@@ -1,22 +1,24 @@
 package org.zalando.nakadi.repository.db;
 
+import org.junit.Before;
+import org.junit.Test;
+import org.zalando.nakadi.domain.EventType;
+import org.zalando.nakadi.domain.Storage;
+import org.zalando.nakadi.domain.Timeline;
+import org.zalando.nakadi.exceptions.runtime.NoStorageException;
+import org.zalando.nakadi.exceptions.runtime.StorageIsUsedException;
+import org.zalando.nakadi.utils.TestUtils;
+
 import java.util.Date;
 import java.util.List;
 import java.util.Optional;
 import java.util.UUID;
 import java.util.stream.Collectors;
+
 import static org.junit.Assert.assertEquals;
 import static org.junit.Assert.assertFalse;
 import static org.junit.Assert.assertNotSame;
 import static org.junit.Assert.assertTrue;
-import org.junit.Before;
-import org.junit.Test;
-import org.zalando.nakadi.domain.EventType;
-import org.zalando.nakadi.domain.Storage;
-import org.zalando.nakadi.domain.Timeline;
-import org.zalando.nakadi.exceptions.runtime.NoStorageException;
-import org.zalando.nakadi.exceptions.runtime.StorageIsUsedException;
-import org.zalando.nakadi.utils.TestUtils;
 import static org.zalando.nakadi.utils.TestUtils.randomUUID;
 import static org.zalando.nakadi.utils.TestUtils.randomValidStringOfLength;
 

diff --git a/src/acceptance-test/java/org/zalando/nakadi/repository/db/TimelineDbRepositoryTest.java b/src/acceptance-test/java/org/zalando/nakadi/repository/db/TimelineDbRepositoryTest.java
@@ -1,11 +1,5 @@
 package org.zalando.nakadi.repository.db;
 
-import java.util.Date;
-import java.util.List;
-import java.util.Optional;
-import java.util.UUID;
-import java.util.stream.Collectors;
-import java.util.stream.LongStream;
 import org.joda.time.DateTime;
 import org.junit.Assert;
 import org.junit.Before;
@@ -15,6 +9,14 @@
 import org.zalando.nakadi.domain.Timeline;
 import org.zalando.nakadi.exceptions.runtime.DuplicatedTimelineException;
 import org.zalando.nakadi.utils.TestUtils;
+
+import java.util.Date;
+import java.util.List;
+import java.util.Optional;
+import java.util.UUID;
+import java.util.stream.Collectors;
+import java.util.stream.LongStream;
+
 import static org.zalando.nakadi.utils.TestUtils.randomUUID;
 
 public class TimelineDbRepositoryTest extends AbstractDbRepositoryTest {

diff --git a/src/acceptance-test/java/org/zalando/nakadi/repository/kafka/KafkaRepositoryAT.java b/src/acceptance-test/java/org/zalando/nakadi/repository/kafka/KafkaRepositoryAT.java
@@ -1,29 +1,15 @@
 package org.zalando.nakadi.repository.kafka;
 
-import java.util.ArrayList;
-import java.util.List;
-import java.util.Map;
-import java.util.UUID;
 import org.apache.curator.CuratorZookeeperClient;
 import org.apache.curator.framework.CuratorFramework;
 import org.apache.kafka.clients.consumer.Consumer;
 import org.apache.kafka.clients.consumer.KafkaConsumer;
 import org.apache.kafka.common.PartitionInfo;
 import org.echocat.jomon.runtime.concurrent.RetryForSpecifiedTimeStrategy;
-import static org.echocat.jomon.runtime.concurrent.Retryer.executeWithRetry;
-import static org.hamcrest.MatcherAssert.assertThat;
-import static org.hamcrest.Matchers.arrayWithSize;
-import static org.hamcrest.Matchers.equalTo;
-import static org.hamcrest.Matchers.hasItem;
-import static org.hamcrest.Matchers.hasSize;
-import static org.hamcrest.Matchers.not;
 import org.junit.Assert;
 import org.junit.Before;
 import org.junit.Test;
-import static org.mockito.Matchers.any;
 import org.mockito.Mockito;
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.when;
 import org.zalando.nakadi.config.NakadiSettings;
 import org.zalando.nakadi.domain.BatchItem;
 import org.zalando.nakadi.domain.EventPublishingStatus;
@@ -33,6 +19,22 @@
 import org.zalando.nakadi.utils.TestUtils;
 import org.zalando.nakadi.webservice.BaseAT;
 
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Map;
+import java.util.UUID;
+
+import static org.echocat.jomon.runtime.concurrent.Retryer.executeWithRetry;
+import static org.hamcrest.MatcherAssert.assertThat;
+import static org.hamcrest.Matchers.arrayWithSize;
+import static org.hamcrest.Matchers.equalTo;
+import static org.hamcrest.Matchers.hasItem;
+import static org.hamcrest.Matchers.hasSize;
+import static org.hamcrest.Matchers.not;
+import static org.mockito.Matchers.any;
+import static org.mockito.Mockito.mock;
+import static org.mockito.Mockito.when;
+
 public class KafkaRepositoryAT extends BaseAT {
 
     private static final int DEFAULT_PARTITION_COUNT = 8;

diff --git a/src/acceptance-test/java/org/zalando/nakadi/webservice/BlockEventPublishingAT.java b/src/acceptance-test/java/org/zalando/nakadi/webservice/BlockEventPublishingAT.java
@@ -1,21 +1,23 @@
 package org.zalando.nakadi.webservice;
 
 import com.fasterxml.jackson.core.JsonProcessingException;
-import static com.jayway.restassured.RestAssured.given;
 import com.jayway.restassured.http.ContentType;
 import com.jayway.restassured.response.Response;
-import java.io.IOException;
-import java.text.MessageFormat;
 import org.apache.http.HttpStatus;
 import org.hamcrest.Matchers;
 import org.junit.Before;
 import org.junit.Test;
 import org.zalando.nakadi.domain.EventType;
 import org.zalando.nakadi.service.BlacklistService;
 import org.zalando.nakadi.utils.EventTypeTestBuilder;
-import static org.zalando.nakadi.utils.TestUtils.waitFor;
 import org.zalando.nakadi.webservice.utils.NakadiTestUtils;
 
+import java.io.IOException;
+import java.text.MessageFormat;
+
+import static com.jayway.restassured.RestAssured.given;
+import static org.zalando.nakadi.utils.TestUtils.waitFor;
+
 public class BlockEventPublishingAT extends BaseAT {
 
     private EventType eventType;

diff --git a/src/acceptance-test/java/org/zalando/nakadi/webservice/EventStreamReadingAT.java b/src/acceptance-test/java/org/zalando/nakadi/webservice/EventStreamReadingAT.java
@@ -4,13 +4,28 @@
 import com.fasterxml.jackson.core.type.TypeReference;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.common.collect.Sets;
-import static com.jayway.restassured.RestAssured.given;
 import com.jayway.restassured.response.Header;
 import com.jayway.restassured.response.Response;
+import org.hamcrest.Matchers;
+import org.junit.Before;
+import org.junit.BeforeClass;
+import org.junit.Ignore;
+import org.junit.Test;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.HttpStatus;
+import org.zalando.nakadi.domain.EventType;
+import org.zalando.nakadi.domain.EventTypeStatistics;
+import org.zalando.nakadi.exceptions.NoSuchEventTypeException;
+import org.zalando.nakadi.repository.kafka.KafkaTestHelper;
+import org.zalando.nakadi.service.BlacklistService;
+import org.zalando.nakadi.utils.EventTypeTestBuilder;
+import org.zalando.nakadi.utils.TestUtils;
+import org.zalando.nakadi.view.Cursor;
+import org.zalando.nakadi.webservice.utils.NakadiTestUtils;
+
 import java.io.IOException;
 import java.net.HttpURLConnection;
 import java.net.URL;
-import static java.text.MessageFormat.format;
 import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
@@ -22,28 +37,15 @@
 import java.util.concurrent.TimeoutException;
 import java.util.function.Predicate;
 import java.util.stream.Collectors;
+
+import static com.jayway.restassured.RestAssured.given;
+import static java.text.MessageFormat.format;
 import static java.util.stream.IntStream.range;
-import org.hamcrest.Matchers;
 import static org.hamcrest.Matchers.equalTo;
 import static org.hamcrest.Matchers.hasKey;
 import static org.hamcrest.Matchers.hasSize;
 import static org.junit.Assert.assertThat;
 import static org.junit.Assert.fail;
-import org.junit.Before;
-import org.junit.BeforeClass;
-import org.junit.Ignore;
-import org.junit.Test;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpStatus;
-import org.zalando.nakadi.domain.EventType;
-import org.zalando.nakadi.domain.EventTypeStatistics;
-import org.zalando.nakadi.exceptions.NoSuchEventTypeException;
-import org.zalando.nakadi.repository.kafka.KafkaTestHelper;
-import org.zalando.nakadi.service.BlacklistService;
-import org.zalando.nakadi.utils.EventTypeTestBuilder;
-import org.zalando.nakadi.utils.TestUtils;
-import org.zalando.nakadi.view.Cursor;
-import org.zalando.nakadi.webservice.utils.NakadiTestUtils;
 
 public class EventStreamReadingAT extends BaseAT {
 

diff --git a/src/acceptance-test/java/org/zalando/nakadi/webservice/EventTypeAT.java b/src/acceptance-test/java/org/zalando/nakadi/webservice/EventTypeAT.java
@@ -2,44 +2,46 @@
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.google.common.collect.ImmutableList;
-import static com.jayway.restassured.RestAssured.given;
-import static com.jayway.restassured.RestAssured.when;
-import static com.jayway.restassured.http.ContentType.JSON;
+import org.apache.http.HttpStatus;
+import org.joda.time.DateTime;
+import org.json.JSONObject;
+import org.junit.Assert;
+import org.junit.Test;
+import org.zalando.nakadi.domain.EventType;
+import org.zalando.nakadi.domain.EventTypeAuthorization;
+import org.zalando.nakadi.domain.EventTypeAuthorizationAttribute;
+import org.zalando.nakadi.domain.Timeline;
+import org.zalando.nakadi.exceptions.NoSuchEventTypeException;
+import org.zalando.nakadi.partitioning.PartitionStrategy;
+import org.zalando.nakadi.repository.kafka.KafkaTestHelper;
+import org.zalando.nakadi.utils.EventTypeTestBuilder;
+import org.zalando.nakadi.webservice.utils.NakadiTestUtils;
+import org.zalando.problem.MoreStatus;
+import org.zalando.problem.Problem;
+
 import java.io.IOException;
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
 import java.util.Set;
 import java.util.stream.Collectors;
 import java.util.stream.IntStream;
-import org.apache.http.HttpStatus;
+
+import static com.jayway.restassured.RestAssured.given;
+import static com.jayway.restassured.RestAssured.when;
+import static com.jayway.restassured.http.ContentType.JSON;
 import static org.hamcrest.CoreMatchers.is;
 import static org.hamcrest.MatcherAssert.assertThat;
 import static org.hamcrest.Matchers.containsString;
 import static org.hamcrest.Matchers.hasItem;
 import static org.hamcrest.Matchers.hasItems;
 import static org.hamcrest.Matchers.not;
 import static org.hamcrest.core.IsEqual.equalTo;
-import org.joda.time.DateTime;
-import org.json.JSONObject;
-import org.junit.Assert;
 import static org.junit.Assert.assertEquals;
-import org.junit.Test;
-import org.zalando.nakadi.domain.EventType;
-import org.zalando.nakadi.domain.EventTypeAuthorization;
-import org.zalando.nakadi.domain.EventTypeAuthorizationAttribute;
-import org.zalando.nakadi.domain.Timeline;
-import org.zalando.nakadi.exceptions.NoSuchEventTypeException;
-import org.zalando.nakadi.partitioning.PartitionStrategy;
-import org.zalando.nakadi.repository.kafka.KafkaTestHelper;
-import org.zalando.nakadi.utils.EventTypeTestBuilder;
 import static org.zalando.nakadi.utils.TestUtils.buildDefaultEventType;
 import static org.zalando.nakadi.utils.TestUtils.resourceAsString;
 import static org.zalando.nakadi.utils.TestUtils.waitFor;
-import org.zalando.nakadi.webservice.utils.NakadiTestUtils;
 import static org.zalando.nakadi.webservice.utils.NakadiTestUtils.publishEvent;
-import org.zalando.problem.MoreStatus;
-import org.zalando.problem.Problem;
 
 public class EventTypeAT extends BaseAT {
 

diff --git a/src/acceptance-test/java/org/zalando/nakadi/webservice/SettingsControllerAT.java b/src/acceptance-test/java/org/zalando/nakadi/webservice/SettingsControllerAT.java
@@ -2,12 +2,9 @@
 
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
-import static com.jayway.restassured.RestAssured.given;
 import com.jayway.restassured.http.ContentType;
-import java.io.IOException;
 import org.apache.curator.framework.CuratorFramework;
 import org.apache.http.HttpStatus;
-import static org.hamcrest.Matchers.hasItems;
 import org.junit.Assert;
 import org.junit.Test;
 import org.zalando.nakadi.config.JsonConfig;
@@ -17,6 +14,11 @@
 import org.zalando.nakadi.webservice.utils.NakadiTestUtils;
 import org.zalando.nakadi.webservice.utils.ZookeeperTestUtils;
 
+import java.io.IOException;
+
+import static com.jayway.restassured.RestAssured.given;
+import static org.hamcrest.Matchers.hasItems;
+
 public class SettingsControllerAT extends BaseAT {
 
     private static final String BLACKLIST_URL = "/settings/blacklist";

diff --git a/src/acceptance-test/java/org/zalando/nakadi/webservice/UserJourneyAT.java b/src/acceptance-test/java/org/zalando/nakadi/webservice/UserJourneyAT.java
@@ -6,43 +6,45 @@
 import com.google.common.collect.ImmutableMap;
 import com.google.common.io.Resources;
 import com.jayway.restassured.RestAssured;
-import static com.jayway.restassured.http.ContentType.JSON;
 import com.jayway.restassured.response.Header;
 import com.jayway.restassured.specification.RequestSpecification;
+import org.echocat.jomon.runtime.concurrent.RetryForSpecifiedTimeStrategy;
+import org.hamcrest.Matchers;
+import org.junit.Before;
+import org.junit.Test;
+import org.zalando.nakadi.config.JsonConfig;
+import org.zalando.nakadi.domain.EventType;
+import org.zalando.nakadi.domain.StreamMetadata;
+import org.zalando.nakadi.domain.Subscription;
+import org.zalando.nakadi.domain.SubscriptionBase;
+import org.zalando.nakadi.repository.kafka.KafkaCursor;
+import org.zalando.nakadi.utils.RandomSubscriptionBuilder;
+import org.zalando.nakadi.view.SubscriptionCursor;
+import org.zalando.nakadi.webservice.hila.StreamBatch;
+import org.zalando.nakadi.webservice.utils.TestStreamingClient;
+
 import java.io.IOException;
 import java.util.List;
 import java.util.stream.Collectors;
+
+import static com.jayway.restassured.http.ContentType.JSON;
 import static java.util.stream.IntStream.rangeClosed;
-import org.echocat.jomon.runtime.concurrent.RetryForSpecifiedTimeStrategy;
 import static org.echocat.jomon.runtime.concurrent.Retryer.executeWithRetry;
 import static org.hamcrest.MatcherAssert.assertThat;
-import org.hamcrest.Matchers;
 import static org.hamcrest.Matchers.hasSize;
 import static org.hamcrest.Matchers.notNullValue;
 import static org.hamcrest.core.IsEqual.equalTo;
-import org.junit.Before;
-import org.junit.Test;
 import static org.springframework.http.HttpStatus.CREATED;
 import static org.springframework.http.HttpStatus.NOT_FOUND;
 import static org.springframework.http.HttpStatus.NO_CONTENT;
 import static org.springframework.http.HttpStatus.OK;
-import org.zalando.nakadi.config.JsonConfig;
-import org.zalando.nakadi.domain.EventType;
-import org.zalando.nakadi.domain.StreamMetadata;
-import org.zalando.nakadi.domain.Subscription;
-import org.zalando.nakadi.domain.SubscriptionBase;
 import static org.zalando.nakadi.domain.SubscriptionBase.InitialPosition.BEGIN;
-import org.zalando.nakadi.repository.kafka.KafkaCursor;
-import org.zalando.nakadi.utils.RandomSubscriptionBuilder;
 import static org.zalando.nakadi.utils.TestUtils.randomTextString;
 import static org.zalando.nakadi.utils.TestUtils.randomValidEventTypeName;
 import static org.zalando.nakadi.utils.TestUtils.waitFor;
-import org.zalando.nakadi.view.SubscriptionCursor;
-import org.zalando.nakadi.webservice.hila.StreamBatch;
 import static org.zalando.nakadi.webservice.hila.StreamBatch.MatcherIgnoringToken.equalToBatchIgnoringToken;
 import static org.zalando.nakadi.webservice.utils.NakadiTestUtils.commitCursors;
 import static org.zalando.nakadi.webservice.utils.NakadiTestUtils.createSubscription;
-import org.zalando.nakadi.webservice.utils.TestStreamingClient;
 
 public class UserJourneyAT extends RealEnvironmentAT {