Package | Description |
---|---|
org.apache.storm.hdfs.bolt | |
org.apache.storm.hdfs.bolt.rotation | |
org.apache.storm.hdfs.common |
Modifier and Type | Field and Description |
---|---|
protected FileRotationPolicy |
AbstractHdfsBolt.rotationPolicy |
Modifier and Type | Method and Description |
---|---|
SequenceFileBolt |
SequenceFileBolt.withRotationPolicy(FileRotationPolicy rotationPolicy) |
AvroGenericRecordBolt |
AvroGenericRecordBolt.withRotationPolicy(FileRotationPolicy rotationPolicy) |
HdfsBolt |
HdfsBolt.withRotationPolicy(FileRotationPolicy rotationPolicy) |
Modifier and Type | Class and Description |
---|---|
class |
FileSizeRotationPolicy
File rotation policy that will rotate files when a certain file size is reached.
|
class |
NoRotationPolicy
File rotation policy that will never rotate… Just one big file.
|
class |
TimedRotationPolicy |
Modifier and Type | Method and Description |
---|---|
FileRotationPolicy |
NoRotationPolicy.copy() |
FileRotationPolicy |
FileSizeRotationPolicy.copy() |
FileRotationPolicy |
TimedRotationPolicy.copy() |
FileRotationPolicy |
FileRotationPolicy.copy()
Must be able to copy the rotation policy.
|
Modifier and Type | Field and Description |
---|---|
protected FileRotationPolicy |
AbstractHDFSWriter.rotationPolicy |
Constructor and Description |
---|
AbstractHDFSWriter(FileRotationPolicy policy,
org.apache.hadoop.fs.Path path) |
AvroGenericRecordHDFSWriter(FileRotationPolicy policy,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.fs.FSDataOutputStream stream,
org.apache.avro.Schema schema) |
HDFSWriter(FileRotationPolicy policy,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.fs.FSDataOutputStream out,
RecordFormat format) |
SequenceFileWriter(FileRotationPolicy policy,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.io.SequenceFile.Writer writer,
SequenceFormat format) |
Copyright © 2020 The Apache Software Foundation. All rights reserved.