public class StormSettings extends Settings
| Constructor and Description |
|---|
StormSettings(java.util.Map<?,?> settings) |
| Modifier and Type | Method and Description |
|---|---|
java.util.Properties |
asProperties() |
Settings |
copy() |
java.lang.String |
getProperty(java.lang.String name) |
boolean |
getStormBoltAck() |
int |
getStormBulkSize() |
java.util.List<java.lang.String> |
getStormSpoutFields() |
boolean |
getStormSpoutReliable() |
int |
getStormSpoutReliableQueueSize() |
int |
getStormSpoutReliableRetriesPerTuple() |
TupleFailureHandling |
getStormSpoutReliableTupleFailureHandling() |
boolean |
getStormTickTupleFlush() |
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, getExcludeSource, getHeartBeatLead, getHttpRetries, getHttpTimeout, getIndexAutoCreate, getIndexReadAllowRedStatus, getIndexReadMissingAsEmpty, getIngestPipeline, getInputAsJson, getInternalVersionOrLatest, getInternalVersionOrThrow, getMappingConstantAutoQuote, getMappingDateRich, getMappingDefaultClassExtractor, getMappingExcludes, getMappingId, getMappingIdExtractorClassName, getMappingIncludes, getMappingIndexExtractorClassName, getMappingIndexFormatterClassName, getMappingJoin, getMappingJoinExtractorClassName, 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, getReadSourceFilter, 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 boolean getStormTickTupleFlush()
public boolean getStormBoltAck()
public int getStormBulkSize()
public boolean getStormSpoutReliable()
public int getStormSpoutReliableQueueSize()
public int getStormSpoutReliableRetriesPerTuple()
public TupleFailureHandling getStormSpoutReliableTupleFailureHandling()
public java.util.List<java.lang.String> getStormSpoutFields()
public 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