com.splicemachine.derby.stream.output.direct

Class DirectDataSetWriter<K>

java.lang.Object

com.splicemachine.derby.stream.output.direct.DirectDataSetWriter<K>

All Implemented Interfaces:

DataSetWriter

public class DirectDataSetWriter<K>
extends java.lang.Object
implements DataSetWriter

Constructor Summary

Constructors

Constructor and Description
DirectDataSetWriter(ControlPairDataSet<K,KVPair> dataSet, DirectPipelineWriter pipelineWriter)

Method Summary

Modifier and Type	Method and Description
byte[]	getDestinationTable()
TxnView	getTxn()
void	setTxn(TxnView childTxn)
DataSet<ExecRow>	write()

Methods inherited from class java.lang.Object

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

Constructor Detail

DirectDataSetWriter

public DirectDataSetWriter(ControlPairDataSet<K,KVPair> dataSet,
                           DirectPipelineWriter pipelineWriter)

Method Detail

write

public DataSet<ExecRow> write()
                       throws StandardException

Specified by:

write in interface DataSetWriter

Throws:

StandardException

setTxn

public void setTxn(TxnView childTxn)

Specified by:

setTxn in interface DataSetWriter

getTxn

public TxnView getTxn()

Specified by:

getTxn in interface DataSetWriter

getDestinationTable

public byte[] getDestinationTable()

Specified by:

getDestinationTable in interface DataSetWriter