public class OutputStreamWriter extends AbstractDataStreamWriter implements DataStoreWriter<byte[]>
OutputStreamWriter is a DataStoreWriter implementation
 able to write byte[]s into raw hdfs files.DEFAULT_MAX_OPEN_ATTEMPTS| Constructor and Description | 
|---|
| OutputStreamWriter(Configuration configuration,
                  Path basePath,
                  CodecInfo codec)Instantiates a new output stream writer. | 
| Modifier and Type | Method and Description | 
|---|---|
| void | close() | 
| void | flush() | 
| protected void | handleIdleTimeout()Handle idle timeout. | 
| void | write(byte[] entity)Write an entity. | 
getOutput, getPosition, setMaxOpenAttemptsfindInitFiles, getOutputContext, getResolvedPath, initOutputContext, onInit, renameFile, setFileNamingStrategy, setInWritingPrefix, setInWritingSuffix, setOverwrite, setRolloverStrategy, setWritePositiondoStart, doStop, getCodec, getConfiguration, getPath, isCompressed, resetIdleTimeout, setIdleTimeoutafterPropertiesSet, getBeanFactory, getPhase, getStoreEventPublisher, getTaskExecutor, getTaskScheduler, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setStoreEventPublisher, setTaskExecutor, setTaskScheduler, start, stop, stoppublic OutputStreamWriter(Configuration configuration, Path basePath, CodecInfo codec)
configuration - the configurationbasePath - the base pathcodec - the codecpublic void flush()
           throws IOException
flush in interface FlushableIOExceptionpublic void close()
           throws IOException
close in interface Closeableclose in interface AutoCloseableIOExceptionpublic void write(byte[] entity)
           throws IOException
DataWriterwrite in interface DataWriter<byte[]>IOException - if an I/O error occursprotected void handleIdleTimeout()
StoreObjectSupporthandleIdleTimeout in class StoreObjectSupport