From 50ff9ab2d2d4fe217fb1ac540d96bddd07c2f6f8 Mon Sep 17 00:00:00 2001 From: vinoyang Date: Wed, 3 Feb 2021 01:15:53 +0800 Subject: [PATCH] [MINOR] Rename FileSystemViewHandler to RequestHandler and corrected the class comment (#2458) --- .../{FileSystemViewHandler.java => RequestHandler.java} | 8 ++++---- .../org/apache/hudi/timeline/service/TimelineService.java | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) rename hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/{FileSystemViewHandler.java => RequestHandler.java} (98%) diff --git a/hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/FileSystemViewHandler.java b/hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/RequestHandler.java similarity index 98% rename from hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/FileSystemViewHandler.java rename to hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/RequestHandler.java index b3e860af7..22d3082c6 100644 --- a/hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/FileSystemViewHandler.java +++ b/hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/RequestHandler.java @@ -50,12 +50,12 @@ import java.util.List; import java.util.stream.Collectors; /** - * Main REST Handler class that handles local view staleness and delegates calls to slice/data-file/timeline handlers. + * Main REST Handler class that handles and delegates calls to timeline relevant handlers. */ -public class FileSystemViewHandler { +public class RequestHandler { private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper(); - private static final Logger LOG = LogManager.getLogger(FileSystemViewHandler.class); + private static final Logger LOG = LogManager.getLogger(RequestHandler.class); private final FileSystemViewManager viewManager; private final Javalin app; @@ -63,7 +63,7 @@ public class FileSystemViewHandler { private final FileSliceHandler sliceHandler; private final BaseFileHandler dataFileHandler; - public FileSystemViewHandler(Javalin app, Configuration conf, FileSystemViewManager viewManager) throws IOException { + public RequestHandler(Javalin app, Configuration conf, FileSystemViewManager viewManager) throws IOException { this.viewManager = viewManager; this.app = app; this.instantHandler = new TimelineHandler(conf, viewManager); diff --git a/hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/TimelineService.java b/hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/TimelineService.java index b1bec621f..47db1fda1 100644 --- a/hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/TimelineService.java +++ b/hudi-timeline-service/src/main/java/org/apache/hudi/timeline/service/TimelineService.java @@ -130,9 +130,9 @@ public class TimelineService { public int startService() throws IOException { app = Javalin.create(); - FileSystemViewHandler router = new FileSystemViewHandler(app, conf, fsViewsManager); + RequestHandler requestHandler = new RequestHandler(app, conf, fsViewsManager); app.get("/", ctx -> ctx.result("Hello World")); - router.register(); + requestHandler.register(); int realServerPort = startServiceOnPort(serverPort); LOG.info("Starting Timeline server on port :" + realServerPort); this.serverPort = realServerPort;