Package | Description |
---|---|
org.apache.storm.hdfs.trident |
Modifier and Type | Method and Description |
---|---|
HdfsState.HdfsFileOptions |
HdfsState.HdfsFileOptions.addRotationAction(RotationAction action)
Deprecated.
|
HdfsState.HdfsFileOptions |
HdfsState.HdfsFileOptions.withBufferSize(int sizeInBytes)
Set the size of the buffer used for hdfs file copy in case of recovery.
|
HdfsState.HdfsFileOptions |
HdfsState.HdfsFileOptions.withConfigKey(String configKey) |
HdfsState.HdfsFileOptions |
HdfsState.HdfsFileOptions.withFileNameFormat(FileNameFormat fileNameFormat) |
HdfsState.HdfsFileOptions |
HdfsState.HdfsFileOptions.withFsUrl(String fsUrl) |
HdfsState.HdfsFileOptions |
HdfsState.HdfsFileOptions.withRecordFormat(RecordFormat format) |
HdfsState.HdfsFileOptions |
HdfsState.HdfsFileOptions.withRotationPolicy(FileRotationPolicy rotationPolicy) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.