aurora-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ma...@apache.org
Subject [4/4] git commit: Moving @Override to a separate line to comply with IntelliJ editor.
Date Wed, 05 Feb 2014 02:10:31 GMT
Moving @Override to a separate line to comply with IntelliJ editor.

Reviewed at https://reviews.apache.org/r/17712/


Project: http://git-wip-us.apache.org/repos/asf/incubator-aurora/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-aurora/commit/e7949b1a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-aurora/tree/e7949b1a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-aurora/diff/e7949b1a

Branch: refs/heads/master
Commit: e7949b1ad238426a95eeb02c61cb9e23735f09d9
Parents: 80106ee
Author: Maxim Khutornenko <maxim@apache.org>
Authored: Tue Feb 4 18:06:34 2014 -0800
Committer: Maxim Khutornenko <maxim@apache.org>
Committed: Tue Feb 4 18:06:34 2014 -0800

----------------------------------------------------------------------
 src/main/java/org/apache/aurora/GuiceUtils.java |  21 ++-
 src/main/java/org/apache/aurora/Protobufs.java  |   3 +-
 .../apache/aurora/auth/UnsecureAuthModule.java  |   9 +-
 .../aurora/scheduler/MesosSchedulerImpl.java    |   6 +-
 .../apache/aurora/scheduler/ResourceSlot.java   |   6 +-
 .../aurora/scheduler/SchedulerLifecycle.java    |  48 ++++---
 .../aurora/scheduler/SchedulerModule.java       |   3 +-
 .../org/apache/aurora/scheduler/TaskVars.java   |  12 +-
 .../apache/aurora/scheduler/app/AppModule.java  |   6 +-
 .../apache/aurora/scheduler/app/Modules.java    |   3 +-
 .../aurora/scheduler/app/SchedulerMain.java     |  12 +-
 .../aurora/scheduler/async/AsyncModule.java     |  27 ++--
 .../aurora/scheduler/async/HistoryPruner.java   |   3 +-
 .../aurora/scheduler/async/OfferQueue.java      |   9 +-
 .../aurora/scheduler/async/Preemptor.java       |  30 +++--
 .../scheduler/async/RescheduleCalculator.java   |   6 +-
 .../aurora/scheduler/async/TaskGroup.java       |   6 +-
 .../aurora/scheduler/async/TaskGroups.java      |  12 +-
 .../aurora/scheduler/async/TaskScheduler.java   |  15 ++-
 .../aurora/scheduler/async/TaskThrottler.java   |   3 +-
 .../aurora/scheduler/async/TaskTimeout.java     |  15 ++-
 .../aurora/scheduler/base/Conversions.java      |   9 +-
 .../apache/aurora/scheduler/base/JobKeys.java   |  12 +-
 .../org/apache/aurora/scheduler/base/Tasks.java |  27 ++--
 .../configuration/ConfigurationManager.java     |  18 ++-
 .../scheduler/configuration/Resources.java      |  21 ++-
 .../scheduler/cron/testing/AbstractCronIT.java  |   3 +-
 .../scheduler/events/PubsubEventModule.java     |   3 +-
 .../scheduler/filter/AttributeFilter.java       |   6 +-
 .../scheduler/filter/ConstraintFilter.java      |   3 +-
 .../scheduler/filter/SchedulingFilterImpl.java  |  30 +++--
 .../aurora/scheduler/http/DisplayUtils.java     |   3 +-
 .../aurora/scheduler/http/HttpStatsFilter.java  |   9 +-
 .../aurora/scheduler/http/LeaderRedirect.java   |   3 +-
 .../aurora/scheduler/http/Maintenance.java      |   9 +-
 .../apache/aurora/scheduler/http/Offers.java    |  15 ++-
 .../apache/aurora/scheduler/http/Quotas.java    |   6 +-
 .../aurora/scheduler/http/SchedulerzJob.java    |  18 ++-
 .../aurora/scheduler/http/SchedulerzRole.java   |  12 +-
 .../aurora/scheduler/http/ServletModule.java    |   6 +-
 .../apache/aurora/scheduler/http/Slaves.java    |  15 ++-
 .../aurora/scheduler/http/StructDump.java       |   9 +-
 .../scheduler/http/TransformationUtils.java     |   9 +-
 .../aurora/scheduler/http/Utilization.java      |  15 ++-
 .../scheduler/local/FakeDriverFactory.java      |  47 ++++---
 .../local/IsolatedSchedulerModule.java          |  21 ++-
 .../aurora/scheduler/log/mesos/MesosLog.java    |  12 +-
 .../log/mesos/MesosLogStreamModule.java         |  15 ++-
 .../aurora/scheduler/log/testing/FileLog.java   |  12 +-
 .../aurora/scheduler/metadata/NearestFit.java   |   6 +-
 .../aurora/scheduler/quota/QuotaManager.java    |   6 +-
 .../aurora/scheduler/state/CronJobManager.java  |  27 ++--
 .../aurora/scheduler/state/LockManagerImpl.java |   9 +-
 .../scheduler/state/MaintenanceController.java  |  27 ++--
 .../scheduler/state/SchedulerCoreImpl.java      |  21 ++-
 .../scheduler/state/StateManagerImpl.java       |  30 +++--
 .../scheduler/state/TaskStateMachine.java       |  24 ++--
 .../aurora/scheduler/stats/CachedCounters.java  |   3 +-
 .../aurora/scheduler/stats/ResourceCounter.java |  15 ++-
 .../aurora/scheduler/stats/SlotSizeCounter.java |   3 +-
 .../storage/CallOrderEnforcingStorage.java      |   6 +-
 .../scheduler/storage/ReadWriteLockManager.java |   3 +-
 .../aurora/scheduler/storage/Storage.java       |  12 +-
 .../scheduler/storage/StorageBackfill.java      |   3 +-
 .../scheduler/storage/backup/BackupModule.java  |   3 +-
 .../scheduler/storage/backup/Recovery.java      |  21 ++-
 .../scheduler/storage/backup/StorageBackup.java |  12 +-
 .../storage/backup/TemporaryStorage.java        |  18 ++-
 .../scheduler/storage/log/LogManager.java       |   3 +-
 .../scheduler/storage/log/LogStorage.java       |  81 ++++++++----
 .../storage/log/SnapshotStoreImpl.java          |  48 ++++---
 .../scheduler/storage/mem/MemJobStore.java      |   3 +-
 .../scheduler/storage/mem/MemStorage.java       |  24 ++--
 .../scheduler/storage/mem/MemTaskStore.java     |  18 ++-
 .../aurora/scheduler/storage/mem/Util.java      |   3 +-
 .../storage/testing/StorageTestUtil.java        |   9 +-
 .../thrift/SchedulerThriftInterface.java        |   9 +-
 .../aurora/scheduler/thrift/ThriftServer.java   |   3 +-
 .../scheduler/thrift/ThriftServerLauncher.java  |   3 +-
 .../aurora/scheduler/thrift/aop/AopModule.java  |   6 +-
 .../thrift/aop/LoggingInterceptor.java          |   6 +-
 .../aop/ThriftStatsExporterInterceptor.java     |   3 +-
 .../thrift/aop/UserCapabilityInterceptor.java   |   3 +-
 .../java/org/apache/aurora/GuiceUtilsTest.java  |  12 +-
 .../scheduler/MesosSchedulerImplTest.java       |  54 +++++---
 .../scheduler/SchedulerLifecycleTest.java       |   3 +-
 .../apache/aurora/scheduler/TaskVarsTest.java   |   3 +-
 .../aurora/scheduler/UserTaskLauncherTest.java  |   3 +-
 .../aurora/scheduler/app/SchedulerIT.java       |  47 ++++---
 .../scheduler/async/HistoryPrunerTest.java      |  12 +-
 .../scheduler/async/OfferQueueImplTest.java     |  15 ++-
 .../scheduler/async/PreemptorImplTest.java      |   3 +-
 .../async/RescheduleCalculatorImplTest.java     |   3 +-
 .../scheduler/async/TaskSchedulerImplTest.java  |   3 +-
 .../scheduler/async/TaskSchedulerTest.java      |   6 +-
 .../scheduler/configuration/ResourcesTest.java  |   3 +-
 .../aurora/scheduler/cron/noop/NoopCronIT.java  |   3 +-
 .../filter/SchedulingFilterImplTest.java        |   3 +-
 .../scheduler/http/LeaderRedirectTest.java      |   6 +-
 .../state/BaseSchedulerCoreImplTest.java        |  21 ++-
 .../scheduler/state/CronJobManagerTest.java     |   3 +-
 .../state/MaintenanceControllerImplTest.java    |   3 +-
 .../scheduler/state/StateManagerImplTest.java   |   3 +-
 .../scheduler/state/TaskStateMachineTest.java   |   3 +-
 .../storage/ReadWriteLockManagerTest.java       |   3 +-
 .../scheduler/storage/StorageBackfillTest.java  |   3 +-
 .../scheduler/storage/backup/RecoveryTest.java  |   3 +-
 .../storage/backup/StorageBackupTest.java       |   3 +-
 .../scheduler/storage/log/LogManagerTest.java   |  12 +-
 .../scheduler/storage/log/LogStorageTest.java   | 132 ++++++++++++-------
 .../scheduler/storage/mem/MemStorageTest.java   |  42 ++++--
 .../scheduler/storage/mem/MemTaskStoreTest.java |  12 +-
 .../thrift/SchedulerThriftInterfaceTest.java    |   3 +-
 .../aurora/scheduler/thrift/ThriftIT.java       |  18 ++-
 .../scheduler/thrift/aop/AopModuleTest.java     |   3 +-
 .../aop/FeatureToggleInterceptorTest.java       |   3 +-
 .../aop/ThriftStatsExporterInterceptorTest.java |   3 +-
 117 files changed, 1024 insertions(+), 522 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/GuiceUtils.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/GuiceUtils.java b/src/main/java/org/apache/aurora/GuiceUtils.java
index d77f8a9..9342d4f 100644
--- a/src/main/java/org/apache/aurora/GuiceUtils.java
+++ b/src/main/java/org/apache/aurora/GuiceUtils.java
@@ -66,7 +66,8 @@ public final class GuiceUtils {
   // '>' is followed by whitespace.
   private static final Function<Method, Pair<String, Class[]>> CANONICALIZE =
       new Function<Method, Pair<String, Class[]>>() {
-        @Override public Pair<String, Class[]> apply(Method method) {
+        @Override
+        public Pair<String, Class[]> apply(Method method) {
           return Pair.of(method.getName(), (Class[]) method.getParameterTypes());
         }
       };
@@ -92,7 +93,8 @@ public final class GuiceUtils {
         .build(CacheLoader.from(CANONICALIZE));
 
     return new AbstractMatcher<Method>() {
-      @Override public boolean matches(Method method) {
+      @Override
+      public boolean matches(Method method) {
         return interfaceMethods.contains(cache.getUnchecked(method));
       }
     };
@@ -112,7 +114,8 @@ public final class GuiceUtils {
         Matchers.subclassesOf(wrapInterface),
         interfaceMatcher(wrapInterface, false),
         new MethodInterceptor() {
-          @Override public Object invoke(MethodInvocation invocation) throws Throwable {
+          @Override
+          public Object invoke(MethodInvocation invocation) throws Throwable {
             Thread currentThread = Thread.currentThread();
             ClassLoader prior = currentThread.getContextClassLoader();
             try {
@@ -126,19 +129,22 @@ public final class GuiceUtils {
   }
 
   private static final Predicate<Method> IS_WHITELISTED = new Predicate<Method>() {
-    @Override public boolean apply(Method method) {
+    @Override
+    public boolean apply(Method method) {
       return method.getAnnotation(AllowUnchecked.class) != null;
     }
   };
 
   private static final Matcher<Method> WHITELIST_MATCHER = new AbstractMatcher<Method>() {
-    @Override public boolean matches(Method method) {
+    @Override
+    public boolean matches(Method method) {
       return IS_WHITELISTED.apply(method);
     }
   };
 
   private static final Predicate<Method> VOID_METHOD = new Predicate<Method>() {
-    @Override public boolean apply(Method method) {
+    @Override
+    public boolean apply(Method method) {
       return method.getReturnType() == Void.TYPE;
     }
   };
@@ -165,7 +171,8 @@ public final class GuiceUtils {
         Matchers.<Method>not(WHITELIST_MATCHER).and(interfaceMatcher(wrapInterface, false));
     binder.bindInterceptor(Matchers.subclassesOf(wrapInterface), matcher,
         new MethodInterceptor() {
-          @Override public Object invoke(MethodInvocation invocation) throws Throwable {
+          @Override
+          public Object invoke(MethodInvocation invocation) throws Throwable {
             try {
               return invocation.proceed();
             } catch (RuntimeException e) {

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/Protobufs.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/Protobufs.java b/src/main/java/org/apache/aurora/Protobufs.java
index 5de376b..1e2f078 100644
--- a/src/main/java/org/apache/aurora/Protobufs.java
+++ b/src/main/java/org/apache/aurora/Protobufs.java
@@ -32,7 +32,8 @@ public final class Protobufs {
    * Function to call {@link #toString(Message)} on message objects.
    */
   public static final Function<Message, String> SHORT_TOSTRING = new Function<Message, String>() {
-    @Override public String apply(Message message) {
+    @Override
+    public String apply(Message message) {
       return Protobufs.toString(message);
     }
   };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/auth/UnsecureAuthModule.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/auth/UnsecureAuthModule.java b/src/main/java/org/apache/aurora/auth/UnsecureAuthModule.java
index 0248c95..8a98400 100644
--- a/src/main/java/org/apache/aurora/auth/UnsecureAuthModule.java
+++ b/src/main/java/org/apache/aurora/auth/UnsecureAuthModule.java
@@ -44,7 +44,8 @@ public class UnsecureAuthModule extends AbstractModule {
         throws AuthFailedException {
 
       return new SessionContext() {
-        @Override public String getIdentity() {
+        @Override
+        public String getIdentity() {
           return UNSECURE;
         }
       };
@@ -62,7 +63,8 @@ public class UnsecureAuthModule extends AbstractModule {
         throws AuthFailedException {
 
       return new SessionContext() {
-        @Override public String getIdentity() {
+        @Override
+        public String getIdentity() {
           return UNSECURE;
         }
       };
@@ -73,7 +75,8 @@ public class UnsecureAuthModule extends AbstractModule {
         throws AuthFailedException {
 
       return new SessionContext() {
-        @Override public String getIdentity() {
+        @Override
+        public String getIdentity() {
           return UNSECURE;
         }
       };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/MesosSchedulerImpl.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/MesosSchedulerImpl.java b/src/main/java/org/apache/aurora/scheduler/MesosSchedulerImpl.java
index 2f84bdf..70ac62e 100644
--- a/src/main/java/org/apache/aurora/scheduler/MesosSchedulerImpl.java
+++ b/src/main/java/org/apache/aurora/scheduler/MesosSchedulerImpl.java
@@ -114,7 +114,8 @@ class MesosSchedulerImpl implements Scheduler {
     LOG.info("Registered with ID " + frameworkId + ", master: " + masterInfo);
 
     storage.write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         storeProvider.getSchedulerStore().saveFrameworkId(frameworkId.getValue());
       }
     });
@@ -152,7 +153,8 @@ class MesosSchedulerImpl implements Scheduler {
     //                asynchronously and augment the task scheduler to skip over offers when the
     //                host attributes cannot be found. (AURORA-116)
     storage.write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         for (final Offer offer : offers) {
           storeProvider.getAttributeStore().saveHostAttributes(Conversions.getAttributes(offer));
         }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/ResourceSlot.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/ResourceSlot.java b/src/main/java/org/apache/aurora/scheduler/ResourceSlot.java
index d3a9959..c5a0f28 100644
--- a/src/main/java/org/apache/aurora/scheduler/ResourceSlot.java
+++ b/src/main/java/org/apache/aurora/scheduler/ResourceSlot.java
@@ -113,7 +113,8 @@ public final class ResourceSlot {
 
   public static ResourceSlot sum(Iterable<ResourceSlot> rs) {
     Resources r = Resources.sum(Iterables.transform(rs, new Function<ResourceSlot, Resources>() {
-      @Override public Resources apply(ResourceSlot input) {
+      @Override
+      public Resources apply(ResourceSlot input) {
         return input.resources;
       }
     }));
@@ -122,7 +123,8 @@ public final class ResourceSlot {
   }
 
   public static final Ordering<ResourceSlot> ORDER = new Ordering<ResourceSlot>() {
-    @Override public int compare(ResourceSlot left, ResourceSlot right) {
+    @Override
+    public int compare(ResourceSlot left, ResourceSlot right) {
       return Resources.RESOURCE_ORDER.compare(left.resources, right.resources);
     }
   };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/SchedulerLifecycle.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/SchedulerLifecycle.java b/src/main/java/org/apache/aurora/scheduler/SchedulerLifecycle.java
index 8f3f75b..1cdbff6 100644
--- a/src/main/java/org/apache/aurora/scheduler/SchedulerLifecycle.java
+++ b/src/main/java/org/apache/aurora/scheduler/SchedulerLifecycle.java
@@ -101,7 +101,8 @@ public class SchedulerLifecycle implements EventSubscriber {
   }
 
   private static final Predicate<Transition<State>> IS_DEAD = new Predicate<Transition<State>>() {
-    @Override public boolean apply(Transition<State> state) {
+    @Override
+    public boolean apply(Transition<State> state) {
       return state.getTo() == State.DEAD;
     }
   };
@@ -208,37 +209,43 @@ public class SchedulerLifecycle implements EventSubscriber {
     checkNotNull(eventSink);
 
     Stats.export(new StatImpl<Integer>("framework_registered") {
-      @Override public Integer read() {
+      @Override
+      public Integer read() {
         return registrationAcked.get() ? 1 : 0;
       }
     });
     for (final State state : State.values()) {
       Stats.export(new StatImpl<Integer>("scheduler_lifecycle_" + state) {
-        @Override public Integer read() {
+        @Override
+        public Integer read() {
           return (state == stateMachine.getState()) ? 1 : 0;
         }
       });
     }
 
     final Closure<Transition<State>> prepareStorage = new Closure<Transition<State>>() {
-      @Override public void execute(Transition<State> transition) {
+      @Override
+      public void execute(Transition<State> transition) {
         storage.prepare();
         stateMachine.transition(State.STORAGE_PREPARED);
       }
     };
 
     final Closure<Transition<State>> handleLeading = new Closure<Transition<State>>() {
-      @Override public void execute(Transition<State> transition) {
+      @Override
+      public void execute(Transition<State> transition) {
         LOG.info("Elected as leading scheduler!");
         storage.start(new MutateWork.NoResult.Quiet() {
-          @Override protected void execute(MutableStoreProvider storeProvider) {
+          @Override
+          protected void execute(MutableStoreProvider storeProvider) {
             StorageBackfill.backfill(storeProvider, clock);
           }
         });
 
         @Nullable final String frameworkId = storage.consistentRead(
             new Work.Quiet<String>() {
-              @Override public String apply(StoreProvider storeProvider) {
+              @Override
+              public String apply(StoreProvider storeProvider) {
                 return storeProvider.getSchedulerStore().fetchFrameworkId();
               }
             });
@@ -249,7 +256,8 @@ public class SchedulerLifecycle implements EventSubscriber {
 
         delayedActions.onRegistrationTimeout(
             new Runnable() {
-              @Override public void run() {
+              @Override
+              public void run() {
                 if (!registrationAcked.get()) {
                   LOG.severe(
                       "Framework has not been registered within the tolerated delay.");
@@ -260,7 +268,8 @@ public class SchedulerLifecycle implements EventSubscriber {
 
         delayedActions.onAutoFailover(
             new Runnable() {
-              @Override public void run() {
+              @Override
+              public void run() {
                 LOG.info("Triggering automatic failover.");
                 stateMachine.transition(State.DEAD);
               }
@@ -272,11 +281,13 @@ public class SchedulerLifecycle implements EventSubscriber {
     };
 
     final Closure<Transition<State>> handleRegistered = new Closure<Transition<State>>() {
-      @Override public void execute(Transition<State> transition) {
+      @Override
+      public void execute(Transition<State> transition) {
         registrationAcked.set(true);
         driver.initialize(driverRef.get());
         delayedActions.blockingDriverJoin(new Runnable() {
-          @Override public void run() {
+          @Override
+          public void run() {
             // Blocks until driver exits.
             driverRef.get().join();
             stateMachine.transition(State.DEAD);
@@ -309,7 +320,8 @@ public class SchedulerLifecycle implements EventSubscriber {
         // The latter is preferable since it makes it easier to reason about the state of an
         // announced scheduler.
         delayedActions.onRegistered(new Runnable() {
-          @Override public void run() {
+          @Override
+          public void run() {
             eventSink.post(new SchedulerActive());
             try {
               leaderControl.get().advertise();
@@ -328,7 +340,8 @@ public class SchedulerLifecycle implements EventSubscriber {
 
     final Closure<Transition<State>> shutDown = new Closure<Transition<State>>() {
       private final AtomicBoolean invoked = new AtomicBoolean(false);
-      @Override public void execute(Transition<State> transition) {
+      @Override
+      public void execute(Transition<State> transition) {
         if (!invoked.compareAndSet(false, true)) {
           LOG.info("Shutdown already invoked, ignoring extra call.");
           return;
@@ -393,7 +406,8 @@ public class SchedulerLifecycle implements EventSubscriber {
 
   private Closure<Transition<State>> dieOnError(final Closure<Transition<State>> closure) {
     return new Closure<Transition<State>>() {
-      @Override public void execute(Transition<State> transition) {
+      @Override
+      public void execute(Transition<State> transition) {
         try {
           closure.execute(transition);
         } catch (RuntimeException e) {
@@ -433,12 +447,14 @@ public class SchedulerLifecycle implements EventSubscriber {
       this.leaderControl = leaderControl;
     }
 
-    @Override public void onLeading(LeaderControl control) {
+    @Override
+    public void onLeading(LeaderControl control) {
       leaderControl.set(control);
       stateMachine.transition(State.LEADER_AWAITING_REGISTRATION);
     }
 
-    @Override public void onDefeated(@Nullable ServerSet.EndpointStatus status) {
+    @Override
+    public void onDefeated(@Nullable ServerSet.EndpointStatus status) {
       LOG.severe("Lost leadership, committing suicide.");
       stateMachine.transition(State.DEAD);
     }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/SchedulerModule.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/SchedulerModule.java b/src/main/java/org/apache/aurora/scheduler/SchedulerModule.java
index aa3b383..92399cc 100644
--- a/src/main/java/org/apache/aurora/scheduler/SchedulerModule.java
+++ b/src/main/java/org/apache/aurora/scheduler/SchedulerModule.java
@@ -83,7 +83,8 @@ public class SchedulerModule extends AbstractModule {
     bind(UserTaskLauncher.class).in(Singleton.class);
 
     install(new PrivateModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         bind(LeadingOptions.class).toInstance(
             new LeadingOptions(MAX_REGISTRATION_DELAY.get(), MAX_LEADING_DURATION.get()));
 

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/TaskVars.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/TaskVars.java b/src/main/java/org/apache/aurora/scheduler/TaskVars.java
index 38e112a..2ddfa87 100644
--- a/src/main/java/org/apache/aurora/scheduler/TaskVars.java
+++ b/src/main/java/org/apache/aurora/scheduler/TaskVars.java
@@ -63,7 +63,8 @@ class TaskVars implements EventSubscriber {
     this.storage = checkNotNull(storage);
     checkNotNull(statProvider);
     counters = CacheBuilder.newBuilder().build(new CacheLoader<String, Counter>() {
-      @Override public Counter load(String statName) {
+      @Override
+      public Counter load(String statName) {
         Counter counter = new Counter(statProvider);
         if (exporting) {
           counter.exportAs(statName);
@@ -84,13 +85,15 @@ class TaskVars implements EventSubscriber {
   }
 
   private static final Predicate<Attribute> IS_RACK = new Predicate<Attribute>() {
-    @Override public boolean apply(Attribute attr) {
+    @Override
+    public boolean apply(Attribute attr) {
       return "rack".equals(attr.getName());
     }
   };
 
   private static final Function<Attribute, String> ATTR_VALUE = new Function<Attribute, String>() {
-    @Override public String apply(Attribute attr) {
+    @Override
+    public String apply(Attribute attr) {
       return Iterables.getOnlyElement(attr.getValues());
     }
   };
@@ -120,7 +123,8 @@ class TaskVars implements EventSubscriber {
     if (stateChange.getNewState() == ScheduleStatus.LOST) {
       final String host = stateChange.getTask().getAssignedTask().getSlaveHost();
       Optional<String> rack = storage.consistentRead(new Work.Quiet<Optional<String>>() {
-        @Override public Optional<String> apply(StoreProvider storeProvider) {
+        @Override
+        public Optional<String> apply(StoreProvider storeProvider) {
           Optional<Attribute> rack = FluentIterable
               .from(AttributeStore.Util.attributesOrNone(storeProvider, host))
               .firstMatch(IS_RACK);

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/app/AppModule.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/app/AppModule.java b/src/main/java/org/apache/aurora/scheduler/app/AppModule.java
index 89d1217..296bc1f 100644
--- a/src/main/java/org/apache/aurora/scheduler/app/AppModule.java
+++ b/src/main/java/org/apache/aurora/scheduler/app/AppModule.java
@@ -112,7 +112,8 @@ class AppModule extends AbstractModule {
   private static class RegisterShutdownStackPrinter implements Command {
     private static final Function<StackTraceElement, String> STACK_ELEM_TOSTRING =
         new Function<StackTraceElement, String>() {
-          @Override public String apply(StackTraceElement element) {
+          @Override
+          public String apply(StackTraceElement element) {
             return element.getClassName() + "." + element.getMethodName()
                 + String.format("(%s:%s)", element.getFileName(), element.getLineNumber());
           }
@@ -128,7 +129,8 @@ class AppModule extends AbstractModule {
     @Override
     public void execute() {
       shutdownRegistry.addAction(new Command() {
-        @Override public void execute() {
+        @Override
+        public void execute() {
           Thread thread = Thread.currentThread();
           String message = new StringBuilder()
               .append("Thread: ").append(thread.getName())

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/app/Modules.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/app/Modules.java b/src/main/java/org/apache/aurora/scheduler/app/Modules.java
index 107abbb..6925c1b 100644
--- a/src/main/java/org/apache/aurora/scheduler/app/Modules.java
+++ b/src/main/java/org/apache/aurora/scheduler/app/Modules.java
@@ -54,7 +54,8 @@ final class Modules {
 
     final Module module = instantiateModule(moduleClass);
     return new PrivateModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         install(module);
         for (Class<?> klass : exposedClasses) {
           expose(klass);

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/app/SchedulerMain.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/app/SchedulerMain.java b/src/main/java/org/apache/aurora/scheduler/app/SchedulerMain.java
index c69a2a6..ec56c64 100644
--- a/src/main/java/org/apache/aurora/scheduler/app/SchedulerMain.java
+++ b/src/main/java/org/apache/aurora/scheduler/app/SchedulerMain.java
@@ -182,7 +182,8 @@ public class SchedulerMain extends AbstractApplication {
     } else {
       // TODO(Kevin Sweeney): Push these bindings down into a "production" module.
       additional = new AbstractModule() {
-        @Override protected void configure() {
+        @Override
+        protected void configure() {
           bind(DriverFactory.class).to(DriverFactoryImpl.class);
           bind(DriverFactoryImpl.class).in(Singleton.class);
           install(new MesosLogStreamModule(zkClientConfig));
@@ -191,9 +192,11 @@ public class SchedulerMain extends AbstractApplication {
     }
 
     Module configModule = new AbstractModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         bind(ThriftConfiguration.class).toInstance(new ThriftConfiguration() {
-          @Override public Optional<InputStream> getSslKeyStream() throws FileNotFoundException {
+          @Override
+          public Optional<InputStream> getSslKeyStream() throws FileNotFoundException {
             if (MESOS_SSL_KEY_FILE.hasAppliedValue()) {
               return Optional.<InputStream>of(new FileInputStream(MESOS_SSL_KEY_FILE.get()));
             } else {
@@ -201,7 +204,8 @@ public class SchedulerMain extends AbstractApplication {
             }
           }
 
-          @Override public int getServingPort() {
+          @Override
+          public int getServingPort() {
             return THRIFT_PORT.get();
           }
         });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/async/AsyncModule.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/async/AsyncModule.java b/src/main/java/org/apache/aurora/scheduler/async/AsyncModule.java
index 430ff03..e7a5a83 100644
--- a/src/main/java/org/apache/aurora/scheduler/async/AsyncModule.java
+++ b/src/main/java/org/apache/aurora/scheduler/async/AsyncModule.java
@@ -131,7 +131,8 @@ public class AsyncModule extends AbstractModule {
   private static final Arg<Boolean> ENABLE_PREEMPTOR = Arg.create(true);
 
   private static final Preemptor NULL_PREEMPTOR = new Preemptor() {
-    @Override public Optional<String> findPreemptionSlotFor(
+    @Override
+    public Optional<String> findPreemptionSlotFor(
         String taskId,
         CachedJobState cachedJobState) {
 
@@ -159,7 +160,8 @@ public class AsyncModule extends AbstractModule {
         new ThreadFactoryBuilder().setNameFormat("AsyncProcessor-%d").setDaemon(true).build());
     Stats.exportSize("timeout_queue_size", executor.getQueue());
     Stats.export(new StatImpl<Long>("async_tasks_completed") {
-      @Override public Long read() {
+      @Override
+      public Long read() {
         return executor.getCompletedTaskCount();
       }
     });
@@ -167,7 +169,8 @@ public class AsyncModule extends AbstractModule {
     // AsyncModule itself is not a subclass of PrivateModule because TaskEventModule internally uses
     // a MultiBinder, which cannot span multiple injectors.
     install(new PrivateModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         bind(new TypeLiteral<Amount<Long, Time>>() { })
             .toInstance(TRANSIENT_TASK_STATE_TIMEOUT.get());
         bind(ScheduledExecutorService.class).toInstance(executor);
@@ -180,7 +183,8 @@ public class AsyncModule extends AbstractModule {
     PubsubEventModule.bindSubscriber(binder(), TaskTimeout.class);
 
     install(new PrivateModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         bind(TaskGroupsSettings.class).toInstance(new TaskGroupsSettings(
             new TruncatedBinaryBackoff(INITIAL_SCHEDULE_DELAY.get(), MAX_SCHEDULE_DELAY.get()),
             RateLimiter.create(MAX_SCHEDULE_ATTEMPTS_PER_SEC.get())));
@@ -212,7 +216,8 @@ public class AsyncModule extends AbstractModule {
     PubsubEventModule.bindSubscriber(binder(), TaskGroups.class);
 
     install(new PrivateModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         bind(OfferReturnDelay.class).to(RandomJitterReturnDelay.class);
         bind(ScheduledExecutorService.class).toInstance(executor);
         bind(OfferQueue.class).to(OfferQueueImpl.class);
@@ -223,7 +228,8 @@ public class AsyncModule extends AbstractModule {
     PubsubEventModule.bindSubscriber(binder(), OfferQueue.class);
 
     install(new PrivateModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         // TODO(ksweeney): Create a configuration validator module so this can be injected.
         // TODO(William Farner): Revert this once large task counts is cheap ala hierarchichal store
         bind(Integer.class).annotatedWith(PruneThreshold.class).toInstance(100);
@@ -238,7 +244,8 @@ public class AsyncModule extends AbstractModule {
     PubsubEventModule.bindSubscriber(binder(), HistoryPruner.class);
 
     install(new PrivateModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         bind(ScheduledExecutorService.class).toInstance(executor);
         bind(TaskThrottler.class).in(Singleton.class);
         expose(TaskThrottler.class);
@@ -259,7 +266,8 @@ public class AsyncModule extends AbstractModule {
       final Key<Preemptor> preemptorKey,
       final Amount<Long, Time> reservationDuration) {
         binder.install(new PrivateModule() {
-          @Override protected void configure() {
+          @Override
+          protected void configure() {
             bind(Preemptor.class).to(preemptorKey);
             bind(new TypeLiteral<Amount<Long, Time>>() { }).annotatedWith(ReservationDuration.class)
                 .toInstance(reservationDuration);
@@ -280,7 +288,8 @@ public class AsyncModule extends AbstractModule {
     private final int minHoldTimeMs = MIN_OFFER_HOLD_TIME.get().as(Time.MILLISECONDS);
     private final Random random = new Random.SystemRandom(new java.util.Random());
 
-    @Override public Amount<Integer, Time> get() {
+    @Override
+    public Amount<Integer, Time> get() {
       return Amount.of(minHoldTimeMs + random.nextInt(JITTER_WINDOW_MS), Time.MILLISECONDS);
     }
   }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/async/HistoryPruner.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/async/HistoryPruner.java b/src/main/java/org/apache/aurora/scheduler/async/HistoryPruner.java
index 9f77bfc..c80c000 100644
--- a/src/main/java/org/apache/aurora/scheduler/async/HistoryPruner.java
+++ b/src/main/java/org/apache/aurora/scheduler/async/HistoryPruner.java
@@ -151,7 +151,8 @@ public class HistoryPruner implements EventSubscriber {
     // Insert the latest inactive task at the tail.
     tasksByJob.put(jobKey, taskId);
     Runnable runnable = new Runnable() {
-      @Override public void run() {
+      @Override
+      public void run() {
         LOG.info("Pruning expired inactive task " + taskId);
         tasksByJob.remove(jobKey, taskId);
         taskIdToFuture.remove(taskId);

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/async/OfferQueue.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/async/OfferQueue.java b/src/main/java/org/apache/aurora/scheduler/async/OfferQueue.java
index a2b3dae..b85e42b 100644
--- a/src/main/java/org/apache/aurora/scheduler/async/OfferQueue.java
+++ b/src/main/java/org/apache/aurora/scheduler/async/OfferQueue.java
@@ -157,7 +157,8 @@ public interface OfferQueue extends EventSubscriber {
         hostOffers.add(new HostOffer(offer, maintenance.getMode(offer.getHostname())));
         executor.schedule(
             new Runnable() {
-              @Override public void run() {
+              @Override
+              public void run() {
                 removeAndDecline(offer.getId());
               }
             },
@@ -200,7 +201,8 @@ public interface OfferQueue extends EventSubscriber {
     public Iterable<Offer> getOffers() {
       return FluentIterable.from(hostOffers.getWeaklyConsistentOffers())
           .transform(new Function<HostOffer, Offer>() {
-            @Override public Offer apply(HostOffer offer) {
+            @Override
+            public Offer apply(HostOffer offer) {
               return offer.offer;
             }
           });
@@ -266,7 +268,8 @@ public interface OfferQueue extends EventSubscriber {
           // Currently, the only preference is based on host maintenance status.
           Ordering.explicit(NONE, SCHEDULED, DRAINING, DRAINED)
               .onResultOf(new Function<HostOffer, MaintenanceMode>() {
-                @Override public MaintenanceMode apply(HostOffer offer) {
+                @Override
+                public MaintenanceMode apply(HostOffer offer) {
                   return offer.mode;
                 }
               })

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/async/Preemptor.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/async/Preemptor.java b/src/main/java/org/apache/aurora/scheduler/async/Preemptor.java
index 7bc3ebf..9d00315 100644
--- a/src/main/java/org/apache/aurora/scheduler/async/Preemptor.java
+++ b/src/main/java/org/apache/aurora/scheduler/async/Preemptor.java
@@ -105,7 +105,8 @@ public interface Preemptor {
 
     private static final Function<IAssignedTask, Integer> GET_PRIORITY =
         new Function<IAssignedTask, Integer>() {
-          @Override public Integer apply(IAssignedTask task) {
+          @Override
+          public Integer apply(IAssignedTask task) {
             return task.getTask().getPriority();
           }
         };
@@ -117,7 +118,8 @@ public interface Preemptor {
     private final AtomicLong noSlotsFound = Stats.exportLong("preemptor_no_slots_found");
 
     private final Predicate<IScheduledTask> isIdleTask = new Predicate<IScheduledTask>() {
-      @Override public boolean apply(IScheduledTask task) {
+      @Override
+      public boolean apply(IScheduledTask task) {
         return (clock.nowMillis() - Tasks.getLatestEvent(task).getTimestamp())
             >= preemptionCandidacyDelay.as(Time.MILLISECONDS);
       }
@@ -170,14 +172,16 @@ public interface Preemptor {
 
     private static final Function<IAssignedTask, String> TASK_TO_SLAVE_ID =
         new Function<IAssignedTask, String>() {
-          @Override public String apply(IAssignedTask input) {
+          @Override
+          public String apply(IAssignedTask input) {
             return input.getSlaveId();
           }
         };
 
     private static Predicate<IAssignedTask> canPreempt(final IAssignedTask pending) {
       return new Predicate<IAssignedTask>() {
-        @Override public boolean apply(IAssignedTask possibleVictim) {
+        @Override
+        public boolean apply(IAssignedTask possibleVictim) {
           return preemptionFilter(possibleVictim).apply(pending);
         }
       };
@@ -185,21 +189,24 @@ public interface Preemptor {
 
     private static final Function<IAssignedTask, ResourceSlot> TASK_TO_RESOURCES =
         new Function<IAssignedTask, ResourceSlot>() {
-          @Override public ResourceSlot apply(IAssignedTask input) {
+          @Override
+          public ResourceSlot apply(IAssignedTask input) {
             return ResourceSlot.from(input.getTask());
           }
         };
 
     private static final Function<Offer, ResourceSlot> OFFER_TO_RESOURCE_SLOT =
         new Function<Offer, ResourceSlot>() {
-          @Override public ResourceSlot apply(Offer offer) {
+          @Override
+          public ResourceSlot apply(Offer offer) {
             return ResourceSlot.from(offer);
           }
         };
 
     private static final Function<Offer, String> OFFER_TO_HOST =
         new Function<Offer, String>() {
-          @Override public String apply(Offer offer) {
+          @Override
+          public String apply(Offer offer) {
             return offer.getHostname();
           }
         };
@@ -278,7 +285,8 @@ public interface Preemptor {
 
     private static final Function<Offer, String> OFFER_TO_SLAVE_ID =
         new Function<Offer, String>() {
-          @Override public String apply(Offer offer) {
+          @Override
+          public String apply(Offer offer) {
             return offer.getSlaveId().getValue();
           }
         };
@@ -379,7 +387,8 @@ public interface Preemptor {
 
     private static Predicate<IAssignedTask> isOwnedBy(final String role) {
       return new Predicate<IAssignedTask>() {
-        @Override public boolean apply(IAssignedTask task) {
+        @Override
+        public boolean apply(IAssignedTask task) {
           return getRole(task).equals(role);
         }
       };
@@ -391,7 +400,8 @@ public interface Preemptor {
 
     private static Predicate<Integer> greaterThan(final int value) {
       return new Predicate<Integer>() {
-        @Override public boolean apply(Integer input) {
+        @Override
+        public boolean apply(Integer input) {
           return input > value;
         }
       };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/async/RescheduleCalculator.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/async/RescheduleCalculator.java b/src/main/java/org/apache/aurora/scheduler/async/RescheduleCalculator.java
index a9ee32b..b7e6447 100644
--- a/src/main/java/org/apache/aurora/scheduler/async/RescheduleCalculator.java
+++ b/src/main/java/org/apache/aurora/scheduler/async/RescheduleCalculator.java
@@ -83,7 +83,8 @@ public interface RescheduleCalculator {
 
     private static final Function<ITaskEvent, ScheduleStatus> TO_STATUS =
         new Function<ITaskEvent, ScheduleStatus>() {
-          @Override public ScheduleStatus apply(ITaskEvent input) {
+          @Override
+          public ScheduleStatus apply(ITaskEvent input) {
             return input.getStatus();
           }
         };
@@ -92,7 +93,8 @@ public interface RescheduleCalculator {
         EnumSet.of(RESTARTING, KILLING);
 
     private final Predicate<IScheduledTask> flapped = new Predicate<IScheduledTask>() {
-      @Override public boolean apply(IScheduledTask task) {
+      @Override
+      public boolean apply(IScheduledTask task) {
         if (!task.isSetTaskEvents()) {
           return false;
         }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/async/TaskGroup.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/async/TaskGroup.java b/src/main/java/org/apache/aurora/scheduler/async/TaskGroup.java
index a834f44..ece7e3a 100644
--- a/src/main/java/org/apache/aurora/scheduler/async/TaskGroup.java
+++ b/src/main/java/org/apache/aurora/scheduler/async/TaskGroup.java
@@ -38,7 +38,8 @@ class TaskGroup {
   private final BackoffStrategy backoffStrategy;
 
   private static final Function<Task, Long> TO_TIMESTAMP = new Function<Task, Long>() {
-    @Override public Long apply(Task item) {
+    @Override
+    public Long apply(Task item) {
       return item.readyTimestampMs;
     }
   };
@@ -63,7 +64,8 @@ class TaskGroup {
 
   private static final Function<Task, String> TO_TASK_ID =
       new Function<Task, String>() {
-        @Override public String apply(Task item) {
+        @Override
+        public String apply(Task item) {
           return item.taskId;
         }
       };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/async/TaskGroups.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/async/TaskGroups.java b/src/main/java/org/apache/aurora/scheduler/async/TaskGroups.java
index 702b0df..6c95c6f 100644
--- a/src/main/java/org/apache/aurora/scheduler/async/TaskGroups.java
+++ b/src/main/java/org/apache/aurora/scheduler/async/TaskGroups.java
@@ -116,14 +116,16 @@ public class TaskGroups implements EventSubscriber {
     this.rescheduleCalculator = checkNotNull(rescheduleCalculator);
 
     final TaskScheduler ratelLimitedScheduler = new TaskScheduler() {
-      @Override public TaskSchedulerResult schedule(String taskId) {
+      @Override
+      public TaskSchedulerResult schedule(String taskId) {
         rateLimiter.acquire();
         return taskScheduler.schedule(taskId);
       }
     };
 
     groups = CacheBuilder.newBuilder().build(new CacheLoader<GroupKey, TaskGroup>() {
-      @Override public TaskGroup load(GroupKey key) {
+      @Override
+      public TaskGroup load(GroupKey key) {
         TaskGroup group = new TaskGroup(key, taskGroupBackoffStrategy);
         LOG.info("Evaluating group " + key + " in " + group.getPenaltyMs() + " ms");
         startGroup(group, executor, ratelLimitedScheduler);
@@ -146,7 +148,8 @@ public class TaskGroups implements EventSubscriber {
       final TaskScheduler taskScheduler) {
 
     Runnable monitor = new Runnable() {
-      @Override public void run() {
+      @Override
+      public void run() {
         GroupState state = group.isReady(clock.nowMillis());
 
         switch (state) {
@@ -194,7 +197,8 @@ public class TaskGroups implements EventSubscriber {
         new ThreadFactoryBuilder().setDaemon(true).setNameFormat("TaskScheduler-%d").build());
     Stats.exportSize("schedule_queue_size", executor.getQueue());
     shutdownRegistry.addAction(new Command() {
-      @Override public void execute() {
+      @Override
+      public void execute() {
         new ExecutorServiceShutdown(executor, Amount.of(1L, Time.SECONDS)).execute();
       }
     });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/async/TaskScheduler.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/async/TaskScheduler.java b/src/main/java/org/apache/aurora/scheduler/async/TaskScheduler.java
index 9c4f691..5357481 100644
--- a/src/main/java/org/apache/aurora/scheduler/async/TaskScheduler.java
+++ b/src/main/java/org/apache/aurora/scheduler/async/TaskScheduler.java
@@ -142,7 +142,8 @@ interface TaskScheduler extends EventSubscriber {
         final IScheduledTask task) {
 
       return new Function<Offer, Optional<TaskInfo>>() {
-        @Override public Optional<TaskInfo> apply(Offer offer) {
+        @Override
+        public Optional<TaskInfo> apply(Offer offer) {
           Optional<String> reservedTaskId = reservations.getSlaveReservation(offer.getSlaveId());
           if (reservedTaskId.isPresent()) {
             if (taskId.equals(reservedTaskId.get())) {
@@ -174,7 +175,8 @@ interface TaskScheduler extends EventSubscriber {
 
     private CachedJobState getJobState(final TaskStore store, final IJobKey jobKey) {
       return new CachedJobState(Suppliers.memoize(new Supplier<ImmutableSet<IScheduledTask>>() {
-        @Override public ImmutableSet<IScheduledTask> get() {
+        @Override
+        public ImmutableSet<IScheduledTask> get() {
           return store.fetchTasks(activeJobStateQuery(jobKey));
         }
       }));
@@ -186,7 +188,8 @@ interface TaskScheduler extends EventSubscriber {
       scheduleAttemptsFired.incrementAndGet();
       try {
         return storage.write(new MutateWork.Quiet<TaskSchedulerResult>() {
-          @Override public TaskSchedulerResult apply(MutableStoreProvider store) {
+          @Override
+          public TaskSchedulerResult apply(MutableStoreProvider store) {
             LOG.fine("Attempting to schedule task " + taskId);
             final IScheduledTask task = Iterables.getOnlyElement(
                 store.getTaskStore().fetchTasks(Query.taskScoped(taskId).byStatus(PENDING)),
@@ -253,13 +256,15 @@ interface TaskScheduler extends EventSubscriber {
         this.reservations = CacheBuilder.newBuilder()
             .expireAfterWrite(duration.as(Time.MINUTES), TimeUnit.MINUTES)
             .ticker(new Ticker() {
-              @Override public long read() {
+              @Override
+              public long read() {
                 return clock.nowNanos();
               }
             })
             .build();
         Stats.export(new StatImpl<Long>("reservation_cache_size") {
-          @Override public Long read() {
+          @Override
+          public Long read() {
             return reservations.size();
           }
         });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/async/TaskThrottler.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/async/TaskThrottler.java b/src/main/java/org/apache/aurora/scheduler/async/TaskThrottler.java
index fd6c188..2334e7f 100644
--- a/src/main/java/org/apache/aurora/scheduler/async/TaskThrottler.java
+++ b/src/main/java/org/apache/aurora/scheduler/async/TaskThrottler.java
@@ -72,7 +72,8 @@ class TaskThrottler implements EventSubscriber {
       throttleStats.accumulate(delayMs);
       executor.schedule(
           new Runnable() {
-            @Override public void run() {
+            @Override
+            public void run() {
               stateManager.changeState(
                   stateChange.getTaskId(),
                   Optional.of(THROTTLED),

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/async/TaskTimeout.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/async/TaskTimeout.java b/src/main/java/org/apache/aurora/scheduler/async/TaskTimeout.java
index 64a1941..609e8cc 100644
--- a/src/main/java/org/apache/aurora/scheduler/async/TaskTimeout.java
+++ b/src/main/java/org/apache/aurora/scheduler/async/TaskTimeout.java
@@ -172,7 +172,8 @@ class TaskTimeout implements EventSubscriber {
       this.key = key;
     }
 
-    @Override public void run() {
+    @Override
+    public void run() {
       Context context = futures.get(key);
       try {
         if (context == null) {
@@ -213,7 +214,8 @@ class TaskTimeout implements EventSubscriber {
   }
 
   private static final Function<Context, Long> CONTEXT_TIMESTAMP = new Function<Context, Long>() {
-    @Override public Long apply(Context context) {
+    @Override
+    public Long apply(Context context) {
       return context.timestampMillis;
     }
   };
@@ -228,7 +230,8 @@ class TaskTimeout implements EventSubscriber {
 
   private void exportStats(StatsProvider statsProvider) {
     statsProvider.makeGauge(TRANSIENT_COUNT_STAT_NAME, new Supplier<Number>() {
-      @Override public Number get() {
+      @Override
+      public Number get() {
           return futures.size();
         }
     });
@@ -236,12 +239,14 @@ class TaskTimeout implements EventSubscriber {
     for (final ScheduleStatus status : TRANSIENT_STATES) {
       statsProvider.makeGauge(waitingTimeStatName(status), new Supplier<Number>() {
         private final Predicate<TimeoutKey> statusMatcher = new Predicate<TimeoutKey>() {
-          @Override public boolean apply(TimeoutKey key) {
+          @Override
+          public boolean apply(TimeoutKey key) {
             return key.status == status;
           }
         };
 
-        @Override public Number get() {
+        @Override
+        public Number get() {
           Iterable<Context> matches = Maps.filterKeys(futures, statusMatcher).values();
           if (Iterables.isEmpty(matches)) {
             return 0L;

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/base/Conversions.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/base/Conversions.java b/src/main/java/org/apache/aurora/scheduler/base/Conversions.java
index 03edce5..564919e 100644
--- a/src/main/java/org/apache/aurora/scheduler/base/Conversions.java
+++ b/src/main/java/org/apache/aurora/scheduler/base/Conversions.java
@@ -72,7 +72,8 @@ public final class Conversions {
 
   private static final Function<Protos.Attribute, String> ATTRIBUTE_NAME =
       new Function<Protos.Attribute, String>() {
-        @Override public String apply(Protos.Attribute attr) {
+        @Override
+        public String apply(Protos.Attribute attr) {
           return attr.getName();
         }
       };
@@ -86,7 +87,8 @@ public final class Conversions {
 
   private static final Function<Protos.Attribute, String> VALUE_CONVERTER =
       new Function<Protos.Attribute, String>() {
-        @Override public String apply(Protos.Attribute attribute) {
+        @Override
+        public String apply(Protos.Attribute attribute) {
           switch (attribute.getType()) {
             case SCALAR:
               return String.valueOf(attribute.getScalar().getValue());
@@ -102,7 +104,8 @@ public final class Conversions {
       };
 
   private static final AttributeConverter ATTRIBUTE_CONVERTER = new AttributeConverter() {
-    @Override public Attribute apply(Entry<String, Collection<Protos.Attribute>> entry) {
+    @Override
+    public Attribute apply(Entry<String, Collection<Protos.Attribute>> entry) {
       // Convert values and filter any that were ignored.
       return new Attribute(
           entry.getKey(),

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/base/JobKeys.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/base/JobKeys.java b/src/main/java/org/apache/aurora/scheduler/base/JobKeys.java
index c9f4687..5f684bc 100644
--- a/src/main/java/org/apache/aurora/scheduler/base/JobKeys.java
+++ b/src/main/java/org/apache/aurora/scheduler/base/JobKeys.java
@@ -40,28 +40,32 @@ public final class JobKeys {
 
   public static final Function<IJobConfiguration, IJobKey> FROM_CONFIG =
       new Function<IJobConfiguration, IJobKey>() {
-        @Override public IJobKey apply(IJobConfiguration job) {
+        @Override
+        public IJobKey apply(IJobConfiguration job) {
           return job.getKey();
         }
       };
 
   public static final Function<IJobKey, String> TO_ROLE =
       new Function<IJobKey, String>() {
-        @Override public String apply(IJobKey jobKey) {
+        @Override
+        public String apply(IJobKey jobKey) {
           return jobKey.getRole();
         }
       };
 
   public static final Function<IJobKey, String> TO_ENVIRONMENT =
       new Function<IJobKey, String>() {
-        @Override public String apply(IJobKey jobKey) {
+        @Override
+        public String apply(IJobKey jobKey) {
           return jobKey.getEnvironment();
         }
       };
 
   public static final Function<IJobKey, String> TO_JOB_NAME =
       new Function<IJobKey, String>() {
-        @Override public String apply(IJobKey jobKey) {
+        @Override
+        public String apply(IJobKey jobKey) {
           return jobKey.getName();
         }
       };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/base/Tasks.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/base/Tasks.java b/src/main/java/org/apache/aurora/scheduler/base/Tasks.java
index 2216b20..0375b96 100644
--- a/src/main/java/org/apache/aurora/scheduler/base/Tasks.java
+++ b/src/main/java/org/apache/aurora/scheduler/base/Tasks.java
@@ -46,14 +46,16 @@ public final class Tasks {
 
   public static final Function<IScheduledTask, IAssignedTask> SCHEDULED_TO_ASSIGNED =
       new Function<IScheduledTask, IAssignedTask>() {
-        @Override public IAssignedTask apply(IScheduledTask task) {
+        @Override
+        public IAssignedTask apply(IScheduledTask task) {
           return task.getAssignedTask();
         }
       };
 
   public static final Function<IAssignedTask, ITaskConfig> ASSIGNED_TO_INFO =
       new Function<IAssignedTask, ITaskConfig>() {
-        @Override public ITaskConfig apply(IAssignedTask task) {
+        @Override
+        public ITaskConfig apply(IAssignedTask task) {
           return task.getTask();
         }
       };
@@ -63,7 +65,8 @@ public final class Tasks {
 
   public static final Function<IAssignedTask, String> ASSIGNED_TO_ID =
       new Function<IAssignedTask, String>() {
-        @Override public String apply(IAssignedTask task) {
+        @Override
+        public String apply(IAssignedTask task) {
           return task.getTaskId();
         }
       };
@@ -73,7 +76,8 @@ public final class Tasks {
 
   public static final Function<IAssignedTask, Integer> ASSIGNED_TO_INSTANCE_ID =
       new Function<IAssignedTask, Integer>() {
-        @Override public Integer apply(IAssignedTask task) {
+        @Override
+        public Integer apply(IAssignedTask task) {
           return task.getInstanceId();
         }
       };
@@ -83,7 +87,8 @@ public final class Tasks {
 
   public static final Function<ITaskConfig, IJobKey> INFO_TO_JOB_KEY =
       new Function<ITaskConfig, IJobKey>() {
-        @Override public IJobKey apply(ITaskConfig task) {
+        @Override
+        public IJobKey apply(ITaskConfig task) {
           return JobKeys.from(task);
         }
       };
@@ -96,7 +101,8 @@ public final class Tasks {
 
   public static final Function<IAssignedTask, String> ASSIGNED_TO_SLAVE_HOST =
       new Function<IAssignedTask, String>() {
-        @Override public String apply(IAssignedTask task) {
+        @Override
+        public String apply(IAssignedTask task) {
           return task.getSlaveHost();
         }
       };
@@ -118,14 +124,16 @@ public final class Tasks {
 
   public static final Predicate<ITaskConfig> IS_PRODUCTION =
       new Predicate<ITaskConfig>() {
-        @Override public boolean apply(ITaskConfig task) {
+        @Override
+        public boolean apply(ITaskConfig task) {
           return task.isProduction();
         }
       };
 
   public static final Function<IScheduledTask, ScheduleStatus> GET_STATUS =
       new Function<IScheduledTask, ScheduleStatus>() {
-        @Override public ScheduleStatus apply(IScheduledTask task) {
+        @Override
+        public ScheduleStatus apply(IScheduledTask task) {
           return task.getStatus();
         }
       };
@@ -194,7 +202,8 @@ public final class Tasks {
 
   public static final Ordering<IScheduledTask> LATEST_ACTIVITY = Ordering.natural()
       .onResultOf(new Function<IScheduledTask, Long>() {
-        @Override public Long apply(IScheduledTask task) {
+        @Override
+        public Long apply(IScheduledTask task) {
           return getLatestEvent(task).getTimestamp();
         }
       });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/configuration/ConfigurationManager.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/configuration/ConfigurationManager.java b/src/main/java/org/apache/aurora/scheduler/configuration/ConfigurationManager.java
index c75241e..388926c 100644
--- a/src/main/java/org/apache/aurora/scheduler/configuration/ConfigurationManager.java
+++ b/src/main/java/org/apache/aurora/scheduler/configuration/ConfigurationManager.java
@@ -76,7 +76,8 @@ public final class ConfigurationManager {
       this.defaultValue = defaultValue;
     }
 
-    @Override public void execute(TaskConfig task) {
+    @Override
+    public void execute(TaskConfig task) {
       if (!task.isSet(field)) {
         task.setFieldValue(field, defaultValue);
       }
@@ -96,7 +97,8 @@ public final class ConfigurationManager {
       this.label = label;
     }
 
-    @Override public void validate(Number value) throws TaskDescriptionException {
+    @Override
+    public void validate(Number value) throws TaskDescriptionException {
       if (this.min >= value.doubleValue()) {
         throw new TaskDescriptionException(label + " must be greater than " + this.min);
       }
@@ -133,14 +135,16 @@ public final class ConfigurationManager {
           new DefaultField(_Fields.CONSTRAINTS, Sets.<Constraint>newHashSet()),
           new DefaultField(_Fields.ENVIRONMENT, DEFAULT_ENVIRONMENT),
           new Closure<TaskConfig>() {
-            @Override public void execute(TaskConfig task) {
+            @Override
+            public void execute(TaskConfig task) {
               if (!Iterables.any(task.getConstraints(), hasName(HOST_CONSTRAINT))) {
                 task.addToConstraints(hostLimitConstraint(1));
               }
             }
           },
           new Closure<TaskConfig>() {
-            @Override public void execute(TaskConfig task) {
+            @Override
+            public void execute(TaskConfig task) {
               if (!isDedicated(ITaskConfig.build(task))
                   && task.isProduction()
                   && task.isIsService()
@@ -344,7 +348,8 @@ public final class ConfigurationManager {
    */
   public static Predicate<IConstraint> getConstraintByName(final String name) {
     return new Predicate<IConstraint>() {
-      @Override public boolean apply(IConstraint constraint) {
+      @Override
+      public boolean apply(IConstraint constraint) {
         return constraint.getName().equals(name);
       }
     };
@@ -363,7 +368,8 @@ public final class ConfigurationManager {
   private static Predicate<Constraint> hasName(final String name) {
     MorePreconditions.checkNotBlank(name);
     return new Predicate<Constraint>() {
-      @Override public boolean apply(Constraint constraint) {
+      @Override
+      public boolean apply(Constraint constraint) {
         return name.equals(constraint.getName());
       }
     };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/configuration/Resources.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/configuration/Resources.java b/src/main/java/org/apache/aurora/scheduler/configuration/Resources.java
index dbad761..a200875 100644
--- a/src/main/java/org/apache/aurora/scheduler/configuration/Resources.java
+++ b/src/main/java/org/apache/aurora/scheduler/configuration/Resources.java
@@ -60,7 +60,8 @@ public class Resources {
 
   private static final Function<Range, Set<Integer>> RANGE_TO_MEMBERS =
       new Function<Range, Set<Integer>>() {
-        @Override public Set<Integer> apply(Range range) {
+        @Override
+        public Set<Integer> apply(Range range) {
           return ContiguousSet.create(
               com.google.common.collect.Range.closed((int) range.getBegin(), (int) range.getEnd()),
               DiscreteDomain.integers());
@@ -267,7 +268,8 @@ public class Resources {
 
   private static Predicate<Resource> withName(final String name) {
     return new Predicate<Resource>() {
-      @Override public boolean apply(Resource resource) {
+      @Override
+      public boolean apply(Resource resource) {
         return resource.getName().equals(name);
       }
     };
@@ -296,7 +298,8 @@ public class Resources {
 
   private static final Function<com.google.common.collect.Range<Integer>, Range> RANGE_TRANSFORM =
       new Function<com.google.common.collect.Range<Integer>, Range>() {
-        @Override public Range apply(com.google.common.collect.Range<Integer> input) {
+        @Override
+        public Range apply(com.google.common.collect.Range<Integer> input) {
           return Range.newBuilder()
               .setBegin(input.lowerEndpoint())
               .setEnd(input.upperEndpoint())
@@ -401,7 +404,8 @@ public class Resources {
    * or equal to the other.
    */
   public static final Ordering<Resources> RESOURCE_ORDER = new Ordering<Resources>() {
-    @Override public int compare(Resources left, Resources right) {
+    @Override
+    public int compare(Resources left, Resources right) {
       int diskC = left.getDisk().compareTo(right.getDisk());
       int ramC = left.getRam().compareTo(right.getRam());
       int portC = Integer.compare(left.getNumPorts(), right.getNumPorts());
@@ -427,19 +431,22 @@ public class Resources {
   };
 
   private static final Predicate<Integer> IS_POSITIVE = new Predicate<Integer>() {
-    @Override public boolean apply(Integer input) {
+    @Override
+    public boolean apply(Integer input) {
       return input > 0;
     }
   };
 
   private static final Predicate<Integer> IS_NEGATIVE = new Predicate<Integer>() {
-    @Override public boolean apply(Integer input) {
+    @Override
+    public boolean apply(Integer input) {
       return input < 0;
     }
   };
 
   private static final Predicate<Integer> IS_ZERO = new Predicate<Integer>() {
-    @Override public boolean apply(Integer input) {
+    @Override
+    public boolean apply(Integer input) {
       return input == 0;
     }
   };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/cron/testing/AbstractCronIT.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/cron/testing/AbstractCronIT.java b/src/main/java/org/apache/aurora/scheduler/cron/testing/AbstractCronIT.java
index 54b6fab..076a745 100644
--- a/src/main/java/org/apache/aurora/scheduler/cron/testing/AbstractCronIT.java
+++ b/src/main/java/org/apache/aurora/scheduler/cron/testing/AbstractCronIT.java
@@ -62,7 +62,8 @@ public abstract class AbstractCronIT extends EasyMockTest {
     scheduler.start();
     final CountDownLatch cronRan = new CountDownLatch(1);
     scheduler.schedule("* * * * *", new Runnable() {
-      @Override public void run() {
+      @Override
+      public void run() {
         cronRan.countDown();
       }
     });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/events/PubsubEventModule.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/events/PubsubEventModule.java b/src/main/java/org/apache/aurora/scheduler/events/PubsubEventModule.java
index ebdede9..385cab3 100644
--- a/src/main/java/org/apache/aurora/scheduler/events/PubsubEventModule.java
+++ b/src/main/java/org/apache/aurora/scheduler/events/PubsubEventModule.java
@@ -65,7 +65,8 @@ public final class PubsubEventModule extends AbstractModule {
     bind(EventBus.class).toInstance(eventBus);
 
     EventSink eventSink = new EventSink() {
-      @Override public void post(PubsubEvent event) {
+      @Override
+      public void post(PubsubEvent event) {
         eventBus.post(event);
       }
     };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/filter/AttributeFilter.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/filter/AttributeFilter.java b/src/main/java/org/apache/aurora/scheduler/filter/AttributeFilter.java
index 93ba8d7..3e74135 100644
--- a/src/main/java/org/apache/aurora/scheduler/filter/AttributeFilter.java
+++ b/src/main/java/org/apache/aurora/scheduler/filter/AttributeFilter.java
@@ -35,7 +35,8 @@ final class AttributeFilter {
 
   private static final Function<Attribute, Set<String>> GET_VALUES =
       new Function<Attribute, Set<String>>() {
-        @Override public Set<String> apply(Attribute attribute) {
+        @Override
+        public Set<String> apply(Attribute attribute) {
           return attribute.getValues();
         }
       };
@@ -73,7 +74,8 @@ final class AttributeFilter {
       final AttributeLoader attributeFetcher) {
 
     Predicate<IScheduledTask> hasAttribute = new Predicate<IScheduledTask>() {
-      @Override public boolean apply(IScheduledTask task) {
+      @Override
+      public boolean apply(IScheduledTask task) {
         Iterable<Attribute> hostAttributes =
             attributeFetcher.apply(task.getAssignedTask().getSlaveHost());
         return Iterables.any(hostAttributes, Predicates.in(attributes));

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/filter/ConstraintFilter.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/filter/ConstraintFilter.java b/src/main/java/org/apache/aurora/scheduler/filter/ConstraintFilter.java
index 8c2313c..c2b9f04 100644
--- a/src/main/java/org/apache/aurora/scheduler/filter/ConstraintFilter.java
+++ b/src/main/java/org/apache/aurora/scheduler/filter/ConstraintFilter.java
@@ -122,7 +122,8 @@ class ConstraintFilter implements Function<IConstraint, Optional<Veto>> {
       this.attributeName = attributeName;
     }
 
-    @Override public boolean apply(Attribute attribute) {
+    @Override
+    public boolean apply(Attribute attribute) {
       return attributeName.equals(attribute.getName());
     }
   }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/filter/SchedulingFilterImpl.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/filter/SchedulingFilterImpl.java b/src/main/java/org/apache/aurora/scheduler/filter/SchedulingFilterImpl.java
index 3420b06..93355c3 100644
--- a/src/main/java/org/apache/aurora/scheduler/filter/SchedulingFilterImpl.java
+++ b/src/main/java/org/apache/aurora/scheduler/filter/SchedulingFilterImpl.java
@@ -97,7 +97,8 @@ public class SchedulingFilterImpl implements SchedulingFilter {
    * Convenience class for a rule that will only ever have a single veto.
    */
   private abstract static class SingleVetoRule implements FilterRule {
-    @Override public final Iterable<Veto> apply(ITaskConfig task) {
+    @Override
+    public final Iterable<Veto> apply(ITaskConfig task) {
       return doApply(task).asSet();
     }
 
@@ -148,27 +149,31 @@ public class SchedulingFilterImpl implements SchedulingFilter {
   private Iterable<FilterRule> rulesFromOffer(final ResourceSlot available) {
     return ImmutableList.<FilterRule>of(
         new SingleVetoRule() {
-          @Override public Optional<Veto> doApply(ITaskConfig task) {
+          @Override
+          public Optional<Veto> doApply(ITaskConfig task) {
             return CPU.maybeVeto(
                 available.getNumCpus(),
                 ResourceSlot.from(task).getNumCpus());
           }
         },
         new SingleVetoRule() {
-          @Override public Optional<Veto> doApply(ITaskConfig task) {
+          @Override
+          public Optional<Veto> doApply(ITaskConfig task) {
             return RAM.maybeVeto(
                 available.getRam().as(Data.MB),
                 ResourceSlot.from(task).getRam().as(Data.MB));
           }
         },
         new SingleVetoRule() {
-          @Override public Optional<Veto> doApply(ITaskConfig task) {
+          @Override
+          public Optional<Veto> doApply(ITaskConfig task) {
             return DISK.maybeVeto(available.getDisk().as(Data.MB),
                 ResourceSlot.from(task).getDisk().as(Data.MB));
           }
         },
         new SingleVetoRule() {
-          @Override public Optional<Veto> doApply(ITaskConfig task) {
+          @Override
+          public Optional<Veto> doApply(ITaskConfig task) {
             return PORTS.maybeVeto(available.getNumPorts(),
                 ResourceSlot.from(task).getNumPorts());
           }
@@ -182,7 +187,8 @@ public class SchedulingFilterImpl implements SchedulingFilter {
 
   private static final Ordering<IConstraint> VALUES_FIRST = Ordering.from(
       new Comparator<IConstraint>() {
-        @Override public int compare(IConstraint a, IConstraint b) {
+        @Override
+        public int compare(IConstraint a, IConstraint b) {
           if (a.getConstraint().getSetField() == b.getConstraint().getSetField()) {
             return 0;
           }
@@ -192,7 +198,8 @@ public class SchedulingFilterImpl implements SchedulingFilter {
 
   private FilterRule getConstraintFilter(final CachedJobState jobState, final String slaveHost) {
     return new FilterRule() {
-      @Override public Iterable<Veto> apply(final ITaskConfig task) {
+      @Override
+      public Iterable<Veto> apply(final ITaskConfig task) {
         if (!task.isSetConstraints()) {
           return ImmutableList.of();
         }
@@ -202,9 +209,11 @@ public class SchedulingFilterImpl implements SchedulingFilter {
         // to correctly satisfy a diversity constraint.  Given that the likelihood is relatively low
         // for both of these, and the impact is also low, the weak consistency is acceptable.
         return storage.weaklyConsistentRead(new Quiet<Iterable<Veto>>() {
-          @Override public Iterable<Veto> apply(final StoreProvider storeProvider) {
+          @Override
+          public Iterable<Veto> apply(final StoreProvider storeProvider) {
             AttributeLoader attributeLoader = new AttributeLoader() {
-              @Override public Iterable<Attribute> apply(String host) {
+              @Override
+              public Iterable<Attribute> apply(String host) {
                 return AttributeStore.Util.attributesOrNone(storeProvider, host);
               }
             };
@@ -251,7 +260,8 @@ public class SchedulingFilterImpl implements SchedulingFilter {
   private boolean isDedicated(final String slaveHost) {
     Iterable<Attribute> slaveAttributes =
         storage.weaklyConsistentRead(new Quiet<Iterable<Attribute>>() {
-          @Override public Iterable<Attribute> apply(final StoreProvider storeProvider) {
+          @Override
+          public Iterable<Attribute> apply(final StoreProvider storeProvider) {
             return AttributeStore.Util.attributesOrNone(storeProvider, slaveHost);
           }
         });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/http/DisplayUtils.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/http/DisplayUtils.java b/src/main/java/org/apache/aurora/scheduler/http/DisplayUtils.java
index 6870fd8..19df788 100644
--- a/src/main/java/org/apache/aurora/scheduler/http/DisplayUtils.java
+++ b/src/main/java/org/apache/aurora/scheduler/http/DisplayUtils.java
@@ -38,7 +38,8 @@ public final class DisplayUtils {
 
   static final Ordering<Job> JOB_ORDERING = Ordering.natural().onResultOf(
       new Function<Job, String>() {
-        @Override public String apply(Job job) {
+        @Override
+        public String apply(Job job) {
           return job.getName();
         }
       });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/http/HttpStatsFilter.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/http/HttpStatsFilter.java b/src/main/java/org/apache/aurora/scheduler/http/HttpStatsFilter.java
index 360a8f4..7de0b66 100644
--- a/src/main/java/org/apache/aurora/scheduler/http/HttpStatsFilter.java
+++ b/src/main/java/org/apache/aurora/scheduler/http/HttpStatsFilter.java
@@ -36,7 +36,8 @@ public class HttpStatsFilter extends AbstractHttpFilter {
 
   private final LoadingCache<Integer, SlidingStats> counters = CacheBuilder.newBuilder()
       .build(new CacheLoader<Integer, SlidingStats>() {
-        @Override public SlidingStats load(Integer status) {
+        @Override
+        public SlidingStats load(Integer status) {
           return new SlidingStats("http_" + status + "_responses", "nanos");
         }
       });
@@ -49,12 +50,14 @@ public class HttpStatsFilter extends AbstractHttpFilter {
       super(resp);
     }
 
-    @Override public void setStatus(int sc) {
+    @Override
+    public void setStatus(int sc) {
       super.setStatus(sc);
       wrappedStatus = sc;
     }
 
-    @Override public void setStatus(int sc, String sm) {
+    @Override
+    public void setStatus(int sc, String sm) {
       super.setStatus(sc, sm);
       wrappedStatus = sc;
     }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/http/LeaderRedirect.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/http/LeaderRedirect.java b/src/main/java/org/apache/aurora/scheduler/http/LeaderRedirect.java
index 3b6cbf5..7797578 100644
--- a/src/main/java/org/apache/aurora/scheduler/http/LeaderRedirect.java
+++ b/src/main/java/org/apache/aurora/scheduler/http/LeaderRedirect.java
@@ -149,7 +149,8 @@ public class LeaderRedirect {
    * Monitor to track scheduler leader changes.
    */
   private class SchedulerMonitor implements HostChangeMonitor<ServiceInstance> {
-    @Override public void onChange(ImmutableSet<ServiceInstance> hostSet) {
+    @Override
+    public void onChange(ImmutableSet<ServiceInstance> hostSet) {
       switch (hostSet.size()) {
         case 0:
           LOG.warning("No schedulers in host set, will not redirect despite not being leader.");

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/http/Maintenance.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/http/Maintenance.java b/src/main/java/org/apache/aurora/scheduler/http/Maintenance.java
index fbba9f8..7337044 100644
--- a/src/main/java/org/apache/aurora/scheduler/http/Maintenance.java
+++ b/src/main/java/org/apache/aurora/scheduler/http/Maintenance.java
@@ -60,7 +60,8 @@ public class Maintenance {
   @Produces(MediaType.APPLICATION_JSON)
   public Response getHosts() {
     return storage.weaklyConsistentRead(new Work.Quiet<Response>() {
-      @Override public Response apply(StoreProvider storeProvider) {
+      @Override
+      public Response apply(StoreProvider storeProvider) {
         Multimap<MaintenanceMode, String> hostsByMode =
             Multimaps.transformValues(
               Multimaps.index(storeProvider.getAttributeStore().getHostAttributes(), GET_MODE),
@@ -87,14 +88,16 @@ public class Maintenance {
 
   private static final Function<HostAttributes, String> HOST_NAME =
       new Function<HostAttributes, String>() {
-        @Override public String apply(HostAttributes attributes) {
+        @Override
+        public String apply(HostAttributes attributes) {
           return attributes.getHost();
         }
       };
 
   private static final Function<HostAttributes, MaintenanceMode> GET_MODE =
       new Function<HostAttributes, MaintenanceMode>() {
-        @Override public MaintenanceMode apply(HostAttributes attrs) {
+        @Override
+        public MaintenanceMode apply(HostAttributes attrs) {
           return attrs.getMode();
         }
       };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/http/Offers.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/http/Offers.java b/src/main/java/org/apache/aurora/scheduler/http/Offers.java
index 63a2524..202e781 100644
--- a/src/main/java/org/apache/aurora/scheduler/http/Offers.java
+++ b/src/main/java/org/apache/aurora/scheduler/http/Offers.java
@@ -63,20 +63,23 @@ public class Offers {
 
   private static final Function<ExecutorID, String> EXECUTOR_ID_TOSTRING =
       new Function<ExecutorID, String>() {
-        @Override public String apply(ExecutorID id) {
+        @Override
+        public String apply(ExecutorID id) {
           return id.getValue();
         }
       };
 
   private static final Function<Range, Object> RANGE_TO_BEAN = new Function<Range, Object>() {
-    @Override public Object apply(Range range) {
+    @Override
+    public Object apply(Range range) {
       return range.getBegin() + "-" + range.getEnd();
     }
   };
 
   private static final Function<Attribute, Object> ATTRIBUTE_TO_BEAN =
       new Function<Attribute, Object>() {
-        @Override public Object apply(Attribute attr) {
+        @Override
+        public Object apply(Attribute attr) {
           ImmutableMap.Builder<String, Object> builder = ImmutableMap.builder();
           builder.put("name", attr.getName());
           if (attr.hasScalar()) {
@@ -97,7 +100,8 @@ public class Offers {
 
   private static final Function<Resource, Object> RESOURCE_TO_BEAN =
       new Function<Resource, Object>() {
-        @Override public Object apply(Resource resource) {
+        @Override
+        public Object apply(Resource resource) {
           ImmutableMap.Builder<String, Object> builder = ImmutableMap.builder();
           builder.put("name", resource.getName());
           if (resource.hasScalar()) {
@@ -119,7 +123,8 @@ public class Offers {
 
   private static final Function<Offer, Map<String, ?>> TO_BEAN =
       new Function<Offer, Map<String, ?>>() {
-        @Override public Map<String, ?> apply(Offer offer) {
+        @Override
+        public Map<String, ?> apply(Offer offer) {
           return ImmutableMap.<String, Object>builder()
               .put("id", offer.getId().getValue())
               .put("framework_id", offer.getFrameworkId().getValue())

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/http/Quotas.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/http/Quotas.java b/src/main/java/org/apache/aurora/scheduler/http/Quotas.java
index 899e993..5f7e34e 100644
--- a/src/main/java/org/apache/aurora/scheduler/http/Quotas.java
+++ b/src/main/java/org/apache/aurora/scheduler/http/Quotas.java
@@ -59,7 +59,8 @@ public class Quotas {
   @Produces(MediaType.APPLICATION_JSON)
   public Response getOffers(@QueryParam("role") final String role) {
     return storage.weaklyConsistentRead(new Work.Quiet<Response>() {
-      @Override public Response apply(StoreProvider storeProvider) {
+      @Override
+      public Response apply(StoreProvider storeProvider) {
         Map<String, IQuota> quotas;
         if (role == null) {
           quotas = storeProvider.getQuotaStore().fetchQuotas();
@@ -78,7 +79,8 @@ public class Quotas {
   }
 
   private static final Function<IQuota, QuotaBean> TO_BEAN = new Function<IQuota, QuotaBean>() {
-    @Override public QuotaBean apply(IQuota quota) {
+    @Override
+    public QuotaBean apply(IQuota quota) {
       return new QuotaBean(quota.getNumCpus(), quota.getRamMb(), quota.getDiskMb());
     }
   };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/http/SchedulerzJob.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/http/SchedulerzJob.java b/src/main/java/org/apache/aurora/scheduler/http/SchedulerzJob.java
index 1e0904f..3686a66 100644
--- a/src/main/java/org/apache/aurora/scheduler/http/SchedulerzJob.java
+++ b/src/main/java/org/apache/aurora/scheduler/http/SchedulerzJob.java
@@ -102,7 +102,8 @@ public class SchedulerzJob extends JerseyTemplateServlet {
       .build();
 
   private static final Function<Veto, String> GET_REASON = new Function<Veto, String>() {
-    @Override public String apply(Veto veto) {
+    @Override
+    public String apply(Veto veto) {
       return veto.getReason();
     }
   };
@@ -138,7 +139,8 @@ public class SchedulerzJob extends JerseyTemplateServlet {
 
   private final Function<IScheduledTask, Map<String, Object>> taskToStringMap =
       new Function<IScheduledTask, Map<String, Object>>() {
-        @Override public Map<String, Object> apply(IScheduledTask scheduledTask) {
+        @Override
+        public Map<String, Object> apply(IScheduledTask scheduledTask) {
           final IAssignedTask task = scheduledTask.getAssignedTask();
           ImmutableMap.Builder<String, Object> builder = ImmutableMap.<String, Object>builder()
             .put("taskId", task.getTaskId())
@@ -160,7 +162,8 @@ public class SchedulerzJob extends JerseyTemplateServlet {
           }
 
           Function<String, String> expander = new Function<String, String>() {
-            @Override public String apply(String input) {
+            @Override
+            public String apply(String input) {
               return expandText(input, task);
             }
           };
@@ -215,7 +218,8 @@ public class SchedulerzJob extends JerseyTemplateServlet {
 
   private static final Function<IConstraint, String> DISPLAY_CONSTRAINT =
       new Function<IConstraint, String>() {
-        @Override public String apply(IConstraint constraint) {
+        @Override
+        public String apply(IConstraint constraint) {
           StringBuilder sb = new StringBuilder().append(constraint.getName()).append(": ");
           ITaskConstraint taskConstraint = constraint.getConstraint();
           switch (taskConstraint.getSetField()) {
@@ -240,7 +244,8 @@ public class SchedulerzJob extends JerseyTemplateServlet {
 
   private static final Function<ITaskConfig, SchedulingDetails> CONFIG_TO_DETAILS =
       new Function<ITaskConfig, SchedulingDetails>() {
-        @Override public SchedulingDetails apply(ITaskConfig task) {
+        @Override
+        public SchedulingDetails apply(ITaskConfig task) {
           String resources = Joiner.on(", ").join(
               "cpu: " + task.getNumCpus(),
               "ram: " + scaleMb(task.getRamMb()),
@@ -335,7 +340,8 @@ public class SchedulerzJob extends JerseyTemplateServlet {
       @QueryParam(ADMIN_VIEW_PARAM) final String adminView) {
 
     return fillTemplate(new Closure<StringTemplate>() {
-      @Override public void execute(StringTemplate template) {
+      @Override
+      public void execute(StringTemplate template) {
         template.setAttribute("cluster_name", clusterName);
         template.setAttribute(ADMIN_VIEW_PARAM, adminView != null);
         IJobKey jobKey = JobKeys.from(role, environment, job);


Mime
View raw message