oracle.spatial.hadoop.vector.nosql

Class NoSQLBaseEntryProcessor<V>

java.lang.Object

oracle.spatial.hadoop.vector.nosql.NoSQLBaseEntryProcessor<V>

Type Parameters:

V - The type

All Implemented Interfaces:

NoSQLEntryProcessor

Direct Known Subclasses:

NoSQLGeoJSONEntryProcessor, NoSQLJGeometryEntryProcessor, NoSQLTextEntryProcessor

public abstract class NoSQLBaseEntryProcessor<V>
extends java.lang.Object
implements NoSQLEntryProcessor

Defines common functionality that can aid on the implementation of a concrete NoSQLEntryProcessor

Field Summary

Fields

Modifier and Type	Field and Description
protected NoSQLConfiguration	kvConfiguration

Constructor Summary

Constructors

Constructor and Description
NoSQLBaseEntryProcessor()

Method Summary

Methods

Modifier and Type	Method and Description
protected java.lang.String	getRecordFieldName(oracle.kv.KeyValueVersion entry)
protected abstract V	getRecordFieldValue(oracle.kv.KeyValueVersion entry)
void	init(NoSQLConfiguration kvConf) Initializes the current processor using the given NoSQLConfiguration
void	processEntry(oracle.kv.KeyValueVersion entry, org.apache.hadoop.io.Text outKey, RecordInfo outValue, NoSQLContext kvContext) Sets information from the given NoSQL entry to the passed outKey and outValue
protected void	setKeyAndId(oracle.kv.KeyValueVersion entry, org.apache.hadoop.io.Text outKey, RecordInfo outValue)
protected void	setOutKey(oracle.kv.KeyValueVersion entry, org.apache.hadoop.io.Text outKey, RecordInfo outValue)
protected void	setOutValueId(oracle.kv.KeyValueVersion entry, org.apache.hadoop.io.Text outKey, RecordInfo outValue)
protected abstract void	setRecordField(RecordInfo record, java.lang.String fieldName, V fieldValue)

Methods inherited from class java.lang.Object

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

Field Detail

kvConfiguration

protected NoSQLConfiguration kvConfiguration

Constructor Detail

NoSQLBaseEntryProcessor

public NoSQLBaseEntryProcessor()

Method Detail

init

public void init(NoSQLConfiguration kvConf)

Description copied from interface: NoSQLEntryProcessor

Initializes the current processor using the given NoSQLConfiguration

Specified by:

init in interface NoSQLEntryProcessor

processEntry

public void processEntry(oracle.kv.KeyValueVersion entry,
                         org.apache.hadoop.io.Text outKey,
                         RecordInfo outValue,
                         NoSQLContext kvContext)

Description copied from interface: NoSQLEntryProcessor

Sets information from the given NoSQL entry to the passed outKey and outValue

Specified by:

processEntry in interface NoSQLEntryProcessor

Parameters:

entry - a NoSQL entry

outKey - the current mapper record key

outValue - the current mapper record value

kvContext - the current NoSQLContext

setKeyAndId

protected void setKeyAndId(oracle.kv.KeyValueVersion entry,
                           org.apache.hadoop.io.Text outKey,
                           RecordInfo outValue)

setOutKey

protected void setOutKey(oracle.kv.KeyValueVersion entry,
                         org.apache.hadoop.io.Text outKey,
                         RecordInfo outValue)

setOutValueId

protected void setOutValueId(oracle.kv.KeyValueVersion entry,
                             org.apache.hadoop.io.Text outKey,
                             RecordInfo outValue)

getRecordFieldName

protected java.lang.String getRecordFieldName(oracle.kv.KeyValueVersion entry)

getRecordFieldValue

protected abstract V getRecordFieldValue(oracle.kv.KeyValueVersion entry)

setRecordField

protected abstract void setRecordField(RecordInfo record,
                                       java.lang.String fieldName,
                                       V fieldValue)