public class DefaultEsTupleMapper extends Object implements EsTupleMapper
| Constructor and Description |
|---|
DefaultEsTupleMapper() |
| Modifier and Type | Method and Description |
|---|---|
String |
getId(ITuple tuple)
Extracts id from tuple.
|
String |
getIndex(ITuple tuple)
Extracts index from tuple.
|
Map<String,String> |
getParams(ITuple tuple,
Map<String,String> defaultValue)
Extracts params from tuple if available.
|
String |
getSource(ITuple tuple)
Extracts source from tuple.
|
String |
getType(ITuple tuple)
Extracts type from tuple.
|
public String getSource(ITuple tuple)
EsTupleMapperExtracts source from tuple.
getSource in interface EsTupleMappertuple - source tuplepublic String getIndex(ITuple tuple)
EsTupleMapperExtracts index from tuple.
getIndex in interface EsTupleMappertuple - source tuplepublic String getType(ITuple tuple)
EsTupleMapperExtracts type from tuple.
getType in interface EsTupleMappertuple - source tuplepublic String getId(ITuple tuple)
EsTupleMapperExtracts id from tuple.
getId in interface EsTupleMappertuple - source tuplepublic Map<String,String> getParams(ITuple tuple, Map<String,String> defaultValue)
EsTupleMapperExtracts params from tuple if available.
getParams in interface EsTupleMappertuple - source tupledefaultValue - value to return if params are missingCopyright © 2021 The Apache Software Foundation. All rights reserved.