Package jdistlib.inference

Class ChunkedDrawSink

java.lang.Object

jdistlib.inference.ChunkedDrawSink

All Implemented Interfaces:

AutoCloseable, DrawSink

public final class ChunkedDrawSink
extends Object
implements DrawSink, AutoCloseable

Selected-coordinate streaming sink with independently compressed, recoverable chunks.

Constructor Summary

Constructors

Constructor	Description
ChunkedDrawSink(Path path, int[] coordinates, int chunkSize)

Method Summary

Modifier and Type	Method	Description
void	accept(int retainedIndex, double[] state, double logDensity, IterationStats statistics)
void	close()
static ColumnarDraws	read(Path path)

Methods inherited from class java.lang.Object

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

Constructor Details

ChunkedDrawSink

public ChunkedDrawSink(Path path,
 int[] coordinates,
 int chunkSize)
                throws IOException

Throws:

IOException

Method Details

accept

public void accept(int retainedIndex,
 double[] state,
 double logDensity,
 IterationStats statistics)

Specified by:

accept in interface DrawSink

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Throws:

IOException

read

public static ColumnarDraws read(Path path)
                          throws IOException

Throws:

IOException