K
- The type of the keysV
- The type of the valuespublic class SpatialFilterInputFormat<K,V> extends WrapperInputFormat<K,V,K,V>
WrapperInputFormat
that is capable of spatially filter records returned by an internal input format.SpatialOperationConfig
must be configured in the current job.ConfigParams.SPATIAL_INDEX_NAME
or setting the spatial index location the job configuration as ConfigParams.SPATIAL_INDEX_LOCATION
.Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CONF_INPUT_FORMAT_FILTER_READERS |
Constructor and Description |
---|
SpatialFilterInputFormat() |
Modifier and Type | Method and Description |
---|---|
<any> |
createRecordReader(InputSplit split, TaskAttemptContext context) |
<any> |
getInputFormat() |
RecordInfoProvider<K,V> |
getRecordInfoProvider() |
SpatialIndexSplitFilter |
getSpatiallyIndexedSplitFilter() |
SpatialOperationConfig |
getSpatialOperationConfig() |
createInternalInputFormat, getFittingInputSplit, getInternalInputFormat, getInternalInputFormatClass, getRecordInfoProvider, getRecordInfoProviderClass, getSplits, setInternalInputFormatClass, setRecordInfoProviderClass
public static final java.lang.String CONF_INPUT_FORMAT_FILTER_READERS
public <any> createRecordReader(InputSplit split, TaskAttemptContext context) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public <any> getInputFormat()
public RecordInfoProvider<K,V> getRecordInfoProvider()
public SpatialIndexSplitFilter getSpatiallyIndexedSplitFilter()
public SpatialOperationConfig getSpatialOperationConfig()
Copyright © 2017 Oracle and/or its affiliates. All Rights Reserved.