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)
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)