public class SequenceFileBolt extends AbstractHdfsBolt
collector, configKey, fileNameFormat, fs, fsUrl, hdfsConfig, rotation, rotationActions, rotationPolicy, rotationTimer, syncPolicy, writeLock
Constructor and Description |
---|
SequenceFileBolt() |
Modifier and Type | Method and Description |
---|---|
SequenceFileBolt |
addRotationAction(RotationAction action) |
void |
doPrepare(Map conf,
TopologyContext topologyContext,
OutputCollector collector) |
void |
execute(Tuple tuple)
Process a single tuple of input.
|
SequenceFileBolt |
withCompressionCodec(String codec) |
SequenceFileBolt |
withCompressionType(org.apache.hadoop.io.SequenceFile.CompressionType compressionType) |
SequenceFileBolt |
withConfigKey(String configKey) |
SequenceFileBolt |
withFileNameFormat(FileNameFormat fileNameFormat) |
SequenceFileBolt |
withFsUrl(String fsUrl) |
SequenceFileBolt |
withRotationPolicy(FileRotationPolicy rotationPolicy) |
SequenceFileBolt |
withSequenceFormat(SequenceFormat format) |
SequenceFileBolt |
withSyncPolicy(SyncPolicy syncPolicy) |
declareOutputFields, prepare, rotateOutputFile
cleanup
getComponentConfiguration
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getComponentConfiguration
public SequenceFileBolt withCompressionCodec(String codec)
public SequenceFileBolt withFsUrl(String fsUrl)
public SequenceFileBolt withConfigKey(String configKey)
public SequenceFileBolt withFileNameFormat(FileNameFormat fileNameFormat)
public SequenceFileBolt withSequenceFormat(SequenceFormat format)
public SequenceFileBolt withSyncPolicy(SyncPolicy syncPolicy)
public SequenceFileBolt withRotationPolicy(FileRotationPolicy rotationPolicy)
public SequenceFileBolt withCompressionType(org.apache.hadoop.io.SequenceFile.CompressionType compressionType)
public SequenceFileBolt addRotationAction(RotationAction action)
public void doPrepare(Map conf, TopologyContext topologyContext, OutputCollector collector) throws IOException
IOException
public void execute(Tuple tuple)
IBolt
Tuples should be emitted using the OutputCollector provided through the prepare method. It is required that all input tuples are acked or failed at some point using the OutputCollector. Otherwise, Storm will be unable to determine when tuples coming off the spouts have been completed.
For the common case of acking an input tuple at the end of the execute method, see IBasicBolt which automates this.
tuple
- The input tuple to be processed.Copyright © 2016 The Apache Software Foundation. All Rights Reserved.