com.actian.dataflow.hive.shims

Class ORCFormatterShimImpl

java.lang.Object

com.pervasive.datarush.operators.io.AbstractRecordFormatter

com.actian.dataflow.hive.shims.ORCFormatterShimImpl

All Implemented Interfaces:

ORCFormatterShim, DataFormat.DataFormatter

public class ORCFormatterShimImpl
extends AbstractRecordFormatter
implements ORCFormatterShim

Constructor Summary

Constructors

Constructor and Description
ORCFormatterShimImpl()
ORCFormatterShimImpl(ORCOptions orcOptions)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	bindInputFields(RecordValued source) Provides the buffer holding input data to be formatted.
void	close() Called to signal that writing is complete.
protected void	formatRecord() Called to write a formatted record.
protected void	initialize(ByteSink sink, WriteMode mode) Prepares the formatter for writing to the provided sink.

Methods inherited from class com.pervasive.datarush.operators.io.AbstractRecordFormatter

bindInput, writeData

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.pervasive.datarush.operators.io.DataFormat.DataFormatter

bindInput, writeData

Constructor Detail

ORCFormatterShimImpl

public ORCFormatterShimImpl(ORCOptions orcOptions)

ORCFormatterShimImpl

public ORCFormatterShimImpl()

Method Detail

bindInputFields

protected void bindInputFields(RecordValued source)

Description copied from class: AbstractRecordFormatter

Provides the buffer holding input data to be formatted. This will be called once, when the input is bound to the formatter.

Specified by:

bindInputFields in class AbstractRecordFormatter

Parameters:

source - a record valued container which will hold the current value to be formatted

initialize

protected void initialize(ByteSink sink,
              WriteMode mode)
                   throws IOException

Description copied from class: AbstractRecordFormatter

Prepares the formatter for writing to the provided sink. This will be called once, after #bindInput(RecordInput) has been called, but before AbstractRecordFormatter.formatRecord() is called.

This method is always called, even if the input has no data.

Specified by:

initialize in class AbstractRecordFormatter

Parameters:

sink - the target to which data is written

mode - how an existing sink should be handled

Throws:

IOException - if an I/O error occurs

formatRecord

protected void formatRecord()
                     throws IOException

Description copied from class: AbstractRecordFormatter

Called to write a formatted record. The method is expected to format the record in the buffer passed in previously through AbstractRecordFormatter.bindInputFields(RecordValued) and write it to the sink passed to AbstractRecordFormatter.initialize(ByteSink, WriteMode).

This method is called repeatedly while the record source still has data.

Specified by:

formatRecord in class AbstractRecordFormatter

Throws:

IOException - if an I/O error occurs while writing the record

close

public void close()

Description copied from class: AbstractRecordFormatter

Called to signal that writing is complete. If AbstractRecordFormatter.bindInputFields(RecordValued) has returned successfully, it is guaranteed that this method will be called, even if errors occur.

This method is called once, after the last call to AbstractRecordFormatter.formatRecord() Any allocated resources which need to be released should be handled within the implementation of this method.

Specified by:

close in interface DataFormat.DataFormatter

Specified by:

close in class AbstractRecordFormatter