Package 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	Description
static String	FIELD_ID
static String	SYSTEM_PROPERTY_STRIP_INVALID_FIELD_CHARS

Constructor Summary

Constructors

Constructor	Description
ElasticSearchUtils()

Method Summary

Modifier and Type	Method	Description
static org.elasticsearch.index.query.QueryBuilder	createQueryBuilderForSimpleWhere(List<org.apache.metamodel.query.FilterItem> whereItems, org.apache.metamodel.query.LogicalOperator logicalOperator)	Creates, if possible, a QueryBuilder object which can be used to push down one or more FilterItems to ElasticSearch's backend.
static org.apache.metamodel.data.Row	createRow(Map<String,Object> sourceMap, String documentId, org.apache.metamodel.data.DataSetHeader header)
static org.apache.metamodel.schema.ColumnType	getColumnTypeFromElasticSearchType(String metaDataFieldType)
static org.elasticsearch.index.query.QueryBuilder	getExistsQuery(String fieldName)
static Map<String,?>	getMappingSource(org.apache.metamodel.schema.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(org.apache.metamodel.schema.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<org.apache.metamodel.query.FilterItem> whereItems,
                                                                                          org.apache.metamodel.query.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 org.apache.metamodel.schema.ColumnType getColumnTypeFromElasticSearchType(String metaDataFieldType)

createRow

public static org.apache.metamodel.data.Row createRow(Map<String,Object> sourceMap,
                                                      String documentId,
                                                      org.apache.metamodel.data.DataSetHeader header)