All Classes and Interfaces
Class
Description
This abstract class can be extended to implement concrete classes capable of (de)serializing generic avro objects
across a Topology.
SyncPolicy implementation that will trigger a
file system sync after a certain number of tuples
have been processed.
SyncPolicy implementation that will trigger a
file system sync after a certain number of tuples
have been processed.
Creates file names with the following format:
Creates file names with the following format:
Basic
SequenceFormat implementation that uses
LongWritable for keys and Text for values.Basic
SequenceFormat implementation that uses
LongWritable for keys and Text for values.RecordFormat implementation that uses field and record delimiters.
RecordFormat implementation that uses field and record delimiters.
Facility to synchronize access to HDFS directory.
Facility to synchronize access to HDFS files.
Formatter interface for determining HDFS file names.
Formatter interface for determining HDFS file names.
Used by the HdfsBolt to decide when to rotate files.
Used by the HdfsBolt to decide when to rotate files.
File rotation policy that will rotate files when a certain
file size is reached.
File rotation policy that will rotate files when a certain
file size is reached.
A class to help (de)serialize a pre-defined set of Avro schemas.
A default implementation of the AvroSerializer that will just pass literal schemas back and forth.
File rotation policy that will never rotate...
File rotation policy that will never rotate...
The NullPartitioner partitions every tuple to the empty string.
Formats a Tuple object into a byte array that will be written to HDFS.
Formats a Tuple object into a byte array that will be written to HDFS.
SequenceFileReader<KeyT extends org.apache.hadoop.io.Writable,ValueT extends org.apache.hadoop.io.Writable>
Interface for converting
Tuple objects to HDFS sequence file key-value pairs.Interface for converting
TridentTuple objects to HDFS sequence file key-value pairs.Interface for controlling when the HdfsBolt
syncs and flushes the filesystem.
Interface for controlling when the HdfsBolt
syncs and flushes the filesystem.