org.apache.metamodel.elasticsearch.common

Class ElasticSearchUtils

java.lang.Object

org.apache.metamodel.elasticsearch.common.ElasticSearchUtils

public class ElasticSearchUtils
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIELD_ID
static String	SYSTEM_PROPERTY_STRIP_INVALID_FIELD_CHARS

Constructor Summary

Constructors

Constructor and Description
ElasticSearchUtils()

Method Summary

Modifier and Type	Method and Description
static org.elasticsearch.index.query.QueryBuilder	createQueryBuilderForSimpleWhere(List<FilterItem> whereItems, LogicalOperator logicalOperator) Creates, if possible, a QueryBuilder object which can be used to push down one or more FilterItems to ElasticSearch's backend.
static Row	createRow(Map<String,Object> sourceMap, String documentId, DataSetHeader header) Creates and returns a Row for the given sourceMap, using the documentId as primary key and the header as definition of which columns are added to the row.
static ColumnType	getColumnTypeFromElasticSearchType(String metaDataFieldType)
static org.elasticsearch.index.query.QueryBuilder	getExistsQuery(String fieldName)
static Map<String,?>	getMappingSource(MutableTable table)
static org.elasticsearch.index.query.QueryBuilder	getMissingQuery(String fieldName)
static String	getValidatedFieldName(String fieldName) Field name special characters are: .

Methods inherited from class java.lang.Object

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

Field Detail

FIELD_ID

public static final String FIELD_ID

See Also:

Constant Field Values

SYSTEM_PROPERTY_STRIP_INVALID_FIELD_CHARS

public static final String SYSTEM_PROPERTY_STRIP_INVALID_FIELD_CHARS

See Also:

Constant Field Values

Constructor Detail

ElasticSearchUtils

public ElasticSearchUtils()

Method Detail

getMissingQuery

public static org.elasticsearch.index.query.QueryBuilder getMissingQuery(String fieldName)

getExistsQuery

public static org.elasticsearch.index.query.QueryBuilder getExistsQuery(String fieldName)

getMappingSource

public static Map<String,?> getMappingSource(MutableTable table)

getValidatedFieldName

public static String getValidatedFieldName(String fieldName)

Field name special characters are: . (used for navigation between name components) # (for delimiting name components in _uid, should work, but is discouraged) * (for matching names)

Parameters:

fieldName -

Returns:

createQueryBuilderForSimpleWhere

public static org.elasticsearch.index.query.QueryBuilder createQueryBuilderForSimpleWhere(List<FilterItem> whereItems,
                                                                                          LogicalOperator logicalOperator)

Creates, if possible, a QueryBuilder object which can be used to push down one or more FilterItems to ElasticSearch's backend.

Returns:

a QueryBuilder if one was produced, or null if the items could not be pushed down to an ElasticSearch query

getColumnTypeFromElasticSearchType

public static ColumnType getColumnTypeFromElasticSearchType(String metaDataFieldType)

createRow

public static Row createRow(Map<String,Object> sourceMap,
                            String documentId,
                            DataSetHeader header)

Creates and returns a Row for the given sourceMap, using the documentId as primary key and the header as definition of which columns are added to the row.