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) |
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)
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.