Serialized Form
Package org.apache.storm.hdfs.bolt |
rotationActions
ArrayList<E> rotationActions
currentFile
org.apache.hadoop.fs.Path currentFile
collector
OutputCollector collector
syncPolicy
SyncPolicy syncPolicy
rotationPolicy
FileRotationPolicy rotationPolicy
fileNameFormat
FileNameFormat fileNameFormat
rotation
int rotation
fsUrl
String fsUrl
configKey
String configKey
format
RecordFormat format
offset
long offset
format
SequenceFormat format
compressionType
org.apache.hadoop.io.SequenceFile.CompressionType compressionType
compressionCodec
String compressionCodec
Package org.apache.storm.hdfs.bolt.format |
componentId
String componentId
taskId
int taskId
path
String path
prefix
String prefix
extension
String extension
keyField
String keyField
valueField
String valueField
fieldDelimiter
String fieldDelimiter
recordDelimiter
String recordDelimiter
fields
Fields fields
Package org.apache.storm.hdfs.bolt.rotation |
maxBytes
long maxBytes
lastOffset
long lastOffset
currentBytesWritten
long currentBytesWritten
interval
long interval
Package org.apache.storm.hdfs.bolt.sync |
count
int count
executeCount
int executeCount
Package org.apache.storm.hdfs.common.rotation |
destination
String destination
Package org.apache.storm.hdfs.trident |
format
RecordFormat format
offset
long offset
fsUrl
String fsUrl
configKey
String configKey
currentFile
org.apache.hadoop.fs.Path currentFile
rotationPolicy
FileRotationPolicy rotationPolicy
fileNameFormat
FileNameFormat fileNameFormat
rotation
int rotation
rotationActions
ArrayList<E> rotationActions
format
SequenceFormat format
compressionType
org.apache.hadoop.io.SequenceFile.CompressionType compressionType
compressionCodec
String compressionCodec
options
HdfsState.Options options
Package org.apache.storm.hdfs.trident.format |
partitionIndex
int partitionIndex
path
String path
prefix
String prefix
extension
String extension
keyField
String keyField
valueField
String valueField
fieldDelimiter
String fieldDelimiter
recordDelimiter
String recordDelimiter
fields
Fields fields
Package org.apache.storm.hdfs.trident.rotation |
maxBytes
long maxBytes
lastOffset
long lastOffset
currentBytesWritten
long currentBytesWritten
interval
long interval
Package org.apache.storm.hdfs.trident.sync |
count
int count
executeCount
int executeCount
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.