Same changes as just went to the branch
git-svn-id: https://svn.apache.org/repos/asf/jakarta/poi/trunk@353160 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
243b3c8dd0
commit
3702367b37
@ -686,37 +686,37 @@ public class Workbook implements Model {
|
|||||||
*
|
*
|
||||||
* @return byte array containing the HSSF-only portions of the POIFS file.
|
* @return byte array containing the HSSF-only portions of the POIFS file.
|
||||||
*/
|
*/
|
||||||
|
// GJS: Not used by system
|
||||||
public byte [] serialize() {
|
// public byte [] serialize() {
|
||||||
log.log(DEBUG, "Serializing Workbook!");
|
// log.log(DEBUG, "Serializing Workbook!");
|
||||||
byte[] retval = null;
|
// byte[] retval = null;
|
||||||
|
//
|
||||||
// ArrayList bytes = new ArrayList(records.size());
|
// // ArrayList bytes = new ArrayList(records.size());
|
||||||
int arraysize = getSize();
|
// int arraysize = getSize();
|
||||||
int pos = 0;
|
// int pos = 0;
|
||||||
|
//
|
||||||
// for (int k = 0; k < records.size(); k++)
|
// // for (int k = 0; k < records.size(); k++)
|
||||||
// {
|
// // {
|
||||||
// bytes.add((( Record ) records.get(k)).serialize());
|
// // bytes.add((( Record ) records.get(k)).serialize());
|
||||||
|
// // }
|
||||||
|
// // for (int k = 0; k < bytes.size(); k++)
|
||||||
|
// // {
|
||||||
|
// // arraysize += (( byte [] ) bytes.get(k)).length;
|
||||||
|
// // }
|
||||||
|
// retval = new byte[ arraysize ];
|
||||||
|
// for (int k = 0; k < records.size(); k++) {
|
||||||
|
//
|
||||||
|
// // byte[] rec = (( byte [] ) bytes.get(k));
|
||||||
|
// // System.arraycopy(rec, 0, retval, pos, rec.length);
|
||||||
|
// Record record = records.get(k);
|
||||||
|
// // Let's skip RECALCID records, as they are only use for optimization
|
||||||
|
// if(record.getSid() != RecalcIdRecord.sid || ((RecalcIdRecord)record).isNeeded()) {
|
||||||
|
// pos += record.serialize(pos, retval); // rec.length;
|
||||||
// }
|
// }
|
||||||
// for (int k = 0; k < bytes.size(); k++)
|
|
||||||
// {
|
|
||||||
// arraysize += (( byte [] ) bytes.get(k)).length;
|
|
||||||
// }
|
// }
|
||||||
retval = new byte[ arraysize ];
|
// log.log(DEBUG, "Exiting serialize workbook");
|
||||||
for (int k = 0; k < records.size(); k++) {
|
// return retval;
|
||||||
|
// }
|
||||||
// byte[] rec = (( byte [] ) bytes.get(k));
|
|
||||||
// System.arraycopy(rec, 0, retval, pos, rec.length);
|
|
||||||
Record record = records.get(k);
|
|
||||||
// Let's skip RECALCID records, as they are only use for optimization
|
|
||||||
if(record.getSid() != RecalcIdRecord.sid || ((RecalcIdRecord)record).isNeeded()) {
|
|
||||||
pos += record.serialize(pos, retval); // rec.length;
|
|
||||||
}
|
|
||||||
}
|
|
||||||
log.log(DEBUG, "Exiting serialize workbook");
|
|
||||||
return retval;
|
|
||||||
}
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Serializes all records int the worksheet section into a big byte array. Use
|
* Serializes all records int the worksheet section into a big byte array. Use
|
||||||
@ -725,29 +725,30 @@ public class Workbook implements Model {
|
|||||||
* @param data array of bytes to write this to
|
* @param data array of bytes to write this to
|
||||||
*/
|
*/
|
||||||
|
|
||||||
public int serialize(int offset, byte [] data) {
|
public int serialize( int offset, byte[] data )
|
||||||
|
{
|
||||||
log.log( DEBUG, "Serializing Workbook with offsets" );
|
log.log( DEBUG, "Serializing Workbook with offsets" );
|
||||||
|
|
||||||
// ArrayList bytes = new ArrayList(records.size());
|
|
||||||
// int arraysize = getSize(); // 0;
|
|
||||||
int pos = 0;
|
int pos = 0;
|
||||||
|
|
||||||
// for (int k = 0; k < records.size(); k++)
|
SSTRecord sst = null;
|
||||||
// {
|
int sstPos = 0;
|
||||||
// bytes.add((( Record ) records.get(k)).serialize());
|
for ( int k = 0; k < records.size(); k++ )
|
||||||
//
|
{
|
||||||
// }
|
|
||||||
// for (int k = 0; k < bytes.size(); k++)
|
|
||||||
// {
|
|
||||||
// arraysize += (( byte [] ) bytes.get(k)).length;
|
|
||||||
// }
|
|
||||||
for (int k = 0; k < records.size(); k++) {
|
|
||||||
|
|
||||||
// byte[] rec = (( byte [] ) bytes.get(k));
|
|
||||||
// System.arraycopy(rec, 0, data, offset + pos, rec.length);
|
|
||||||
Record record = records.get( k );
|
Record record = records.get( k );
|
||||||
// Let's skip RECALCID records, as they are only use for optimization
|
// Let's skip RECALCID records, as they are only use for optimization
|
||||||
if(record.getSid() != RecalcIdRecord.sid || ((RecalcIdRecord)record).isNeeded()) {
|
if ( record.getSid() != RecalcIdRecord.sid || ( (RecalcIdRecord) record ).isNeeded() )
|
||||||
|
{
|
||||||
|
if (record instanceof SSTRecord)
|
||||||
|
{
|
||||||
|
sst = (SSTRecord)record;
|
||||||
|
sstPos = pos;
|
||||||
|
}
|
||||||
|
if (record.getSid() == ExtSSTRecord.sid && sst != null)
|
||||||
|
{
|
||||||
|
record = sst.createExtSSTRecord(sstPos + offset);
|
||||||
|
}
|
||||||
pos += record.serialize( pos + offset, data ); // rec.length;
|
pos += record.serialize( pos + offset, data ); // rec.length;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@ -755,19 +756,27 @@ public class Workbook implements Model {
|
|||||||
return pos;
|
return pos;
|
||||||
}
|
}
|
||||||
|
|
||||||
public int getSize() {
|
public int getSize()
|
||||||
|
{
|
||||||
int retval = 0;
|
int retval = 0;
|
||||||
|
|
||||||
for (int k = 0; k < records.size(); k++) {
|
SSTRecord sst = null;
|
||||||
|
for ( int k = 0; k < records.size(); k++ )
|
||||||
|
{
|
||||||
Record record = records.get( k );
|
Record record = records.get( k );
|
||||||
// Let's skip RECALCID records, as they are only use for optimization
|
// Let's skip RECALCID records, as they are only use for optimization
|
||||||
if(record.getSid() != RecalcIdRecord.sid || ((RecalcIdRecord)record).isNeeded()) {
|
if ( record.getSid() != RecalcIdRecord.sid || ( (RecalcIdRecord) record ).isNeeded() )
|
||||||
|
{
|
||||||
|
if (record instanceof SSTRecord)
|
||||||
|
sst = (SSTRecord)record;
|
||||||
|
if (record.getSid() == ExtSSTRecord.sid && sst != null)
|
||||||
|
retval += sst.calcExtSSTRecordSize();
|
||||||
|
else
|
||||||
retval += record.getRecordSize();
|
retval += record.getRecordSize();
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
return retval;
|
return retval;
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* creates the BOF record
|
* creates the BOF record
|
||||||
* @see org.apache.poi.hssf.record.BOFRecord
|
* @see org.apache.poi.hssf.record.BOFRecord
|
||||||
|
@ -114,7 +114,7 @@ public class ExtSSTInfoSubRecord
|
|||||||
field_1_stream_pos = pos;
|
field_1_stream_pos = pos;
|
||||||
}
|
}
|
||||||
|
|
||||||
public void setBucketSSTOffset(short offset)
|
public void setBucketRecordOffset(short offset)
|
||||||
{
|
{
|
||||||
field_2_bucket_sst_offset = offset;
|
field_2_bucket_sst_offset = offset;
|
||||||
}
|
}
|
||||||
@ -159,6 +159,6 @@ public class ExtSSTInfoSubRecord
|
|||||||
|
|
||||||
public short getSid()
|
public short getSid()
|
||||||
{
|
{
|
||||||
return this.sid;
|
return sid;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
@ -79,6 +79,7 @@ public class ExtSSTRecord
|
|||||||
private short field_1_strings_per_bucket;
|
private short field_1_strings_per_bucket;
|
||||||
private ArrayList field_2_sst_info;
|
private ArrayList field_2_sst_info;
|
||||||
|
|
||||||
|
|
||||||
public ExtSSTRecord()
|
public ExtSSTRecord()
|
||||||
{
|
{
|
||||||
field_2_sst_info = new ArrayList();
|
field_2_sst_info = new ArrayList();
|
||||||
@ -189,26 +190,39 @@ public class ExtSSTRecord
|
|||||||
public int serialize(int offset, byte [] data)
|
public int serialize(int offset, byte [] data)
|
||||||
{
|
{
|
||||||
LittleEndian.putShort(data, 0 + offset, sid);
|
LittleEndian.putShort(data, 0 + offset, sid);
|
||||||
|
LittleEndian.putShort(data, 2 + offset, (short)(getRecordSize() - 4));
|
||||||
// LittleEndian.putShort(data,2,(short)(2 + (getNumInfoRecords() *8)));
|
LittleEndian.putShort(data, 4 + offset, field_1_strings_per_bucket);
|
||||||
LittleEndian.putShort(data, 2 + offset, ( short ) (2 + (0x3fa - 2)));
|
int pos = 6;
|
||||||
int pos = 4;
|
|
||||||
|
|
||||||
for (int k = 0; k < getNumInfoRecords(); k++)
|
for (int k = 0; k < getNumInfoRecords(); k++)
|
||||||
{
|
{
|
||||||
System.arraycopy(getInfoRecordAt(k).serialize(), 0, data,
|
System.arraycopy(getInfoRecordAt(k).serialize(), 0, data,
|
||||||
pos + offset, 8);
|
pos + offset, 8);
|
||||||
|
pos += getInfoRecordAt(k).getRecordSize();
|
||||||
}
|
}
|
||||||
return getRecordSize();
|
return getRecordSize();
|
||||||
}
|
}
|
||||||
|
|
||||||
public int getRecordSize()
|
public int getRecordSize()
|
||||||
{
|
{
|
||||||
return 6 + 0x3fa - 2;
|
return 4 + 2 + field_2_sst_info.size() * 8;
|
||||||
}
|
}
|
||||||
|
|
||||||
public short getSid()
|
public short getSid()
|
||||||
{
|
{
|
||||||
return this.sid;
|
return sid;
|
||||||
|
}
|
||||||
|
|
||||||
|
public void setBucketOffsets( int[] bucketAbsoluteOffsets, int[] bucketRelativeOffsets )
|
||||||
|
{
|
||||||
|
this.field_2_sst_info = new ArrayList(bucketAbsoluteOffsets.length);
|
||||||
|
for ( int i = 0; i < bucketAbsoluteOffsets.length; i++ )
|
||||||
|
{
|
||||||
|
ExtSSTInfoSubRecord r = new ExtSSTInfoSubRecord();
|
||||||
|
r.setBucketRecordOffset((short)bucketRelativeOffsets[i]);
|
||||||
|
r.setStreamPos(bucketAbsoluteOffsets[i]);
|
||||||
|
field_2_sst_info.add(r);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
}
|
||||||
|
@ -70,16 +70,6 @@ package org.apache.poi.hssf.record;
|
|||||||
public abstract class Record
|
public abstract class Record
|
||||||
{
|
{
|
||||||
|
|
||||||
/**
|
|
||||||
* The static ID, subclasses should override this value with the id for the
|
|
||||||
* record type they handle.
|
|
||||||
*/
|
|
||||||
|
|
||||||
public short sid = 0;
|
|
||||||
private short id = 0;
|
|
||||||
private short size = 0;
|
|
||||||
private byte[] data = null;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* instantiates a blank record strictly for ID matching
|
* instantiates a blank record strictly for ID matching
|
||||||
*/
|
*/
|
||||||
@ -98,9 +88,6 @@ public abstract class Record
|
|||||||
|
|
||||||
public Record(short id, short size, byte [] data)
|
public Record(short id, short size, byte [] data)
|
||||||
{
|
{
|
||||||
this.id = id;
|
|
||||||
this.size = size;
|
|
||||||
this.data = data;
|
|
||||||
validateSid(id);
|
validateSid(id);
|
||||||
fillFields(data, size);
|
fillFields(data, size);
|
||||||
}
|
}
|
||||||
@ -115,9 +102,6 @@ public abstract class Record
|
|||||||
|
|
||||||
public Record(short id, short size, byte [] data, int offset)
|
public Record(short id, short size, byte [] data, int offset)
|
||||||
{
|
{
|
||||||
this.id = id;
|
|
||||||
this.size = size;
|
|
||||||
this.data = data;
|
|
||||||
validateSid(id);
|
validateSid(id);
|
||||||
fillFields(data, size, offset);
|
fillFields(data, size, offset);
|
||||||
}
|
}
|
||||||
|
@ -156,5 +156,10 @@ class RecordProcessor
|
|||||||
recordOffset += amount;
|
recordOffset += amount;
|
||||||
available -= amount;
|
available -= amount;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public int getRecordOffset()
|
||||||
|
{
|
||||||
|
return recordOffset;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -60,7 +60,6 @@ import org.apache.poi.util.LittleEndianConsts;
|
|||||||
|
|
||||||
import java.util.Iterator;
|
import java.util.Iterator;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.ArrayList;
|
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Title: Static String Table Record
|
* Title: Static String Table Record
|
||||||
@ -73,7 +72,7 @@ import java.util.ArrayList;
|
|||||||
* @author Andrew C. Oliver (acoliver at apache dot org)
|
* @author Andrew C. Oliver (acoliver at apache dot org)
|
||||||
* @author Marc Johnson (mjohnson at apache dot org)
|
* @author Marc Johnson (mjohnson at apache dot org)
|
||||||
* @author Glen Stampoultzis (glens at apache.org)
|
* @author Glen Stampoultzis (glens at apache.org)
|
||||||
* @version 2.0-pre
|
*
|
||||||
* @see org.apache.poi.hssf.record.LabelSSTRecord
|
* @see org.apache.poi.hssf.record.LabelSSTRecord
|
||||||
* @see org.apache.poi.hssf.record.ContinueRecord
|
* @see org.apache.poi.hssf.record.ContinueRecord
|
||||||
*/
|
*/
|
||||||
@ -112,10 +111,14 @@ public class SSTRecord
|
|||||||
private List _record_lengths = null;
|
private List _record_lengths = null;
|
||||||
private SSTDeserializer deserializer;
|
private SSTDeserializer deserializer;
|
||||||
|
|
||||||
|
/** Offsets from the beginning of the SST record (even across continuations) */
|
||||||
|
int[] bucketAbsoluteOffsets;
|
||||||
|
/** Offsets relative the start of the current SST or continue record */
|
||||||
|
int[] bucketRelativeOffsets;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* default constructor
|
* default constructor
|
||||||
*/
|
*/
|
||||||
|
|
||||||
public SSTRecord()
|
public SSTRecord()
|
||||||
{
|
{
|
||||||
field_1_num_strings = 0;
|
field_1_num_strings = 0;
|
||||||
@ -220,7 +223,7 @@ public class SSTRecord
|
|||||||
field_1_num_strings++;
|
field_1_num_strings++;
|
||||||
String str = ( string == null ) ? ""
|
String str = ( string == null ) ? ""
|
||||||
: string;
|
: string;
|
||||||
int rval = -1;
|
int rval;
|
||||||
UnicodeString ucs = new UnicodeString();
|
UnicodeString ucs = new UnicodeString();
|
||||||
|
|
||||||
ucs.setString( str );
|
ucs.setString( str );
|
||||||
@ -334,7 +337,7 @@ public class SSTRecord
|
|||||||
for ( int k = 0; k < field_3_strings.size(); k++ )
|
for ( int k = 0; k < field_3_strings.size(); k++ )
|
||||||
{
|
{
|
||||||
buffer.append( " .string_" + k + " = " )
|
buffer.append( " .string_" + k + " = " )
|
||||||
.append( ( (UnicodeString) field_3_strings
|
.append( ( field_3_strings
|
||||||
.get( new Integer( k ) ) ).toString() ).append( "\n" );
|
.get( new Integer( k ) ) ).toString() ).append( "\n" );
|
||||||
}
|
}
|
||||||
buffer.append( "[/SST]\n" );
|
buffer.append( "[/SST]\n" );
|
||||||
@ -394,7 +397,7 @@ public class SSTRecord
|
|||||||
* The data consists of sets of string data. This string data is
|
* The data consists of sets of string data. This string data is
|
||||||
* arranged as follows:
|
* arranged as follows:
|
||||||
* <P>
|
* <P>
|
||||||
* <CODE>
|
* <CODE><pre>
|
||||||
* short string_length; // length of string data
|
* short string_length; // length of string data
|
||||||
* byte string_flag; // flag specifying special string
|
* byte string_flag; // flag specifying special string
|
||||||
* // handling
|
* // handling
|
||||||
@ -407,7 +410,7 @@ public class SSTRecord
|
|||||||
* // array is run_count)
|
* // array is run_count)
|
||||||
* byte[] extension; // optional extension (length of array
|
* byte[] extension; // optional extension (length of array
|
||||||
* // is extend_length)
|
* // is extend_length)
|
||||||
* </CODE>
|
* </pre></CODE>
|
||||||
* <P>
|
* <P>
|
||||||
* The string_flag is bit mapped as follows:
|
* The string_flag is bit mapped as follows:
|
||||||
* <P>
|
* <P>
|
||||||
@ -507,14 +510,22 @@ public class SSTRecord
|
|||||||
* Subclasses should implement this so that their data is passed back in a
|
* Subclasses should implement this so that their data is passed back in a
|
||||||
* byte array.
|
* byte array.
|
||||||
*
|
*
|
||||||
* @return byte array containing instance data
|
* @return size
|
||||||
*/
|
*/
|
||||||
|
|
||||||
public int serialize( int offset, byte[] data )
|
public int serialize( int offset, byte[] data )
|
||||||
{
|
{
|
||||||
SSTSerializer serializer = new SSTSerializer(
|
SSTSerializer serializer = new SSTSerializer(
|
||||||
_record_lengths, field_3_strings, getNumStrings(), getNumUniqueStrings() );
|
_record_lengths, field_3_strings, getNumStrings(), getNumUniqueStrings() );
|
||||||
return serializer.serialize( getRecordSize(), offset, data );
|
int bytes = serializer.serialize( getRecordSize(), offset, data );
|
||||||
|
bucketAbsoluteOffsets = serializer.getBucketAbsoluteOffsets();
|
||||||
|
bucketRelativeOffsets = serializer.getBucketRelativeOffsets();
|
||||||
|
// for ( int i = 0; i < bucketAbsoluteOffsets.length; i++ )
|
||||||
|
// {
|
||||||
|
// System.out.println( "bucketAbsoluteOffset = " + bucketAbsoluteOffsets[i] );
|
||||||
|
// System.out.println( "bucketRelativeOffset = " + bucketRelativeOffsets[i] );
|
||||||
|
// }
|
||||||
|
return bytes;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
@ -538,6 +549,45 @@ public class SSTRecord
|
|||||||
{
|
{
|
||||||
deserializer.processContinueRecord( record );
|
deserializer.processContinueRecord( record );
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Creates an extended string record based on the current contents of
|
||||||
|
* the current SST record. The offset within the stream to the SST record
|
||||||
|
* is required because the extended string record points directly to the
|
||||||
|
* strings in the SST record.
|
||||||
|
* <p>
|
||||||
|
* NOTE: THIS FUNCTION MUST ONLY BE CALLED AFTER THE SST RECORD HAS BEEN
|
||||||
|
* SERIALIZED.
|
||||||
|
*
|
||||||
|
* @param sstOffset The offset in the stream to the start of the
|
||||||
|
* SST record.
|
||||||
|
* @return The new SST record.
|
||||||
|
*/
|
||||||
|
public ExtSSTRecord createExtSSTRecord(int sstOffset)
|
||||||
|
{
|
||||||
|
if (bucketAbsoluteOffsets == null || bucketAbsoluteOffsets == null)
|
||||||
|
throw new IllegalStateException("SST record has not yet been serialized.");
|
||||||
|
|
||||||
|
ExtSSTRecord extSST = new ExtSSTRecord();
|
||||||
|
extSST.setNumStringsPerBucket((short)8);
|
||||||
|
int[] absoluteOffsets = (int[]) bucketAbsoluteOffsets.clone();
|
||||||
|
int[] relativeOffsets = (int[]) bucketRelativeOffsets.clone();
|
||||||
|
for ( int i = 0; i < absoluteOffsets.length; i++ )
|
||||||
|
absoluteOffsets[i] += sstOffset;
|
||||||
|
extSST.setBucketOffsets(absoluteOffsets, relativeOffsets);
|
||||||
|
return extSST;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* Calculates the size in bytes of the EXTSST record as it would be if the
|
||||||
|
* record was serialized.
|
||||||
|
*
|
||||||
|
* @return The size of the ExtSST record in bytes.
|
||||||
|
*/
|
||||||
|
public int calcExtSSTRecordSize()
|
||||||
|
{
|
||||||
|
return 4 + 2 + ((field_3_strings.size() / SSTSerializer.DEFAULT_BUCKET_SIZE) + 1) * 8;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@ -61,7 +61,9 @@ import java.util.List;
|
|||||||
import java.util.Map;
|
import java.util.Map;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Used to calculate the record sizes for a particular record.
|
* Used to calculate the record sizes for a particular record. This kind of
|
||||||
|
* sucks because it's similar to the SST serialization code. In general
|
||||||
|
* the SST serialization code needs to be rewritten.
|
||||||
*
|
*
|
||||||
* @author Glen Stampoultzis (glens at apache.org)
|
* @author Glen Stampoultzis (glens at apache.org)
|
||||||
*/
|
*/
|
||||||
|
@ -77,6 +77,14 @@ class SSTSerializer
|
|||||||
private int numUniqueStrings;
|
private int numUniqueStrings;
|
||||||
private SSTRecordHeader sstRecordHeader;
|
private SSTRecordHeader sstRecordHeader;
|
||||||
|
|
||||||
|
/** Offsets from the beginning of the SST record (even across continuations) */
|
||||||
|
int[] bucketAbsoluteOffsets;
|
||||||
|
/** Offsets relative the start of the current SST or continue record */
|
||||||
|
int[] bucketRelativeOffsets;
|
||||||
|
int startOfSST, startOfRecord;
|
||||||
|
/** The default bucket size (this is used for ExternSST) */
|
||||||
|
final static int DEFAULT_BUCKET_SIZE = 8;
|
||||||
|
|
||||||
public SSTSerializer( List recordLengths, BinaryTree strings, int numStrings, int numUniqueStrings )
|
public SSTSerializer( List recordLengths, BinaryTree strings, int numStrings, int numUniqueStrings )
|
||||||
{
|
{
|
||||||
this.recordLengths = recordLengths;
|
this.recordLengths = recordLengths;
|
||||||
@ -84,6 +92,9 @@ class SSTSerializer
|
|||||||
this.numStrings = numStrings;
|
this.numStrings = numStrings;
|
||||||
this.numUniqueStrings = numUniqueStrings;
|
this.numUniqueStrings = numUniqueStrings;
|
||||||
this.sstRecordHeader = new SSTRecordHeader( numStrings, numUniqueStrings );
|
this.sstRecordHeader = new SSTRecordHeader( numStrings, numUniqueStrings );
|
||||||
|
|
||||||
|
this.bucketAbsoluteOffsets = new int[strings.size()/DEFAULT_BUCKET_SIZE+1];
|
||||||
|
this.bucketRelativeOffsets = new int[strings.size()/DEFAULT_BUCKET_SIZE+1];
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -133,7 +144,6 @@ class SSTSerializer
|
|||||||
|
|
||||||
/**
|
/**
|
||||||
* This case is chosen when an SST record does not span over to a continue record.
|
* This case is chosen when an SST record does not span over to a continue record.
|
||||||
*
|
|
||||||
*/
|
*/
|
||||||
private void serializeSingleSSTRecord( byte[] data, int offset, int record_length_index )
|
private void serializeSingleSSTRecord( byte[] data, int offset, int record_length_index )
|
||||||
{
|
{
|
||||||
@ -144,6 +154,11 @@ class SSTSerializer
|
|||||||
|
|
||||||
for ( int k = 0; k < strings.size(); k++ )
|
for ( int k = 0; k < strings.size(); k++ )
|
||||||
{
|
{
|
||||||
|
if (k % DEFAULT_BUCKET_SIZE == 0)
|
||||||
|
{
|
||||||
|
bucketAbsoluteOffsets[k / DEFAULT_BUCKET_SIZE] = pos;
|
||||||
|
bucketRelativeOffsets[k / DEFAULT_BUCKET_SIZE] = pos;
|
||||||
|
}
|
||||||
System.arraycopy( getUnicodeString( k ).serialize(), 0, data, pos + offset, getUnicodeString( k ).getRecordSize() );
|
System.arraycopy( getUnicodeString( k ).serialize(), 0, data, pos + offset, getUnicodeString( k ).getRecordSize() );
|
||||||
pos += getUnicodeString( k ).getRecordSize();
|
pos += getUnicodeString( k ).getRecordSize();
|
||||||
}
|
}
|
||||||
@ -157,6 +172,8 @@ class SSTSerializer
|
|||||||
private void serializeLargeRecord( int record_size, int record_length_index, byte[] buffer, int offset )
|
private void serializeLargeRecord( int record_size, int record_length_index, byte[] buffer, int offset )
|
||||||
{
|
{
|
||||||
|
|
||||||
|
startOfSST = offset;
|
||||||
|
|
||||||
byte[] stringReminant = null;
|
byte[] stringReminant = null;
|
||||||
int stringIndex = 0;
|
int stringIndex = 0;
|
||||||
boolean lastneedcontinue = false;
|
boolean lastneedcontinue = false;
|
||||||
@ -170,6 +187,7 @@ class SSTSerializer
|
|||||||
recordLength, numStrings, numUniqueStrings );
|
recordLength, numStrings, numUniqueStrings );
|
||||||
|
|
||||||
// write the appropriate header
|
// write the appropriate header
|
||||||
|
startOfRecord = offset + totalWritten;
|
||||||
recordProcessor.writeRecordHeader( offset, totalWritten, recordLength, first_record );
|
recordProcessor.writeRecordHeader( offset, totalWritten, recordLength, first_record );
|
||||||
first_record = false;
|
first_record = false;
|
||||||
|
|
||||||
@ -189,6 +207,12 @@ class SSTSerializer
|
|||||||
{
|
{
|
||||||
UnicodeString unistr = getUnicodeString( stringIndex );
|
UnicodeString unistr = getUnicodeString( stringIndex );
|
||||||
|
|
||||||
|
if (stringIndex % DEFAULT_BUCKET_SIZE == 0)
|
||||||
|
{
|
||||||
|
bucketAbsoluteOffsets[stringIndex / DEFAULT_BUCKET_SIZE] = offset + totalWritten + recordProcessor.getRecordOffset() - startOfSST;
|
||||||
|
bucketRelativeOffsets[stringIndex / DEFAULT_BUCKET_SIZE] = offset + totalWritten + recordProcessor.getRecordOffset() - startOfRecord;
|
||||||
|
}
|
||||||
|
|
||||||
if ( unistr.getRecordSize() <= recordProcessor.getAvailable() )
|
if ( unistr.getRecordSize() <= recordProcessor.getAvailable() )
|
||||||
{
|
{
|
||||||
recordProcessor.writeWholeString( unistr, offset, totalWritten );
|
recordProcessor.writeWholeString( unistr, offset, totalWritten );
|
||||||
@ -235,4 +259,14 @@ class SSTSerializer
|
|||||||
{
|
{
|
||||||
return recordLengths;
|
return recordLengths;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
public int[] getBucketAbsoluteOffsets()
|
||||||
|
{
|
||||||
|
return bucketAbsoluteOffsets;
|
||||||
|
}
|
||||||
|
|
||||||
|
public int[] getBucketRelativeOffsets()
|
||||||
|
{
|
||||||
|
return bucketRelativeOffsets;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user