You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by xi...@apache.org on 2020/03/05 08:40:52 UTC
[incubator-pinot] 01/01: Make jar scheme default to LocalPinotFS
This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a commit to branch make_jar_protocol_talk_to_local
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git
commit 98c84547faa41d86dcba3cf8dc33a85c6bdc8ca4
Author: Xiang Fu <fx...@gmail.com>
AuthorDate: Thu Mar 5 00:40:30 2020 -0800
Make jar scheme default to LocalPinotFS
---
.../main/java/org/apache/pinot/spi/filesystem/PinotFSFactory.java | 5 +++++
1 file changed, 5 insertions(+)
diff --git a/pinot-spi/src/main/java/org/apache/pinot/spi/filesystem/PinotFSFactory.java b/pinot-spi/src/main/java/org/apache/pinot/spi/filesystem/PinotFSFactory.java
index 38d0eff..2be01d4 100644
--- a/pinot-spi/src/main/java/org/apache/pinot/spi/filesystem/PinotFSFactory.java
+++ b/pinot-spi/src/main/java/org/apache/pinot/spi/filesystem/PinotFSFactory.java
@@ -38,6 +38,7 @@ public class PinotFSFactory {
private static final Logger LOGGER = LoggerFactory.getLogger(PinotFSFactory.class);
private static final String LOCAL_PINOT_FS_SCHEME = "file";
+ private static final String JAR_PINOT_FS_SCHEME = "jar";
private static final String CLASS = "class";
private static Map<String, PinotFS> PINOT_FS_MAP = new HashMap<>();
@@ -71,6 +72,10 @@ public class PinotFSFactory {
LOGGER.info("LocalPinotFS not configured, adding as default");
PINOT_FS_MAP.put(LOCAL_PINOT_FS_SCHEME, new LocalPinotFS());
}
+ if (!PINOT_FS_MAP.containsKey(JAR_PINOT_FS_SCHEME)) {
+ LOGGER.info("JarPinotFS not configured, adding as default");
+ PINOT_FS_MAP.put(JAR_PINOT_FS_SCHEME, new LocalPinotFS());
+ }
}
public static PinotFS create(String scheme) {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org