public class ShapeFileRecordReader
extends java.lang.Object
org.apache.hadoop.mapred.RecordReader
for ESRI Shapefiles. The input has to be the main file (.shp). The directories in HDFS where the index files and DBF files are located can be specified. As well a directory to find .cpg files can be specified to define the encoding. By default the same directory as the main shapefile will be used. DBF and .cpg files are optional. Keys are the position in the main file, and values are Maps with the attributes of the Shapefile record including the ShapeFileInputFormat.GEOMETRY_ATTRIBUTE.Constructor and Description |
---|
ShapeFileRecordReader(JobConf conf, FileSplit split, java.lang.String indexFilesPath, java.lang.String dbfFilesPath, java.lang.String cpgFilesPath)
Create an instance.
|
Modifier and Type | Method and Description |
---|---|
void |
close() |
LongWritable |
createKey() |
MapWritable |
createValue() |
long |
getPos() |
float |
getProgress() |
boolean |
next(LongWritable key, MapWritable value) |
public ShapeFileRecordReader(JobConf conf, FileSplit split, java.lang.String indexFilesPath, java.lang.String dbfFilesPath, java.lang.String cpgFilesPath) throws java.io.IOException
conf
- the job configurationsplit
- file split of the main fileindexFilesPath
- index files pathdbfFilesPath
- DBF files pathcpgFilesPath
- CPG files pathjava.io.IOException
- if an IOException is thrownpublic void close() throws java.io.IOException
java.io.IOException
public LongWritable createKey()
public MapWritable createValue()
public long getPos() throws java.io.IOException
java.io.IOException
public float getProgress() throws java.io.IOException
java.io.IOException
public boolean next(LongWritable key, MapWritable value) throws java.io.IOException
java.io.IOException
Copyright © 2017, 2019 Oracle and/or its affiliates. All Rights Reserved.