io.druid.indexer

Class Utils

java.lang.Object

io.druid.indexer.Utils

public class Utils
extends Object

Constructor Summary

Constructors

Constructor and Description
Utils()

Method Summary

Methods

Modifier and Type	Method and Description
static boolean	exists(org.apache.hadoop.mapreduce.JobContext job, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path inputPath)
static Map<String,Object>	getStats(org.apache.hadoop.mapreduce.JobContext job, org.apache.hadoop.fs.Path statsPath)
static OutputStream	makePathAndOutputStream(org.apache.hadoop.mapreduce.JobContext job, org.apache.hadoop.fs.Path outputPath, boolean deleteExisting)
static InputStream	openInputStream(org.apache.hadoop.mapreduce.JobContext job, org.apache.hadoop.fs.Path inputPath)
static InputStream	openInputStream(org.apache.hadoop.mapreduce.JobContext job, org.apache.hadoop.fs.Path inputPath, org.apache.hadoop.fs.FileSystem fileSystem)
static void	storeStats(org.apache.hadoop.mapreduce.JobContext job, org.apache.hadoop.fs.Path path, Map<String,Object> stats)
static <K,V> Map<K,V>	zipMap(Iterable<K> keys, Iterable<V> values)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Utils

public Utils()

Method Detail

zipMap

public static <K,V> Map<K,V> zipMap(Iterable<K> keys,
                    Iterable<V> values)

makePathAndOutputStream

public static OutputStream makePathAndOutputStream(org.apache.hadoop.mapreduce.JobContext job,
                                   org.apache.hadoop.fs.Path outputPath,
                                   boolean deleteExisting)
                                            throws IOException

Throws:

IOException

openInputStream

public static InputStream openInputStream(org.apache.hadoop.mapreduce.JobContext job,
                          org.apache.hadoop.fs.Path inputPath)
                                   throws IOException

Throws:

IOException

exists

public static boolean exists(org.apache.hadoop.mapreduce.JobContext job,
             org.apache.hadoop.fs.FileSystem fs,
             org.apache.hadoop.fs.Path inputPath)
                      throws IOException

Throws:

IOException

openInputStream

public static InputStream openInputStream(org.apache.hadoop.mapreduce.JobContext job,
                          org.apache.hadoop.fs.Path inputPath,
                          org.apache.hadoop.fs.FileSystem fileSystem)
                                   throws IOException

Throws:

IOException

getStats

public static Map<String,Object> getStats(org.apache.hadoop.mapreduce.JobContext job,
                          org.apache.hadoop.fs.Path statsPath)
                                   throws IOException

Throws:

IOException

storeStats

public static void storeStats(org.apache.hadoop.mapreduce.JobContext job,
              org.apache.hadoop.fs.Path path,
              Map<String,Object> stats)
                       throws IOException

Throws:

IOException