aurora-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ma...@apache.org
Subject [2/4] Moving @Override to a separate line to comply with IntelliJ editor.
Date Wed, 05 Feb 2014 02:10:29 GMT
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/log/SnapshotStoreImpl.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/log/SnapshotStoreImpl.java b/src/main/java/org/apache/aurora/scheduler/storage/log/SnapshotStoreImpl.java
index 4342932..cb0ba50 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/log/SnapshotStoreImpl.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/log/SnapshotStoreImpl.java
@@ -59,11 +59,13 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
   private static final Logger LOG = Logger.getLogger(SnapshotStoreImpl.class.getName());
 
   private static final SnapshotField ATTRIBUTE_FIELD = new SnapshotField() {
-    @Override public void saveToSnapshot(StoreProvider storeProvider, Snapshot snapshot) {
+    @Override
+    public void saveToSnapshot(StoreProvider storeProvider, Snapshot snapshot) {
       snapshot.setHostAttributes(storeProvider.getAttributeStore().getHostAttributes());
     }
 
-    @Override public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
+    @Override
+    public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
       store.getAttributeStore().deleteHostAttributes();
 
       if (snapshot.isSetHostAttributes()) {
@@ -77,12 +79,14 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
   private static final Iterable<SnapshotField> SNAPSHOT_FIELDS = Arrays.asList(
       ATTRIBUTE_FIELD,
       new SnapshotField() {
-        @Override public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
+        @Override
+        public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
           snapshot.setTasks(
               IScheduledTask.toBuildersSet(store.getTaskStore().fetchTasks(Query.unscoped())));
         }
 
-        @Override public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
+        @Override
+        public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
           store.getUnsafeTaskStore().deleteAllTasks();
 
           if (snapshot.isSetTasks()) {
@@ -92,7 +96,8 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
         }
       },
       new SnapshotField() {
-        @Override public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
+        @Override
+        public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
           ImmutableSet.Builder<StoredJob> jobs = ImmutableSet.builder();
           for (String managerId : store.getJobStore().fetchManagerIds()) {
             for (IJobConfiguration config : store.getJobStore().fetchJobs(managerId)) {
@@ -102,7 +107,8 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
           snapshot.setJobs(jobs.build());
         }
 
-        @Override public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
+        @Override
+        public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
           store.getJobStore().deleteJobs();
 
           if (snapshot.isSetJobs()) {
@@ -115,7 +121,8 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
         }
       },
       new SnapshotField() {
-        @Override public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
+        @Override
+        public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
           Properties props = new BuildInfo().getProperties();
 
           snapshot.setSchedulerMetadata(
@@ -129,7 +136,8 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
                   .setVersion(CURRENT_API_VERSION));
         }
 
-        @Override public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
+        @Override
+        public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
           if (snapshot.isSetSchedulerMetadata()) {
             // No delete necessary here since this is a single value.
 
@@ -139,7 +147,8 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
         }
       },
       new SnapshotField() {
-        @Override public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
+        @Override
+        public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
           ImmutableSet.Builder<QuotaConfiguration> quotas = ImmutableSet.builder();
           for (Map.Entry<String, IQuota> entry : store.getQuotaStore().fetchQuotas().entrySet()) {
             quotas.add(new QuotaConfiguration(entry.getKey(), entry.getValue().newBuilder()));
@@ -148,7 +157,8 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
           snapshot.setQuotaConfigurations(quotas.build());
         }
 
-        @Override public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
+        @Override
+        public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
           store.getQuotaStore().deleteQuotas();
 
           if (snapshot.isSetQuotaConfigurations()) {
@@ -159,11 +169,13 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
         }
       },
       new SnapshotField() {
-        @Override public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
+        @Override
+        public void saveToSnapshot(StoreProvider store, Snapshot snapshot) {
           snapshot.setLocks(ILock.toBuildersSet(store.getLockStore().fetchLocks()));
         }
 
-        @Override public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
+        @Override
+        public void restoreFromSnapshot(MutableStoreProvider store, Snapshot snapshot) {
           store.getLockStore().deleteLocks();
 
           if (snapshot.isSetLocks()) {
@@ -185,9 +197,11 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
   }
 
   @Timed("snapshot_create")
-  @Override public Snapshot createSnapshot() {
+  @Override
+  public Snapshot createSnapshot() {
     return storage.consistentRead(new Work.Quiet<Snapshot>() {
-      @Override public Snapshot apply(StoreProvider storeProvider) {
+      @Override
+      public Snapshot apply(StoreProvider storeProvider) {
         Snapshot snapshot = new Snapshot();
 
         // Capture timestamp to signify the beginning of a snapshot operation, apply after in case
@@ -203,11 +217,13 @@ public class SnapshotStoreImpl implements SnapshotStore<Snapshot> {
   }
 
   @Timed("snapshot_apply")
-  @Override public void applySnapshot(final Snapshot snapshot) {
+  @Override
+  public void applySnapshot(final Snapshot snapshot) {
     checkNotNull(snapshot);
 
     storage.write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         LOG.info("Restoring snapshot.");
 
         for (SnapshotField field : SNAPSHOT_FIELDS) {

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemJobStore.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemJobStore.java b/src/main/java/org/apache/aurora/scheduler/storage/mem/MemJobStore.java
index 0419b45..c3a93d1 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemJobStore.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/mem/MemJobStore.java
@@ -41,7 +41,8 @@ class MemJobStore implements JobStore.Mutable {
 
   private final LoadingCache<String, Manager> managers = CacheBuilder.newBuilder()
       .build(new CacheLoader<String, Manager>() {
-        @Override public Manager load(String key) {
+        @Override
+        public Manager load(String key) {
           return new Manager();
         }
       });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemStorage.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemStorage.java b/src/main/java/org/apache/aurora/scheduler/storage/mem/MemStorage.java
index 0769b68..30d77cc 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemStorage.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/mem/MemStorage.java
@@ -62,37 +62,45 @@ public class MemStorage implements Storage {
       final AttributeStore.Mutable attributeStore) {
 
     storeProvider = new MutableStoreProvider() {
-      @Override public SchedulerStore.Mutable getSchedulerStore() {
+      @Override
+      public SchedulerStore.Mutable getSchedulerStore() {
         return schedulerStore;
       }
 
-      @Override public JobStore.Mutable getJobStore() {
+      @Override
+      public JobStore.Mutable getJobStore() {
         return jobStore;
       }
 
-      @Override public TaskStore getTaskStore() {
+      @Override
+      public TaskStore getTaskStore() {
         return taskStore;
       }
 
-      @Override public TaskStore.Mutable getUnsafeTaskStore() {
+      @Override
+      public TaskStore.Mutable getUnsafeTaskStore() {
         return taskStore;
       }
 
-      @Override public LockStore.Mutable getLockStore() {
+      @Override
+      public LockStore.Mutable getLockStore() {
         return lockStore;
       }
 
-      @Override public QuotaStore.Mutable getQuotaStore() {
+      @Override
+      public QuotaStore.Mutable getQuotaStore() {
         return quotaStore;
       }
 
-      @Override public AttributeStore.Mutable getAttributeStore() {
+      @Override
+      public AttributeStore.Mutable getAttributeStore() {
         return attributeStore;
       }
     };
 
     Stats.export(new StatImpl<Integer>("storage_lock_threads_waiting") {
-      @Override public Integer read() {
+      @Override
+      public Integer read() {
         return lockManager.getQueueLength();
       }
     });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemTaskStore.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemTaskStore.java b/src/main/java/org/apache/aurora/scheduler/storage/mem/MemTaskStore.java
index 796fd75..d1ab503 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/mem/MemTaskStore.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/mem/MemTaskStore.java
@@ -74,13 +74,15 @@ class MemTaskStore implements TaskStore.Mutable {
 
   private static final Function<Query.Builder, Optional<IJobKey>> QUERY_TO_JOB_KEY =
       new Function<Query.Builder, Optional<IJobKey>>() {
-        @Override public Optional<IJobKey> apply(Query.Builder query) {
+        @Override
+        public Optional<IJobKey> apply(Query.Builder query) {
           return JobKeys.from(query);
         }
       };
   private static final Function<Query.Builder, Optional<String>> QUERY_TO_SLAVE_HOST =
       new Function<Query.Builder, Optional<String>>() {
-        @Override public Optional<String> apply(Query.Builder query) {
+        @Override
+        public Optional<String> apply(Query.Builder query) {
           return Optional.fromNullable(query.get().getSlaveHost());
         }
       };
@@ -132,7 +134,8 @@ class MemTaskStore implements TaskStore.Mutable {
 
   private final Function<IScheduledTask, Task> toTask =
       new Function<IScheduledTask, Task>() {
-        @Override public Task apply(IScheduledTask task) {
+        @Override
+        public Task apply(IScheduledTask task) {
           return new Task(task, configInterner);
         }
       };
@@ -224,7 +227,8 @@ class MemTaskStore implements TaskStore.Mutable {
 
   private static Predicate<Task> queryFilter(final TaskQuery query) {
     return new Predicate<Task>() {
-      @Override public boolean apply(Task canonicalTask) {
+      @Override
+      public boolean apply(Task canonicalTask) {
         IScheduledTask task = canonicalTask.task;
         ITaskConfig config = task.getAssignedTask().getTask();
         if (query.getOwner() != null) {
@@ -314,7 +318,8 @@ class MemTaskStore implements TaskStore.Mutable {
 
   private static final Function<Task, IScheduledTask> TO_SCHEDULED =
       new Function<Task, IScheduledTask>() {
-        @Override public IScheduledTask apply(Task task) {
+        @Override
+        public IScheduledTask apply(Task task) {
           return task.task;
         }
       };
@@ -412,7 +417,8 @@ class MemTaskStore implements TaskStore.Mutable {
     }
 
     private final Function<K, Iterable<String>> lookup = new Function<K, Iterable<String>>() {
-      @Override public Iterable<String> apply(K key) {
+      @Override
+      public Iterable<String> apply(K key) {
         hitCount.incrementAndGet();
         return index.get(key);
       }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/mem/Util.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/mem/Util.java b/src/main/java/org/apache/aurora/scheduler/storage/mem/Util.java
index 2d9941c..9cfb878 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/mem/Util.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/mem/Util.java
@@ -39,7 +39,8 @@ final class Util {
    */
   static <T extends TBase<T, ?>> Function<T, T> deepCopier() {
     return new Function<T, T>() {
-      @Override public T apply(@Nullable T input) {
+      @Override
+      public T apply(@Nullable T input) {
         if (input == null) {
           return null;
         }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/testing/StorageTestUtil.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/testing/StorageTestUtil.java b/src/main/java/org/apache/aurora/scheduler/storage/testing/StorageTestUtil.java
index 6f71fe2..005bad2 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/testing/StorageTestUtil.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/testing/StorageTestUtil.java
@@ -77,7 +77,8 @@ public class StorageTestUtil {
   private <T> IExpectationSetters<T> expectConsistentRead() {
     final Capture<Work<T, RuntimeException>> work = EasyMockTest.createCapture();
     return expect(storage.consistentRead(capture(work))).andAnswer(new IAnswer<T>() {
-      @Override public T answer() {
+      @Override
+      public T answer() {
         return work.getValue().apply(storeProvider);
       }
     });
@@ -86,7 +87,8 @@ public class StorageTestUtil {
   private <T> IExpectationSetters<T> expectWeaklyConsistentRead() {
     final Capture<Work<T, RuntimeException>> work = EasyMockTest.createCapture();
     return expect(storage.weaklyConsistentRead(capture(work))).andAnswer(new IAnswer<T>() {
-      @Override public T answer() {
+      @Override
+      public T answer() {
         return work.getValue().apply(storeProvider);
       }
     });
@@ -95,7 +97,8 @@ public class StorageTestUtil {
   private <T> IExpectationSetters<T> expectWriteOperation() {
     final Capture<MutateWork<T, RuntimeException>> work = EasyMockTest.createCapture();
     return expect(storage.write(capture(work))).andAnswer(new IAnswer<T>() {
-      @Override public T answer() {
+      @Override
+      public T answer() {
         return work.getValue().apply(mutableStoreProvider);
       }
     });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterface.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterface.java b/src/main/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterface.java
index 479c2d9..a03627d 100644
--- a/src/main/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterface.java
+++ b/src/main/java/org/apache/aurora/scheduler/thrift/SchedulerThriftInterface.java
@@ -157,7 +157,8 @@ class SchedulerThriftInterface implements AuroraAdmin.Iface {
 
   private static final Function<IScheduledTask, String> GET_ROLE = Functions.compose(
       new Function<ITaskConfig, String>() {
-        @Override public String apply(ITaskConfig task) {
+        @Override
+        public String apply(ITaskConfig task) {
           return task.getOwner().getRole();
         }
       },
@@ -542,7 +543,8 @@ class SchedulerThriftInterface implements AuroraAdmin.Iface {
     final Query.Builder activeQuery = Query.arbitrary(query.setStatuses(Tasks.ACTIVE_STATES));
     try {
       backoff.doUntilSuccess(new Supplier<Boolean>() {
-        @Override public Boolean get() {
+        @Override
+        public Boolean get() {
           Set<IScheduledTask> tasks = Storage.Util.consistentFetchTasks(storage, activeQuery);
           if (tasks.isEmpty()) {
             LOG.info("Tasks all killed, done waiting.");
@@ -792,7 +794,8 @@ class SchedulerThriftInterface implements AuroraAdmin.Iface {
     }
 
     return storage.write(new MutateWork.Quiet<Response>() {
-      @Override public Response apply(MutableStoreProvider storeProvider) {
+      @Override
+      public Response apply(MutableStoreProvider storeProvider) {
         List<String> errors = Lists.newArrayList();
 
         for (ConfigRewrite command : request.getRewriteCommands()) {

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServer.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServer.java b/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServer.java
index 3cc872f..5b55e94 100644
--- a/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServer.java
+++ b/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServer.java
@@ -60,7 +60,8 @@ class ThriftServer {
 
     Thread listeningThread = new ThreadFactoryBuilder().setDaemon(false).build()
         .newThread(new Runnable() {
-          @Override public void run() {
+          @Override
+          public void run() {
             try {
               starting.serve();
             } catch (Throwable t) {

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServerLauncher.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServerLauncher.java b/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServerLauncher.java
index 504ac69..bb93be3 100644
--- a/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServerLauncher.java
+++ b/src/main/java/org/apache/aurora/scheduler/thrift/ThriftServerLauncher.java
@@ -73,7 +73,8 @@ class ThriftServerLauncher implements ServiceRunner {
         new AuroraAdmin.Processor<>(schedulerThriftInterface));
 
     Command shutdown = new Command() {
-      @Override public void execute() {
+      @Override
+      public void execute() {
         LOG.info("Stopping thrift server.");
         schedulerThriftServer.shutdown();
       }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/thrift/aop/AopModule.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/thrift/aop/AopModule.java b/src/main/java/org/apache/aurora/scheduler/thrift/aop/AopModule.java
index 7c29094..c68977a 100644
--- a/src/main/java/org/apache/aurora/scheduler/thrift/aop/AopModule.java
+++ b/src/main/java/org/apache/aurora/scheduler/thrift/aop/AopModule.java
@@ -77,7 +77,8 @@ public class AopModule extends AbstractModule {
   }
 
   private static final Function<Method, String> GET_NAME = new Function<Method, String>() {
-    @Override public String apply(Method method) {
+    @Override
+    public String apply(Method method) {
       return method.getName();
     }
   };
@@ -104,7 +105,8 @@ public class AopModule extends AbstractModule {
         authInterceptor);
 
     install(new PrivateModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         // Ensure that the provided methods exist on the decorated interface.
         List<Method> methods =
             ImmutableList.copyOf(AuroraSchedulerManager.Iface.class.getMethods());

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/thrift/aop/LoggingInterceptor.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/thrift/aop/LoggingInterceptor.java b/src/main/java/org/apache/aurora/scheduler/thrift/aop/LoggingInterceptor.java
index e66a885..5f8143c 100644
--- a/src/main/java/org/apache/aurora/scheduler/thrift/aop/LoggingInterceptor.java
+++ b/src/main/java/org/apache/aurora/scheduler/thrift/aop/LoggingInterceptor.java
@@ -52,7 +52,8 @@ class LoggingInterceptor implements MethodInterceptor {
       ImmutableMap.<Class<?>, Function<Object, String>>of(
           JobConfiguration.class,
           new Function<Object, String>() {
-            @Override public String apply(Object input) {
+            @Override
+            public String apply(Object input) {
               JobConfiguration configuration = ((JobConfiguration) input).deepCopy();
               if (configuration.isSetTaskConfig()) {
                 configuration.getTaskConfig().setExecutorConfig(
@@ -63,7 +64,8 @@ class LoggingInterceptor implements MethodInterceptor {
           },
           SessionKey.class,
           new Function<Object, String>() {
-            @Override public String apply(Object input) {
+            @Override
+            public String apply(Object input) {
               SessionKey key = (SessionKey) input;
               return validator.toString(key);
             }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptor.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptor.java b/src/main/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptor.java
index 9f7e8bb..c2a613f 100644
--- a/src/main/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptor.java
+++ b/src/main/java/org/apache/aurora/scheduler/thrift/aop/ThriftStatsExporterInterceptor.java
@@ -33,7 +33,8 @@ class ThriftStatsExporterInterceptor implements MethodInterceptor {
 
   private final LoadingCache<Method, SlidingStats> stats =
       CacheBuilder.newBuilder().build(new CacheLoader<Method, SlidingStats>() {
-        @Override public SlidingStats load(Method method) {
+        @Override
+        public SlidingStats load(Method method) {
           return new SlidingStats(
               Stats.normalizeName(String.format("scheduler_thrift_%s", method.getName())),
               "nanos");

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/thrift/aop/UserCapabilityInterceptor.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/thrift/aop/UserCapabilityInterceptor.java b/src/main/java/org/apache/aurora/scheduler/thrift/aop/UserCapabilityInterceptor.java
index 8e6e52d..801e7ae 100644
--- a/src/main/java/org/apache/aurora/scheduler/thrift/aop/UserCapabilityInterceptor.java
+++ b/src/main/java/org/apache/aurora/scheduler/thrift/aop/UserCapabilityInterceptor.java
@@ -52,7 +52,8 @@ class UserCapabilityInterceptor implements MethodInterceptor {
   @Inject private CapabilityValidator capabilityValidator;
 
   private static final Function<Object, SessionKey> CAST = new Function<Object, SessionKey>() {
-    @Override public SessionKey apply(Object o) {
+    @Override
+    public SessionKey apply(Object o) {
       return (SessionKey) o;
     }
   };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/GuiceUtilsTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/GuiceUtilsTest.java b/src/test/java/org/apache/aurora/GuiceUtilsTest.java
index 45d527c..5186008 100644
--- a/src/test/java/org/apache/aurora/GuiceUtilsTest.java
+++ b/src/test/java/org/apache/aurora/GuiceUtilsTest.java
@@ -65,7 +65,8 @@ public class GuiceUtilsTest {
       throw new RuntimeException("Call failed");
     }
 
-    @Override public void get() {
+    @Override
+    public void get() {
       throw new RuntimeException("Call failed");
     }
   }
@@ -73,7 +74,8 @@ public class GuiceUtilsTest {
   @Test
   public void testExceptionTrapping() {
     Injector injector = Guice.createInjector(new AbstractModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         GuiceUtils.bindExceptionTrap(binder(), Flaky.class);
         bind(Flaky.class).to(NotSoFlakyImpl.class);
         bind(AlsoFlaky.class).to(NotSoFlakyImpl.class);
@@ -114,7 +116,8 @@ public class GuiceUtilsTest {
   @Test(expected = CreationException.class)
   public void testNoTrappingNonVoidMethods() {
     Guice.createInjector(new AbstractModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         GuiceUtils.bindExceptionTrap(binder(), NonVoid.class);
         fail("Bind should have failed.");
       }
@@ -129,7 +132,8 @@ public class GuiceUtilsTest {
   @Test
   public void testWhitelistNonVoidMethods() {
     Guice.createInjector(new AbstractModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         GuiceUtils.bindExceptionTrap(binder(), NonVoidWhitelisted.class);
       }
     });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/MesosSchedulerImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/MesosSchedulerImplTest.java b/src/test/java/org/apache/aurora/scheduler/MesosSchedulerImplTest.java
index fd4d5d5..92c77d5 100644
--- a/src/test/java/org/apache/aurora/scheduler/MesosSchedulerImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/MesosSchedulerImplTest.java
@@ -120,7 +120,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
     eventSink = createMock(EventSink.class);
 
     Injector injector = Guice.createInjector(new AbstractModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         bind(Storage.class).toInstance(storageUtil.storage);
         bind(SchedulerCore.class).toInstance(createMock(SchedulerCore.class));
         bind(Lifecycle.class).toInstance(lifecycle);
@@ -144,7 +145,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
   @Test
   public void testNoOffers() throws Exception {
     new RegisteredFixture() {
-      @Override void test() {
+      @Override
+      void test() {
         scheduler.resourceOffers(driver, ImmutableList.<Offer>of());
       }
     }.run();
@@ -153,7 +155,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
   @Test
   public void testNoAccepts() throws Exception {
     new OfferFixture() {
-      @Override void respondToOffer() throws Exception {
+      @Override
+      void respondToOffer() throws Exception {
         expectOfferAttributesSaved(OFFER);
         expect(systemLauncher.createTask(OFFER)).andReturn(Optional.<TaskInfo>absent());
         expect(userLauncher.createTask(OFFER)).andReturn(Optional.<TaskInfo>absent());
@@ -164,7 +167,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
   @Test
   public void testOfferFirstAccepts() throws Exception {
     new OfferFixture() {
-      @Override void respondToOffer() throws Exception {
+      @Override
+      void respondToOffer() throws Exception {
         expectOfferAttributesSaved(OFFER);
         expect(systemLauncher.createTask(OFFER)).andReturn(Optional.of(TASK));
         expectLaunch(TASK);
@@ -175,7 +179,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
   @Test
   public void testOfferSchedulerAccepts() throws Exception {
     new OfferFixture() {
-      @Override void respondToOffer() throws Exception {
+      @Override
+      void respondToOffer() throws Exception {
         expectOfferAttributesSaved(OFFER);
         expect(systemLauncher.createTask(OFFER)).andReturn(Optional.<TaskInfo>absent());
         expect(userLauncher.createTask(OFFER)).andReturn(Optional.of(TASK));
@@ -187,7 +192,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
   @Test
   public void testAcceptedExceedsOffer() throws Exception {
     new OfferFixture() {
-      @Override void respondToOffer() throws Exception {
+      @Override
+      void respondToOffer() throws Exception {
         expectOfferAttributesSaved(OFFER);
         expect(systemLauncher.createTask(OFFER)).andReturn(Optional.of(BIGGER_TASK));
         expect(userLauncher.createTask(OFFER)).andReturn(Optional.<TaskInfo>absent());
@@ -198,7 +204,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
   @Test
   public void testStatusUpdateNoAccepts() throws Exception {
     new StatusFixture() {
-      @Override void expectations() throws Exception {
+      @Override
+      void expectations() throws Exception {
         expect(systemLauncher.statusUpdate(STATUS)).andReturn(false);
         expect(userLauncher.statusUpdate(STATUS)).andReturn(false);
       }
@@ -208,7 +215,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
   @Test
   public void testStatusUpdateFirstAccepts() throws Exception {
     new StatusFixture() {
-      @Override void expectations() throws Exception {
+      @Override
+      void expectations() throws Exception {
         expect(systemLauncher.statusUpdate(STATUS)).andReturn(true);
       }
     }.run();
@@ -217,7 +225,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
   @Test
   public void testStatusUpdateSecondAccepts() throws Exception {
     new StatusFixture() {
-      @Override void expectations() throws Exception {
+      @Override
+      void expectations() throws Exception {
         expect(systemLauncher.statusUpdate(STATUS)).andReturn(false);
         expect(userLauncher.statusUpdate(STATUS)).andReturn(true);
       }
@@ -227,7 +236,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
   @Test(expected = SchedulerException.class)
   public void testStatusUpdateFails() throws Exception {
     new StatusFixture() {
-      @Override void expectations() throws Exception {
+      @Override
+      void expectations() throws Exception {
         expect(systemLauncher.statusUpdate(STATUS)).andReturn(false);
         expect(userLauncher.statusUpdate(STATUS)).andThrow(new StorageException("Injected."));
       }
@@ -237,7 +247,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
   @Test
   public void testMultipleOffers() throws Exception {
     new RegisteredFixture() {
-      @Override void expectations() throws Exception {
+      @Override
+      void expectations() throws Exception {
         expectOfferAttributesSaved(OFFER);
         expectOfferAttributesSaved(OFFER_2);
         expect(systemLauncher.createTask(OFFER)).andReturn(Optional.<TaskInfo>absent());
@@ -247,7 +258,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
         expect(userLauncher.createTask(OFFER_2)).andReturn(Optional.<TaskInfo>absent());
       }
 
-      @Override void test() {
+      @Override
+      void test() {
         scheduler.resourceOffers(driver, ImmutableList.of(OFFER, OFFER_2));
       }
     }.run();
@@ -256,11 +268,13 @@ public class MesosSchedulerImplTest extends EasyMockTest {
   @Test
   public void testDisconnected() throws Exception {
     new RegisteredFixture() {
-      @Override void expectations() throws Exception {
+      @Override
+      void expectations() throws Exception {
         eventSink.post(new DriverDisconnected());
       }
 
-      @Override void test() {
+      @Override
+      void test() {
         scheduler.disconnected(driver);
       }
     }.run();
@@ -276,7 +290,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
     RegisteredFixture() throws Exception {
       // Prevent otherwise silent noop tests that forget to call run().
       addTearDown(new TearDown() {
-        @Override public void tearDown() {
+        @Override
+        public void tearDown() {
           assertTrue(runCalled.get());
         }
       });
@@ -313,11 +328,13 @@ public class MesosSchedulerImplTest extends EasyMockTest {
 
     abstract void respondToOffer() throws Exception;
 
-    @Override void expectations() throws Exception {
+    @Override
+    void expectations() throws Exception {
       respondToOffer();
     }
 
-    @Override void test() {
+    @Override
+    void test() {
       scheduler.resourceOffers(driver, ImmutableList.of(OFFER));
     }
   }
@@ -327,7 +344,8 @@ public class MesosSchedulerImplTest extends EasyMockTest {
       super();
     }
 
-    @Override void test() {
+    @Override
+    void test() {
       scheduler.statusUpdate(driver, STATUS);
     }
   }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/SchedulerLifecycleTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/SchedulerLifecycleTest.java b/src/test/java/org/apache/aurora/scheduler/SchedulerLifecycleTest.java
index 282cb02..1b1e948 100644
--- a/src/test/java/org/apache/aurora/scheduler/SchedulerLifecycleTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/SchedulerLifecycleTest.java
@@ -73,7 +73,8 @@ public class SchedulerLifecycleTest extends EasyMockTest {
         driverFactory,
         storageUtil.storage,
         new Lifecycle(shutdownRegistry, new UncaughtExceptionHandler() {
-          @Override public void uncaughtException(Thread t, Throwable e) {
+          @Override
+          public void uncaughtException(Thread t, Throwable e) {
             fail(e.getMessage());
           }
         }),

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/TaskVarsTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/TaskVarsTest.java b/src/test/java/org/apache/aurora/scheduler/TaskVarsTest.java
index d6fc72e..728d3a5 100644
--- a/src/test/java/org/apache/aurora/scheduler/TaskVarsTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/TaskVarsTest.java
@@ -80,7 +80,8 @@ public class TaskVarsTest extends EasyMockTest {
     expect(trackedStats.makeGauge(EasyMock.eq(name), EasyMock.<Supplier<Long>>anyObject()))
         .andAnswer(new IAnswer<Stat<Long>>() {
           @SuppressWarnings("unchecked")
-          @Override public Stat<Long> answer() {
+          @Override
+          public Stat<Long> answer() {
             assertFalse(globalCounters.containsKey(name));
             globalCounters.put(name, (Supplier<Long>) EasyMock.getCurrentArguments()[1]);
             return null;

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/UserTaskLauncherTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/UserTaskLauncherTest.java b/src/test/java/org/apache/aurora/scheduler/UserTaskLauncherTest.java
index ffc37db..ecf4f90 100644
--- a/src/test/java/org/apache/aurora/scheduler/UserTaskLauncherTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/UserTaskLauncherTest.java
@@ -185,7 +185,8 @@ public class UserTaskLauncherTest extends EasyMockTest {
 
     Ranges portRanges = Ranges.newBuilder()
         .addAllRange(Iterables.transform(ports, new Function<Pair<Integer, Integer>, Range>() {
-          @Override public Range apply(Pair<Integer, Integer> range) {
+          @Override
+          public Range apply(Pair<Integer, Integer> range) {
             return Range.newBuilder().setBegin(range.getFirst()).setEnd(range.getSecond()).build();
           }
         }))

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/app/SchedulerIT.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/app/SchedulerIT.java b/src/test/java/org/apache/aurora/scheduler/app/SchedulerIT.java
index 9c0e32d..6cfaf39 100644
--- a/src/test/java/org/apache/aurora/scheduler/app/SchedulerIT.java
+++ b/src/test/java/org/apache/aurora/scheduler/app/SchedulerIT.java
@@ -141,7 +141,8 @@ public class SchedulerIT extends BaseZooKeeperTest {
   public void mySetUp() throws Exception {
     control = createControl();
     addTearDown(new TearDown() {
-      @Override public void tearDown() {
+      @Override
+      public void tearDown() {
         if (mainException.get().isPresent()) {
           RuntimeException e = mainException.get().get();
           LOG.log(Level.SEVERE, "Scheduler main exited with an exception", e);
@@ -152,7 +153,8 @@ public class SchedulerIT extends BaseZooKeeperTest {
     });
     backupDir = FileUtils.createTempDir();
     addTearDown(new TearDown() {
-      @Override public void tearDown() throws Exception {
+      @Override
+      public void tearDown() throws Exception {
         org.apache.commons.io.FileUtils.deleteDirectory(backupDir);
       }
     });
@@ -170,20 +172,21 @@ public class SchedulerIT extends BaseZooKeeperTest {
     zkClient = createZkClient();
 
     Module testModule = new AbstractModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         bind(DriverFactory.class).toInstance(driverFactory);
         bind(Log.class).toInstance(log);
         bind(ThriftConfiguration.class).toInstance(
             new ThriftConfiguration() {
-              @Override public Optional<? extends InputStream> getSslKeyStream()
-                  throws IOException {
-
+              @Override
+              public Optional<? extends InputStream> getSslKeyStream() throws IOException {
                 return Optional.of(
                     com.google.common.io.Resources.getResource(getClass(), "AuroraTestKeyStore")
                         .openStream());
               }
 
-              @Override public int getServingPort() {
+              @Override
+              public int getServingPort() {
                 return 0;
               }
             }
@@ -214,7 +217,8 @@ public class SchedulerIT extends BaseZooKeeperTest {
     // Mimic AppLauncher running main.
     final SchedulerMain main = injector.getInstance(SchedulerMain.class);
     executor.submit(new Runnable() {
-      @Override public void run() {
+      @Override
+      public void run() {
         try {
           main.run();
         } catch (RuntimeException e) {
@@ -224,7 +228,8 @@ public class SchedulerIT extends BaseZooKeeperTest {
       }
     });
     addTearDown(new TearDown() {
-      @Override public void tearDown() throws Exception {
+      @Override
+      public void tearDown() throws Exception {
         lifecycle.shutdown();
         new ExecutorServiceShutdown(executor, Amount.of(10L, Time.SECONDS)).execute();
       }
@@ -233,12 +238,14 @@ public class SchedulerIT extends BaseZooKeeperTest {
 
   private HostAndPort awaitSchedulerReady() throws Exception {
     return executor.submit(new Callable<HostAndPort>() {
-      @Override public HostAndPort call() throws Exception {
+      @Override
+      public HostAndPort call() throws Exception {
         final AtomicReference<HostAndPort> thriftEndpoint = Atomics.newReference();
         ServerSet schedulerService = new ServerSetImpl(zkClient, SERVERSET_PATH);
         final CountDownLatch schedulerReady = new CountDownLatch(1);
         schedulerService.watch(new HostChangeMonitor<ServiceInstance>() {
-          @Override public void onChange(ImmutableSet<ServiceInstance> hostSet) {
+          @Override
+          public void onChange(ImmutableSet<ServiceInstance> hostSet) {
             if (!hostSet.isEmpty()) {
               Endpoint endpoint = Iterables.getOnlyElement(hostSet).getServiceEndpoint();
               thriftEndpoint.set(HostAndPort.fromParts(endpoint.getHost(), endpoint.getPort()));
@@ -262,7 +269,8 @@ public class SchedulerIT extends BaseZooKeeperTest {
       this.pos = pos;
     }
 
-    @Override public int compareTo(Position position) {
+    @Override
+    public int compareTo(Position position) {
       return pos - ((IntPosition) position).pos;
     }
   }
@@ -273,9 +281,11 @@ public class SchedulerIT extends BaseZooKeeperTest {
   private Iterable<Entry> toEntries(LogEntry... entries) {
     return Iterables.transform(Arrays.asList(entries),
         new Function<LogEntry, Entry>() {
-          @Override public Entry apply(final LogEntry entry) {
+          @Override
+          public Entry apply(final LogEntry entry) {
             return new Entry() {
-              @Override public byte[] contents() {
+              @Override
+              public byte[] contents() {
                 try {
                   return entrySerializer.serialize(entry)[0];
                 } catch (CodingException e) {
@@ -329,7 +339,8 @@ public class SchedulerIT extends BaseZooKeeperTest {
 
     final CountDownLatch driverStarted = new CountDownLatch(1);
     expect(driver.start()).andAnswer(new IAnswer<Status>() {
-      @Override public Status answer() {
+      @Override
+      public Status answer() {
         driverStarted.countDown();
         return Status.DRIVER_RUNNING;
       }
@@ -338,13 +349,15 @@ public class SchedulerIT extends BaseZooKeeperTest {
     // Try to be a good test suite citizen by releasing the blocked thread when the test case exits.
     final CountDownLatch testCompleted = new CountDownLatch(1);
     expect(driver.join()).andAnswer(new IAnswer<Status>() {
-      @Override public Status answer() throws Throwable {
+      @Override
+      public Status answer() throws Throwable {
         testCompleted.await();
         return Status.DRIVER_STOPPED;
       }
     });
     addTearDown(new TearDown() {
-      @Override public void tearDown() {
+      @Override
+      public void tearDown() {
         testCompleted.countDown();
       }
     });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/async/HistoryPrunerTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/async/HistoryPrunerTest.java b/src/test/java/org/apache/aurora/scheduler/async/HistoryPrunerTest.java
index afb7ce9..811f68c 100644
--- a/src/test/java/org/apache/aurora/scheduler/async/HistoryPrunerTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/async/HistoryPrunerTest.java
@@ -254,7 +254,8 @@ public class HistoryPrunerTest extends EasyMockTest {
 
     pruner = prunerWithRealExecutor();
     Command onDeleted = new Command() {
-      @Override public void execute() {
+      @Override
+      public void execute() {
         // The goal is to verify that the call does not deadlock. We do not care about the outcome.
         changeState("b", ASSIGNED, STARTING);
       }
@@ -277,7 +278,8 @@ public class HistoryPrunerTest extends EasyMockTest {
 
     pruner = prunerWithRealExecutor();
     Command onDeleted = new Command() {
-      @Override public void execute() {
+      @Override
+      public void execute() {
         // The goal is to verify that the call does not deadlock. We do not care about the outcome.
         pruner.tasksDeleted(
             new TasksDeleted(ImmutableSet.of(makeTask("a", ScheduleStatus.KILLED))));
@@ -311,7 +313,8 @@ public class HistoryPrunerTest extends EasyMockTest {
     final CountDownLatch eventDelivered = new CountDownLatch(1);
 
     Thread eventDispatch = new Thread() {
-      @Override public void run() {
+      @Override
+      public void run() {
         try {
           deleteCalled.await();
         } catch (InterruptedException e) {
@@ -329,7 +332,8 @@ public class HistoryPrunerTest extends EasyMockTest {
 
     stateManager.deleteTasks(ImmutableSet.of(taskId));
     expectLastCall().andAnswer(new IAnswer<Void>() {
-      @Override public Void answer() {
+      @Override
+      public Void answer() {
         deleteCalled.countDown();
         try {
           eventDelivered.await();

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/async/OfferQueueImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/async/OfferQueueImplTest.java b/src/test/java/org/apache/aurora/scheduler/async/OfferQueueImplTest.java
index 441fbef..17ba406 100644
--- a/src/test/java/org/apache/aurora/scheduler/async/OfferQueueImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/async/OfferQueueImplTest.java
@@ -71,7 +71,8 @@ public class OfferQueueImplTest extends EasyMockTest {
     executor = Executors.newSingleThreadScheduledExecutor(threadFactory);
     testExecutor = Executors.newCachedThreadPool(threadFactory);
     addTearDown(new TearDown() {
-      @Override public void tearDown() throws Exception {
+      @Override
+      public void tearDown() throws Exception {
         new ExecutorServiceShutdown(executor, Amount.of(1L, Time.SECONDS)).execute();
         new ExecutorServiceShutdown(testExecutor, Amount.of(1L, Time.SECONDS)).execute();
       }
@@ -79,7 +80,8 @@ public class OfferQueueImplTest extends EasyMockTest {
     maintenanceController = createMock(MaintenanceController.class);
     offerAcceptor = createMock(new Clazz<Function<Offer, Optional<TaskInfo>>>() { });
     OfferReturnDelay returnDelay = new OfferReturnDelay() {
-      @Override public Amount<Integer, Time> get() {
+      @Override
+      public Amount<Integer, Time> get() {
         return RETURN_DELAY;
       }
     };
@@ -92,7 +94,8 @@ public class OfferQueueImplTest extends EasyMockTest {
     // the intrinsic lock and the storage lock.
     final CountDownLatch launchAttempted = new CountDownLatch(1);
     expect(maintenanceController.getMode(HOST_A)).andAnswer(new IAnswer<MaintenanceMode>() {
-      @Override public MaintenanceMode answer() throws InterruptedException {
+      @Override
+      public MaintenanceMode answer() throws InterruptedException {
         launchAttempted.await();
         return MaintenanceMode.NONE;
       }
@@ -102,13 +105,15 @@ public class OfferQueueImplTest extends EasyMockTest {
 
     final CountDownLatch offerAdded = new CountDownLatch(1);
     testExecutor.submit(new Runnable() {
-      @Override public void run() {
+      @Override
+      public void run() {
         offerQueue.addOffer(OFFER_A);
         offerAdded.countDown();
       }
     });
     testExecutor.submit(new Runnable() {
-      @Override public void run() {
+      @Override
+      public void run() {
         try {
           offerQueue.launchFirst(offerAcceptor);
           launchAttempted.countDown();

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/async/PreemptorImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/async/PreemptorImplTest.java b/src/test/java/org/apache/aurora/scheduler/async/PreemptorImplTest.java
index 3384a3a..bf097d7 100644
--- a/src/test/java/org/apache/aurora/scheduler/async/PreemptorImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/async/PreemptorImplTest.java
@@ -505,7 +505,8 @@ public class PreemptorImplTest extends EasyMockTest {
         EasyMock.<String>anyObject(),
         EasyMock.eq(EMPTY_JOB))).andAnswer(
         new IAnswer<Set<Veto>>() {
-          @Override public Set<Veto> answer() {
+          @Override
+          public Set<Veto> answer() {
             return ImmutableSet.of();
           }
         }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/async/RescheduleCalculatorImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/async/RescheduleCalculatorImplTest.java b/src/test/java/org/apache/aurora/scheduler/async/RescheduleCalculatorImplTest.java
index c450276..70eb52a 100644
--- a/src/test/java/org/apache/aurora/scheduler/async/RescheduleCalculatorImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/async/RescheduleCalculatorImplTest.java
@@ -177,7 +177,8 @@ public class RescheduleCalculatorImplTest extends EasyMockTest {
 
   private static final Function<Map.Entry<ScheduleStatus, Long>, TaskEvent> TO_EVENT =
       new Function<Entry<ScheduleStatus, Long>, TaskEvent>() {
-        @Override public TaskEvent apply(Entry<ScheduleStatus, Long> input) {
+        @Override
+        public TaskEvent apply(Entry<ScheduleStatus, Long> input) {
           return new TaskEvent().setStatus(input.getKey()).setTimestamp(input.getValue());
         }
       };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerImplTest.java b/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerImplTest.java
index 4572895..4c86d8a 100644
--- a/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerImplTest.java
@@ -90,7 +90,8 @@ public class TaskSchedulerImplTest extends EasyMockTest {
     preemptor = createMock(Preemptor.class);
 
     Injector injector = Guice.createInjector(new AbstractModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         PubsubTestUtil.installPubsub(binder());
         bind(AsyncModule.PREEMPTOR_KEY).toInstance(preemptor);
         AsyncModule.bindTaskScheduler(binder(), AsyncModule.PREEMPTOR_KEY, reservationDuration);

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerTest.java b/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerTest.java
index 34e0186..4112d61 100644
--- a/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/async/TaskSchedulerTest.java
@@ -175,7 +175,8 @@ public class TaskSchedulerTest extends EasyMockTest {
     final IScheduledTask copy = IScheduledTask.build(task.newBuilder().setStatus(newState));
     // Insert the task if it doesn't already exist.
     storage.write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         TaskStore.Mutable taskStore = storeProvider.getUnsafeTaskStore();
         if (taskStore.fetchTasks(Query.taskScoped(Tasks.id(copy))).isEmpty()) {
           taskStore.saveTasks(ImmutableSet.of(copy));
@@ -254,7 +255,8 @@ public class TaskSchedulerTest extends EasyMockTest {
     final IScheduledTask b = makeTask("b", PENDING);
     final IScheduledTask c = makeTask("c", RUNNING);
     storage.write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider store) {
+      @Override
+      protected void execute(MutableStoreProvider store) {
         store.getUnsafeTaskStore().saveTasks(ImmutableSet.of(a, b, c));
       }
     });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/configuration/ResourcesTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/configuration/ResourcesTest.java b/src/test/java/org/apache/aurora/scheduler/configuration/ResourcesTest.java
index f9f147c..b237677 100644
--- a/src/test/java/org/apache/aurora/scheduler/configuration/ResourcesTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/configuration/ResourcesTest.java
@@ -170,7 +170,8 @@ public class ResourcesTest {
     Set<Pair<Long, Long>> actual = ImmutableSet.copyOf(Iterables.transform(
         resource.getRanges().getRangeList(),
         new Function<Range, Pair<Long, Long>>() {
-          @Override public Pair<Long, Long> apply(Range range) {
+          @Override
+          public Pair<Long, Long> apply(Range range) {
             return Pair.of(range.getBegin(), range.getEnd());
           }
         }));

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/cron/noop/NoopCronIT.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/cron/noop/NoopCronIT.java b/src/test/java/org/apache/aurora/scheduler/cron/noop/NoopCronIT.java
index 566fb47..94441b8 100644
--- a/src/test/java/org/apache/aurora/scheduler/cron/noop/NoopCronIT.java
+++ b/src/test/java/org/apache/aurora/scheduler/cron/noop/NoopCronIT.java
@@ -48,7 +48,8 @@ public class NoopCronIT {
   @Test
   public void testSchedule() throws Exception {
     cronScheduler.schedule(SCHEDULE, new Runnable() {
-      @Override public void run() {
+      @Override
+      public void run() {
         // No-op.
       }
     });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/filter/SchedulingFilterImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/filter/SchedulingFilterImplTest.java b/src/test/java/org/apache/aurora/scheduler/filter/SchedulingFilterImplTest.java
index 2ace24a..56de3aa 100644
--- a/src/test/java/org/apache/aurora/scheduler/filter/SchedulingFilterImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/filter/SchedulingFilterImplTest.java
@@ -129,7 +129,8 @@ public class SchedulingFilterImplTest extends EasyMockTest {
   private void expectReads() throws Exception {
     expect(storage.weaklyConsistentRead(EasyMock.<Quiet<?>>anyObject()))
         .andAnswer(new IAnswer<Object>() {
-          @Override public Object answer() throws Exception {
+          @Override
+          public Object answer() throws Exception {
             Quiet<?> arg = (Quiet<?>) EasyMock.getCurrentArguments()[0];
             return arg.apply(storeProvider);
           }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/http/LeaderRedirectTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/http/LeaderRedirectTest.java b/src/test/java/org/apache/aurora/scheduler/http/LeaderRedirectTest.java
index 089db12..aa2313f 100644
--- a/src/test/java/org/apache/aurora/scheduler/http/LeaderRedirectTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/http/LeaderRedirectTest.java
@@ -53,7 +53,8 @@ public class LeaderRedirectTest extends EasyMockTest {
 
   private static final Function<HostAndPort, ServiceInstance> CREATE_INSTANCE =
       new Function<HostAndPort, ServiceInstance>() {
-        @Override public ServiceInstance apply(HostAndPort endpoint) {
+        @Override
+        public ServiceInstance apply(HostAndPort endpoint) {
           return new ServiceInstance()
               .setAdditionalEndpoints(ImmutableMap.of(HTTP_PORT_NAME,
                   new Endpoint(endpoint.getHostText(), endpoint.getPort())));
@@ -70,7 +71,8 @@ public class LeaderRedirectTest extends EasyMockTest {
         createMock(new Clazz<DynamicHostSet<ServiceInstance>>() { });
 
     ServiceRunner fakeRunner = new ServiceRunner() {
-      @Override public LocalService launch() {
+      @Override
+      public LocalService launch() {
         return LocalService.auxiliaryService(HTTP_PORT_NAME, HTTP_PORT, Commands.NOOP);
       }
     };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/state/BaseSchedulerCoreImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/state/BaseSchedulerCoreImplTest.java b/src/test/java/org/apache/aurora/scheduler/state/BaseSchedulerCoreImplTest.java
index 79f09cd..8ad5e7a 100644
--- a/src/test/java/org/apache/aurora/scheduler/state/BaseSchedulerCoreImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/state/BaseSchedulerCoreImplTest.java
@@ -151,7 +151,8 @@ public abstract class BaseSchedulerCoreImplTest extends EasyMockTest {
   // TODO(William Farner): Set up explicit expectations for calls to generate task IDs.
   private final AtomicLong idCounter = new AtomicLong();
   private TaskIdGenerator taskIdGenerator = new TaskIdGenerator() {
-    @Override public String generate(ITaskConfig input, int instanceId) {
+    @Override
+    public String generate(ITaskConfig input, int instanceId) {
       return "task-" + idCounter.incrementAndGet();
     }
   };
@@ -193,7 +194,8 @@ public abstract class BaseSchedulerCoreImplTest extends EasyMockTest {
   private void buildScheduler(Storage newStorage) throws Exception {
     this.storage = newStorage;
     storage.write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         StorageBackfill.backfill(storeProvider, clock);
       }
     });
@@ -306,7 +308,8 @@ public abstract class BaseSchedulerCoreImplTest extends EasyMockTest {
         .setTaskLinks(ImmutableMap.<String, String>of());
 
     storage.write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         storeProvider.getUnsafeTaskStore().saveTasks(ImmutableSet.of(
             IScheduledTask.build(
               new ScheduledTask()
@@ -355,7 +358,8 @@ public abstract class BaseSchedulerCoreImplTest extends EasyMockTest {
     final Set<IScheduledTask> badTasks = ImmutableSet.copyOf(Iterables
         .transform(job.getTaskConfigs().values(),
             new Function<ITaskConfig, IScheduledTask>() {
-              @Override public IScheduledTask apply(ITaskConfig task) {
+              @Override
+              public IScheduledTask apply(ITaskConfig task) {
                 return IScheduledTask.build(new ScheduledTask()
                     .setStatus(RUNNING)
                     .setAssignedTask(
@@ -367,7 +371,8 @@ public abstract class BaseSchedulerCoreImplTest extends EasyMockTest {
             }));
 
     storage.write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         storeProvider.getUnsafeTaskStore().saveTasks(badTasks);
       }
     });
@@ -1153,7 +1158,8 @@ public abstract class BaseSchedulerCoreImplTest extends EasyMockTest {
   @Test
   public void testTaskIdLimit() throws Exception {
     taskIdGenerator = new TaskIdGenerator() {
-      @Override public String generate(ITaskConfig input, int instanceCount) {
+      @Override
+      public String generate(ITaskConfig input, int instanceCount) {
         return Strings.repeat("a", SchedulerCoreImpl.MAX_TASK_ID_LENGTH);
       }
     };
@@ -1167,7 +1173,8 @@ public abstract class BaseSchedulerCoreImplTest extends EasyMockTest {
   @Test(expected = ScheduleException.class)
   public void testRejectLongTaskId() throws Exception {
     taskIdGenerator = new TaskIdGenerator() {
-      @Override public String generate(ITaskConfig input, int instanceCount) {
+      @Override
+      public String generate(ITaskConfig input, int instanceCount) {
         return Strings.repeat("a", SchedulerCoreImpl.MAX_TASK_ID_LENGTH + 1);
       }
     };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/state/CronJobManagerTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/state/CronJobManagerTest.java b/src/test/java/org/apache/aurora/scheduler/state/CronJobManagerTest.java
index 684e239..462e64f 100644
--- a/src/test/java/org/apache/aurora/scheduler/state/CronJobManagerTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/state/CronJobManagerTest.java
@@ -148,7 +148,8 @@ public class CronJobManagerTest extends EasyMockTest {
     control.replay();
 
     Injector injector = Guice.createInjector(new AbstractModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         bind(StateManager.class).toInstance(stateManager);
         bind(Storage.class).toInstance(storageUtil.storage);
         bind(CronScheduler.class).toInstance(cronScheduler);

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/state/MaintenanceControllerImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/state/MaintenanceControllerImplTest.java b/src/test/java/org/apache/aurora/scheduler/state/MaintenanceControllerImplTest.java
index f7f7632..56b691e 100644
--- a/src/test/java/org/apache/aurora/scheduler/state/MaintenanceControllerImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/state/MaintenanceControllerImplTest.java
@@ -71,7 +71,8 @@ public class MaintenanceControllerImplTest extends EasyMockTest {
 
     Injector injector = Guice.createInjector(
         new AbstractModule() {
-          @Override protected void configure() {
+          @Override
+          protected void configure() {
             PubsubTestUtil.installPubsub(binder());
             StateModule.bindMaintenanceController(binder());
             bind(Storage.class).toInstance(storageUtil.storage);

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/state/StateManagerImplTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/state/StateManagerImplTest.java b/src/test/java/org/apache/aurora/scheduler/state/StateManagerImplTest.java
index a0525e5..24949c0 100644
--- a/src/test/java/org/apache/aurora/scheduler/state/StateManagerImplTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/state/StateManagerImplTest.java
@@ -232,7 +232,8 @@ public class StateManagerImplTest extends EasyMockTest {
     // Trigger an event that produces a side-effect and a PubSub event .
     eventSink.post(matchStateChange(id, INIT, PENDING));
     expectLastCall().andAnswer(new IAnswer<Void>() {
-      @Override public Void answer() throws Throwable {
+      @Override
+      public Void answer() throws Throwable {
         changeState(id, ASSIGNED);
         return null;
       }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/state/TaskStateMachineTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/state/TaskStateMachineTest.java b/src/test/java/org/apache/aurora/scheduler/state/TaskStateMachineTest.java
index cc7d59d..a2aaeeb 100644
--- a/src/test/java/org/apache/aurora/scheduler/state/TaskStateMachineTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/state/TaskStateMachineTest.java
@@ -229,7 +229,8 @@ public class TaskStateMachineTest {
 
   private static final Function<Action, SideEffect> TO_SIDE_EFFECT =
       new Function<Action, SideEffect>() {
-        @Override public SideEffect apply(Action action) {
+        @Override
+        public SideEffect apply(Action action) {
           return new SideEffect(action, Optional.<ScheduleStatus>absent());
         }
       };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/storage/ReadWriteLockManagerTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/storage/ReadWriteLockManagerTest.java b/src/test/java/org/apache/aurora/scheduler/storage/ReadWriteLockManagerTest.java
index 2a13f8b..5dc7df1 100644
--- a/src/test/java/org/apache/aurora/scheduler/storage/ReadWriteLockManagerTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/storage/ReadWriteLockManagerTest.java
@@ -71,7 +71,8 @@ public class ReadWriteLockManagerTest extends TearDownTestCase {
     final CountDownLatch fastReadFinished = new CountDownLatch(1);
 
     Future<String> slowReadResult = executor.submit(new Callable<String>() {
-      @Override public String call() throws Exception {
+      @Override
+      public String call() throws Exception {
         lockManager.readLock();
         slowReadStarted.countDown();
         fastReadFinished.await();

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/storage/StorageBackfillTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/storage/StorageBackfillTest.java b/src/test/java/org/apache/aurora/scheduler/storage/StorageBackfillTest.java
index f6ece9c..c0cc0a4 100644
--- a/src/test/java/org/apache/aurora/scheduler/storage/StorageBackfillTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/storage/StorageBackfillTest.java
@@ -54,7 +54,8 @@ public class StorageBackfillTest {
         IScheduledTask.build(makeTask(taskId).newBuilder().setStatus(ScheduleStatus.DRAINING));
 
     storage.write(new Storage.MutateWork.NoResult.Quiet() {
-      @Override protected void execute(Storage.MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(Storage.MutableStoreProvider storeProvider) {
         storeProvider.getUnsafeTaskStore().saveTasks(ImmutableSet.of(savedTask));
         StorageBackfill.backfill(storeProvider, clock);
       }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/storage/backup/RecoveryTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/storage/backup/RecoveryTest.java b/src/test/java/org/apache/aurora/scheduler/storage/backup/RecoveryTest.java
index ad59e9c..b85e270 100644
--- a/src/test/java/org/apache/aurora/scheduler/storage/backup/RecoveryTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/storage/backup/RecoveryTest.java
@@ -78,7 +78,8 @@ public class RecoveryTest extends EasyMockTest {
   public void setUp() {
     final File backupDir = FileUtils.createTempDir();
     addTearDown(new TearDown() {
-      @Override public void tearDown() throws Exception {
+      @Override
+      public void tearDown() throws Exception {
         org.apache.commons.io.FileUtils.deleteDirectory(backupDir);
       }
     });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/storage/backup/StorageBackupTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/storage/backup/StorageBackupTest.java b/src/test/java/org/apache/aurora/scheduler/storage/backup/StorageBackupTest.java
index 7dd96fe..a07f3c9 100644
--- a/src/test/java/org/apache/aurora/scheduler/storage/backup/StorageBackupTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/storage/backup/StorageBackupTest.java
@@ -65,7 +65,8 @@ public class StorageBackupTest extends EasyMockTest {
     clock = new FakeClock();
     final File backupDir = FileUtils.createTempDir();
     addTearDown(new TearDown() {
-      @Override public void tearDown() throws Exception {
+      @Override
+      public void tearDown() throws Exception {
         org.apache.commons.io.FileUtils.deleteDirectory(backupDir);
       }
     });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/test/java/org/apache/aurora/scheduler/storage/log/LogManagerTest.java
----------------------------------------------------------------------
diff --git a/src/test/java/org/apache/aurora/scheduler/storage/log/LogManagerTest.java b/src/test/java/org/apache/aurora/scheduler/storage/log/LogManagerTest.java
index 1a88dd1..040125e 100644
--- a/src/test/java/org/apache/aurora/scheduler/storage/log/LogManagerTest.java
+++ b/src/test/java/org/apache/aurora/scheduler/storage/log/LogManagerTest.java
@@ -85,7 +85,8 @@ public class LogManagerTest extends EasyMockTest {
       Amount.of(Integer.MAX_VALUE, Data.GB);
 
   private static final Function<LogEntry, byte[]> ENCODE = new Function<LogEntry, byte[]>() {
-    @Override public byte[] apply(LogEntry entry) {
+    @Override
+    public byte[] apply(LogEntry entry) {
       try {
         return encode(entry);
       } catch (CodingException e) {
@@ -288,7 +289,8 @@ public class LogManagerTest extends EasyMockTest {
       this.header = LogEntry.frame(header);
       this.chunks = ImmutableList.copyOf(Iterables.transform(chunks,
           new Function<Frame, LogEntry>() {
-            @Override public LogEntry apply(Frame frame) {
+            @Override
+            public LogEntry apply(Frame frame) {
               return LogEntry.frame(frame);
             }
           }));
@@ -396,7 +398,8 @@ public class LogManagerTest extends EasyMockTest {
     tr1.add(op1);
 
     Thread snapshotThread = new Thread() {
-      @Override public void run() {
+      @Override
+      public void run() {
         StreamTransaction tr2 = streamManager.startTransaction();
         tr2.add(op2);
         try {
@@ -512,7 +515,8 @@ public class LogManagerTest extends EasyMockTest {
   private SaveTasks createSaveTasks(String... taskIds) {
     return new SaveTasks(ImmutableSet.copyOf(Iterables.transform(ImmutableList.copyOf(taskIds),
         new Function<String, ScheduledTask>() {
-          @Override public ScheduledTask apply(String taskId) {
+          @Override
+          public ScheduledTask apply(String taskId) {
             return new ScheduledTask().setAssignedTask(new AssignedTask().setTaskId(taskId));
           }
         })));


Mime
View raw message