public class AvroGenericRecordHDFSWriter extends AbstractHDFSWriter
filePath, lastUsedTime, needsRotation, offset, rotationPolicy| Constructor and Description |
|---|
AvroGenericRecordHDFSWriter(FileRotationPolicy policy,
org.apache.hadoop.fs.Path path,
org.apache.hadoop.fs.FSDataOutputStream stream,
org.apache.avro.Schema schema) |
| Modifier and Type | Method and Description |
|---|---|
protected void |
doClose() |
protected void |
doSync() |
protected void |
doWrite(Tuple tuple) |
close, getFilePath, needsRotation, sync, writepublic AvroGenericRecordHDFSWriter(FileRotationPolicy policy, org.apache.hadoop.fs.Path path, org.apache.hadoop.fs.FSDataOutputStream stream, org.apache.avro.Schema schema) throws IOException
IOExceptionprotected 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.