public static class HdfsState.HdfsFileOptions extends HdfsState.Options
Modifier and Type | Field and Description |
---|---|
protected RecordFormat |
format |
configKey, fileNameFormat, fs, fsUrl, hdfsConfig, rotation, rotationActions, rotationPolicy, rotationTimer, writeLock
Constructor and Description |
---|
HdfsFileOptions() |
Modifier and Type | Method and Description |
---|---|
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) |
rotateOutputFile
protected RecordFormat format
public HdfsState.HdfsFileOptions withFsUrl(String fsUrl)
public HdfsState.HdfsFileOptions withConfigKey(String configKey)
public HdfsState.HdfsFileOptions withFileNameFormat(FileNameFormat fileNameFormat)
public HdfsState.HdfsFileOptions withRecordFormat(RecordFormat format)
public HdfsState.HdfsFileOptions withRotationPolicy(FileRotationPolicy rotationPolicy)
public HdfsState.HdfsFileOptions addRotationAction(RotationAction action)
public void execute(List<TridentTuple> tuples) throws IOException
IOException
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.