public abstract class Settings
extends java.lang.Object
| Constructor and Description |
|---|
Settings() |
| Modifier and Type | Method and Description |
|---|---|
abstract java.util.Properties |
asProperties() |
abstract Settings |
copy() |
Settings |
excludeFilter(java.lang.String prefix) |
boolean |
getBatchFlushManual() |
boolean |
getBatchRefreshAfterWrite() |
int |
getBatchSizeInBytes() |
int |
getBatchSizeInEntries() |
int |
getBatchWriteRetryCount() |
int |
getBatchWriteRetryLimit() |
java.lang.String |
getBatchWriteRetryPolicy() |
long |
getBatchWriteRetryWait() |
org.elasticsearch.hadoop.util.ClusterInfo |
getClusterInfoOrNull()
Get the internal cluster name and version or null if not present in the settings
|
org.elasticsearch.hadoop.util.ClusterInfo |
getClusterInfoOrThrow()
Get the internal cluster name and version or throw an
IllegalArgumentException if not present |
org.elasticsearch.hadoop.util.ClusterInfo |
getClusterInfoOrUnnamedLatest()
Deprecated.
This is a dangerous method to use, because it assumes that you care about which cluster you are working with,
but the info you receive from this call may not be accurate, and thus, cannot be trusted to let you make accurate
decisions about the ES cluster you are speaking with. Prefer to use the
getClusterInfoOrThrow()
instead. |
boolean |
getDataFrameWriteNullValues() |
boolean |
getExcludeSource() |
org.elasticsearch.hadoop.util.unit.TimeValue |
getHeartBeatLead() |
int |
getHttpRetries() |
long |
getHttpTimeout() |
boolean |
getIndexAutoCreate() |
boolean |
getIndexReadAllowRedStatus() |
boolean |
getIndexReadMissingAsEmpty() |
java.lang.String |
getIngestPipeline() |
boolean |
getInputAsJson() |
org.elasticsearch.hadoop.util.EsMajorVersion |
getInternalVersionOrLatest()
Deprecated.
This is kind of a dangerous method to use, because it assumes that you care about which version you are working with,
but the version you receive from this call may not be accurate, and thus, cannot be trusted to let you make accurate
decisions about the version of ES you are speaking with. Prefer to use the
getInternalVersionOrThrow()
instead. |
org.elasticsearch.hadoop.util.EsMajorVersion |
getInternalVersionOrThrow()
Get the internal version or throw an
IllegalArgumentException if not present |
boolean |
getMappingConstantAutoQuote() |
boolean |
getMappingDateRich() |
java.lang.String |
getMappingDefaultClassExtractor() |
java.lang.String |
getMappingExcludes() |
java.lang.String |
getMappingId() |
java.lang.String |
getMappingIdExtractorClassName() |
java.lang.String |
getMappingIncludes() |
java.lang.String |
getMappingIndexExtractorClassName() |
java.lang.String |
getMappingIndexFormatterClassName() |
java.lang.String |
getMappingJoin() |
java.lang.String |
getMappingJoinExtractorClassName() |
java.lang.String |
getMappingMetadataExtractorClassName() |
java.lang.String |
getMappingParamsExtractorClassName() |
java.lang.String |
getMappingParent() |
java.lang.String |
getMappingParentExtractorClassName() |
java.lang.String |
getMappingRouting() |
java.lang.String |
getMappingRoutingExtractorClassName() |
java.lang.String |
getMappingTimestamp() |
java.lang.String |
getMappingTimestampExtractorClassName() |
java.lang.String |
getMappingTtl() |
java.lang.String |
getMappingTtlExtractorClassName() |
java.lang.String |
getMappingVersion() |
java.lang.String |
getMappingVersionExtractorClassName() |
java.lang.String |
getMappingVersionType() |
java.lang.Integer |
getMaxDocsPerPartition() |
java.lang.String |
getNetworkHttpAuthPass()
Deprecated.
|
java.lang.String |
getNetworkHttpAuthUser() |
boolean |
getNetworkHttpsUseSystemProperties() |
boolean |
getNetworkHttpUseSystemProperties() |
java.lang.String |
getNetworkProxyHttpHost() |
java.lang.String |
getNetworkProxyHttpPass()
Deprecated.
|
int |
getNetworkProxyHttpPort() |
java.lang.String |
getNetworkProxyHttpsHost() |
java.lang.String |
getNetworkProxyHttpsPass()
Deprecated.
|
int |
getNetworkProxyHttpsPort() |
java.lang.String |
getNetworkProxyHttpsUser() |
java.lang.String |
getNetworkProxyHttpUser() |
java.lang.String |
getNetworkProxySocksHost() |
java.lang.String |
getNetworkProxySocksPass()
Deprecated.
|
int |
getNetworkProxySocksPort() |
java.lang.String |
getNetworkProxySocksUser() |
boolean |
getNetworkSocksUseSystemProperties() |
java.lang.String |
getNetworkSpnegoAuthElasticsearchPrincipal() |
boolean |
getNetworkSpnegoAuthMutual() |
boolean |
getNetworkSSLAcceptSelfSignedCert() |
boolean |
getNetworkSSLEnabled() |
java.lang.String |
getNetworkSSLKeyStoreLocation() |
java.lang.String |
getNetworkSSLKeyStorePass()
Deprecated.
|
java.lang.String |
getNetworkSSLKeyStoreType() |
java.lang.String |
getNetworkSSLProtocol() |
java.lang.String |
getNetworkSSLTrustStoreLocation() |
java.lang.String |
getNetworkSSLTrustStorePass()
Deprecated.
|
java.lang.String |
getNodes() |
boolean |
getNodesClientOnly() |
boolean |
getNodesDataOnly() |
boolean |
getNodesDiscovery() |
boolean |
getNodesIngestOnly() |
java.lang.String |
getNodesPathPrefix() |
boolean |
getNodesResolveHostnames() |
boolean |
getNodesWANOnly() |
java.lang.String |
getOpaqueId() |
java.lang.String |
getOperation() |
boolean |
getOutputAsJson() |
int |
getPort() |
abstract java.lang.String |
getProperty(java.lang.String name) |
java.lang.String |
getProperty(java.lang.String name,
java.lang.String defaultValue) |
java.lang.String |
getQuery() |
java.lang.String |
getReadFieldAsArrayExclude() |
java.lang.String |
getReadFieldAsArrayInclude() |
boolean |
getReadFieldEmptyAsNull() |
java.lang.String |
getReadFieldExclude() |
FieldPresenceValidation |
getReadFieldExistanceValidation() |
java.lang.String |
getReadFieldInclude() |
boolean |
getReadMappingMissingFieldsIgnore() |
boolean |
getReadMetadata() |
java.lang.String |
getReadMetadataField() |
boolean |
getReadMetadataVersion() |
java.lang.String |
getReadSourceFilter() |
protected java.lang.String |
getResource() |
java.lang.String |
getResourceRead() |
java.lang.String |
getResourceWrite() |
java.lang.String |
getScrollFields() |
long |
getScrollKeepAlive() |
long |
getScrollLimit() |
long |
getScrollSize() |
AuthenticationMethod |
getSecurityAuthenticationMethod() |
java.lang.String |
getSecurityUserProviderClass() |
java.lang.String |
getSerializerBytesConverterClassName() |
java.lang.String |
getSerializerValueReaderClassName() |
java.lang.String |
getSerializerValueWriterClassName() |
Settings |
getSettingsView(java.lang.String name) |
java.lang.String |
getShardPreference() |
org.elasticsearch.hadoop.util.unit.TimeValue |
getTransportPoolingExpirationTimeout() |
int |
getUpdateRetryOnConflict() |
java.lang.String |
getUpdateScript() |
java.lang.String |
getUpdateScriptFile() |
java.lang.String |
getUpdateScriptInline() |
java.lang.String |
getUpdateScriptLang() |
java.lang.String |
getUpdateScriptParams() |
java.lang.String |
getUpdateScriptParamsJson() |
java.lang.String |
getUpdateScriptStored() |
java.lang.Boolean |
getUpdateScriptUpsert() |
boolean |
hasMappingVersionType() |
boolean |
hasScriptUpsert() |
boolean |
hasUpdateScript() |
boolean |
hasUpdateScriptParams() |
boolean |
hasUpdateScriptParamsJson() |
Settings |
load(java.lang.String source) |
abstract java.io.InputStream |
loadResource(java.lang.String location) |
Settings |
merge(java.util.Map<java.lang.String,java.lang.String> map) |
Settings |
merge(java.util.Properties properties) |
java.lang.String |
save() |
Settings |
setHosts(java.lang.String hosts)
Deprecated.
|
Settings |
setInternalClusterInfo(org.elasticsearch.hadoop.util.ClusterInfo clusterInfo) |
Settings |
setInternalVersion(org.elasticsearch.hadoop.util.EsMajorVersion version)
Deprecated.
prefer to use Settings#setInternalClusterInfo
|
Settings |
setMaxDocsPerPartition(int size) |
Settings |
setNodes(java.lang.String hosts) |
Settings |
setOpaqueId(java.lang.String opaqueId) |
Settings |
setPort(int port) |
abstract void |
setProperty(java.lang.String name,
java.lang.String value) |
Settings |
setQuery(java.lang.String query) |
Settings |
setResourceRead(java.lang.String index) |
Settings |
setResourceWrite(java.lang.String index) |
Settings |
setUserAgent(java.lang.String userAgent) |
public org.elasticsearch.hadoop.util.EsMajorVersion getInternalVersionOrThrow()
IllegalArgumentException if not presentEsMajorVersion extracted from the properties@Deprecated public org.elasticsearch.hadoop.util.EsMajorVersion getInternalVersionOrLatest()
getInternalVersionOrThrow()
instead.EsMajorVersion.LATEST if not presentEsMajorVersion extracted from the properties or EsMajorVersion.LATEST if not presentpublic org.elasticsearch.hadoop.util.ClusterInfo getClusterInfoOrThrow()
IllegalArgumentException if not presentClusterInfo extracted from the propertiespublic org.elasticsearch.hadoop.util.ClusterInfo getClusterInfoOrNull()
ClusterInfo extracted from the properties or null if not present@Deprecated public org.elasticsearch.hadoop.util.ClusterInfo getClusterInfoOrUnnamedLatest()
getClusterInfoOrThrow()
instead.IllegalArgumentException if not presentClusterInfo extracted from the propertiespublic java.lang.String getNodes()
public int getPort()
public boolean getNodesDiscovery()
public java.lang.String getShardPreference()
public java.lang.String getNodesPathPrefix()
public boolean getNodesDataOnly()
public boolean getNodesIngestOnly()
public boolean getNodesClientOnly()
public boolean getNodesWANOnly()
public long getHttpTimeout()
public int getHttpRetries()
public int getBatchSizeInBytes()
public int getBatchSizeInEntries()
public int getBatchWriteRetryCount()
public int getBatchWriteRetryLimit()
public long getBatchWriteRetryWait()
public java.lang.String getBatchWriteRetryPolicy()
public boolean getBatchRefreshAfterWrite()
public boolean getBatchFlushManual()
public long getScrollKeepAlive()
public long getScrollSize()
public long getScrollLimit()
public java.lang.String getScrollFields()
public boolean getExcludeSource()
public java.lang.String getSerializerValueWriterClassName()
public java.lang.String getSerializerBytesConverterClassName()
public java.lang.String getSerializerValueReaderClassName()
public boolean getIndexAutoCreate()
public boolean getIndexReadMissingAsEmpty()
public boolean getIndexReadAllowRedStatus()
public boolean getInputAsJson()
public boolean getOutputAsJson()
public java.lang.String getOperation()
public java.lang.String getMappingId()
public java.lang.String getMappingParent()
public java.lang.String getMappingJoin()
public java.lang.String getMappingVersion()
public boolean hasMappingVersionType()
public java.lang.String getMappingVersionType()
public java.lang.String getMappingRouting()
public java.lang.String getMappingTtl()
public java.lang.String getMappingTimestamp()
public java.lang.String getMappingDefaultClassExtractor()
public java.lang.String getMappingMetadataExtractorClassName()
public java.lang.String getMappingIdExtractorClassName()
public java.lang.String getMappingParentExtractorClassName()
public java.lang.String getMappingJoinExtractorClassName()
public java.lang.String getMappingVersionExtractorClassName()
public java.lang.String getMappingRoutingExtractorClassName()
public java.lang.String getMappingTtlExtractorClassName()
public java.lang.String getMappingTimestampExtractorClassName()
public java.lang.String getMappingIndexExtractorClassName()
public java.lang.String getMappingIndexFormatterClassName()
public java.lang.String getMappingParamsExtractorClassName()
public boolean getMappingConstantAutoQuote()
public boolean getMappingDateRich()
public java.lang.String getMappingIncludes()
public java.lang.String getMappingExcludes()
public java.lang.String getIngestPipeline()
public int getUpdateRetryOnConflict()
public java.lang.String getUpdateScript()
public java.lang.String getUpdateScriptInline()
public java.lang.Boolean getUpdateScriptUpsert()
public java.lang.String getUpdateScriptFile()
public java.lang.String getUpdateScriptStored()
public java.lang.String getUpdateScriptLang()
public java.lang.String getUpdateScriptParams()
public java.lang.String getUpdateScriptParamsJson()
public boolean hasUpdateScript()
public boolean hasUpdateScriptParams()
public boolean hasUpdateScriptParamsJson()
public boolean hasScriptUpsert()
public boolean getReadFieldEmptyAsNull()
public FieldPresenceValidation getReadFieldExistanceValidation()
public java.lang.String getReadFieldInclude()
public java.lang.String getReadFieldExclude()
public java.lang.String getReadFieldAsArrayInclude()
public java.lang.String getReadFieldAsArrayExclude()
public java.lang.String getReadSourceFilter()
public org.elasticsearch.hadoop.util.unit.TimeValue getHeartBeatLead()
public org.elasticsearch.hadoop.util.unit.TimeValue getTransportPoolingExpirationTimeout()
public boolean getNetworkSSLEnabled()
public java.lang.String getNetworkSSLKeyStoreLocation()
public java.lang.String getNetworkSSLProtocol()
public java.lang.String getNetworkSSLKeyStoreType()
@Deprecated public java.lang.String getNetworkSSLKeyStorePass()
public java.lang.String getNetworkSSLTrustStoreLocation()
@Deprecated public java.lang.String getNetworkSSLTrustStorePass()
public boolean getNetworkSSLAcceptSelfSignedCert()
public java.lang.String getNetworkHttpAuthUser()
@Deprecated public java.lang.String getNetworkHttpAuthPass()
public java.lang.String getNetworkSpnegoAuthElasticsearchPrincipal()
public boolean getNetworkSpnegoAuthMutual()
public java.lang.String getNetworkProxyHttpHost()
public int getNetworkProxyHttpPort()
public java.lang.String getNetworkProxyHttpUser()
@Deprecated public java.lang.String getNetworkProxyHttpPass()
public boolean getNetworkHttpUseSystemProperties()
public java.lang.String getNetworkProxyHttpsHost()
public int getNetworkProxyHttpsPort()
public java.lang.String getNetworkProxyHttpsUser()
@Deprecated public java.lang.String getNetworkProxyHttpsPass()
public boolean getNetworkHttpsUseSystemProperties()
public java.lang.String getNetworkProxySocksHost()
public int getNetworkProxySocksPort()
public java.lang.String getNetworkProxySocksUser()
@Deprecated public java.lang.String getNetworkProxySocksPass()
public boolean getNetworkSocksUseSystemProperties()
public boolean getNodesResolveHostnames()
public Settings setInternalClusterInfo(org.elasticsearch.hadoop.util.ClusterInfo clusterInfo)
@Deprecated public Settings setInternalVersion(org.elasticsearch.hadoop.util.EsMajorVersion version)
public Settings setNodes(java.lang.String hosts)
@Deprecated public Settings setHosts(java.lang.String hosts)
public Settings setPort(int port)
public Settings setResourceRead(java.lang.String index)
public Settings setResourceWrite(java.lang.String index)
public Settings setQuery(java.lang.String query)
public Settings setMaxDocsPerPartition(int size)
protected java.lang.String getResource()
public java.lang.String getResourceRead()
public java.lang.String getResourceWrite()
public java.lang.String getQuery()
public java.lang.Integer getMaxDocsPerPartition()
public boolean getReadMetadata()
public java.lang.String getReadMetadataField()
public boolean getReadMetadataVersion()
public boolean getReadMappingMissingFieldsIgnore()
public boolean getDataFrameWriteNullValues()
public AuthenticationMethod getSecurityAuthenticationMethod()
public java.lang.String getSecurityUserProviderClass()
public abstract java.io.InputStream loadResource(java.lang.String location)
public abstract Settings copy()
public java.lang.String getProperty(java.lang.String name,
java.lang.String defaultValue)
public abstract java.lang.String getProperty(java.lang.String name)
public abstract void setProperty(java.lang.String name,
java.lang.String value)
public Settings getSettingsView(java.lang.String name)
public Settings excludeFilter(java.lang.String prefix)
public Settings merge(java.util.Properties properties)
public Settings merge(java.util.Map<java.lang.String,java.lang.String> map)
public Settings load(java.lang.String source)
public java.lang.String save()
public abstract java.util.Properties asProperties()
public Settings setOpaqueId(java.lang.String opaqueId)
public java.lang.String getOpaqueId()
public Settings setUserAgent(java.lang.String userAgent)