Sha256: f9ab551fd10328d4e88c0c6442b25ff8e8a20718bee4bdd99a04a12549f8af10
Contents?: true
Size: 1.1 KB
Versions: 118
Compression:
Stored size: 1.1 KB
Contents
package org.embulk.spi;
abstract class PageFormat
{
// PageHeader
// +---+
// | 4 |
// +---+
// count (number of records)
private PageFormat() { }
static final int PAGE_HEADER_SIZE = 4;
// PageBuilder.setVariableLengthData and PageReader.readVariableLengthData
// uses 4 bytes integer
static final int VARIABLE_LENGTH_COLUMN_SIZE = 4;
static int nullBitSetSize(Schema schema)
{
return (schema.getColumnCount() + 7) / 8;
}
static int recordHeaderSize(Schema schema)
{
return 4 + nullBitSetSize(schema);
}
static int totalColumnSize(Schema schema)
{
return recordHeaderSize(schema) + schema.getFixedStorageSize();
}
static int[] columnOffsets(Schema schema)
{
int[] offsets = new int[schema.getColumnCount()];
if (!schema.isEmpty()) {
offsets[0] = recordHeaderSize(schema);
for (int i=0; i < schema.getColumnCount()-1; i++) {
offsets[i+1] = offsets[i] + schema.getColumnType(i).getFixedStorageSize();
}
}
return offsets;
}
}
Version data entries
118 entries across 118 versions & 1 rubygems