public class StormSettings extends Settings
| Constructor and Description |
|---|
StormSettings(Map<?,?> settings) |
| Modifier and Type | Method and Description |
|---|---|
protected Properties |
asProperties() |
Settings |
copy() |
String |
getProperty(String name) |
boolean |
getStormBoltAck() |
int |
getStormBulkSize() |
List<String> |
getStormSpoutFields() |
boolean |
getStormSpoutReliable() |
int |
getStormSpoutReliableQueueSize() |
int |
getStormSpoutReliableRetriesPerTuple() |
TupleFailureHandling |
getStormSpoutReliableTupleFailureHandling() |
boolean |
getStormTickTupleFlush() |
InputStream |
loadResource(String location) |
void |
setProperty(String name,
String value) |
getBatchFlushManual, getBatchRefreshAfterWrite, getBatchSizeInBytes, getBatchSizeInEntries, getBatchWriteRetryCount, getBatchWriteRetryPolicy, getBatchWriteRetryWait, getFieldExistanceValidation, getFieldReadEmptyAsNull, getHeartBeatLead, getHttpRetries, getHttpTimeout, getIndexAutoCreate, getIndexReadMissingAsEmpty, getInputAsJson, getMappingConstantAutoQuote, getMappingDateRich, getMappingDefaultClassExtractor, getMappingExcludes, getMappingId, getMappingIdExtractorClassName, getMappingIncludes, getMappingIndexExtractorClassName, getMappingIndexFormatterClassName, getMappingParamsExtractorClassName, getMappingParent, getMappingParentExtractorClassName, getMappingRouting, getMappingRoutingExtractorClassName, getMappingTimestamp, getMappingTimestampExtractorClassName, getMappingTtl, getMappingTtlExtractorClassName, getMappingVersion, getMappingVersionExtractorClassName, getMappingVersionType, getNetworkHttpAuthPass, getNetworkHttpAuthUser, getNetworkHttpUseSystemProperties, getNetworkProxyHttpHost, getNetworkProxyHttpPass, getNetworkProxyHttpPort, getNetworkProxyHttpUser, getNetworkProxySocksHost, getNetworkProxySocksPass, getNetworkProxySocksPort, getNetworkProxySocksUser, getNetworkSocksUseSystemProperties, getNetworkSSLAcceptSelfSignedCert, getNetworkSSLEnabled, getNetworkSSLKeyStoreLocation, getNetworkSSLKeyStorePass, getNetworkSSLKeyStoreType, getNetworkSSLProtocol, getNetworkSSLTrustStoreLocation, getNetworkSSLTrustStorePass, getNodes, getNodesClientOnly, getNodesDiscovery, getOperation, getOutputAsJson, getPort, getProperty, getQuery, getReadMetadata, getReadMetadataField, getReadMetadataVersion, getResource, getResourceRead, getResourceWrite, getScrollEscapeUri, getScrollFields, getScrollKeepAlive, getScrollSize, getSerializerBytesConverterClassName, getSerializerValueReaderClassName, getSerializerValueWriterClassName, getUpdateRetryOnConflict, getUpdateScript, getUpdateScriptLang, getUpdateScriptParams, getUpdateScriptParamsJson, hasMappingVersionType, hasUpdateScript, hasUpdateScriptParams, hasUpdateScriptParamsJson, load, merge, merge, save, setHosts, setNodes, setPort, setQuery, setResourceRead, setResourceWritepublic StormSettings(Map<?,?> settings)
public boolean getStormTickTupleFlush()
public boolean getStormBoltAck()
public int getStormBulkSize()
public boolean getStormSpoutReliable()
public int getStormSpoutReliableQueueSize()
public int getStormSpoutReliableRetriesPerTuple()
public TupleFailureHandling getStormSpoutReliableTupleFailureHandling()
public InputStream loadResource(String location)
loadResource in class Settingspublic String getProperty(String name)
getProperty in class Settingspublic void setProperty(String name, String value)
setProperty in class Settingsprotected Properties asProperties()
asProperties in class Settings