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

SolutionSetStreamEncoder(String name)

Method Summary

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