public class SequenceFileWriter extends AbstractHDFSWriter
filePath, lastUsedTime, needsRotation, offset, rotationPolicy| Constructor and Description |
|---|
SequenceFileWriter(FileRotationPolicy policy,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.io.SequenceFile.Writer writer,
SequenceFormat format) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doClose() |
protected void |
doSync() |
protected void |
doWrite(Tuple tuple) |
close, getFilePath, needsRotation, sync, writepublic SequenceFileWriter(FileRotationPolicy policy, org.apache.hadoop.fs.Path path, org.apache.hadoop.io.SequenceFile.Writer writer, SequenceFormat format)
protected void doWrite(Tuple tuple) throws IOException
doWrite in class AbstractHDFSWriterIOExceptionprotected void doSync()
throws IOException
doSync in class AbstractHDFSWriterIOExceptionprotected void doClose()
throws IOException
doClose in class AbstractHDFSWriterIOExceptionCopyright © 2021 The Apache Software Foundation. All rights reserved.