public class SparkSettings extends Settings
| Constructor and Description |
|---|
SparkSettings(org.apache.spark.SparkConf cfg) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Properties |
asProperties() |
Settings |
copy() |
java.lang.String |
getProperty(java.lang.String name) |
java.io.InputStream |
loadResource(java.lang.String location) |
void |
setProperty(java.lang.String name,
java.lang.String value) |
getBatchFlushManual, getBatchRefreshAfterWrite, getBatchSizeInBytes, getBatchSizeInEntries, getBatchWriteRetryCount, getBatchWriteRetryPolicy, getBatchWriteRetryWait, getDataFrameWriteNullValues, getHeartBeatLead, getHttpRetries, getHttpTimeout, getIndexAutoCreate, getIndexReadMissingAsEmpty, getIngestPipeline, getInputAsJson, getInternalVersionOrLatest, getInternalVersionOrThrow, getMappingConstantAutoQuote, getMappingDateRich, getMappingDefaultClassExtractor, getMappingExcludes, getMappingId, getMappingIdExtractorClassName, getMappingIncludes, getMappingIndexExtractorClassName, getMappingIndexFormatterClassName, getMappingParamsExtractorClassName, getMappingParent, getMappingParentExtractorClassName, getMappingRouting, getMappingRoutingExtractorClassName, getMappingTimestamp, getMappingTimestampExtractorClassName, getMappingTtl, getMappingTtlExtractorClassName, getMappingVersion, getMappingVersionExtractorClassName, getMappingVersionType, getMaxDocsPerPartition, getNetworkHttpAuthPass, getNetworkHttpAuthUser, getNetworkHttpsUseSystemProperties, getNetworkHttpUseSystemProperties, getNetworkProxyHttpHost, getNetworkProxyHttpPass, getNetworkProxyHttpPort, getNetworkProxyHttpsHost, getNetworkProxyHttpsPass, getNetworkProxyHttpsPort, getNetworkProxyHttpsUser, getNetworkProxyHttpUser, getNetworkProxySocksHost, getNetworkProxySocksPass, getNetworkProxySocksPort, getNetworkProxySocksUser, getNetworkSocksUseSystemProperties, getNetworkSSLAcceptSelfSignedCert, getNetworkSSLEnabled, getNetworkSSLKeyStoreLocation, getNetworkSSLKeyStorePass, getNetworkSSLKeyStoreType, getNetworkSSLProtocol, getNetworkSSLTrustStoreLocation, getNetworkSSLTrustStorePass, getNodes, getNodesClientOnly, getNodesDataOnly, getNodesDiscovery, getNodesIngestOnly, getNodesPathPrefix, getNodesResolveHostnames, getNodesWANOnly, getOperation, getOutputAsJson, getPort, getProperty, getQuery, getReadFieldAsArrayExclude, getReadFieldAsArrayInclude, getReadFieldEmptyAsNull, getReadFieldExclude, getReadFieldExistanceValidation, getReadFieldInclude, getReadMappingMissingFieldsIgnore, getReadMetadata, getReadMetadataField, getReadMetadataVersion, getResource, getResourceRead, getResourceWrite, getScrollFields, getScrollKeepAlive, getScrollLimit, getScrollSize, getSerializerBytesConverterClassName, getSerializerValueReaderClassName, getSerializerValueWriterClassName, getTransportPoolingExpirationTimeout, getUpdateRetryOnConflict, getUpdateScript, getUpdateScriptLang, getUpdateScriptParams, getUpdateScriptParamsJson, hasMappingVersionType, hasUpdateScript, hasUpdateScriptParams, hasUpdateScriptParamsJson, load, merge, merge, save, setHosts, setInternalVersion, setMaxDocsPerPartition, setNodes, setPort, setQuery, setResourceRead, setResourceWritepublic java.io.InputStream loadResource(java.lang.String location)
loadResource in class Settingspublic java.lang.String getProperty(java.lang.String name)
getProperty in class Settingspublic void setProperty(java.lang.String name,
java.lang.String value)
setProperty in class Settingspublic java.util.Properties asProperties()
asProperties in class Settings