org.ojai.json.mapreduce

Class Hadoop

java.lang.Object

org.ojai.json.mapreduce.Hadoop

@API.Public
 @API.Factory
public class Hadoop
extends Object

This class serves as a factory for a creating OJAI DocumentStream from Hadoop FileSystem files.

Constructor Summary

Constructors

Constructor and Description
Hadoop()

Method Summary

Modifier and Type	Method and Description
static org.ojai.DocumentStream	newDocumentStream(org.apache.hadoop.fs.FileSystem fs, String path)
static org.ojai.DocumentStream	newDocumentStream(org.apache.hadoop.fs.FileSystem fs, String path, org.ojai.json.Events.Delegate eventDelegate)
static org.ojai.DocumentStream	newDocumentStream(org.apache.hadoop.fs.FileSystem fs, String path, Map<org.ojai.FieldPath,org.ojai.Value.Type> fieldPathTypeMap)
static org.ojai.DocumentStream	newDocumentStream(org.apache.hadoop.fs.FileSystem fs, String path, Map<org.ojai.FieldPath,org.ojai.Value.Type> map, org.ojai.json.Events.Delegate delegate)

Methods inherited from class java.lang.Object

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

Constructor Detail

Hadoop

public Hadoop()

Method Detail

newDocumentStream

public static org.ojai.DocumentStream newDocumentStream(@API.NonNullable
                                                        org.apache.hadoop.fs.FileSystem fs,
                                                        @API.NonNullable
                                                        String path)
                                                 throws org.ojai.exceptions.DecodingException,
                                                        IOException

Throws:

org.ojai.exceptions.DecodingException

IOException

newDocumentStream

public static org.ojai.DocumentStream newDocumentStream(@API.NonNullable
                                                        org.apache.hadoop.fs.FileSystem fs,
                                                        @API.NonNullable
                                                        String path,
                                                        @API.NonNullable
                                                        Map<org.ojai.FieldPath,org.ojai.Value.Type> fieldPathTypeMap)
                                                 throws org.ojai.exceptions.DecodingException,
                                                        IOException

Throws:

org.ojai.exceptions.DecodingException

IOException

newDocumentStream

public static org.ojai.DocumentStream newDocumentStream(@API.NonNullable
                                                        org.apache.hadoop.fs.FileSystem fs,
                                                        @API.NonNullable
                                                        String path,
                                                        @API.NonNullable
                                                        org.ojai.json.Events.Delegate eventDelegate)
                                                 throws org.ojai.exceptions.DecodingException,
                                                        IOException

Throws:

org.ojai.exceptions.DecodingException

IOException

newDocumentStream

public static org.ojai.DocumentStream newDocumentStream(org.apache.hadoop.fs.FileSystem fs,
                                                        String path,
                                                        Map<org.ojai.FieldPath,org.ojai.Value.Type> map,
                                                        org.ojai.json.Events.Delegate delegate)
                                                 throws IllegalArgumentException,
                                                        IOException

Throws:

IllegalArgumentException

IOException