From b7a88706f373a1309159a0d2ad16aab3c15735cd Mon Sep 17 00:00:00 2001
From: baruchz <baruchz@gmail.com>
Date: Sun, 12 Feb 2017 18:37:58 -0800
Subject: [PATCH] Add maprfs scheme (#3920)

Add maprfs scheme to JobHelper to treated as HDFS deep storage
---
 indexing-hadoop/src/main/java/io/druid/indexer/JobHelper.java | 1 +
 1 file changed, 1 insertion(+)

diff --git a/indexing-hadoop/src/main/java/io/druid/indexer/JobHelper.java b/indexing-hadoop/src/main/java/io/druid/indexer/JobHelper.java
index c703e490637f..8cb750422ce7 100644
--- a/indexing-hadoop/src/main/java/io/druid/indexer/JobHelper.java
+++ b/indexing-hadoop/src/main/java/io/druid/indexer/JobHelper.java
@@ -420,6 +420,7 @@ public long push() throws IOException
     switch (outputFS.getScheme()) {
       case "hdfs":
       case "viewfs":
+      case "maprfs":
         loadSpec = ImmutableMap.<String, Object>of(
             "type", "hdfs",
             "path", indexOutURI.toString()