de.lmu.ifi.dbs.elki.datasource.bundle

Class BundleReader

java.lang.Object

de.lmu.ifi.dbs.elki.datasource.bundle.BundleReader

All Implemented Interfaces:

BundleStreamSource

public class BundleReader
extends Object
implements BundleStreamSource

Read an ELKI bundle file into a data stream. TODO: resize buffer when necessary?

Author:

Erich Schubert

Nested Class Summary

Nested classes/interfaces inherited from interface de.lmu.ifi.dbs.elki.datasource.bundle.BundleStreamSource

BundleStreamSource.Event

Field Summary

Fields

Modifier and Type	Field and Description
(package private) MappedByteBuffer	buffer The stream buffer.
(package private) Object[]	data Current object.
(package private) boolean	hasids Whether or not we have DBIDs.
(package private) FileChannel	input Input channel.
static int	MAGIC Magic number, shared with BundleReader.
(package private) BundleMeta	meta Bundle metadata.
(package private) ByteBufferSerializer<?>[]	sers Serializers to use.

Constructor Summary

Constructors

Constructor and Description
BundleReader(FileChannel input) Constructor.
BundleReader(MappedByteBuffer buffer) Constructor.

Method Summary

Methods

Modifier and Type	Method and Description
MultipleObjectsBundle	asMultipleObjectsBundle() Return (or collect) the stream as bundle.
boolean	assignDBID(DBIDVar var) Assign the current object ID to a DBIDVar.
Object	data(int rnum) Access a particular object and representation.
BundleMeta	getMeta() Get the current meta data.
boolean	hasDBIDs() Indicate whether the stream contains DBIDs.
BundleStreamSource.Event	nextEvent() Get the next event
(package private) void	openBuffer() Map the input file.
(package private) void	readMeta() Read the metadata.
(package private) void	readObject() Read an object.

Methods inherited from class java.lang.Object

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

Field Detail

MAGIC

public static final int MAGIC

Magic number, shared with BundleReader.

See Also:

Constant Field Values

buffer

MappedByteBuffer buffer

The stream buffer.

meta

BundleMeta meta

Bundle metadata.

input

FileChannel input

Input channel.

sers

ByteBufferSerializer<?>[] sers

Serializers to use.

data

Object[] data

Current object.

hasids

boolean hasids

Whether or not we have DBIDs.

Constructor Detail

BundleReader

public BundleReader(MappedByteBuffer buffer)

Constructor.

Parameters:

buffer - Input buffer

BundleReader

public BundleReader(FileChannel input)

Constructor.

Parameters:

input - Input channel

Method Detail

getMeta

public BundleMeta getMeta()

Description copied from interface: BundleStreamSource

Get the current meta data.

Specified by:

getMeta in interface BundleStreamSource

Returns:

Metadata

openBuffer

void openBuffer()

Map the input file.

readMeta

void readMeta()

Read the metadata.

readObject

void readObject()

Read an object.

nextEvent

public BundleStreamSource.Event nextEvent()

Description copied from interface: BundleStreamSource

Get the next event

Specified by:

nextEvent in interface BundleStreamSource

Returns:

Event type

data

public Object data(int rnum)

Description copied from interface: BundleStreamSource

Access a particular object and representation.

Specified by:

data in interface BundleStreamSource

Parameters:

rnum - Representation number

Returns:

Contained data

hasDBIDs

public boolean hasDBIDs()

Description copied from interface: BundleStreamSource

Indicate whether the stream contains DBIDs.

Specified by:

hasDBIDs in interface BundleStreamSource

Returns:

true if the stream contains DBIDs.

assignDBID

public boolean assignDBID(DBIDVar var)

Description copied from interface: BundleStreamSource

Assign the current object ID to a DBIDVar.

Specified by:

assignDBID in interface BundleStreamSource

Parameters:

var - Variable to assign the object id to

Returns:

false when no object id is available

asMultipleObjectsBundle

public MultipleObjectsBundle asMultipleObjectsBundle()

Description copied from interface: BundleStreamSource

Return (or collect) the stream as bundle.

Specified by:

asMultipleObjectsBundle in interface BundleStreamSource

Returns:

Bundle