Package org.apache.storm.hdfs.trident
Class HdfsState.HdfsFileOptions
java.lang.Object
org.apache.storm.hdfs.trident.HdfsState.Options
org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions
- All Implemented Interfaces:
- Serializable
- Enclosing class:
- HdfsState
- See Also:
- 
Field SummaryFieldsFields inherited from class org.apache.storm.hdfs.trident.HdfsState.OptionsconfigKey, fileNameFormat, fs, fsUrl, hdfsConfig, rotation, rotationActions, rotationPolicy
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionaddRotationAction(RotationAction action) Deprecated.voidvoidexecute(List<TridentTuple> tuples) longwithBufferSize(int sizeInBytes) Set the size of the buffer used for hdfs file copy in case of recovery.withConfigKey(String configKey) withFileNameFormat(FileNameFormat fileNameFormat) withRecordFormat(RecordFormat format) withRotationPolicy(FileRotationPolicy rotationPolicy) Methods inherited from class org.apache.storm.hdfs.trident.HdfsState.OptionsrotateOutputFile, rotateOutputFile
- 
Field Details- 
format
 
- 
- 
Constructor Details- 
HdfsFileOptionspublic HdfsFileOptions()
 
- 
- 
Method Details- 
withFsUrl
- 
withConfigKey
- 
withFileNameFormat
- 
withRecordFormat
- 
withRotationPolicy
- 
withBufferSizeSet the size of the buffer used for hdfs file copy in case of recovery. The default value is 131072. Note: The lower limit for the parameter is 4096, below which the option is ignored. - Parameters:
- sizeInBytes- the buffer size in bytes
- Returns:
- HdfsState.HdfsFileOptions
 
- 
addRotationActionDeprecated.
- 
getCurrentOffsetpublic long getCurrentOffset()
- 
doCommit- Throws:
- IOException
 
- 
execute- Throws:
- IOException
 
 
-