com.bigdata.rdf.internal.encoder

Class SolutionSetStreamEncoder

java.lang.Object

com.bigdata.rdf.internal.encoder.SolutionSetStreamEncoder

public class SolutionSetStreamEncoder
extends Object

Stream encoder for solution sets (chunk oriented).

Author:

Bryan Thompson TODO Refactor the test suite for this from the SparqlCache test suite.

See Also:

SolutionSetStreamDecoder

Constructor Summary

Constructors

Constructor and Description
SolutionSetStreamEncoder(String name)

Method Summary

Methods

Modifier and Type	Method and Description
void	encode(DataOutputStream os, ICloseableIterator<IBindingSet[]> src2) Encode solutions onto the output stream.
long	getSolutionCount() #of solutions written.
ISolutionSetStats	getStats() The statistics for the encoded solutions (set when done).

Methods inherited from class java.lang.Object

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

Constructor Detail

SolutionSetStreamEncoder

public SolutionSetStreamEncoder(String name)

Method Detail

getSolutionCount

public long getSolutionCount()

#of solutions written.

getStats

public ISolutionSetStats getStats()

The statistics for the encoded solutions (set when done).

encode

public void encode(DataOutputStream os,
          ICloseableIterator<IBindingSet[]> src2)
            throws IOException

Encode solutions onto the output stream.

Parameters:

os - The output stream.

src2 - The solutions to be encoded.

Throws:

IOException