edu.iu.dsc.tws.data.arrow

Class Twister2ArrowFileWriter

java.lang.Object

edu.iu.dsc.tws.data.arrow.Twister2ArrowFileWriter

All Implemented Interfaces:

ITwister2ArrowFileWriter, java.io.Serializable

public class Twister2ArrowFileWriter
extends java.lang.Object
implements ITwister2ArrowFileWriter, java.io.Serializable

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Twister2ArrowFileWriter(java.lang.String arrowfile, boolean flag, java.lang.String schema, int parallelism)

Method Summary

Modifier and Type	Method and Description
void	close()
void	commitArrowData()
void	queueArrowData(java.lang.Object data)
boolean	setUpTwister2ArrowWrite(int workerId)

Methods inherited from class java.lang.Object

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

Constructor Detail

Twister2ArrowFileWriter

public Twister2ArrowFileWriter(java.lang.String arrowfile,
                               boolean flag,
                               java.lang.String schema,
                               int parallelism)

Method Detail

setUpTwister2ArrowWrite

public boolean setUpTwister2ArrowWrite(int workerId)
                                throws java.lang.Exception

Specified by:

setUpTwister2ArrowWrite in interface ITwister2ArrowFileWriter

Throws:

java.lang.Exception

queueArrowData

public void queueArrowData(java.lang.Object data)

Specified by:

queueArrowData in interface ITwister2ArrowFileWriter

commitArrowData

public void commitArrowData()
                     throws java.lang.Exception

Specified by:

commitArrowData in interface ITwister2ArrowFileWriter

Throws:

java.lang.Exception

close

public void close()