Package org.apache.nifi.processors.standard.calcite

Class RecordResultSetOutputStreamCallback

java.lang.Object

org.apache.nifi.processors.standard.calcite.RecordResultSetOutputStreamCallback

All Implemented Interfaces:

org.apache.nifi.processor.io.OutputStreamCallback

public class RecordResultSetOutputStreamCallback
extends Object
implements org.apache.nifi.processor.io.OutputStreamCallback

Field Summary

Fields

Modifier and Type	Field	Description
private final Integer	defaultPrecision
private final Integer	defaultScale
private final org.apache.nifi.logging.ComponentLog	logger
private String	mimeType
private final Map<String,String>	originalAttributes
private final RecordSetWriterFactory	recordSetWriterFactory
private final ResultSet	rs
private WriteResult	writeResult
private final RecordSchema	writerSchema

Constructor Summary

Constructors

Constructor	Description
RecordResultSetOutputStreamCallback(org.apache.nifi.logging.ComponentLog logger, ResultSet rs, RecordSchema writerSchema, Integer defaultPrecision, Integer defaultScale, RecordSetWriterFactory recordSetWriterFactory, Map<String,String> originalAttributes)

Method Summary

Modifier and Type	Method	Description
String	getMimeType()
WriteResult	getWriteResult()
void	process(OutputStream out)

Methods inherited from class java.lang.Object

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

Field Details

logger

private final org.apache.nifi.logging.ComponentLog logger

rs

private final ResultSet rs

writerSchema

private final RecordSchema writerSchema

defaultPrecision

private final Integer defaultPrecision

defaultScale

private final Integer defaultScale

recordSetWriterFactory

private final RecordSetWriterFactory recordSetWriterFactory

originalAttributes

private final Map<String,String> originalAttributes

writeResult

private WriteResult writeResult

mimeType

private String mimeType

Constructor Details

RecordResultSetOutputStreamCallback

public RecordResultSetOutputStreamCallback(org.apache.nifi.logging.ComponentLog logger,
 ResultSet rs,
 RecordSchema writerSchema,
 Integer defaultPrecision,
 Integer defaultScale,
 RecordSetWriterFactory recordSetWriterFactory,
 Map<String,String> originalAttributes)

Method Details

getWriteResult

public WriteResult getWriteResult()
                           throws org.apache.nifi.processor.exception.ProcessException

Throws:

org.apache.nifi.processor.exception.ProcessException

getMimeType

public String getMimeType()

process

public void process(OutputStream out)
             throws IOException

Specified by:

process in interface org.apache.nifi.processor.io.OutputStreamCallback

Throws:

IOException