org.apache.drill.exec.physical.impl.spill

Class SpillSet

java.lang.Object

org.apache.drill.exec.physical.impl.spill.SpillSet

public class SpillSet
extends Object

Generates the set of spill files for this sort session.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	SpillSet.CountingInputStream Wrapper around an input stream to collect the total bytes read through the stream for use in reporting performance metrics.
static class	SpillSet.CountingOutputStream Wrapper around an output stream to collect the total bytes written through the stream for use in reporting performance metrics.

Constructor Summary

Constructors

Constructor and Description
SpillSet(DrillConfig config, ExecProtos.FragmentHandle handle, PhysicalOperator popConfig)
SpillSet(FragmentContext context, PhysicalOperator popConfig)

Method Summary

Modifier and Type	Method and Description
void	close()
void	close(VectorSerializer.Writer writer)
void	delete(String fileName)
int	getFileCount()
String	getNextSpillFile()
String	getNextSpillFile(String extraName)
long	getPosition(InputStream inputStream)
long	getPosition(WritableByteChannel channel)
long	getReadBytes()
long	getWriteBytes()
boolean	hasSpilled()
InputStream	openForInput(String fileName)
WritableByteChannel	openForOutput(String fileName)
void	tallyReadBytes(long readLength)
void	tallyWriteBytes(long writeLength)
VectorSerializer.Writer	writer(String fileName)

Methods inherited from class java.lang.Object

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

Constructor Detail

SpillSet

public SpillSet(FragmentContext context,
                PhysicalOperator popConfig)

SpillSet

public SpillSet(DrillConfig config,
                ExecProtos.FragmentHandle handle,
                PhysicalOperator popConfig)

Method Detail

getNextSpillFile

public String getNextSpillFile()

getNextSpillFile

public String getNextSpillFile(String extraName)

hasSpilled

public boolean hasSpilled()

getFileCount

public int getFileCount()

openForInput

public InputStream openForInput(String fileName)
                         throws IOException

Throws:

IOException

openForOutput

public WritableByteChannel openForOutput(String fileName)
                                  throws IOException

Throws:

IOException

delete

public void delete(String fileName)
            throws IOException

Throws:

IOException

getWriteBytes

public long getWriteBytes()

getReadBytes

public long getReadBytes()

close

public void close()

getPosition

public long getPosition(InputStream inputStream)

getPosition

public long getPosition(WritableByteChannel channel)

tallyReadBytes

public void tallyReadBytes(long readLength)

tallyWriteBytes

public void tallyWriteBytes(long writeLength)

writer

public VectorSerializer.Writer writer(String fileName)
                               throws IOException

Throws:

IOException

close

public void close(VectorSerializer.Writer writer)
           throws IOException

Throws:

IOException