public static class HdfsState.SequenceFileOptions extends HdfsState.Options
configKey, fileNameFormat, fs, fsUrl, hdfsConfig, rotation, rotationActions, rotationPolicy, rotationTimer, writeLock
Constructor and Description |
---|
SequenceFileOptions() |
Modifier and Type | Method and Description |
---|---|
HdfsState.SequenceFileOptions |
addRotationAction(RotationAction action) |
void |
execute(List<TridentTuple> tuples) |
HdfsState.SequenceFileOptions |
withCompressionCodec(String codec) |
HdfsState.SequenceFileOptions |
withCompressionType(org.apache.hadoop.io.SequenceFile.CompressionType compressionType) |
HdfsState.SequenceFileOptions |
withConfigKey(String configKey) |
HdfsState.SequenceFileOptions |
withFileNameFormat(FileNameFormat fileNameFormat) |
HdfsState.SequenceFileOptions |
withFsUrl(String fsUrl) |
HdfsState.SequenceFileOptions |
withRotationPolicy(FileRotationPolicy rotationPolicy) |
HdfsState.SequenceFileOptions |
withSequenceFormat(SequenceFormat format) |
rotateOutputFile
public HdfsState.SequenceFileOptions withCompressionCodec(String codec)
public HdfsState.SequenceFileOptions withFsUrl(String fsUrl)
public HdfsState.SequenceFileOptions withConfigKey(String configKey)
public HdfsState.SequenceFileOptions withFileNameFormat(FileNameFormat fileNameFormat)
public HdfsState.SequenceFileOptions withSequenceFormat(SequenceFormat format)
public HdfsState.SequenceFileOptions withRotationPolicy(FileRotationPolicy rotationPolicy)
public HdfsState.SequenceFileOptions withCompressionType(org.apache.hadoop.io.SequenceFile.CompressionType compressionType)
public HdfsState.SequenceFileOptions addRotationAction(RotationAction action)
public void execute(List<TridentTuple> tuples) throws IOException
IOException
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.