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:51 UTC
[incubator-pinot] branch make_jar_protocol_talk_to_local created
(now 98c8454)
This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a change to branch make_jar_protocol_talk_to_local
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
at 98c8454 Make jar scheme default to LocalPinotFS
This branch includes the following new commits:
new 98c8454 Make jar scheme default to LocalPinotFS
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org
[incubator-pinot] 01/01: Make jar scheme default to LocalPinotFS
Posted by xi...@apache.org.
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