A B C D E F G H K L M N O P R S T U V W

A

AbstractHdfsBolt - Class in org.apache.storm.hdfs.bolt
 
AbstractHdfsBolt() - Constructor for class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
addRotationAction(RotationAction) - Method in class org.apache.storm.hdfs.bolt.HdfsBolt
 
addRotationAction(RotationAction) - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt
 
addRotationAction(RotationAction) - Method in class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions
 
addRotationAction(RotationAction) - Method in class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions
 

B

beginCommit(Long) - Method in class org.apache.storm.hdfs.trident.HdfsState
 

C

collector - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
commit(Long) - Method in class org.apache.storm.hdfs.trident.HdfsState
 
configKey - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
configKey - Variable in class org.apache.storm.hdfs.trident.HdfsState.Options
 
CountSyncPolicy - Class in org.apache.storm.hdfs.bolt.sync
SyncPolicy implementation that will trigger a file system sync after a certain number of tuples have been processed.
CountSyncPolicy(int) - Constructor for class org.apache.storm.hdfs.bolt.sync.CountSyncPolicy
 
CountSyncPolicy - Class in org.apache.storm.hdfs.trident.sync
SyncPolicy implementation that will trigger a file system sync after a certain number of tuples have been processed.
CountSyncPolicy(int) - Constructor for class org.apache.storm.hdfs.trident.sync.CountSyncPolicy
 

D

declareOutputFields(OutputFieldsDeclarer) - Method in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
DEFAULT_FIELD_DELIMITER - Static variable in class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat
 
DEFAULT_FIELD_DELIMITER - Static variable in class org.apache.storm.hdfs.trident.format.DelimitedRecordFormat
 
DEFAULT_RECORD_DELIMITER - Static variable in class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat
 
DEFAULT_RECORD_DELIMITER - Static variable in class org.apache.storm.hdfs.trident.format.DelimitedRecordFormat
 
DefaultFileNameFormat - Class in org.apache.storm.hdfs.bolt.format
Creates file names with the following format:
DefaultFileNameFormat() - Constructor for class org.apache.storm.hdfs.bolt.format.DefaultFileNameFormat
 
DefaultFileNameFormat - Class in org.apache.storm.hdfs.trident.format
Creates file names with the following format:
DefaultFileNameFormat() - Constructor for class org.apache.storm.hdfs.trident.format.DefaultFileNameFormat
 
DefaultSequenceFormat - Class in org.apache.storm.hdfs.bolt.format
Basic SequenceFormat implementation that uses LongWritable for keys and Text for values.
DefaultSequenceFormat(String, String) - Constructor for class org.apache.storm.hdfs.bolt.format.DefaultSequenceFormat
 
DefaultSequenceFormat - Class in org.apache.storm.hdfs.trident.format
Basic SequenceFormat implementation that uses LongWritable for keys and Text for values.
DefaultSequenceFormat(String, String) - Constructor for class org.apache.storm.hdfs.trident.format.DefaultSequenceFormat
 
DelimitedRecordFormat - Class in org.apache.storm.hdfs.bolt.format
RecordFormat implementation that uses field and record delimiters.
DelimitedRecordFormat() - Constructor for class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat
 
DelimitedRecordFormat - Class in org.apache.storm.hdfs.trident.format
RecordFormat implementation that uses field and record delimiters.
DelimitedRecordFormat() - Constructor for class org.apache.storm.hdfs.trident.format.DelimitedRecordFormat
 
doPrepare(Map, TopologyContext, OutputCollector) - Method in class org.apache.storm.hdfs.bolt.HdfsBolt
 
doPrepare(Map, TopologyContext, OutputCollector) - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt
 

E

execute(Tuple) - Method in class org.apache.storm.hdfs.bolt.HdfsBolt
 
execute(Tuple) - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt
 
execute(FileSystem, Path) - Method in class org.apache.storm.hdfs.common.rotation.MoveFileAction
 
execute(FileSystem, Path) - Method in interface org.apache.storm.hdfs.common.rotation.RotationAction
 
execute(List<TridentTuple>) - Method in class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions
 
execute(List<TridentTuple>) - Method in class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions
 

F

fileNameFormat - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
FileNameFormat - Interface in org.apache.storm.hdfs.bolt.format
Formatter interface for determining HDFS file names.
FileNameFormat - Interface in org.apache.storm.hdfs.trident.format
Formatter interface for determining HDFS file names.
fileNameFormat - Variable in class org.apache.storm.hdfs.trident.HdfsState.Options
 
FileRotationPolicy - Interface in org.apache.storm.hdfs.bolt.rotation
Used by the HdfsBolt to decide when to rotate files.
FileRotationPolicy - Interface in org.apache.storm.hdfs.trident.rotation
Used by the HdfsBolt to decide when to rotate files.
FileSizeRotationPolicy - Class in org.apache.storm.hdfs.bolt.rotation
File rotation policy that will rotate files when a certain file size is reached.
FileSizeRotationPolicy(float, FileSizeRotationPolicy.Units) - Constructor for class org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicy
 
FileSizeRotationPolicy - Class in org.apache.storm.hdfs.trident.rotation
File rotation policy that will rotate files when a certain file size is reached.
FileSizeRotationPolicy(float, FileSizeRotationPolicy.Units) - Constructor for class org.apache.storm.hdfs.trident.rotation.FileSizeRotationPolicy
 
FileSizeRotationPolicy.Units - Enum in org.apache.storm.hdfs.bolt.rotation
 
FileSizeRotationPolicy.Units - Enum in org.apache.storm.hdfs.trident.rotation
 
format(Tuple) - Method in class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat
 
format(Tuple) - Method in interface org.apache.storm.hdfs.bolt.format.RecordFormat
 
format(TridentTuple) - Method in class org.apache.storm.hdfs.trident.format.DelimitedRecordFormat
 
format(TridentTuple) - Method in interface org.apache.storm.hdfs.trident.format.RecordFormat
 
format - Variable in class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions
 
fs - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
fs - Variable in class org.apache.storm.hdfs.trident.HdfsState.Options
 
fsUrl - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
fsUrl - Variable in class org.apache.storm.hdfs.trident.HdfsState.Options
 

G

getByteCount() - Method in enum org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicy.Units
 
getByteCount() - Method in enum org.apache.storm.hdfs.trident.rotation.FileSizeRotationPolicy.Units
 
getInterval() - Method in class org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicy
 
getInterval() - Method in class org.apache.storm.hdfs.trident.rotation.TimedRotationPolicy
 
getMilliSeconds() - Method in enum org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicy.TimeUnit
 
getMilliSeconds() - Method in enum org.apache.storm.hdfs.trident.rotation.TimedRotationPolicy.TimeUnit
 
getName(long, long) - Method in class org.apache.storm.hdfs.bolt.format.DefaultFileNameFormat
 
getName(long, long) - Method in interface org.apache.storm.hdfs.bolt.format.FileNameFormat
Returns the filename the HdfsBolt will create.
getName(long, long) - Method in class org.apache.storm.hdfs.trident.format.DefaultFileNameFormat
 
getName(long, long) - Method in interface org.apache.storm.hdfs.trident.format.FileNameFormat
Returns the filename the HdfsBolt will create.
getPath() - Method in class org.apache.storm.hdfs.bolt.format.DefaultFileNameFormat
 
getPath() - Method in interface org.apache.storm.hdfs.bolt.format.FileNameFormat
 
getPath() - Method in class org.apache.storm.hdfs.trident.format.DefaultFileNameFormat
 
getPath() - Method in interface org.apache.storm.hdfs.trident.format.FileNameFormat
 

H

HdfsBolt - Class in org.apache.storm.hdfs.bolt
 
HdfsBolt() - Constructor for class org.apache.storm.hdfs.bolt.HdfsBolt
 
hdfsConfig - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
hdfsConfig - Variable in class org.apache.storm.hdfs.trident.HdfsState.Options
 
HdfsSecurityUtil - Class in org.apache.storm.hdfs.common.security
This class provides util methods for storm-hdfs connector communicating with secured HDFS.
HdfsSecurityUtil() - Constructor for class org.apache.storm.hdfs.common.security.HdfsSecurityUtil
 
HdfsState - Class in org.apache.storm.hdfs.trident
 
HdfsState.HdfsFileOptions - Class in org.apache.storm.hdfs.trident
 
HdfsState.HdfsFileOptions() - Constructor for class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions
 
HdfsState.Options - Class in org.apache.storm.hdfs.trident
 
HdfsState.Options() - Constructor for class org.apache.storm.hdfs.trident.HdfsState.Options
 
HdfsState.SequenceFileOptions - Class in org.apache.storm.hdfs.trident
 
HdfsState.SequenceFileOptions() - Constructor for class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions
 
HdfsStateFactory - Class in org.apache.storm.hdfs.trident
 
HdfsStateFactory() - Constructor for class org.apache.storm.hdfs.trident.HdfsStateFactory
 
HdfsUpdater - Class in org.apache.storm.hdfs.trident
 
HdfsUpdater() - Constructor for class org.apache.storm.hdfs.trident.HdfsUpdater
 

K

key(Tuple) - Method in class org.apache.storm.hdfs.bolt.format.DefaultSequenceFormat
 
key(Tuple) - Method in interface org.apache.storm.hdfs.bolt.format.SequenceFormat
Given a tuple, return the key that should be written to the sequence file.
key(TridentTuple) - Method in class org.apache.storm.hdfs.trident.format.DefaultSequenceFormat
 
key(TridentTuple) - Method in interface org.apache.storm.hdfs.trident.format.SequenceFormat
Given a tuple, return the key that should be written to the sequence file.
keyClass() - Method in class org.apache.storm.hdfs.bolt.format.DefaultSequenceFormat
 
keyClass() - Method in interface org.apache.storm.hdfs.bolt.format.SequenceFormat
Key class used by implementation (e.g.
keyClass() - Method in class org.apache.storm.hdfs.trident.format.DefaultSequenceFormat
 
keyClass() - Method in interface org.apache.storm.hdfs.trident.format.SequenceFormat
Key class used by implementation (e.g.

L

LOG - Static variable in class org.apache.storm.hdfs.trident.HdfsState
 
login(Map, Configuration) - Static method in class org.apache.storm.hdfs.common.security.HdfsSecurityUtil
 

M

makeState(Map, IMetricsContext, int, int) - Method in class org.apache.storm.hdfs.trident.HdfsStateFactory
 
mark(Tuple, long) - Method in interface org.apache.storm.hdfs.bolt.rotation.FileRotationPolicy
Called for every tuple the HdfsBolt executes.
mark(Tuple, long) - Method in class org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicy
 
mark(Tuple, long) - Method in class org.apache.storm.hdfs.bolt.rotation.NoRotationPolicy
 
mark(Tuple, long) - Method in class org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicy
Called for every tuple the HdfsBolt executes.
mark(Tuple, long) - Method in class org.apache.storm.hdfs.bolt.sync.CountSyncPolicy
 
mark(Tuple, long) - Method in interface org.apache.storm.hdfs.bolt.sync.SyncPolicy
Called for every tuple the HdfsBolt executes.
mark(TridentTuple, long) - Method in interface org.apache.storm.hdfs.trident.rotation.FileRotationPolicy
Called for every tuple the HdfsBolt executes.
mark(TridentTuple, long) - Method in class org.apache.storm.hdfs.trident.rotation.FileSizeRotationPolicy
 
mark(TridentTuple, long) - Method in class org.apache.storm.hdfs.trident.rotation.NoRotationPolicy
 
mark(TridentTuple, long) - Method in class org.apache.storm.hdfs.trident.rotation.TimedRotationPolicy
Called for every tuple the HdfsBolt executes.
mark(TridentTuple, long) - Method in class org.apache.storm.hdfs.trident.sync.CountSyncPolicy
 
mark(TridentTuple, long) - Method in interface org.apache.storm.hdfs.trident.sync.SyncPolicy
Called for every tuple the HdfsBolt executes.
MoveFileAction - Class in org.apache.storm.hdfs.common.rotation
 
MoveFileAction() - Constructor for class org.apache.storm.hdfs.common.rotation.MoveFileAction
 

N

NoRotationPolicy - Class in org.apache.storm.hdfs.bolt.rotation
File rotation policy that will never rotate...
NoRotationPolicy() - Constructor for class org.apache.storm.hdfs.bolt.rotation.NoRotationPolicy
 
NoRotationPolicy - Class in org.apache.storm.hdfs.trident.rotation
File rotation policy that will never rotate...
NoRotationPolicy() - Constructor for class org.apache.storm.hdfs.trident.rotation.NoRotationPolicy
 

O

org.apache.storm.hdfs.bolt - package org.apache.storm.hdfs.bolt
 
org.apache.storm.hdfs.bolt.format - package org.apache.storm.hdfs.bolt.format
 
org.apache.storm.hdfs.bolt.rotation - package org.apache.storm.hdfs.bolt.rotation
 
org.apache.storm.hdfs.bolt.sync - package org.apache.storm.hdfs.bolt.sync
 
org.apache.storm.hdfs.common.rotation - package org.apache.storm.hdfs.common.rotation
 
org.apache.storm.hdfs.common.security - package org.apache.storm.hdfs.common.security
 
org.apache.storm.hdfs.trident - package org.apache.storm.hdfs.trident
 
org.apache.storm.hdfs.trident.format - package org.apache.storm.hdfs.trident.format
 
org.apache.storm.hdfs.trident.rotation - package org.apache.storm.hdfs.trident.rotation
 
org.apache.storm.hdfs.trident.sync - package org.apache.storm.hdfs.trident.sync
 

P

prepare(Map, TopologyContext, OutputCollector) - Method in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
Marked as final to prevent override.
prepare(Map, TopologyContext) - Method in class org.apache.storm.hdfs.bolt.format.DefaultFileNameFormat
 
prepare(Map, TopologyContext) - Method in interface org.apache.storm.hdfs.bolt.format.FileNameFormat
 
prepare(Map, int, int) - Method in class org.apache.storm.hdfs.trident.format.DefaultFileNameFormat
 
prepare(Map, int, int) - Method in interface org.apache.storm.hdfs.trident.format.FileNameFormat
 

R

RecordFormat - Interface in org.apache.storm.hdfs.bolt.format
Formats a Tuple object into a byte array that will be written to HDFS.
RecordFormat - Interface in org.apache.storm.hdfs.trident.format
Formats a Tuple object into a byte array that will be written to HDFS.
reset() - Method in interface org.apache.storm.hdfs.bolt.rotation.FileRotationPolicy
Called after the HdfsBolt rotates a file.
reset() - Method in class org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicy
 
reset() - Method in class org.apache.storm.hdfs.bolt.rotation.NoRotationPolicy
 
reset() - Method in class org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicy
Called after the HdfsBolt rotates a file.
reset() - Method in class org.apache.storm.hdfs.bolt.sync.CountSyncPolicy
 
reset() - Method in interface org.apache.storm.hdfs.bolt.sync.SyncPolicy
Called after the HdfsBolt performs a sync.
reset() - Method in interface org.apache.storm.hdfs.trident.rotation.FileRotationPolicy
Called after the HdfsBolt rotates a file.
reset() - Method in class org.apache.storm.hdfs.trident.rotation.FileSizeRotationPolicy
 
reset() - Method in class org.apache.storm.hdfs.trident.rotation.NoRotationPolicy
 
reset() - Method in class org.apache.storm.hdfs.trident.rotation.TimedRotationPolicy
Called after the HdfsBolt rotates a file.
reset() - Method in class org.apache.storm.hdfs.trident.sync.CountSyncPolicy
 
reset() - Method in interface org.apache.storm.hdfs.trident.sync.SyncPolicy
Called after the HdfsBolt performs a sync.
rotateOutputFile() - Method in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
rotateOutputFile() - Method in class org.apache.storm.hdfs.trident.HdfsState.Options
 
rotation - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
rotation - Variable in class org.apache.storm.hdfs.trident.HdfsState.Options
 
RotationAction - Interface in org.apache.storm.hdfs.common.rotation
 
rotationActions - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
rotationActions - Variable in class org.apache.storm.hdfs.trident.HdfsState.Options
 
rotationPolicy - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
rotationPolicy - Variable in class org.apache.storm.hdfs.trident.HdfsState.Options
 
rotationTimer - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
rotationTimer - Variable in class org.apache.storm.hdfs.trident.HdfsState.Options
 

S

SequenceFileBolt - Class in org.apache.storm.hdfs.bolt
 
SequenceFileBolt() - Constructor for class org.apache.storm.hdfs.bolt.SequenceFileBolt
 
SequenceFormat - Interface in org.apache.storm.hdfs.bolt.format
Interface for converting Tuple objects to HDFS sequence file key-value pairs.
SequenceFormat - Interface in org.apache.storm.hdfs.trident.format
Interface for converting TridentTuple objects to HDFS sequence file key-value pairs.
STORM_KEYTAB_FILE_KEY - Static variable in class org.apache.storm.hdfs.common.security.HdfsSecurityUtil
 
STORM_USER_NAME_KEY - Static variable in class org.apache.storm.hdfs.common.security.HdfsSecurityUtil
 
syncPolicy - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
SyncPolicy - Interface in org.apache.storm.hdfs.bolt.sync
Interface for controlling when the HdfsBolt syncs and flushes the filesystem.
SyncPolicy - Interface in org.apache.storm.hdfs.trident.sync
Interface for controlling when the HdfsBolt syncs and flushes the filesystem.

T

TimedRotationPolicy - Class in org.apache.storm.hdfs.bolt.rotation
 
TimedRotationPolicy(float, TimedRotationPolicy.TimeUnit) - Constructor for class org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicy
 
TimedRotationPolicy - Class in org.apache.storm.hdfs.trident.rotation
 
TimedRotationPolicy(float, TimedRotationPolicy.TimeUnit) - Constructor for class org.apache.storm.hdfs.trident.rotation.TimedRotationPolicy
 
TimedRotationPolicy.TimeUnit - Enum in org.apache.storm.hdfs.bolt.rotation
 
TimedRotationPolicy.TimeUnit - Enum in org.apache.storm.hdfs.trident.rotation
 
toDestination(String) - Method in class org.apache.storm.hdfs.common.rotation.MoveFileAction
 

U

updateState(List<TridentTuple>, TridentCollector) - Method in class org.apache.storm.hdfs.trident.HdfsState
 
updateState(HdfsState, List<TridentTuple>, TridentCollector) - Method in class org.apache.storm.hdfs.trident.HdfsUpdater
 

V

value(Tuple) - Method in class org.apache.storm.hdfs.bolt.format.DefaultSequenceFormat
 
value(Tuple) - Method in interface org.apache.storm.hdfs.bolt.format.SequenceFormat
Given a tuple, return the value that should be written to the sequence file.
value(TridentTuple) - Method in class org.apache.storm.hdfs.trident.format.DefaultSequenceFormat
 
value(TridentTuple) - Method in interface org.apache.storm.hdfs.trident.format.SequenceFormat
Given a tuple, return the value that should be written to the sequence file.
valueClass() - Method in class org.apache.storm.hdfs.bolt.format.DefaultSequenceFormat
 
valueClass() - Method in interface org.apache.storm.hdfs.bolt.format.SequenceFormat
Value class used by implementation (e.g.
valueClass() - Method in class org.apache.storm.hdfs.trident.format.DefaultSequenceFormat
 
valueClass() - Method in interface org.apache.storm.hdfs.trident.format.SequenceFormat
Value class used by implementation (e.g.
valueOf(String) - Static method in enum org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicy.Units
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicy.TimeUnit
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.storm.hdfs.trident.rotation.FileSizeRotationPolicy.Units
Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.apache.storm.hdfs.trident.rotation.TimedRotationPolicy.TimeUnit
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.storm.hdfs.bolt.rotation.FileSizeRotationPolicy.Units
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.storm.hdfs.bolt.rotation.TimedRotationPolicy.TimeUnit
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.storm.hdfs.trident.rotation.FileSizeRotationPolicy.Units
Returns an array containing the constants of this enum type, in the order they are declared.
values() - Static method in enum org.apache.storm.hdfs.trident.rotation.TimedRotationPolicy.TimeUnit
Returns an array containing the constants of this enum type, in the order they are declared.

W

withCompressionCodec(String) - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt
 
withCompressionCodec(String) - Method in class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions
 
withCompressionType(SequenceFile.CompressionType) - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt
 
withCompressionType(SequenceFile.CompressionType) - Method in class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions
 
withConfigKey(String) - Method in class org.apache.storm.hdfs.bolt.HdfsBolt
 
withConfigKey(String) - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt
 
withConfigKey(String) - Method in class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions
 
withConfigKey(String) - Method in class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions
 
withExtension(String) - Method in class org.apache.storm.hdfs.bolt.format.DefaultFileNameFormat
Overrides the default file extension.
withExtension(String) - Method in class org.apache.storm.hdfs.trident.format.DefaultFileNameFormat
Overrides the default file extension.
withFieldDelimiter(String) - Method in class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat
Overrides the default field delimiter.
withFieldDelimiter(String) - Method in class org.apache.storm.hdfs.trident.format.DelimitedRecordFormat
Overrides the default field delimiter.
withFields(Fields) - Method in class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat
Only output the specified fields.
withFields(Fields) - Method in class org.apache.storm.hdfs.trident.format.DelimitedRecordFormat
Only output the specified fields.
withFileNameFormat(FileNameFormat) - Method in class org.apache.storm.hdfs.bolt.HdfsBolt
 
withFileNameFormat(FileNameFormat) - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt
 
withFileNameFormat(FileNameFormat) - Method in class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions
 
withFileNameFormat(FileNameFormat) - Method in class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions
 
withFsUrl(String) - Method in class org.apache.storm.hdfs.bolt.HdfsBolt
 
withFsUrl(String) - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt
 
withFsUrl(String) - Method in class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions
 
withFsUrl(String) - Method in class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions
 
withOptions(HdfsState.Options) - Method in class org.apache.storm.hdfs.trident.HdfsStateFactory
 
withPath(String) - Method in class org.apache.storm.hdfs.bolt.format.DefaultFileNameFormat
 
withPath(String) - Method in class org.apache.storm.hdfs.trident.format.DefaultFileNameFormat
 
withPrefix(String) - Method in class org.apache.storm.hdfs.bolt.format.DefaultFileNameFormat
Overrides the default prefix.
withPrefix(String) - Method in class org.apache.storm.hdfs.trident.format.DefaultFileNameFormat
Overrides the default prefix.
withRecordDelimiter(String) - Method in class org.apache.storm.hdfs.bolt.format.DelimitedRecordFormat
Overrides the default record delimiter.
withRecordDelimiter(String) - Method in class org.apache.storm.hdfs.trident.format.DelimitedRecordFormat
Overrides the default record delimiter.
withRecordFormat(RecordFormat) - Method in class org.apache.storm.hdfs.bolt.HdfsBolt
 
withRecordFormat(RecordFormat) - Method in class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions
 
withRotationPolicy(FileRotationPolicy) - Method in class org.apache.storm.hdfs.bolt.HdfsBolt
 
withRotationPolicy(FileRotationPolicy) - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt
 
withRotationPolicy(FileRotationPolicy) - Method in class org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions
 
withRotationPolicy(FileRotationPolicy) - Method in class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions
 
withSequenceFormat(SequenceFormat) - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt
 
withSequenceFormat(SequenceFormat) - Method in class org.apache.storm.hdfs.trident.HdfsState.SequenceFileOptions
 
withSyncPolicy(SyncPolicy) - Method in class org.apache.storm.hdfs.bolt.HdfsBolt
 
withSyncPolicy(SyncPolicy) - Method in class org.apache.storm.hdfs.bolt.SequenceFileBolt
 
writeLock - Variable in class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
 
writeLock - Variable in class org.apache.storm.hdfs.trident.HdfsState.Options
 

A B C D E F G H K L M N O P R S T U V W

Copyright © 2016 The Apache Software Foundation. All Rights Reserved.