Constant Field Values

Contents

• org.elasticsearch.*

org.elasticsearch.*

org.elasticsearch.hadoop.cfg.ConfigurationOptions

Modifier and Type	Constant Field	Value
public static final String	ES_BATCH_FLUSH_MANUAL	"es.batch.flush.manual"
public static final String	ES_BATCH_FLUSH_MANUAL_DEFAULT	"false"
public static final String	ES_BATCH_SIZE_BYTES	"es.batch.size.bytes"
public static final String	ES_BATCH_SIZE_BYTES_DEFAULT	"1mb"
public static final String	ES_BATCH_SIZE_ENTRIES	"es.batch.size.entries"
public static final String	ES_BATCH_SIZE_ENTRIES_DEFAULT	"1000"
public static final String	ES_BATCH_WRITE_REFRESH	"es.batch.write.refresh"
public static final String	ES_BATCH_WRITE_REFRESH_DEFAULT	"true"
public static final String	ES_BATCH_WRITE_RETRY_COUNT	"es.batch.write.retry.count"
public static final String	ES_BATCH_WRITE_RETRY_COUNT_DEFAULT	"3"
public static final String	ES_BATCH_WRITE_RETRY_LIMIT	"es.batch.write.retry.limit"
public static final String	ES_BATCH_WRITE_RETRY_LIMIT_DEFAULT	"50"
public static final String	ES_BATCH_WRITE_RETRY_POLICY	"es.batch.write.retry.policy"
public static final String	ES_BATCH_WRITE_RETRY_POLICY_DEFAULT	"simple"
public static final String	ES_BATCH_WRITE_RETRY_POLICY_NONE	"none"
public static final String	ES_BATCH_WRITE_RETRY_POLICY_SIMPLE	"simple"
public static final String	ES_BATCH_WRITE_RETRY_WAIT	"es.batch.write.retry.wait"
public static final String	ES_BATCH_WRITE_RETRY_WAIT_DEFAULT	"10s"
public static final int	ES_DEFAULT_MAX_DOCS_PER_PARTITION	100000
public static final String	ES_HEART_BEAT_LEAD	"es.action.heart.beat.lead"
public static final String	ES_HEART_BEAT_LEAD_DEFAULT	"15s"
public static final String	ES_HTTP_RETRIES	"es.http.retries"
public static final String	ES_HTTP_RETRIES_DEFAULT	"3"
public static final String	ES_HTTP_TIMEOUT	"es.http.timeout"
public static final String	ES_HTTP_TIMEOUT_DEFAULT	"1m"
public static final String	ES_INDEX_AUTO_CREATE	"es.index.auto.create"
public static final String	ES_INDEX_AUTO_CREATE_DEFAULT	"yes"
public static final String	ES_INDEX_READ_ALLOW_RED_STATUS	"es.index.read.allow.red.status"
public static final String	ES_INDEX_READ_ALLOW_RED_STATUS_DEFAULT	"false"
public static final String	ES_INDEX_READ_MISSING_AS_EMPTY	"es.index.read.missing.as.empty"
public static final String	ES_INDEX_READ_MISSING_AS_EMPTY_DEFAULT	"false"
public static final String	ES_INGEST_PIPELINE	"es.ingest.pipeline"
public static final String	ES_INGEST_PIPELINE_DEFAULT	""
public static final String	ES_INPUT_JSON	"es.input.json"
public static final String	ES_INPUT_JSON_DEFAULT	"no"
public static final String	ES_INPUT_USE_SLICED_PARTITIONS	"es.input.use.sliced.partitions"
public static final String	ES_INPUT_USE_SLICED_PARTITIONS_DEFAULT	"true"
public static final String	ES_KEYSTORE_LOCATION	"es.keystore.location"
public static final String	ES_MAPPING_CONSTANT_AUTO_QUOTE	"es.mapping.constant.auto.quote"
public static final String	ES_MAPPING_CONSTANT_AUTO_QUOTE_DEFAULT	"true"
public static final String	ES_MAPPING_DATE_RICH_OBJECT	"es.mapping.date.rich"
public static final String	ES_MAPPING_DATE_RICH_OBJECT_DEFAULT	"true"
public static final String	ES_MAPPING_DEFAULT_EXTRACTOR_CLASS	"es.mapping.default.extractor.class"
public static final String	ES_MAPPING_EXCLUDE	"es.mapping.exclude"
public static final String	ES_MAPPING_EXCLUDE_DEFAULT	""
public static final String	ES_MAPPING_ID	"es.mapping.id"
public static final String	ES_MAPPING_ID_EXTRACTOR_CLASS	"es.mapping.id.extractor.class"
public static final String	ES_MAPPING_INCLUDE	"es.mapping.include"
public static final String	ES_MAPPING_INCLUDE_DEFAULT	""
public static final String	ES_MAPPING_INDEX_EXTRACTOR_CLASS	"es.mapping.index.extractor.class"
public static final String	ES_MAPPING_INDEX_FORMATTER_CLASS	"es.mapping.index.formatter.class"
public static final String	ES_MAPPING_JOIN	"es.mapping.join"
public static final String	ES_MAPPING_JOIN_EXTRACTOR_CLASS	"es.mapping.join.extractor.class"
public static final String	ES_MAPPING_PARAMS_EXTRACTOR_CLASS	"es.mapping.params.extractor.class"
public static final String	ES_MAPPING_PARENT	"es.mapping.parent"
public static final String	ES_MAPPING_PARENT_EXTRACTOR_CLASS	"es.mapping.parent.extractor.class"
public static final String	ES_MAPPING_ROUTING	"es.mapping.routing"
public static final String	ES_MAPPING_ROUTING_EXTRACTOR_CLASS	"es.mapping.routing.extractor.class"
public static final String	ES_MAPPING_TIMESTAMP	"es.mapping.timestamp"
public static final String	ES_MAPPING_TIMESTAMP_EXTRACTOR_CLASS	"es.mapping.timestamp.extractor.class"
public static final String	ES_MAPPING_TTL	"es.mapping.ttl"
public static final String	ES_MAPPING_TTL_EXTRACTOR_CLASS	"es.mapping.ttl.extractor.class"
public static final String	ES_MAPPING_VERSION	"es.mapping.version"
public static final String	ES_MAPPING_VERSION_EXTRACTOR_CLASS	"es.mapping.version.extractor.class"
public static final String	ES_MAPPING_VERSION_TYPE	"es.mapping.version.type"
public static final String	ES_MAPPING_VERSION_TYPE_EXTERNAL	"external"
public static final String	ES_MAPPING_VERSION_TYPE_EXTERNAL_GT	"external_gt"
public static final String	ES_MAPPING_VERSION_TYPE_EXTERNAL_GTE	"external_gte"
public static final String	ES_MAPPING_VERSION_TYPE_FORCE	"force"
public static final String	ES_MAPPING_VERSION_TYPE_INTERNAL	"internal"
public static final String	ES_MAX_DOCS_PER_PARTITION	"es.input.max.docs.per.partition"
public static final String	ES_NET_HTTP_AUTH_PASS	"es.net.http.auth.pass"
public static final String	ES_NET_HTTP_AUTH_USER	"es.net.http.auth.user"
public static final String	ES_NET_HTTP_HEADER_PREFIX	"es.net.http.header."
public static final String	ES_NET_PROXY_HTTP_HOST	"es.net.proxy.http.host"
public static final String	ES_NET_PROXY_HTTP_PASS	"es.net.proxy.http.pass"
public static final String	ES_NET_PROXY_HTTP_PORT	"es.net.proxy.http.port"
public static final String	ES_NET_PROXY_HTTP_USE_SYSTEM_PROPS	"es.net.proxy.http.use.system.props"
public static final String	ES_NET_PROXY_HTTP_USE_SYSTEM_PROPS_DEFAULT	"yes"
public static final String	ES_NET_PROXY_HTTP_USER	"es.net.proxy.http.user"
public static final String	ES_NET_PROXY_HTTPS_HOST	"es.net.proxy.https.host"
public static final String	ES_NET_PROXY_HTTPS_PASS	"es.net.proxy.https.pass"
public static final String	ES_NET_PROXY_HTTPS_PORT	"es.net.proxy.https.port"
public static final String	ES_NET_PROXY_HTTPS_USE_SYSTEM_PROPS	"es.net.proxy.https.use.system.props"
public static final String	ES_NET_PROXY_HTTPS_USE_SYSTEM_PROPS_DEFAULT	"yes"
public static final String	ES_NET_PROXY_HTTPS_USER	"es.net.proxy.https.user"
public static final String	ES_NET_PROXY_SOCKS_HOST	"es.net.proxy.socks.host"
public static final String	ES_NET_PROXY_SOCKS_PASS	"es.net.proxy.socks.pass"
public static final String	ES_NET_PROXY_SOCKS_PORT	"es.net.proxy.socks.port"
public static final String	ES_NET_PROXY_SOCKS_USE_SYSTEM_PROPS	"es.net.proxy.socks.use.system.props"
public static final String	ES_NET_PROXY_SOCKS_USE_SYSTEM_PROPS_DEFAULT	"yes"
public static final String	ES_NET_PROXY_SOCKS_USER	"es.net.proxy.socks.user"
public static final String	ES_NET_SSL_CERT_ALLOW_SELF_SIGNED	"es.net.ssl.cert.allow.self.signed"
public static final String	ES_NET_SSL_CERT_ALLOW_SELF_SIGNED_DEFAULT	"false"
public static final String	ES_NET_SSL_KEYSTORE_LOCATION	"es.net.ssl.keystore.location"
public static final String	ES_NET_SSL_KEYSTORE_PASS	"es.net.ssl.keystore.pass"
public static final String	ES_NET_SSL_KEYSTORE_TYPE	"es.net.ssl.keystore.type"
public static final String	ES_NET_SSL_KEYSTORE_TYPE_DEFAULT	"JKS"
public static final String	ES_NET_SSL_PROTOCOL	"es.net.ssl.protocol"
public static final String	ES_NET_SSL_PROTOCOL_DEFAULT	"TLS"
public static final String	ES_NET_SSL_TRUST_STORE_LOCATION	"es.net.ssl.truststore.location"
public static final String	ES_NET_SSL_TRUST_STORE_PASS	"es.net.ssl.truststore.pass"
public static final String	ES_NET_TRANSPORT_POOLING_EXPIRATION_TIMEOUT	"es.net.transport.pooling.expiration.timeout"
public static final String	ES_NET_TRANSPORT_POOLING_EXPIRATION_TIMEOUT_DEFAULT	"5m"
public static final String	ES_NET_USE_SSL	"es.net.ssl"
public static final String	ES_NET_USE_SSL_DEFAULT	"false"
public static final String	ES_NODES	"es.nodes"
public static final String	ES_NODES_CLIENT_ONLY	"es.nodes.client.only"
public static final String	ES_NODES_CLIENT_ONLY_DEFAULT	"false"
public static final String	ES_NODES_DATA_ONLY	"es.nodes.data.only"
public static final String	ES_NODES_DATA_ONLY_DEFAULT	"true"
public static final String	ES_NODES_DEFAULT	"localhost"
public static final String	ES_NODES_DISCOVERY	"es.nodes.discovery"
public static final String	ES_NODES_DISCOVERY_DEFAULT	"true"
public static final String	ES_NODES_INGEST_ONLY	"es.nodes.ingest.only"
public static final String	ES_NODES_INGEST_ONLY_DEFAULT	"false"
public static final String	ES_NODES_PATH_PREFIX	"es.nodes.path.prefix"
public static final String	ES_NODES_PATH_PREFIX_DEFAULT	""
public static final String	ES_NODES_RESOLVE_HOST_NAME	"es.nodes.resolve.hostname"
public static final String	ES_NODES_WAN_ONLY	"es.nodes.wan.only"
public static final String	ES_NODES_WAN_ONLY_DEFAULT	"false"
public static final String	ES_OPERATION_CREATE	"create"
public static final String	ES_OPERATION_DELETE	"delete"
public static final String	ES_OPERATION_INDEX	"index"
public static final String	ES_OPERATION_UPDATE	"update"
public static final String	ES_OPERATION_UPSERT	"upsert"
public static final String	ES_OUTPUT_JSON	"es.output.json"
public static final String	ES_OUTPUT_JSON_DEFAULT	"no"
public static final String	ES_PORT	"es.port"
public static final String	ES_PORT_DEFAULT	"9200"
public static final String	ES_QUERY	"es.query"
public static final String	ES_READ_FIELD_AS_ARRAY_EXCLUDE	"es.read.field.as.array.exclude"
public static final String	ES_READ_FIELD_AS_ARRAY_INCLUDE	"es.read.field.as.array.include"
public static final String	ES_READ_FIELD_EMPTY_AS_NULL	"es.read.field.empty.as.null"
public static final String	ES_READ_FIELD_EMPTY_AS_NULL_DEFAULT	"yes"
public static final String	ES_READ_FIELD_EMPTY_AS_NULL_LEGACY	"es.field.read.empty.as.null"
public static final String	ES_READ_FIELD_EXCLUDE	"es.read.field.exclude"
public static final String	ES_READ_FIELD_INCLUDE	"es.read.field.include"
public static final String	ES_READ_FIELD_VALIDATE_PRESENCE	"es.read.field.validate.presence"
public static final String	ES_READ_FIELD_VALIDATE_PRESENCE_DEFAULT	"warn"
public static final String	ES_READ_FIELD_VALIDATE_PRESENCE_LEGACY	"es.field.read.validate.presence"
public static final String	ES_READ_METADATA	"es.read.metadata"
public static final String	ES_READ_METADATA_DEFAULT	"false"
public static final String	ES_READ_METADATA_FIELD	"es.read.metadata.field"
public static final String	ES_READ_METADATA_FIELD_DEFAULT	"_metadata"
public static final String	ES_READ_METADATA_VERSION	"es.read.metadata.version"
public static final String	ES_READ_METADATA_VERSION_DEFAULT	"false"
public static final String	ES_READ_SOURCE_FILTER	"es.read.source.filter"
public static final String	ES_READ_UNMAPPED_FIELDS_IGNORE	"es.read.unmapped.fields.ignore"
public static final String	ES_READ_UNMAPPED_FIELDS_IGNORE_DEFAULT	"true"
public static final String	ES_RESOURCE	"es.resource"
public static final String	ES_RESOURCE_READ	"es.resource.read"
public static final String	ES_RESOURCE_WRITE	"es.resource.write"
public static final String	ES_SCROLL_KEEPALIVE	"es.scroll.keepalive"
public static final String	ES_SCROLL_KEEPALIVE_DEFAULT	"5m"
public static final String	ES_SCROLL_LIMIT	"es.scroll.limit"
public static final String	ES_SCROLL_LIMIT_DEFAULT	"-1"
public static final String	ES_SCROLL_SIZE	"es.scroll.size"
public static final String	ES_SCROLL_SIZE_DEFAULT	"50"
public static final String	ES_SERIALIZATION_READER_VALUE_CLASS	"es.ser.reader.value.class"
public static final String	ES_SERIALIZATION_WRITER_BYTES_CLASS	"es.ser.writer.bytes.class"
public static final String	ES_SERIALIZATION_WRITER_VALUE_CLASS	"es.ser.writer.value.class"
public static final String	ES_SPARK_DATAFRAME_WRITE_NULL_VALUES	"es.spark.dataframe.write.null"
public static final String	ES_SPARK_DATAFRAME_WRITE_NULL_VALUES_DEFAULT	"false"
public static final String	ES_UPDATE_RETRY_ON_CONFLICT	"es.update.retry.on.conflict"
public static final String	ES_UPDATE_RETRY_ON_CONFLICT_DEFAULT	"0"
public static final String	ES_UPDATE_SCRIPT_FILE	"es.update.script.file"
public static final String	ES_UPDATE_SCRIPT_INLINE	"es.update.script.inline"
public static final String	ES_UPDATE_SCRIPT_LANG	"es.update.script.lang"
public static final String	ES_UPDATE_SCRIPT_LEGACY	"es.update.script"
public static final String	ES_UPDATE_SCRIPT_PARAMS	"es.update.script.params"
public static final String	ES_UPDATE_SCRIPT_PARAMS_JSON	"es.update.script.params.json"
public static final String	ES_UPDATE_SCRIPT_STORED	"es.update.script.stored"
public static final String	ES_WRITE_OPERATION	"es.write.operation"
public static final String	ES_WRITE_OPERATION_DEFAULT	"index"

org.elasticsearch.hadoop.cfg.InternalConfigurationOptions

Modifier and Type	Constant Field	Value
public static final String	INTERNAL_ES_DISCOVERED_NODES	"es.internal.discovered.nodes"
public static final String	INTERNAL_ES_EXCLUDE_SOURCE	"es.internal.exclude.source"
public static final String	INTERNAL_ES_EXCLUDE_SOURCE_DEFAULT	"false"
public static final String	INTERNAL_ES_PINNED_NODE	"es.internal.pinned.node"
public static final String	INTERNAL_ES_QUERY_FILTERS	"es.internal.query.filters"
public static final String	INTERNAL_ES_TARGET_FIELDS	"es.internal.mr.target.fields"
public static final String	INTERNAL_ES_VERSION	"es.internal.es.version"
public static final String	INTERNAL_TRANSPORT_POOLING_KEY	"es.internal.transport.pooling.key"

org.elasticsearch.hadoop.handler.impl.DropAndLog<I extends Exceptional,O,C extends ErrorCollector<O>>

Modifier and Type	Constant Field	Value
public static final String	CONF_LOGGER_CLASS	"logger.class"
public static final String	CONF_LOGGER_LEVEL	"logger.level"
public static final String	CONF_LOGGER_NAME	"logger.name"

org.elasticsearch.hadoop.handler.impl.elasticsearch.ElasticsearchHandler<I extends Exceptional,O,C extends ErrorCollector<O>>

Modifier and Type	Constant Field	Value
public static final String	CONF_CLIENT_CONF	"client.conf"
public static final String	CONF_CLIENT_INHERIT	"client.inherit"
public static final String	CONF_CLIENT_NODES	"client.nodes"
public static final String	CONF_CLIENT_PORT	"client.port"
public static final String	CONF_CLIENT_RESOURCE	"client.resource"
public static final String	CONF_LABEL	"label"
public static final String	CONF_PASS_REASON_SUFFIX	"reason"
public static final String	CONF_RETURN_ERROR	"return.error"
public static final String	CONF_RETURN_VALUE	"return.default"
public static final String	CONF_TAGS	"tags"

org.elasticsearch.hadoop.mr.MultiOutputFormat

Modifier and Type	Constant Field	Value
public static final String	CFG_FIELD	"es.hadoop.multi.of"

org.elasticsearch.storm.cfg.StormConfigurationOptions

Modifier and Type	Constant Field	Value
public static final String	ES_STORM_BOLT_ACK	"es.storm.bolt.write.ack"
public static final String	ES_STORM_BOLT_ACK_DEFAULT	"false"
public static final String	ES_STORM_BOLT_FLUSH_ENTRIES_SIZE	"es.storm.bolt.flush.entries.size"
public static final String	ES_STORM_BOLT_TICK_TUPLE_FLUSH	"es.storm.bolt.tick.tuple.flush"
public static final String	ES_STORM_BOLT_TICK_TUPLE_FLUSH_DEFAULT	"true"
public static final String	ES_STORM_SPOUT_FIELDS	"es.storm.spout.fields"
public static final String	ES_STORM_SPOUT_FIELDS_DEFAULT	""
public static final String	ES_STORM_SPOUT_RELIABLE	"es.storm.spout.reliable"
public static final String	ES_STORM_SPOUT_RELIABLE_DEFAULT	"false"
public static final String	ES_STORM_SPOUT_RELIABLE_QUEUE_SIZE	"es.storm.spout.reliable.queue.size"
public static final String	ES_STORM_SPOUT_RELIABLE_QUEUE_SIZE_DEFAULT	"0"
public static final String	ES_STORM_SPOUT_RELIABLE_RETRIES_PER_TUPLE	"es.storm.spout.reliable.retries.per.tuple"
public static final String	ES_STORM_SPOUT_RELIABLE_RETRIES_PER_TUPLE_DEFAULT	"5"
public static final String	ES_STORM_SPOUT_RELIABLE_TUPLE_FAILURE_HANDLE	"es.storm.spout.reliable.handle.tuple.failure"
public static final String	ES_STORM_SPOUT_RELIABLE_TUPLE_FAILURE_HANDLE_DEFAULT	"abort"