org.apache.storm.hdfs.bolt
Class SequenceFileBolt

java.lang.Object
  extended by backtype.storm.topology.base.BaseComponent
      extended by backtype.storm.topology.base.BaseRichBolt
          extended by org.apache.storm.hdfs.bolt.AbstractHdfsBolt
              extended by org.apache.storm.hdfs.bolt.SequenceFileBolt
All Implemented Interfaces:
IBolt, IComponent, IRichBolt, Serializable

public class SequenceFileBolt
extends AbstractHdfsBolt

See Also:
Serialized Form

Field Summary
 
Fields inherited from class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
collector, configKey, fileNameFormat, fs, fsUrl, hdfsConfig, rotation, rotationActions, rotationPolicy, rotationTimer, syncPolicy, writeLock
 
Constructor Summary
SequenceFileBolt()
           
 
Method Summary
 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)
           
 
Methods inherited from class org.apache.storm.hdfs.bolt.AbstractHdfsBolt
declareOutputFields, prepare, rotateOutputFile
 
Methods inherited from class backtype.storm.topology.base.BaseRichBolt
cleanup
 
Methods inherited from class backtype.storm.topology.base.BaseComponent
getComponentConfiguration
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 
Methods inherited from interface backtype.storm.topology.IComponent
getComponentConfiguration
 

Constructor Detail

SequenceFileBolt

public SequenceFileBolt()
Method Detail

withCompressionCodec

public SequenceFileBolt withCompressionCodec(String codec)

withFsUrl

public SequenceFileBolt withFsUrl(String fsUrl)

withConfigKey

public SequenceFileBolt withConfigKey(String configKey)

withFileNameFormat

public SequenceFileBolt withFileNameFormat(FileNameFormat fileNameFormat)

withSequenceFormat

public SequenceFileBolt withSequenceFormat(SequenceFormat format)

withSyncPolicy

public SequenceFileBolt withSyncPolicy(SyncPolicy syncPolicy)

withRotationPolicy

public SequenceFileBolt withRotationPolicy(FileRotationPolicy rotationPolicy)

withCompressionType

public SequenceFileBolt withCompressionType(org.apache.hadoop.io.SequenceFile.CompressionType compressionType)

addRotationAction

public SequenceFileBolt addRotationAction(RotationAction action)

doPrepare

public void doPrepare(Map conf,
                      TopologyContext topologyContext,
                      OutputCollector collector)
               throws IOException
Throws:
IOException

execute

public void execute(Tuple tuple)


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