org.apache.storm.hdfs.trident
Class HdfsState.HdfsFileOptions

java.lang.Object
  extended by org.apache.storm.hdfs.trident.HdfsState.Options
      extended by org.apache.storm.hdfs.trident.HdfsState.HdfsFileOptions
All Implemented Interfaces:
Serializable
Enclosing class:
HdfsState

public static class HdfsState.HdfsFileOptions
extends HdfsState.Options

See Also:
Serialized Form

Field Summary
protected  RecordFormat format
           
 
Fields inherited from class org.apache.storm.hdfs.trident.HdfsState.Options
configKey, fileNameFormat, fs, fsUrl, hdfsConfig, rotation, rotationActions, rotationPolicy, rotationTimer, writeLock
 
Constructor Summary
HdfsState.HdfsFileOptions()
           
 
Method Summary
 HdfsState.HdfsFileOptions addRotationAction(RotationAction action)
           
 void execute(List<TridentTuple> tuples)
           
 HdfsState.HdfsFileOptions withConfigKey(String configKey)
           
 HdfsState.HdfsFileOptions withFileNameFormat(FileNameFormat fileNameFormat)
           
 HdfsState.HdfsFileOptions withFsUrl(String fsUrl)
           
 HdfsState.HdfsFileOptions withRecordFormat(RecordFormat format)
           
 HdfsState.HdfsFileOptions withRotationPolicy(FileRotationPolicy rotationPolicy)
           
 
Methods inherited from class org.apache.storm.hdfs.trident.HdfsState.Options
rotateOutputFile
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Field Detail

format

protected RecordFormat format
Constructor Detail

HdfsState.HdfsFileOptions

public HdfsState.HdfsFileOptions()
Method Detail

withFsUrl

public HdfsState.HdfsFileOptions withFsUrl(String fsUrl)

withConfigKey

public HdfsState.HdfsFileOptions withConfigKey(String configKey)

withFileNameFormat

public HdfsState.HdfsFileOptions withFileNameFormat(FileNameFormat fileNameFormat)

withRecordFormat

public HdfsState.HdfsFileOptions withRecordFormat(RecordFormat format)

withRotationPolicy

public HdfsState.HdfsFileOptions withRotationPolicy(FileRotationPolicy rotationPolicy)

addRotationAction

public HdfsState.HdfsFileOptions addRotationAction(RotationAction action)

execute

public void execute(List<TridentTuple> tuples)
             throws IOException
Throws:
IOException


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