public class ChunkWriter
extends java.lang.Object
implements java.io.Closeable
Modifier and Type | Field and Description |
---|---|
private java.lang.String |
chunkName |
private java.io.DataOutputStream |
dataOutputStream |
private static int |
F_INDEXED |
private static int |
F_STORED |
private static int |
F_TOKENIZED |
private java.util.Date |
timestamp |
private int |
version |
Constructor and Description |
---|
ChunkWriter(java.lang.String chunkName,
java.io.OutputStream outputStream,
int version,
java.util.Date timestamp) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes this reader and it's underlying input.
|
java.lang.String |
getName()
Returns the chunk name.
|
java.util.Date |
getTimestamp()
Returns the index timestamp of last update of the index.
|
int |
getVersion()
Returns index version.
|
int |
writeChunk(java.util.Iterator<java.util.Map<java.lang.String,java.lang.String>> iterator)
Writes out the record iterator and returns the written record count.
|
private static void |
writeField(java.lang.String fieldName,
java.lang.String fieldValue,
java.io.DataOutput dataOutput) |
private static void |
writeRecord(java.util.Map<java.lang.String,java.lang.String> record,
java.io.DataOutput dataOutput) |
private static void |
writeUTF(java.lang.String str,
java.io.DataOutput dataOutput) |
private static final int F_INDEXED
private static final int F_TOKENIZED
private static final int F_STORED
private final java.lang.String chunkName
private final java.io.DataOutputStream dataOutputStream
private final int version
private final java.util.Date timestamp
public ChunkWriter(java.lang.String chunkName, java.io.OutputStream outputStream, int version, java.util.Date timestamp) throws java.io.IOException
java.io.IOException
public java.lang.String getName()
public int getVersion()
1
.public java.util.Date getTimestamp()
public int writeChunk(java.util.Iterator<java.util.Map<java.lang.String,java.lang.String>> iterator) throws java.io.IOException
java.io.IOException
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
private static void writeRecord(java.util.Map<java.lang.String,java.lang.String> record, java.io.DataOutput dataOutput) throws java.io.IOException
java.io.IOException
private static void writeField(java.lang.String fieldName, java.lang.String fieldValue, java.io.DataOutput dataOutput) throws java.io.IOException
java.io.IOException
private static void writeUTF(java.lang.String str, java.io.DataOutput dataOutput) throws java.io.IOException
java.io.IOException