public class ScalaRowValueReader extends ScalaValueReader implements RowValueReader, org.elasticsearch.hadoop.serialization.builder.ValueParsingCallback
| Constructor and Description |
|---|
ScalaRowValueReader() |
| Modifier and Type | Method and Description |
|---|---|
Object |
addToArray(Object array,
List<Object> values) |
void |
addToMap(Object map,
Object key,
Object value) |
void |
beginDoc() |
void |
beginGeoField() |
void |
beginLeadMetadata() |
void |
beginSource() |
void |
beginTrailMetadata() |
Object |
createArray(org.elasticsearch.hadoop.serialization.FieldType typ) |
Timestamp |
createDate(long value) |
Object |
createMap() |
scala.collection.Seq<String> |
currentArrayRowOrder() |
void |
endDoc() |
void |
endGeoField() |
void |
endLeadMetadata() |
void |
endSource() |
void |
endTrailMetadata() |
void |
excludeSource() |
boolean |
inArray() |
boolean |
metadataMap() |
Object |
readValue(org.elasticsearch.hadoop.serialization.Parser parser,
String value,
org.elasticsearch.hadoop.serialization.FieldType esType) |
boolean |
rootLevel() |
arrayDepth, arrayExclude, arrayInclude, binaryValue, booleanValue, byteValue, checkNull, createDate, date, doubleValue, emptyAsNull, floatValue, intValue, longValue, nullValue, parseBinary, parseBoolean, parseByte, parseDate, parseDouble, parseFloat, parseInt, parseLong, parseShort, parseText, richDate, setSettings, shortValue, textValue, wrapArray, wrapStringbeginField, endField, getCurrentFieldclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddToBuffer, arrayFields, currentFieldIsGeo, metadataField, readMetadata, rowColumns, rowColumnsMap, setSettings, sparkRowFieldpublic Object addToArray(Object array, List<Object> values)
addToArray in interface org.elasticsearch.hadoop.serialization.builder.ValueReaderaddToArray in class ScalaValueReaderpublic void addToMap(Object map, Object key, Object value)
addToMap in interface org.elasticsearch.hadoop.serialization.builder.ValueReaderaddToMap in class ScalaValueReaderpublic void beginDoc()
beginDoc in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallbackpublic void beginGeoField()
beginGeoField in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallbackpublic void beginLeadMetadata()
beginLeadMetadata in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallbackpublic void beginSource()
beginSource in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallbackpublic void beginTrailMetadata()
beginTrailMetadata in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallbackpublic Object createArray(org.elasticsearch.hadoop.serialization.FieldType typ)
createArray in interface org.elasticsearch.hadoop.serialization.builder.ValueReadercreateArray in class ScalaValueReaderpublic Timestamp createDate(long value)
createDate in class ScalaValueReaderpublic Object createMap()
createMap in interface org.elasticsearch.hadoop.serialization.builder.ValueReadercreateMap in class ScalaValueReaderpublic scala.collection.Seq<String> currentArrayRowOrder()
public void endDoc()
endDoc in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallbackpublic void endGeoField()
endGeoField in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallbackpublic void endLeadMetadata()
endLeadMetadata in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallbackpublic void endSource()
endSource in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallbackpublic void endTrailMetadata()
endTrailMetadata in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallbackpublic void excludeSource()
excludeSource in interface org.elasticsearch.hadoop.serialization.builder.ValueParsingCallbackpublic boolean inArray()
public boolean metadataMap()
public Object readValue(org.elasticsearch.hadoop.serialization.Parser parser, String value, org.elasticsearch.hadoop.serialization.FieldType esType)
readValue in interface org.elasticsearch.hadoop.serialization.builder.ValueReaderreadValue in class ScalaValueReaderpublic boolean rootLevel()