org.apache.solr.store.hdfs

Class HdfsFileWriter

java.lang.Object

org.apache.lucene.store.DataOutput

org.apache.solr.store.hdfs.HdfsFileWriter

All Implemented Interfaces:

Closeable

public class HdfsFileWriter
extends DataOutput
implements Closeable

Field Summary

Fields

Modifier and Type	Field and Description
static String	HDFS_SYNC_BLOCK
static org.slf4j.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
HdfsFileWriter(org.apache.hadoop.fs.FileSystem fileSystem, org.apache.hadoop.fs.Path path)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
void	flush()
long	getPosition()
long	length()
void	seek(long pos)
void	writeByte(byte b)
void	writeBytes(byte[] b, int offset, int length)

Methods inherited from class org.apache.lucene.store.DataOutput

copyBytes, writeBytes, writeInt, writeLong, writeShort, writeString, writeStringSet, writeStringStringMap, writeVInt, writeVLong

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

public static org.slf4j.Logger LOG

HDFS_SYNC_BLOCK

public static final String HDFS_SYNC_BLOCK

See Also:

Constant Field Values

Constructor Detail

HdfsFileWriter

public HdfsFileWriter(org.apache.hadoop.fs.FileSystem fileSystem,
              org.apache.hadoop.fs.Path path)
               throws IOException

Throws:

IOException

Method Detail

length

public long length()

seek

public void seek(long pos)
          throws IOException

Throws:

IOException

flush

public void flush()
           throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Throws:

IOException

writeByte

public void writeByte(byte b)
               throws IOException

Specified by:

writeByte in class DataOutput

Throws:

IOException

writeBytes

public void writeBytes(byte[] b,
              int offset,
              int length)
                throws IOException

Specified by:

writeBytes in class DataOutput

Throws:

IOException

getPosition

public long getPosition()