aurora-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ma...@apache.org
Subject [3/4] Moving @Override to a separate line to comply with IntelliJ editor.
Date Wed, 05 Feb 2014 02:10:30 GMT
http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/http/SchedulerzRole.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/http/SchedulerzRole.java b/src/main/java/org/apache/aurora/scheduler/http/SchedulerzRole.java
index 4cfe6fe..4cb5882 100644
--- a/src/main/java/org/apache/aurora/scheduler/http/SchedulerzRole.java
+++ b/src/main/java/org/apache/aurora/scheduler/http/SchedulerzRole.java
@@ -128,7 +128,8 @@ public class SchedulerzRole extends JerseyTemplateServlet {
 
   private Response processRequest(final Optional<String> role, final Optional<String> environment) {
     return fillTemplate(new Closure<StringTemplate>() {
-      @Override public void execute(StringTemplate template) {
+      @Override
+      public void execute(StringTemplate template) {
 
         if (!role.isPresent()) {
           template.setAttribute("exception", "Please specify a user.");
@@ -181,7 +182,8 @@ public class SchedulerzRole extends JerseyTemplateServlet {
       final Optional<String> environment) {
 
     Predicate<IJobConfiguration> byRoleEnv = new Predicate<IJobConfiguration>() {
-      @Override public boolean apply(IJobConfiguration job) {
+      @Override
+      public boolean apply(IJobConfiguration job) {
         boolean roleMatch = job.getOwner().getRole().equals(role);
         boolean envMatch = !environment.isPresent()
             || job.getKey().getEnvironment().equals(environment.get());
@@ -195,7 +197,8 @@ public class SchedulerzRole extends JerseyTemplateServlet {
 
     return Maps.transformValues(Maps.uniqueIndex(jobs, JobKeys.FROM_CONFIG),
         new Function<IJobConfiguration, Map<?, ?>>() {
-          @Override public Map<?, ?> apply(IJobConfiguration job) {
+          @Override
+          public Map<?, ?> apply(IJobConfiguration job) {
             return ImmutableMap.<Object, Object>builder()
                 .put("jobKey", job.getKey())
                 .put("name", job.getKey().getName())
@@ -233,7 +236,8 @@ public class SchedulerzRole extends JerseyTemplateServlet {
 
     final Function<Map.Entry<IJobKey, Collection<IScheduledTask>>, Job> toJob =
         new Function<Map.Entry<IJobKey, Collection<IScheduledTask>>, Job>() {
-          @Override public Job apply(Map.Entry<IJobKey, Collection<IScheduledTask>> tasksByJobKey) {
+          @Override
+          public Job apply(Map.Entry<IJobKey, Collection<IScheduledTask>> tasksByJobKey) {
             IJobKey jobKey = tasksByJobKey.getKey();
             Collection<IScheduledTask> tasks = tasksByJobKey.getValue();
 

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/http/ServletModule.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/http/ServletModule.java b/src/main/java/org/apache/aurora/scheduler/http/ServletModule.java
index 60ce15c..ba37e26 100644
--- a/src/main/java/org/apache/aurora/scheduler/http/ServletModule.java
+++ b/src/main/java/org/apache/aurora/scheduler/http/ServletModule.java
@@ -78,7 +78,8 @@ public class ServletModule extends AbstractModule {
         }
       }
 
-      @Override protected void configureServlets() {
+      @Override
+      protected void configureServlets() {
         bind(HttpStatsFilter.class).in(Singleton.class);
         filter("/scheduler*").through(HttpStatsFilter.class);
         // Servlets may assign a special meaning to trailing /, but this confuses AngularJS's
@@ -244,7 +245,8 @@ public class ServletModule extends AbstractModule {
       this.redirector = Preconditions.checkNotNull(redirector);
     }
 
-    @Override public void execute() throws MonitorException {
+    @Override
+    public void execute() throws MonitorException {
       redirector.monitor();
     }
   }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/http/Slaves.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/http/Slaves.java b/src/main/java/org/apache/aurora/scheduler/http/Slaves.java
index 336b3c1..cc8971c 100644
--- a/src/main/java/org/apache/aurora/scheduler/http/Slaves.java
+++ b/src/main/java/org/apache/aurora/scheduler/http/Slaves.java
@@ -64,7 +64,8 @@ public class Slaves extends JerseyTemplateServlet {
 
   private Iterable<HostAttributes> getHostAttributes() {
     return storage.weaklyConsistentRead(new Work.Quiet<Iterable<HostAttributes>>() {
-      @Override public Iterable<HostAttributes> apply(StoreProvider storeProvider) {
+      @Override
+      public Iterable<HostAttributes> apply(StoreProvider storeProvider) {
         return storeProvider.getAttributeStore().getHostAttributes();
       }
     });
@@ -72,7 +73,8 @@ public class Slaves extends JerseyTemplateServlet {
 
   private static final Function<HostAttributes, Slave> TO_SLAVE =
       new Function<HostAttributes, Slave>() {
-        @Override public Slave apply(HostAttributes attributes) {
+        @Override
+        public Slave apply(HostAttributes attributes) {
           return new Slave(attributes);
         }
       };
@@ -86,7 +88,8 @@ public class Slaves extends JerseyTemplateServlet {
   @Produces(MediaType.TEXT_HTML)
   public Response get() {
     return fillTemplate(new Closure<StringTemplate>() {
-      @Override public void execute(StringTemplate template) {
+      @Override
+      public void execute(StringTemplate template) {
         template.setAttribute("cluster_name", clusterName);
 
         template.setAttribute("slaves",
@@ -97,7 +100,8 @@ public class Slaves extends JerseyTemplateServlet {
 
   private static final Ordering<Attribute> ATTR_ORDER = Ordering.natural().onResultOf(
       new Function<Attribute, String>() {
-        @Override public String apply(Attribute attr) {
+        @Override
+        public String apply(Attribute attr) {
           return attr .getName();
         }
       });
@@ -126,7 +130,8 @@ public class Slaves extends JerseyTemplateServlet {
 
     private static final Function<Attribute, String> ATTR_TO_STRING =
         new Function<Attribute, String>() {
-          @Override public String apply(Attribute attr) {
+          @Override
+          public String apply(Attribute attr) {
             return attr.getName() + "=[" + Joiner.on(",").join(attr.getValues()) + "]";
           }
         };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/http/StructDump.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/http/StructDump.java b/src/main/java/org/apache/aurora/scheduler/http/StructDump.java
index e324dd6..b7a33a6 100644
--- a/src/main/java/org/apache/aurora/scheduler/http/StructDump.java
+++ b/src/main/java/org/apache/aurora/scheduler/http/StructDump.java
@@ -78,7 +78,8 @@ public class StructDump extends JerseyTemplateServlet {
       @PathParam("task") final String taskId) {
 
     return dumpEntity("Task " + taskId, new Work.Quiet<Optional<? extends TBase<?, ?>>>() {
-      @Override public Optional<? extends TBase<?, ?>> apply(StoreProvider storeProvider) {
+      @Override
+      public Optional<? extends TBase<?, ?>> apply(StoreProvider storeProvider) {
         // Deep copy the struct to sidestep any subclass trickery inside the storage system.
         return Optional.fromNullable(Iterables.getOnlyElement(
                 storeProvider.getTaskStore().fetchTasks(Query.taskScoped(taskId)),
@@ -104,7 +105,8 @@ public class StructDump extends JerseyTemplateServlet {
     final IJobKey jobKey = JobKeys.from(role, environment, job);
     return dumpEntity("Cron job " + JobKeys.toPath(jobKey),
         new Work.Quiet<Optional<? extends TBase<?, ?>>>() {
-          @Override public Optional<JobConfiguration> apply(StoreProvider storeProvider) {
+          @Override
+          public Optional<JobConfiguration> apply(StoreProvider storeProvider) {
             return storeProvider.getJobStore().fetchJob(CronJobManager.MANAGER_KEY, jobKey)
                 .transform(IJobConfiguration.TO_BUILDER);
           }
@@ -113,7 +115,8 @@ public class StructDump extends JerseyTemplateServlet {
 
   private Response dumpEntity(final String id, final Quiet<Optional<? extends TBase<?, ?>>> work) {
     return fillTemplate(new Closure<StringTemplate>() {
-      @Override public void execute(StringTemplate template) {
+      @Override
+      public void execute(StringTemplate template) {
         template.setAttribute("id", id);
         Optional<? extends TBase<?, ?>> struct = storage.weaklyConsistentRead(work);
         if (!struct.isPresent()) {

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/http/TransformationUtils.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/http/TransformationUtils.java b/src/main/java/org/apache/aurora/scheduler/http/TransformationUtils.java
index 3d3b6cd..b6ee04e 100644
--- a/src/main/java/org/apache/aurora/scheduler/http/TransformationUtils.java
+++ b/src/main/java/org/apache/aurora/scheduler/http/TransformationUtils.java
@@ -31,14 +31,16 @@ import org.apache.aurora.scheduler.storage.entities.IPackage;
 final class TransformationUtils {
   public static final Function<IPackage, String> PACKAGE_TOSTRING =
       new Function<IPackage, String>() {
-        @Override public String apply(IPackage pkg) {
+        @Override
+        public String apply(IPackage pkg) {
           return pkg.getRole() + "/" + pkg.getName() + " v" + pkg.getVersion();
         }
       };
 
   public static final Function<Range<Integer>, String> RANGE_TOSTRING =
       new Function<Range<Integer>, String>() {
-        @Override public String apply(Range<Integer> range) {
+        @Override
+        public String apply(Range<Integer> range) {
           int lower = range.lowerEndpoint();
           int upper = range.upperEndpoint();
           return (lower == upper) ? String.valueOf(lower) : (lower + " - " + upper);
@@ -47,7 +49,8 @@ final class TransformationUtils {
 
   public static final Function<Collection<Integer>, String> INSTANCES_TOSTRING =
       new Function<Collection<Integer>, String>() {
-        @Override public String apply(Collection<Integer> instances) {
+        @Override
+        public String apply(Collection<Integer> instances) {
           return Joiner.on(", ")
               .join(Iterables.transform(Numbers.toRanges(instances), RANGE_TOSTRING));
         }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/http/Utilization.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/http/Utilization.java b/src/main/java/org/apache/aurora/scheduler/http/Utilization.java
index 437f8a8..0cbdeea 100644
--- a/src/main/java/org/apache/aurora/scheduler/http/Utilization.java
+++ b/src/main/java/org/apache/aurora/scheduler/http/Utilization.java
@@ -67,7 +67,8 @@ public class Utilization {
   private String fillTemplate(Map<Display, Metric> metrics) {
     Function<Entry<Display, Metric>, DisplayMetric> transform =
         new Function<Entry<Display, Metric>, DisplayMetric>() {
-          @Override public DisplayMetric apply(Entry<Display, Metric> entry) {
+          @Override
+          public DisplayMetric apply(Entry<Display, Metric> entry) {
             return new DisplayMetric(entry.getKey(), entry.getValue());
           }
         };
@@ -78,7 +79,8 @@ public class Utilization {
     StringWriter output = new StringWriter();
     try {
       templateHelper.writeTemplate(output, new Closure<StringTemplate>() {
-        @Override public void execute(StringTemplate template) {
+        @Override
+        public void execute(StringTemplate template) {
           template.setAttribute("cluster_name", clusterName);
           template.setAttribute("metrics", metrics);
         }
@@ -135,7 +137,8 @@ public class Utilization {
 
   private static final Function<GlobalMetric, DisplayMetric> TO_DISPLAY =
       new Function<GlobalMetric, DisplayMetric>() {
-        @Override public DisplayMetric apply(GlobalMetric count) {
+        @Override
+        public DisplayMetric apply(GlobalMetric count) {
           return new DisplayMetric(
               new Display(
                   count.type.name().replace('_', ' ').toLowerCase(),
@@ -179,7 +182,8 @@ public class Utilization {
     final MetricType type = getTypeByName(metric);
 
     Function<ITaskConfig, Display> toKey = new Function<ITaskConfig, Display>() {
-      @Override public Display apply(ITaskConfig task) {
+      @Override
+      public Display apply(ITaskConfig task) {
         String role = task.getOwner().getRole();
         return new Display(role, metric + "/" + role);
       }
@@ -205,7 +209,8 @@ public class Utilization {
 
     MetricType type = getTypeByName(metric);
     Function<ITaskConfig, Display> toKey = new Function<ITaskConfig, Display>() {
-      @Override public Display apply(ITaskConfig task) {
+      @Override
+      public Display apply(ITaskConfig task) {
         return new Display(task.getJobName(), null);
       }
     };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/local/FakeDriverFactory.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/local/FakeDriverFactory.java b/src/main/java/org/apache/aurora/scheduler/local/FakeDriverFactory.java
index 9f191e0..45f5986 100644
--- a/src/main/java/org/apache/aurora/scheduler/local/FakeDriverFactory.java
+++ b/src/main/java/org/apache/aurora/scheduler/local/FakeDriverFactory.java
@@ -57,7 +57,8 @@ class FakeDriverFactory implements DriverFactory {
   @Override
   public SchedulerDriver apply(@Nullable final String frameworkId) {
     return new FakeSchedulerDriver() {
-      @Override public Status run() {
+      @Override
+      public Status run() {
         scheduler.get().registered(
             this,
             FrameworkID.newBuilder().setValue(
@@ -70,61 +71,73 @@ class FakeDriverFactory implements DriverFactory {
   }
 
   static class FakeSchedulerDriver implements SchedulerDriver {
-    @Override public Status start() {
+    @Override
+    public Status start() {
       return null;
     }
 
-    @Override public Status stop(boolean b) {
+    @Override
+    public Status stop(boolean b) {
       return null;
     }
 
-    @Override public Status stop() {
+    @Override
+    public Status stop() {
       return null;
     }
 
-    @Override public Status abort() {
+    @Override
+    public Status abort() {
       return null;
     }
 
-    @Override public Status join() {
+    @Override
+    public Status join() {
       return run();
     }
 
-    @Override public Status run() {
+    @Override
+    public Status run() {
       return null;
     }
 
-    @Override public Status requestResources(Collection<Request> requests) {
+    @Override
+    public Status requestResources(Collection<Request> requests) {
       return null;
     }
 
-    @Override public Status launchTasks(OfferID offerID, Collection<TaskInfo> taskInfos,
-        Filters filters) {
+    @Override
+    public Status launchTasks(OfferID offerID, Collection<TaskInfo> taskInfos, Filters filters) {
       return null;
     }
 
-    @Override public Status launchTasks(OfferID offerID, Collection<TaskInfo> taskInfos) {
+    @Override
+    public Status launchTasks(OfferID offerID, Collection<TaskInfo> taskInfos) {
       return null;
     }
 
-    @Override public Status killTask(TaskID taskID) {
+    @Override
+    public Status killTask(TaskID taskID) {
       return null;
     }
 
-    @Override public Status declineOffer(OfferID offerID, Filters filters) {
+    @Override
+    public Status declineOffer(OfferID offerID, Filters filters) {
       return null;
     }
 
-    @Override public Status declineOffer(OfferID offerID) {
+    @Override
+    public Status declineOffer(OfferID offerID) {
       return null;
     }
 
-    @Override public Status reviveOffers() {
+    @Override
+    public Status reviveOffers() {
       return null;
     }
 
-    @Override public Status sendFrameworkMessage(ExecutorID executorID, SlaveID slaveID,
-        byte[] bytes) {
+    @Override
+    public Status sendFrameworkMessage(ExecutorID executorID, SlaveID slaveID, byte[] bytes) {
       return null;
     }
 

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/local/IsolatedSchedulerModule.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/local/IsolatedSchedulerModule.java b/src/main/java/org/apache/aurora/scheduler/local/IsolatedSchedulerModule.java
index 95729e1..6ff70af 100644
--- a/src/main/java/org/apache/aurora/scheduler/local/IsolatedSchedulerModule.java
+++ b/src/main/java/org/apache/aurora/scheduler/local/IsolatedSchedulerModule.java
@@ -110,7 +110,8 @@ public class IsolatedSchedulerModule extends AbstractModule {
 
     private final AtomicLong offerId = new AtomicLong();
     private final Function<FakeSlave, Offer> slaveToOffer = new Function<FakeSlave, Offer>() {
-      @Override public Offer apply(FakeSlave slave) {
+      @Override
+      public Offer apply(FakeSlave slave) {
         return slave.makeOffer(offerId.incrementAndGet());
       }
     };
@@ -137,7 +138,8 @@ public class IsolatedSchedulerModule extends AbstractModule {
           1,
           new ThreadFactoryBuilder().setDaemon(true).setNameFormat("TaskScheduler-%d").build()) {
 
-        @Override protected void afterExecute(Runnable runnable, @Nullable Throwable throwable) {
+        @Override
+        protected void afterExecute(Runnable runnable, @Nullable Throwable throwable) {
           if (throwable != null) {
             LOG.log(Level.WARNING, "Error: " + throwable, throwable);
           } else if (runnable instanceof Future) {
@@ -152,7 +154,8 @@ public class IsolatedSchedulerModule extends AbstractModule {
       };
       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();
         }
       });
@@ -161,7 +164,8 @@ public class IsolatedSchedulerModule extends AbstractModule {
 
     private void offerClusterResources() {
       executor.submit(new Runnable() {
-        @Override public void run() {
+        @Override
+        public void run() {
           scheduler.get().resourceOffers(
               driver,
               FluentIterable.from(cluster).transform(slaveToOffer).toList());
@@ -171,7 +175,8 @@ public class IsolatedSchedulerModule extends AbstractModule {
 
     private void setQuotas() {
       executor.submit(new Runnable() {
-        @Override public void run() {
+        @Override
+        public void run() {
           try {
             thrift.setQuota(
                 "mesos",
@@ -187,7 +192,8 @@ public class IsolatedSchedulerModule extends AbstractModule {
     @Subscribe
     public void registered(DriverRegistered event) {
       executor.submit(new Runnable() {
-        @Override public void run() {
+        @Override
+        public void run() {
           Identity mesosUser = new Identity("mesos", "mesos");
           for (int i = 0; i < 20; i++) {
             JobConfiguration service = createJob("serviceJob" + i, mesosUser);
@@ -220,7 +226,8 @@ public class IsolatedSchedulerModule extends AbstractModule {
 
     private void moveTaskToState(final String taskId, final TaskState state, long delaySeconds) {
       Runnable changeState = new Runnable() {
-        @Override public void run() {
+        @Override
+        public void run() {
           scheduler.get().statusUpdate(
               driver,
               TaskStatus.newBuilder()

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/log/mesos/MesosLog.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/log/mesos/MesosLog.java b/src/main/java/org/apache/aurora/scheduler/log/mesos/MesosLog.java
index c27cfbe..a8e6c83 100644
--- a/src/main/java/org/apache/aurora/scheduler/log/mesos/MesosLog.java
+++ b/src/main/java/org/apache/aurora/scheduler/log/mesos/MesosLog.java
@@ -151,7 +151,8 @@ public class MesosLog implements org.apache.aurora.scheduler.log.Log {
 
     private static final Function<Log.Entry, LogEntry> MESOS_ENTRY_TO_ENTRY =
         new Function<Log.Entry, LogEntry>() {
-          @Override public LogEntry apply(Log.Entry entry) {
+          @Override
+          public LogEntry apply(Log.Entry entry) {
             return new LogEntry(entry);
           }
         };
@@ -278,7 +279,8 @@ public class MesosLog implements org.apache.aurora.scheduler.log.Log {
       Preconditions.checkNotNull(contents);
 
       Log.Position position = mutate(append, new Mutation<Log.Position>() {
-        @Override public Log.Position apply(WriterInterface logWriter)
+        @Override
+        public Log.Position apply(WriterInterface logWriter)
             throws TimeoutException, Log.WriterFailedException {
           return logWriter.append(contents, writeTimeout, writeTimeUnit);
         }
@@ -295,7 +297,8 @@ public class MesosLog implements org.apache.aurora.scheduler.log.Log {
 
       final Log.Position before = ((LogPosition) position).unwrap();
       mutate(truncate, new Mutation<Void>() {
-        @Override public Void apply(WriterInterface logWriter)
+        @Override
+        public Void apply(WriterInterface logWriter)
             throws TimeoutException, Log.WriterFailedException {
           logWriter.truncate(before, writeTimeout, writeTimeUnit);
           return null;
@@ -356,7 +359,8 @@ public class MesosLog implements org.apache.aurora.scheduler.log.Log {
         return underlying;
       }
 
-      @Override public int compareTo(Position o) {
+      @Override
+      public int compareTo(Position o) {
         Preconditions.checkArgument(o instanceof LogPosition);
         return underlying.compareTo(((LogPosition) o).underlying);
       }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/log/mesos/MesosLogStreamModule.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/log/mesos/MesosLogStreamModule.java b/src/main/java/org/apache/aurora/scheduler/log/mesos/MesosLogStreamModule.java
index 451f826..faa30d1 100644
--- a/src/main/java/org/apache/aurora/scheduler/log/mesos/MesosLogStreamModule.java
+++ b/src/main/java/org/apache/aurora/scheduler/log/mesos/MesosLogStreamModule.java
@@ -152,7 +152,8 @@ public class MesosLogStreamModule extends PrivateModule {
   @Provides
   LogInterface provideLogInterface(final Log log) {
     return new LogInterface() {
-      @Override public Log.Position position(byte[] identity) {
+      @Override
+      public Log.Position position(byte[] identity) {
         return log.position(identity);
       }
     };
@@ -168,11 +169,13 @@ public class MesosLogStreamModule extends PrivateModule {
         return reader.read(from, to, timeout, unit);
       }
 
-      @Override public Log.Position beginning() {
+      @Override
+      public Log.Position beginning() {
         return reader.beginning();
       }
 
-      @Override public Log.Position ending() {
+      @Override
+      public Log.Position ending() {
         return reader.ending();
       }
     };
@@ -181,12 +184,14 @@ public class MesosLogStreamModule extends PrivateModule {
   @Provides
   WriterInterface provideWriterInterface(final Log.Writer writer) {
     return new WriterInterface() {
-      @Override public Log.Position append(byte[] data, long timeout, TimeUnit unit)
+      @Override
+      public Log.Position append(byte[] data, long timeout, TimeUnit unit)
           throws TimeoutException, Log.WriterFailedException {
         return writer.append(data, timeout, unit);
       }
 
-      @Override public Log.Position truncate(Log.Position to, long timeout, TimeUnit unit)
+      @Override
+      public Log.Position truncate(Log.Position to, long timeout, TimeUnit unit)
           throws TimeoutException, Log.WriterFailedException {
         return writer.truncate(to, timeout, unit);
       }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/log/testing/FileLog.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/log/testing/FileLog.java b/src/main/java/org/apache/aurora/scheduler/log/testing/FileLog.java
index 9f061d5..5b69e4e 100644
--- a/src/main/java/org/apache/aurora/scheduler/log/testing/FileLog.java
+++ b/src/main/java/org/apache/aurora/scheduler/log/testing/FileLog.java
@@ -72,7 +72,8 @@ class FileLog implements Log {
         logContents = ThriftBinaryCodec.decode(FileLogContents.class, Files.toByteArray(logFile));
       }
       Closure<FileLogContents> logWriter = new Closure<FileLogContents>() {
-        @Override public void execute(FileLogContents logContents) {
+        @Override
+        public void execute(FileLogContents logContents) {
           try {
             Files.write(ThriftBinaryCodec.encode(logContents), logFile);
           } catch (IOException | CodingException e) {
@@ -109,9 +110,11 @@ class FileLog implements Log {
     }
 
     private static final Function<LogRecord, Entry> TO_ENTRY = new Function<LogRecord, Entry>() {
-      @Override public Entry apply(final LogRecord record) {
+      @Override
+      public Entry apply(final LogRecord record) {
         return new Entry() {
-          @Override public byte[] contents() {
+          @Override
+          public byte[] contents() {
             return record.getContents();
           }
         };
@@ -136,7 +139,8 @@ class FileLog implements Log {
 
       final long truncateBefore = ((CounterPosition) position).value;
       Iterables.removeIf(logContents.getRecords().keySet(), new Predicate<Long>() {
-        @Override public boolean apply(Long recordPosition) {
+        @Override
+        public boolean apply(Long recordPosition) {
           return recordPosition < truncateBefore;
         }
       });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/metadata/NearestFit.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/metadata/NearestFit.java b/src/main/java/org/apache/aurora/scheduler/metadata/NearestFit.java
index 96fcbc4..c328ff8 100644
--- a/src/main/java/org/apache/aurora/scheduler/metadata/NearestFit.java
+++ b/src/main/java/org/apache/aurora/scheduler/metadata/NearestFit.java
@@ -59,7 +59,8 @@ public class NearestFit implements EventSubscriber {
         .expireAfterWrite(EXPIRATION.getValue(), EXPIRATION.getUnit().getTimeUnit())
         .ticker(ticker)
         .build(new CacheLoader<String, Fit>() {
-          @Override public Fit load(String taskId) {
+          @Override
+          public Fit load(String taskId) {
             return new Fit();
           }
         });
@@ -106,7 +107,8 @@ public class NearestFit implements EventSubscriber {
   }
 
   private static final Predicate<Veto> IS_CONSTRAINT_MISMATCH = new Predicate<Veto>() {
-    @Override public boolean apply(Veto veto) {
+    @Override
+    public boolean apply(Veto veto) {
       return veto.isConstraintMismatch();
     }
   };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/quota/QuotaManager.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/quota/QuotaManager.java b/src/main/java/org/apache/aurora/scheduler/quota/QuotaManager.java
index c93e57f..9868abc 100644
--- a/src/main/java/org/apache/aurora/scheduler/quota/QuotaManager.java
+++ b/src/main/java/org/apache/aurora/scheduler/quota/QuotaManager.java
@@ -96,7 +96,8 @@ public interface QuotaManager {
       }
 
       storage.write(new Storage.MutateWork.NoResult.Quiet() {
-        @Override protected void execute(Storage.MutableStoreProvider storeProvider) {
+        @Override
+        protected void execute(Storage.MutableStoreProvider storeProvider) {
           storeProvider.getQuotaStore().saveQuota(ownerRole, quota);
         }
       });
@@ -105,7 +106,8 @@ public interface QuotaManager {
     @Override
     public QuotaInfo getQuotaInfo(final String role) {
       return storage.consistentRead(new Work.Quiet<QuotaInfo>() {
-        @Override public QuotaInfo apply(StoreProvider storeProvider) {
+        @Override
+        public QuotaInfo apply(StoreProvider storeProvider) {
           FluentIterable<ITaskConfig> tasks = FluentIterable
               .from(storeProvider.getTaskStore().fetchTasks(Query.roleScoped(role).active()))
               .transform(Tasks.SCHEDULED_TO_INFO);

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/state/CronJobManager.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/state/CronJobManager.java b/src/main/java/org/apache/aurora/scheduler/state/CronJobManager.java
index 371addf..6d16286 100644
--- a/src/main/java/org/apache/aurora/scheduler/state/CronJobManager.java
+++ b/src/main/java/org/apache/aurora/scheduler/state/CronJobManager.java
@@ -167,14 +167,16 @@ public class CronJobManager extends JobManager implements EventSubscriber {
   public void schedulerActive(SchedulerActive schedulerActive) {
     cron.start();
     shutdownRegistry.addAction(new ExceptionalCommand<CronException>() {
-      @Override public void execute() throws CronException {
+      @Override
+      public void execute() throws CronException {
         cron.stop();
       }
     });
 
     Iterable<IJobConfiguration> crons =
         storage.consistentRead(new Work.Quiet<Iterable<IJobConfiguration>>() {
-          @Override public Iterable<IJobConfiguration> apply(Storage.StoreProvider storeProvider) {
+          @Override
+          public Iterable<IJobConfiguration> apply(Storage.StoreProvider storeProvider) {
             return storeProvider.getJobStore().fetchJobs(MANAGER_KEY);
           }
         });
@@ -220,7 +222,8 @@ public class CronJobManager extends JobManager implements EventSubscriber {
       // There was no run already pending for this job, launch a task to delay launch until the
       // existing run has terminated.
       delayedRunExecutor.execute(new Runnable() {
-        @Override public void run() {
+        @Override
+        public void run() {
           runWhenTerminated(query, jobKey);
         }
       });
@@ -230,7 +233,8 @@ public class CronJobManager extends JobManager implements EventSubscriber {
   private void runWhenTerminated(final Query.Builder query, final IJobKey jobKey) {
     try {
       delayedStartBackoff.doUntilSuccess(new Supplier<Boolean>() {
-        @Override public Boolean get() {
+        @Override
+        public Boolean get() {
           if (!hasTasks(query)) {
             LOG.info("Initiating delayed launch of cron " + jobKey);
             SanitizedConfiguration config = pendingRuns.remove(jobKey);
@@ -352,7 +356,8 @@ public class CronJobManager extends JobManager implements EventSubscriber {
 
     SanitizedCronJob cronJob = new SanitizedCronJob(config, cron);
     storage.write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(Storage.MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(Storage.MutableStoreProvider storeProvider) {
         storeProvider.getJobStore().saveAcceptedJob(MANAGER_KEY, job);
       }
     });
@@ -367,7 +372,8 @@ public class CronJobManager extends JobManager implements EventSubscriber {
     LOG.info(String.format("Scheduling cron job %s: %s", jobPath, job.getCronSchedule()));
     try {
       return cron.schedule(job.getCronSchedule(), new Runnable() {
-        @Override public void run() {
+        @Override
+        public void run() {
           // TODO(William Farner): May want to record information about job runs.
           LOG.info("Running cron job: " + jobPath);
           cronTriggered(cronJob);
@@ -396,7 +402,8 @@ public class CronJobManager extends JobManager implements EventSubscriber {
   private Optional<IJobConfiguration> fetchJob(final IJobKey jobKey) {
     checkNotNull(jobKey);
     return storage.consistentRead(new Work.Quiet<Optional<IJobConfiguration>>() {
-      @Override public Optional<IJobConfiguration> apply(Storage.StoreProvider storeProvider) {
+      @Override
+      public Optional<IJobConfiguration> apply(Storage.StoreProvider storeProvider) {
         return storeProvider.getJobStore().fetchJob(MANAGER_KEY, jobKey);
       }
     });
@@ -414,7 +421,8 @@ public class CronJobManager extends JobManager implements EventSubscriber {
     if (scheduledJobKey != null) {
       cron.deschedule(scheduledJobKey);
       storage.write(new MutateWork.NoResult.Quiet() {
-        @Override protected void execute(Storage.MutableStoreProvider storeProvider) {
+        @Override
+        protected void execute(Storage.MutableStoreProvider storeProvider) {
           storeProvider.getJobStore().removeJob(jobKey);
         }
       });
@@ -424,7 +432,8 @@ public class CronJobManager extends JobManager implements EventSubscriber {
   }
 
   private final Function<String, String> keyToSchedule = new Function<String, String>() {
-    @Override public String apply(String key) {
+    @Override
+    public String apply(String key) {
       return cron.getSchedule(key).or("Not found.");
     }
   };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/state/LockManagerImpl.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/state/LockManagerImpl.java b/src/main/java/org/apache/aurora/scheduler/state/LockManagerImpl.java
index bf0a650..5696485 100644
--- a/src/main/java/org/apache/aurora/scheduler/state/LockManagerImpl.java
+++ b/src/main/java/org/apache/aurora/scheduler/state/LockManagerImpl.java
@@ -54,7 +54,8 @@ class LockManagerImpl implements LockManager {
   @Override
   public ILock acquireLock(final ILockKey lockKey, final String user) throws LockException {
     return storage.write(new MutateWork<ILock, LockException>() {
-      @Override public ILock apply(Storage.MutableStoreProvider storeProvider)
+      @Override
+      public ILock apply(Storage.MutableStoreProvider storeProvider)
           throws LockException {
 
         LockStore.Mutable lockStore = storeProvider.getLockStore();
@@ -83,7 +84,8 @@ class LockManagerImpl implements LockManager {
   @Override
   public void releaseLock(final ILock lock) {
     storage.write(new MutateWork.NoResult.Quiet() {
-      @Override public void execute(MutableStoreProvider storeProvider) {
+      @Override
+      public void execute(MutableStoreProvider storeProvider) {
         storeProvider.getLockStore().removeLock(lock.getKey());
       }
     });
@@ -94,7 +96,8 @@ class LockManagerImpl implements LockManager {
       throws LockException {
 
     Optional<ILock> stored = storage.consistentRead(new Work.Quiet<Optional<ILock>>() {
-      @Override public Optional<ILock> apply(StoreProvider storeProvider) {
+      @Override
+      public Optional<ILock> apply(StoreProvider storeProvider) {
         return storeProvider.getLockStore().fetchLock(context);
       }
     });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/state/MaintenanceController.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/state/MaintenanceController.java b/src/main/java/org/apache/aurora/scheduler/state/MaintenanceController.java
index af10d44..0e2c17b 100644
--- a/src/main/java/org/apache/aurora/scheduler/state/MaintenanceController.java
+++ b/src/main/java/org/apache/aurora/scheduler/state/MaintenanceController.java
@@ -155,7 +155,8 @@ public interface MaintenanceController {
       if (Tasks.isTerminated(change.getNewState())) {
         final String host = change.getTask().getAssignedTask().getSlaveHost();
         storage.write(new MutateWork.NoResult.Quiet() {
-          @Override public void execute(MutableStoreProvider store) {
+          @Override
+          public void execute(MutableStoreProvider store) {
             // If the task _was_ associated with a draining host, and it was the last task on the
             // host.
             Optional<HostAttributes> attributes = store.getAttributeStore().getHostAttributes(host);
@@ -173,7 +174,8 @@ public interface MaintenanceController {
     @Override
     public Set<HostStatus> startMaintenance(final Set<String> hosts) {
       return storage.write(new MutateWork.Quiet<Set<HostStatus>>() {
-        @Override public Set<HostStatus> apply(MutableStoreProvider storeProvider) {
+        @Override
+        public Set<HostStatus> apply(MutableStoreProvider storeProvider) {
           return setMaintenanceMode(storeProvider, hosts, MaintenanceMode.SCHEDULED);
         }
       });
@@ -186,7 +188,8 @@ public interface MaintenanceController {
     @Override
     public Set<HostStatus> drain(final Set<String> hosts) {
       return storage.write(new MutateWork.Quiet<Set<HostStatus>>() {
-        @Override public Set<HostStatus> apply(MutableStoreProvider store) {
+        @Override
+        public Set<HostStatus> apply(MutableStoreProvider store) {
           return watchDrainingTasks(store, hosts);
         }
       });
@@ -194,21 +197,24 @@ public interface MaintenanceController {
 
     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, HostStatus> ATTRS_TO_STATUS =
         new Function<HostAttributes, HostStatus>() {
-          @Override public HostStatus apply(HostAttributes attributes) {
+          @Override
+          public HostStatus apply(HostAttributes attributes) {
             return new HostStatus().setHost(attributes.getHost()).setMode(attributes.getMode());
           }
         };
 
     private static final Function<HostStatus, MaintenanceMode> GET_MODE =
       new Function<HostStatus, MaintenanceMode>() {
-        @Override public MaintenanceMode apply(HostStatus status) {
+        @Override
+        public MaintenanceMode apply(HostStatus status) {
           return status.getMode();
         }
       };
@@ -216,7 +222,8 @@ public interface MaintenanceController {
     @Override
     public MaintenanceMode getMode(final String host) {
       return storage.weaklyConsistentRead(new Work.Quiet<MaintenanceMode>() {
-        @Override public MaintenanceMode apply(StoreProvider storeProvider) {
+        @Override
+        public MaintenanceMode apply(StoreProvider storeProvider) {
           return storeProvider.getAttributeStore().getHostAttributes(host)
               .transform(ATTRS_TO_STATUS)
               .transform(GET_MODE)
@@ -228,7 +235,8 @@ public interface MaintenanceController {
     @Override
     public Set<HostStatus> getStatus(final Set<String> hosts) {
       return storage.weaklyConsistentRead(new Work.Quiet<Set<HostStatus>>() {
-        @Override public Set<HostStatus> apply(StoreProvider storeProvider) {
+        @Override
+        public Set<HostStatus> apply(StoreProvider storeProvider) {
           // Warning - this is filtering _all_ host attributes.  If using this to frequently query
           // for a small set of hosts, a getHostAttributes variant should be added.
           return FluentIterable.from(storeProvider.getAttributeStore().getHostAttributes())
@@ -241,7 +249,8 @@ public interface MaintenanceController {
     @Override
     public Set<HostStatus> endMaintenance(final Set<String> hosts) {
       return storage.write(new MutateWork.Quiet<Set<HostStatus>>() {
-        @Override public Set<HostStatus> apply(MutableStoreProvider storeProvider) {
+        @Override
+        public Set<HostStatus> apply(MutableStoreProvider storeProvider) {
           return setMaintenanceMode(storeProvider, hosts, MaintenanceMode.NONE);
         }
       });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/state/SchedulerCoreImpl.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/state/SchedulerCoreImpl.java b/src/main/java/org/apache/aurora/scheduler/state/SchedulerCoreImpl.java
index 8ad24f9..8b7e470 100644
--- a/src/main/java/org/apache/aurora/scheduler/state/SchedulerCoreImpl.java
+++ b/src/main/java/org/apache/aurora/scheduler/state/SchedulerCoreImpl.java
@@ -129,9 +129,8 @@ class SchedulerCoreImpl implements SchedulerCore {
       throws ScheduleException {
 
     storage.write(new MutateWork.NoResult<ScheduleException>() {
-      @Override protected void execute(MutableStoreProvider storeProvider)
-          throws ScheduleException {
-
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) throws ScheduleException {
         final IJobConfiguration job = sanitizedConfiguration.getJobConfig();
         if (hasActiveJob(job)) {
           throw new ScheduleException("Job already exists: " + JobKeys.toPath(job));
@@ -209,9 +208,8 @@ class SchedulerCoreImpl implements SchedulerCore {
       final ITaskConfig config) throws ScheduleException {
 
     storage.write(new MutateWork.NoResult<ScheduleException>() {
-      @Override protected void execute(MutableStoreProvider storeProvider)
-          throws ScheduleException {
-
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) throws ScheduleException {
         validateTaskLimits(config, instanceIds.size());
 
         ImmutableSet<IScheduledTask> tasks =
@@ -249,7 +247,8 @@ class SchedulerCoreImpl implements SchedulerCore {
    */
   private static Predicate<JobManager> managerHasJob(final IJobConfiguration job) {
     return new Predicate<JobManager>() {
-      @Override public boolean apply(JobManager manager) {
+      @Override
+      public boolean apply(JobManager manager) {
         return manager.hasJob(job.getKey());
       }
     };
@@ -293,7 +292,8 @@ class SchedulerCoreImpl implements SchedulerCore {
         : query;
 
     int tasksAffected = storage.write(new MutateWork.Quiet<Integer>() {
-      @Override public Integer apply(MutableStoreProvider storeProvider) {
+      @Override
+      public Integer apply(MutableStoreProvider storeProvider) {
         int total = 0;
         for (String taskId : Tasks.ids(storeProvider.getTaskStore().fetchTasks(taskQuery))) {
           boolean changed = stateManager.changeState(
@@ -331,9 +331,8 @@ class SchedulerCoreImpl implements SchedulerCore {
 
     final Query.Builder query = Query.instanceScoped(jobKey, shards).active();
     storage.write(new MutateWork.NoResult<ScheduleException>() {
-      @Override protected void execute(MutableStoreProvider storeProvider)
-          throws ScheduleException {
-
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) throws ScheduleException {
         Set<IScheduledTask> matchingTasks = storeProvider.getTaskStore().fetchTasks(query);
         if (matchingTasks.size() != shards.size()) {
           throw new ScheduleException("Not all requested shards are active.");

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/state/StateManagerImpl.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/state/StateManagerImpl.java b/src/main/java/org/apache/aurora/scheduler/state/StateManagerImpl.java
index 6fee43c..7371c12 100644
--- a/src/main/java/org/apache/aurora/scheduler/state/StateManagerImpl.java
+++ b/src/main/java/org/apache/aurora/scheduler/state/StateManagerImpl.java
@@ -122,13 +122,15 @@ public class StateManagerImpl implements StateManager {
     // Done outside the write transaction to minimize the work done inside a transaction.
     final Set<IScheduledTask> scheduledTasks = FluentIterable.from(tasks.entrySet())
         .transform(new Function<Entry<Integer, ITaskConfig>, IScheduledTask>() {
-          @Override public IScheduledTask apply(Entry<Integer, ITaskConfig> entry) {
+          @Override
+          public IScheduledTask apply(Entry<Integer, ITaskConfig> entry) {
             return createTask(entry.getKey(), entry.getValue());
           }
         }).toSet();
 
     storage.write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         storeProvider.getUnsafeTaskStore().saveTasks(scheduledTasks);
 
         for (IScheduledTask task : scheduledTasks) {
@@ -165,7 +167,8 @@ public class StateManagerImpl implements StateManager {
     checkNotNull(assignedPorts);
 
     return storage.write(new MutateWork.Quiet<IAssignedTask>() {
-      @Override public IAssignedTask apply(MutableStoreProvider storeProvider) {
+      @Override
+      public IAssignedTask apply(MutableStoreProvider storeProvider) {
         boolean success = updateTaskAndExternalState(
             Optional.<ScheduleStatus>absent(),
             taskId,
@@ -226,7 +229,8 @@ public class StateManagerImpl implements StateManager {
   @VisibleForTesting
   static final Supplier<String> LOCAL_HOST_SUPPLIER = Suppliers.memoize(
       new Supplier<String>() {
-        @Override public String get() {
+        @Override
+        public String get() {
           try {
             return InetAddress.getLocalHost().getHostName();
           } catch (UnknownHostException e) {
@@ -243,7 +247,8 @@ public class StateManagerImpl implements StateManager {
       final Optional<String> transitionMessage) {
 
     return storage.write(new MutateWork.Quiet<Boolean>() {
-      @Override public Boolean apply(MutableStoreProvider storeProvider) {
+      @Override
+      public Boolean apply(MutableStoreProvider storeProvider) {
         Optional<IScheduledTask> task = Optional.fromNullable(Iterables.getOnlyElement(
             storeProvider.getTaskStore().fetchTasks(Query.taskScoped(taskId)),
             null));
@@ -262,7 +267,8 @@ public class StateManagerImpl implements StateManager {
 
   private static final Function<SideEffect, Action> GET_ACTION =
       new Function<SideEffect, Action>() {
-        @Override public Action apply(SideEffect sideEffect) {
+        @Override
+        public Action apply(SideEffect sideEffect) {
           return sideEffect.getAction();
         }
       };
@@ -309,7 +315,8 @@ public class StateManagerImpl implements StateManager {
         : new TaskStateMachine(taskId);
 
     boolean success = storage.write(new MutateWork.Quiet<Boolean>() {
-      @Override public Boolean apply(MutableStoreProvider storeProvider) {
+      @Override
+      public Boolean apply(MutableStoreProvider storeProvider) {
         TransitionResult result = stateMachine.updateState(targetState);
         Query.Builder query = Query.taskScoped(taskId);
 
@@ -320,7 +327,8 @@ public class StateManagerImpl implements StateManager {
           switch (sideEffect.getAction()) {
             case INCREMENT_FAILURES:
               storeProvider.getUnsafeTaskStore().mutateTasks(query, new TaskMutation() {
-                @Override public IScheduledTask apply(IScheduledTask task) {
+                @Override
+                public IScheduledTask apply(IScheduledTask task) {
                   return IScheduledTask.build(
                       task.newBuilder().setFailureCount(task.getFailureCount() + 1));
                 }
@@ -333,7 +341,8 @@ public class StateManagerImpl implements StateManager {
                   "Operation expected task " + taskId + " to be present.");
 
               storeProvider.getUnsafeTaskStore().mutateTasks(query, new TaskMutation() {
-                @Override public IScheduledTask apply(IScheduledTask task) {
+                @Override
+                public IScheduledTask apply(IScheduledTask task) {
                   ScheduledTask mutableTask = task.newBuilder();
                   mutableTask.setStatus(stateMachine.getState());
                   mutableTask.addToTaskEvents(new TaskEvent()
@@ -426,7 +435,8 @@ public class StateManagerImpl implements StateManager {
   @Override
   public void deleteTasks(final Set<String> taskIds) {
     storage.write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(final MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(final MutableStoreProvider storeProvider) {
         eventSink.post(deleteTasks(storeProvider, taskIds));
       }
     });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/state/TaskStateMachine.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/state/TaskStateMachine.java b/src/main/java/org/apache/aurora/scheduler/state/TaskStateMachine.java
index ebccc74..0b39b84 100644
--- a/src/main/java/org/apache/aurora/scheduler/state/TaskStateMachine.java
+++ b/src/main/java/org/apache/aurora/scheduler/state/TaskStateMachine.java
@@ -132,7 +132,8 @@ class TaskStateMachine {
 
     final Closure<Transition<ScheduleStatus>> manageRestartingTask =
         new Closure<Transition<ScheduleStatus>>() {
-          @Override public void execute(Transition<ScheduleStatus> transition) {
+          @Override
+          public void execute(Transition<ScheduleStatus> transition) {
             switch (transition.getTo()) {
               case ASSIGNED:
                 addFollowup(KILL);
@@ -175,7 +176,8 @@ class TaskStateMachine {
 
     // To be called on a task transitioning into the FINISHED state.
     final Command rescheduleIfService = new Command() {
-      @Override public void execute() {
+      @Override
+      public void execute() {
         if (task.get().getAssignedTask().getTask().isIsService()) {
           addFollowup(RESCHEDULE);
         }
@@ -184,7 +186,8 @@ class TaskStateMachine {
 
     // To be called on a task transitioning into the FAILED state.
     final Command incrementFailuresMaybeReschedule = new Command() {
-      @Override public void execute() {
+      @Override
+      public void execute() {
         addFollowup(INCREMENT_FAILURES);
 
         // Max failures is ignored for service task.
@@ -225,7 +228,8 @@ class TaskStateMachine {
                     KILLING, LOST, PREEMPTING)
                 .withCallback(
                     new Closure<Transition<ScheduleStatus>>() {
-                      @Override public void execute(Transition<ScheduleStatus> transition) {
+                      @Override
+                      public void execute(Transition<ScheduleStatus> transition) {
                         switch (transition.getTo()) {
                           case FINISHED:
                             rescheduleIfService.execute();
@@ -267,7 +271,8 @@ class TaskStateMachine {
                 .to(RUNNING, FINISHED, FAILED, RESTARTING, KILLING, KILLED, LOST, PREEMPTING)
                 .withCallback(
                     new Closure<Transition<ScheduleStatus>>() {
-                      @Override public void execute(Transition<ScheduleStatus> transition) {
+                      @Override
+                      public void execute(Transition<ScheduleStatus> transition) {
                         switch (transition.getTo()) {
                           case FINISHED:
                             rescheduleIfService.execute();
@@ -314,7 +319,8 @@ class TaskStateMachine {
                 .to(FINISHED, RESTARTING, FAILED, KILLING, KILLED, LOST, PREEMPTING)
                 .withCallback(
                     new Closure<Transition<ScheduleStatus>>() {
-                      @Override public void execute(Transition<ScheduleStatus> transition) {
+                      @Override
+                      public void execute(Transition<ScheduleStatus> transition) {
                         switch (transition.getTo()) {
                           case FINISHED:
                             rescheduleIfService.execute();
@@ -390,7 +396,8 @@ class TaskStateMachine {
         // must be the last chained transition callback.
         .onAnyTransition(
             new Closure<Transition<ScheduleStatus>>() {
-              @Override public void execute(final Transition<ScheduleStatus> transition) {
+              @Override
+              public void execute(final Transition<ScheduleStatus> transition) {
                 if (transition.isValidStateChange()) {
                   ScheduleStatus from = transition.getFrom();
                   ScheduleStatus to = transition.getTo();
@@ -437,7 +444,8 @@ class TaskStateMachine {
 
   private Closure<Transition<ScheduleStatus>> addFollowupClosure(final Action action) {
     return new Closure<Transition<ScheduleStatus>>() {
-      @Override public void execute(Transition<ScheduleStatus> item) {
+      @Override
+      public void execute(Transition<ScheduleStatus> item) {
         addFollowup(action);
       }
     };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/stats/CachedCounters.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/stats/CachedCounters.java b/src/main/java/org/apache/aurora/scheduler/stats/CachedCounters.java
index c8d3335..8a5ca20 100644
--- a/src/main/java/org/apache/aurora/scheduler/stats/CachedCounters.java
+++ b/src/main/java/org/apache/aurora/scheduler/stats/CachedCounters.java
@@ -34,7 +34,8 @@ class CachedCounters {
   CachedCounters(final StatsProvider stats) {
     cache = CacheBuilder.newBuilder().build(
         new CacheLoader<String, AtomicLong>() {
-          @Override public AtomicLong load(String key) {
+          @Override
+          public AtomicLong load(String key) {
             return stats.makeCounter(key);
           }
         }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/stats/ResourceCounter.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/stats/ResourceCounter.java b/src/main/java/org/apache/aurora/scheduler/stats/ResourceCounter.java
index d2ced53..8855bfb 100644
--- a/src/main/java/org/apache/aurora/scheduler/stats/ResourceCounter.java
+++ b/src/main/java/org/apache/aurora/scheduler/stats/ResourceCounter.java
@@ -86,7 +86,8 @@ public class ResourceCounter {
    */
   public Metric computeQuotaAllocationTotals() throws StorageException {
     return storage.weaklyConsistentRead(new Work.Quiet<Metric>() {
-      @Override public Metric apply(StoreProvider storeProvider) {
+      @Override
+      public Metric apply(StoreProvider storeProvider) {
         Metric allocation = new Metric();
         for (IQuota quota : storeProvider.getQuotaStore().fetchQuotas().values()) {
           allocation.accumulate(quota);
@@ -113,7 +114,8 @@ public class ResourceCounter {
 
     LoadingCache<K, Metric> metrics = CacheBuilder.newBuilder()
         .build(new CacheLoader<K, Metric>() {
-          @Override public Metric load(K key) {
+          @Override
+          public Metric load(K key) {
             return new Metric();
           }
         });
@@ -126,17 +128,20 @@ public class ResourceCounter {
   public enum MetricType {
     TOTAL_CONSUMED(Predicates.<ITaskConfig>alwaysTrue()),
     DEDICATED_CONSUMED(new Predicate<ITaskConfig>() {
-      @Override public boolean apply(ITaskConfig task) {
+      @Override
+      public boolean apply(ITaskConfig task) {
         return ConfigurationManager.isDedicated(task);
       }
     }),
     QUOTA_CONSUMED(new Predicate<ITaskConfig>() {
-      @Override public boolean apply(ITaskConfig task) {
+      @Override
+      public boolean apply(ITaskConfig task) {
         return task.isProduction();
       }
     }),
     FREE_POOL_CONSUMED(new Predicate<ITaskConfig>() {
-      @Override public boolean apply(ITaskConfig task) {
+      @Override
+      public boolean apply(ITaskConfig task) {
         return !ConfigurationManager.isDedicated(task) && !task.isProduction();
       }
     });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/stats/SlotSizeCounter.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/stats/SlotSizeCounter.java b/src/main/java/org/apache/aurora/scheduler/stats/SlotSizeCounter.java
index 81a952d..e3dffe0 100644
--- a/src/main/java/org/apache/aurora/scheduler/stats/SlotSizeCounter.java
+++ b/src/main/java/org/apache/aurora/scheduler/stats/SlotSizeCounter.java
@@ -96,7 +96,8 @@ class SlotSizeCounter implements Runnable {
 
   private int countSlots(Iterable<IQuota> slots, final IQuota slotSize) {
     Function<IQuota, Integer> counter = new Function<IQuota, Integer>() {
-      @Override public Integer apply(IQuota machineSlack) {
+      @Override
+      public Integer apply(IQuota machineSlack) {
         return Quotas.divide(machineSlack, slotSize);
       }
     };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/CallOrderEnforcingStorage.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/CallOrderEnforcingStorage.java b/src/main/java/org/apache/aurora/scheduler/storage/CallOrderEnforcingStorage.java
index a556ae2..61870ea 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/CallOrderEnforcingStorage.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/CallOrderEnforcingStorage.java
@@ -94,7 +94,8 @@ public class CallOrderEnforcingStorage implements NonVolatileStorage {
     wrapped.start(initializationLogic);
     stateMachine.transition(State.READY);
     wrapped.write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         Iterable<IScheduledTask> tasks = Tasks.LATEST_ACTIVITY.sortedCopy(
             storeProvider.getTaskStore().fetchTasks(Query.unscoped()));
         for (IScheduledTask task : tasks) {
@@ -146,7 +147,8 @@ public class CallOrderEnforcingStorage implements NonVolatileStorage {
    */
   public static Module wrappingModule(final Class<? extends NonVolatileStorage> storageClass) {
     return new PrivateModule() {
-      @Override protected void configure() {
+      @Override
+      protected void configure() {
         bind(Storage.class).to(CallOrderEnforcingStorage.class);
         bind(NonVolatileStorage.class).to(CallOrderEnforcingStorage.class);
         bind(CallOrderEnforcingStorage.class).in(Singleton.class);

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/ReadWriteLockManager.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/ReadWriteLockManager.java b/src/main/java/org/apache/aurora/scheduler/storage/ReadWriteLockManager.java
index 513a159..a029914 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/ReadWriteLockManager.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/ReadWriteLockManager.java
@@ -59,7 +59,8 @@ public class ReadWriteLockManager {
   }
 
   private final ThreadLocal<LockState> lockState = new ThreadLocal<LockState>() {
-    @Override protected LockState initialValue() {
+    @Override
+    protected LockState initialValue() {
       return new LockState();
     }
   };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/Storage.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/Storage.java b/src/main/java/org/apache/aurora/scheduler/storage/Storage.java
index 984f506..9cc1d1e 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/Storage.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/Storage.java
@@ -101,7 +101,8 @@ public interface Storage {
   interface MutateWork<T, E extends Exception> {
 
     NoResult.Quiet NOOP = new NoResult.Quiet() {
-      @Override protected void execute(Storage.MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(Storage.MutableStoreProvider storeProvider) {
         // No-op.
       }
     };
@@ -132,7 +133,8 @@ public interface Storage {
      */
     abstract class NoResult<E extends Exception> implements MutateWork<Void, E> {
 
-      @Override public final Void apply(MutableStoreProvider storeProvider) throws E {
+      @Override
+      public final Void apply(MutableStoreProvider storeProvider) throws E {
         execute(storeProvider);
         return null;
       }
@@ -279,7 +281,8 @@ public interface Storage {
         final Query.Builder query) {
 
       return storage.consistentRead(new Work.Quiet<ImmutableSet<IScheduledTask>>() {
-        @Override public ImmutableSet<IScheduledTask> apply(StoreProvider storeProvider) {
+        @Override
+        public ImmutableSet<IScheduledTask> apply(StoreProvider storeProvider) {
           return storeProvider.getTaskStore().fetchTasks(query);
         }
       });
@@ -299,7 +302,8 @@ public interface Storage {
         final Query.Builder query) {
 
       return storage.weaklyConsistentRead(new Work.Quiet<ImmutableSet<IScheduledTask>>() {
-        @Override public ImmutableSet<IScheduledTask> apply(StoreProvider storeProvider) {
+        @Override
+        public ImmutableSet<IScheduledTask> apply(StoreProvider storeProvider) {
           return storeProvider.getTaskStore().fetchTasks(query);
         }
       });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/StorageBackfill.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/StorageBackfill.java b/src/main/java/org/apache/aurora/scheduler/storage/StorageBackfill.java
index aa54659..714bceb 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/StorageBackfill.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/StorageBackfill.java
@@ -125,7 +125,8 @@ public final class StorageBackfill {
 
     LOG.info("Performing shard uniqueness sanity check.");
     storeProvider.getUnsafeTaskStore().mutateTasks(Query.unscoped(), new TaskMutation() {
-      @Override public IScheduledTask apply(final IScheduledTask task) {
+      @Override
+      public IScheduledTask apply(final IScheduledTask task) {
         ScheduledTask builder = task.newBuilder();
         ConfigurationManager.applyDefaultsIfUnset(builder.getAssignedTask().getTask());
         // TODO(ksweeney): Guarantee tasks pass current validation code here and quarantine if they

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/backup/BackupModule.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/backup/BackupModule.java b/src/main/java/org/apache/aurora/scheduler/storage/backup/BackupModule.java
index 82e5b48..9f8ade9 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/backup/BackupModule.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/backup/BackupModule.java
@@ -114,7 +114,8 @@ public class BackupModule extends PrivateModule {
       this.lifecycle = checkNotNull(lifecycle);
     }
 
-    @Override public void execute() {
+    @Override
+    public void execute() {
       lifecycle.shutdown();
     }
   }

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/backup/Recovery.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/backup/Recovery.java b/src/main/java/org/apache/aurora/scheduler/storage/backup/Recovery.java
index e3c4203..88e83e9 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/backup/Recovery.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/backup/Recovery.java
@@ -129,11 +129,13 @@ public interface Recovery {
       this.shutDownNow = checkNotNull(shutDownNow);
     }
 
-    @Override public Set<String> listBackups() {
+    @Override
+    public Set<String> listBackups() {
       return ImmutableSet.<String>builder().add(backupDir.list()).build();
     }
 
-    @Override public void stage(String backupName) throws RecoveryException {
+    @Override
+    public void stage(String backupName) throws RecoveryException {
       File backupFile = new File(backupDir, backupName);
       if (!backupFile.exists()) {
         throw new RecoveryException("Backup " + backupName + " does not exist.");
@@ -162,19 +164,23 @@ public interface Recovery {
       return loaded;
     }
 
-    @Override public Set<IScheduledTask> query(Query.Builder query) throws RecoveryException {
+    @Override
+    public Set<IScheduledTask> query(Query.Builder query) throws RecoveryException {
       return getLoadedRecovery().query(query);
     }
 
-    @Override public void deleteTasks(Query.Builder query) throws RecoveryException {
+    @Override
+    public void deleteTasks(Query.Builder query) throws RecoveryException {
       getLoadedRecovery().delete(query);
     }
 
-    @Override public void unload() {
+    @Override
+    public void unload() {
       recovery.set(null);
     }
 
-    @Override public void commit() throws RecoveryException {
+    @Override
+    public void commit() throws RecoveryException {
       getLoadedRecovery().commit();
     }
 
@@ -187,7 +193,8 @@ public interface Recovery {
 
       void commit() {
         primaryStorage.write(new MutateWork.NoResult.Quiet() {
-          @Override protected void execute(MutableStoreProvider storeProvider) {
+          @Override
+          protected void execute(MutableStoreProvider storeProvider) {
             try {
               distributedStore.persist(tempStorage.toSnapshot());
               shutDownNow.execute();

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/backup/StorageBackup.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/backup/StorageBackup.java b/src/main/java/org/apache/aurora/scheduler/storage/backup/StorageBackup.java
index 22b0c2f..8499f30 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/backup/StorageBackup.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/backup/StorageBackup.java
@@ -129,7 +129,8 @@ public interface StorageBackup {
       lastBackupMs = clock.nowMillis();
     }
 
-    @Override public Snapshot createSnapshot() {
+    @Override
+    public Snapshot createSnapshot() {
       Snapshot snapshot = delegate.createSnapshot();
       if (clock.nowMillis() >= (lastBackupMs + backupIntervalMs)) {
         save(snapshot);
@@ -137,7 +138,8 @@ public interface StorageBackup {
       return snapshot;
     }
 
-    @Override public void backupNow() {
+    @Override
+    public void backupNow() {
       save(delegate.createSnapshot());
     }
 
@@ -189,14 +191,16 @@ public interface StorageBackup {
     }
 
     private static final FilenameFilter BACKUP_FILTER = new FilenameFilter() {
-      @Override public boolean accept(File file, String s) {
+      @Override
+      public boolean accept(File file, String s) {
         return s.startsWith(FILE_PREFIX);
       }
     };
 
     @VisibleForTesting
     static final Function<File, String> FILE_NAME = new Function<File, String>() {
-      @Override public String apply(File file) {
+      @Override
+      public String apply(File file) {
         return file.getName();
       }
     };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/backup/TemporaryStorage.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/backup/TemporaryStorage.java b/src/main/java/org/apache/aurora/scheduler/storage/backup/TemporaryStorage.java
index 0386b0a..dec9cc4 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/backup/TemporaryStorage.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/backup/TemporaryStorage.java
@@ -66,7 +66,8 @@ interface TemporaryStorage {
    * A factory that creates temporary storage instances, detached from the rest of the system.
    */
   class TemporaryStorageFactory implements Function<Snapshot, TemporaryStorage> {
-    @Override public TemporaryStorage apply(Snapshot snapshot) {
+    @Override
+    public TemporaryStorage apply(Snapshot snapshot) {
       final Storage storage = MemStorage.newEmptyStorage();
       FakeClock clock = new FakeClock();
       clock.setNowMillis(snapshot.getTimestamp());
@@ -74,9 +75,11 @@ interface TemporaryStorage {
       snapshotStore.applySnapshot(snapshot);
 
       return new TemporaryStorage() {
-        @Override public void deleteTasks(final Query.Builder query) {
+        @Override
+        public void deleteTasks(final Query.Builder query) {
           storage.write(new MutateWork.NoResult.Quiet() {
-            @Override protected void execute(MutableStoreProvider storeProvider) {
+            @Override
+            protected void execute(MutableStoreProvider storeProvider) {
               Set<String> ids = FluentIterable.from(storeProvider.getTaskStore().fetchTasks(query))
                   .transform(Tasks.SCHEDULED_TO_ID)
                   .toSet();
@@ -85,15 +88,18 @@ interface TemporaryStorage {
           });
         }
 
-        @Override public Set<IScheduledTask> fetchTasks(final Query.Builder query) {
+        @Override
+        public Set<IScheduledTask> fetchTasks(final Query.Builder query) {
           return storage.consistentRead(new Work.Quiet<Set<IScheduledTask>>() {
-            @Override public Set<IScheduledTask> apply(StoreProvider storeProvider) {
+            @Override
+            public Set<IScheduledTask> apply(StoreProvider storeProvider) {
               return storeProvider.getTaskStore().fetchTasks(query);
             }
           });
         }
 
-        @Override public Snapshot toSnapshot() {
+        @Override
+        public Snapshot toSnapshot() {
           return snapshotStore.createSnapshot();
         }
       };

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/log/LogManager.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/log/LogManager.java b/src/main/java/org/apache/aurora/scheduler/storage/log/LogManager.java
index cc8f625..b59b9d0 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/log/LogManager.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/log/LogManager.java
@@ -122,7 +122,8 @@ public final class LogManager {
   public StreamManager open() throws IOException {
     final Stream stream = log.open();
     shutdownRegistry.addAction(new ExceptionalCommand<IOException>() {
-      @Override public void execute() throws IOException {
+      @Override
+      public void execute() throws IOException {
         stream.close();
       }
     });

http://git-wip-us.apache.org/repos/asf/incubator-aurora/blob/e7949b1a/src/main/java/org/apache/aurora/scheduler/storage/log/LogStorage.java
----------------------------------------------------------------------
diff --git a/src/main/java/org/apache/aurora/scheduler/storage/log/LogStorage.java b/src/main/java/org/apache/aurora/scheduler/storage/log/LogStorage.java
index 948fee4..36e4082 100644
--- a/src/main/java/org/apache/aurora/scheduler/storage/log/LogStorage.java
+++ b/src/main/java/org/apache/aurora/scheduler/storage/log/LogStorage.java
@@ -178,31 +178,38 @@ public class LogStorage extends ForwardingStore
   private StreamTransaction transaction = null;
 
   private final MutableStoreProvider logStoreProvider = new MutableStoreProvider() {
-    @Override public SchedulerStore.Mutable getSchedulerStore() {
+    @Override
+    public SchedulerStore.Mutable getSchedulerStore() {
       return LogStorage.this;
     }
 
-    @Override public JobStore.Mutable getJobStore() {
+    @Override
+    public JobStore.Mutable getJobStore() {
       return LogStorage.this;
     }
 
-    @Override public TaskStore getTaskStore() {
+    @Override
+    public TaskStore getTaskStore() {
       return LogStorage.this;
     }
 
-    @Override public TaskStore.Mutable getUnsafeTaskStore() {
+    @Override
+    public TaskStore.Mutable getUnsafeTaskStore() {
       return LogStorage.this;
     }
 
-    @Override public LockStore.Mutable getLockStore() {
+    @Override
+    public LockStore.Mutable getLockStore() {
       return LogStorage.this;
     }
 
-    @Override public QuotaStore.Mutable getQuotaStore() {
+    @Override
+    public QuotaStore.Mutable getQuotaStore() {
       return LogStorage.this;
     }
 
-    @Override public AttributeStore.Mutable getAttributeStore() {
+    @Override
+    public AttributeStore.Mutable getAttributeStore() {
       return LogStorage.this;
     }
   };
@@ -296,7 +303,8 @@ public class LogStorage extends ForwardingStore
   @Override
   public synchronized void start(final MutateWork.NoResult.Quiet initializationLogic) {
     write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider unused) {
+      @Override
+      protected void execute(MutableStoreProvider unused) {
         // Must have the underlying storage started so we can query it for the last checkpoint.
         // We replay these entries in the forwarded storage system's transactions but not ours - we
         // do not want to re-record these ops to the log.
@@ -321,7 +329,8 @@ public class LogStorage extends ForwardingStore
   void recover() throws RecoveryFailedException {
     try {
       streamManager.readFromBeginning(new Closure<LogEntry>() {
-        @Override public void execute(LogEntry logEntry) {
+        @Override
+        public void execute(LogEntry logEntry) {
           replay(logEntry);
         }
       });
@@ -424,7 +433,8 @@ public class LogStorage extends ForwardingStore
   private void scheduleSnapshots() {
     if (snapshotInterval.getValue() > 0) {
       schedulingService.doEvery(snapshotInterval, new Runnable() {
-        @Override public void run() {
+        @Override
+        public void run() {
           try {
             snapshot();
           } catch (StorageException e) {
@@ -449,7 +459,8 @@ public class LogStorage extends ForwardingStore
   @Timed("scheduler_log_snapshot")
   void doSnapshot() throws CodingException, InvalidPositionException, StreamAccessException {
     super.write(new MutateWork.NoResult<CodingException>() {
-      @Override protected void execute(MutableStoreProvider unused)
+      @Override
+      protected void execute(MutableStoreProvider unused)
           throws CodingException, InvalidPositionException, StreamAccessException {
 
         persist(snapshotStore.createSnapshot());
@@ -479,7 +490,8 @@ public class LogStorage extends ForwardingStore
     // store provider so any mutations performed by work get logged.
     if (transaction != null) {
       return super.write(new MutateWork<T, E>() {
-        @Override public T apply(MutableStoreProvider unused) throws E {
+        @Override
+        public T apply(MutableStoreProvider unused) throws E {
           return work.apply(logStoreProvider);
         }
       });
@@ -488,7 +500,8 @@ public class LogStorage extends ForwardingStore
     transaction = streamManager.startTransaction();
     try {
       return super.write(new MutateWork<T, E>() {
-        @Override public T apply(MutableStoreProvider unused) throws E {
+        @Override
+        public T apply(MutableStoreProvider unused) throws E {
           T result = work.apply(logStoreProvider);
           try {
             transaction.commit();
@@ -511,7 +524,8 @@ public class LogStorage extends ForwardingStore
   @Override
   public void saveFrameworkId(final String frameworkId) {
     write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider unused) {
+      @Override
+      protected void execute(MutableStoreProvider unused) {
         log(Op.saveFrameworkId(new SaveFrameworkId(frameworkId)));
         LogStorage.super.saveFrameworkId(frameworkId);
       }
@@ -522,7 +536,8 @@ public class LogStorage extends ForwardingStore
   @Override
   public void saveAcceptedJob(final String managerId, final IJobConfiguration jobConfig) {
     write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider unused) {
+      @Override
+      protected void execute(MutableStoreProvider unused) {
         log(Op.saveAcceptedJob(new SaveAcceptedJob(managerId, jobConfig.newBuilder())));
         LogStorage.super.saveAcceptedJob(managerId, jobConfig);
       }
@@ -535,7 +550,8 @@ public class LogStorage extends ForwardingStore
     checkNotNull(jobKey);
 
     write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider unused) {
+      @Override
+      protected void execute(MutableStoreProvider unused) {
         log(Op.removeJob(new RemoveJob().setJobKey(jobKey.newBuilder())));
         LogStorage.super.removeJob(jobKey);
       }
@@ -546,7 +562,8 @@ public class LogStorage extends ForwardingStore
   @Override
   public void saveTasks(final Set<IScheduledTask> newTasks) throws IllegalStateException {
     write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider unused) {
+      @Override
+      protected void execute(MutableStoreProvider unused) {
         log(Op.saveTasks(new SaveTasks(IScheduledTask.toBuildersSet(newTasks))));
         LogStorage.super.saveTasks(newTasks);
       }
@@ -556,7 +573,8 @@ public class LogStorage extends ForwardingStore
   @Override
   public void deleteAllTasks() {
     write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider storeProvider) {
+      @Override
+      protected void execute(MutableStoreProvider storeProvider) {
         Query.Builder query = Query.unscoped();
         Set<String> ids = FluentIterable.from(storeProvider.getTaskStore().fetchTasks(query))
             .transform(Tasks.SCHEDULED_TO_ID)
@@ -570,7 +588,8 @@ public class LogStorage extends ForwardingStore
   @Override
   public void deleteTasks(final Set<String> taskIds) {
     write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider unused) {
+      @Override
+      protected void execute(MutableStoreProvider unused) {
         log(Op.removeTasks(new RemoveTasks(taskIds)));
         LogStorage.super.deleteTasks(taskIds);
       }
@@ -584,7 +603,8 @@ public class LogStorage extends ForwardingStore
       final Function<IScheduledTask, IScheduledTask> mutator) {
 
     return write(new MutateWork.Quiet<ImmutableSet<IScheduledTask>>() {
-      @Override public ImmutableSet<IScheduledTask> apply(MutableStoreProvider unused) {
+      @Override
+      public ImmutableSet<IScheduledTask> apply(MutableStoreProvider unused) {
         ImmutableSet<IScheduledTask> mutated = LogStorage.super.mutateTasks(query, mutator);
 
         Map<String, IScheduledTask> tasksById = Tasks.mapById(mutated);
@@ -604,7 +624,8 @@ public class LogStorage extends ForwardingStore
   @Override
   public boolean unsafeModifyInPlace(final String taskId, final ITaskConfig taskConfiguration) {
     return write(new MutateWork.Quiet<Boolean>() {
-      @Override public Boolean apply(MutableStoreProvider storeProvider) {
+      @Override
+      public Boolean apply(MutableStoreProvider storeProvider) {
         boolean mutated = LogStorage.super.unsafeModifyInPlace(taskId, taskConfiguration);
         if (mutated) {
           log(Op.rewriteTask(new RewriteTask(taskId, taskConfiguration.newBuilder())));
@@ -618,7 +639,8 @@ public class LogStorage extends ForwardingStore
   @Override
   public void removeQuota(final String role) {
     write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider unused) {
+      @Override
+      protected void execute(MutableStoreProvider unused) {
         log(Op.removeQuota(new RemoveQuota(role)));
         LogStorage.super.removeQuota(role);
       }
@@ -629,7 +651,8 @@ public class LogStorage extends ForwardingStore
   @Override
   public void saveQuota(final String role, final IQuota quota) {
     write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider unused) {
+      @Override
+      protected void execute(MutableStoreProvider unused) {
         log(Op.saveQuota(new SaveQuota(role, quota.newBuilder())));
         LogStorage.super.saveQuota(role, quota);
       }
@@ -640,7 +663,8 @@ public class LogStorage extends ForwardingStore
   @Override
   public void saveHostAttributes(final HostAttributes attrs) {
     write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider unused) {
+      @Override
+      protected void execute(MutableStoreProvider unused) {
         // Pass the updated attributes upstream, and then check if the stored value changes.
         // We do this since different parts of the system write partial HostAttributes objects
         // and they are merged together internally.
@@ -660,7 +684,8 @@ public class LogStorage extends ForwardingStore
   @Override
   public void saveLock(final ILock lock) {
     write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider unused) {
+      @Override
+      protected void execute(MutableStoreProvider unused) {
         log(Op.saveLock(new SaveLock(lock.newBuilder())));
         LogStorage.super.saveLock(lock);
       }
@@ -671,7 +696,8 @@ public class LogStorage extends ForwardingStore
   @Override
   public void removeLock(final ILockKey lockKey) {
     write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider unused) {
+      @Override
+      protected void execute(MutableStoreProvider unused) {
         log(Op.removeLock(new RemoveLock(lockKey.newBuilder())));
         LogStorage.super.removeLock(lockKey);
       }
@@ -681,7 +707,8 @@ public class LogStorage extends ForwardingStore
   @Override
   public boolean setMaintenanceMode(final String host, final MaintenanceMode mode) {
     write(new MutateWork.NoResult.Quiet() {
-      @Override protected void execute(MutableStoreProvider unused) {
+      @Override
+      protected void execute(MutableStoreProvider unused) {
         Optional<HostAttributes> saved = LogStorage.super.getHostAttributes(host);
         if (saved.isPresent()) {
           HostAttributes attributes = saved.get().setMode(mode);


Mime
View raw message