This is an automated email from the ASF dual-hosted git repository.

nehapawar pushed a commit to branch periodic_task_order
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git


The following commit(s) were added to refs/heads/periodic_task_order by this 
push:
     new 815b120  Lower access modifier for overriden methods
815b120 is described below

commit 815b120c00442c108485e81007be29dc4e6b00ad
Author: Neha Pawar <[email protected]>
AuthorDate: Tue Dec 18 14:05:30 2018 -0800

    Lower access modifier for overriden methods
---
 .../com/linkedin/pinot/controller/helix/SegmentStatusChecker.java   | 6 +++---
 .../pinot/controller/helix/core/minion/PinotTaskManager.java        | 2 +-
 .../controller/helix/core/periodictask/ControllerPeriodicTask.java  | 2 +-
 .../com/linkedin/pinot/controller/validation/ValidationManager.java | 6 +++---
 4 files changed, 8 insertions(+), 8 deletions(-)

diff --git 
a/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/SegmentStatusChecker.java
 
b/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/SegmentStatusChecker.java
index d444e67..191a902 100644
--- 
a/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/SegmentStatusChecker.java
+++ 
b/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/SegmentStatusChecker.java
@@ -90,7 +90,7 @@ public class SegmentStatusChecker extends 
ControllerPeriodicTask {
   }
 
   @Override
-  public void preprocess() {
+  protected void preprocess() {
     _realTimeTableCount = 0;
     _offlineTableCount = 0;
     _disabledTableCount = 0;
@@ -106,12 +106,12 @@ public class SegmentStatusChecker extends 
ControllerPeriodicTask {
   }
 
   @Override
-  public void process(String tableNameWithType) {
+  protected void process(String tableNameWithType) {
     updateSegmentMetrics(tableNameWithType);
   }
 
   @Override
-  public void postprocess() {
+  protected void postprocess() {
     
_metricsRegistry.setValueOfGlobalGauge(ControllerGauge.REALTIME_TABLE_COUNT, 
_realTimeTableCount);
     
_metricsRegistry.setValueOfGlobalGauge(ControllerGauge.OFFLINE_TABLE_COUNT, 
_offlineTableCount);
     
_metricsRegistry.setValueOfGlobalGauge(ControllerGauge.DISABLED_TABLE_COUNT, 
_disabledTableCount);
diff --git 
a/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/minion/PinotTaskManager.java
 
b/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/minion/PinotTaskManager.java
index d1ebd96..507a6f1 100644
--- 
a/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/minion/PinotTaskManager.java
+++ 
b/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/minion/PinotTaskManager.java
@@ -160,7 +160,7 @@ public class PinotTaskManager extends 
ControllerPeriodicTask {
    * Returns the tasks that have been scheduled as part of the postprocess
    * @return
    */
-  public Map<String, String> getTasksScheduled() {
+  private Map<String, String> getTasksScheduled() {
     return _tasksScheduled;
   }
 }
diff --git 
a/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/periodictask/ControllerPeriodicTask.java
 
b/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/periodictask/ControllerPeriodicTask.java
index 9ce5c59..a370695 100644
--- 
a/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/periodictask/ControllerPeriodicTask.java
+++ 
b/pinot-controller/src/main/java/com/linkedin/pinot/controller/helix/core/periodictask/ControllerPeriodicTask.java
@@ -124,7 +124,7 @@ public abstract class ControllerPeriodicTask extends 
BasePeriodicTask {
   protected abstract void preprocess();
 
   /**
-   * Process the controller periodic task for the given table
+   * Execute the controller periodic task for the given table
    * @param tableNameWithType
    */
   protected abstract void process(String tableNameWithType);
diff --git 
a/pinot-controller/src/main/java/com/linkedin/pinot/controller/validation/ValidationManager.java
 
b/pinot-controller/src/main/java/com/linkedin/pinot/controller/validation/ValidationManager.java
index b9b775d..24ead61 100644
--- 
a/pinot-controller/src/main/java/com/linkedin/pinot/controller/validation/ValidationManager.java
+++ 
b/pinot-controller/src/main/java/com/linkedin/pinot/controller/validation/ValidationManager.java
@@ -76,7 +76,7 @@ public class ValidationManager extends ControllerPeriodicTask 
{
   }
 
   @Override
-  public void preprocess() {
+  protected void preprocess() {
     // Run segment level validation using a separate interval
     _runSegmentLevelValidation = false;
     long currentTimeMs = System.currentTimeMillis();
@@ -92,12 +92,12 @@ public class ValidationManager extends 
ControllerPeriodicTask {
   }
 
   @Override
-  public void process(String tableNameWithType) {
+  protected void process(String tableNameWithType) {
     runValidation(tableNameWithType);
   }
 
   @Override
-  public void postprocess() {
+  protected void postprocess() {
 
   }
 


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to