Package org.apache.nifi.processors.standard

Class ListDatabaseTables.RecordTableListingWriter

java.lang.Object

org.apache.nifi.processors.standard.ListDatabaseTables.RecordTableListingWriter

All Implemented Interfaces:

ListDatabaseTables.TableListingWriter

Enclosing class:

ListDatabaseTables

static class ListDatabaseTables.RecordTableListingWriter
extends Object
implements ListDatabaseTables.TableListingWriter

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.nifi.flowfile.FlowFile	flowFile
private final org.apache.nifi.logging.ComponentLog	logger
private static final RecordSchema	RECORD_SCHEMA
private RecordSetWriter	recordWriter
private final org.apache.nifi.processor.ProcessSession	session
static final String	TABLE_CATALOG
static final String	TABLE_FULLNAME
static final String	TABLE_NAME
static final String	TABLE_REMARKS
static final String	TABLE_ROW_COUNT
static final String	TABLE_SCHEMA
static final String	TABLE_TYPE
private String	transitUri
private final RecordSetWriterFactory	writerFactory

Constructor Summary

Constructors

Constructor	Description
RecordTableListingWriter(org.apache.nifi.processor.ProcessSession session, RecordSetWriterFactory writerFactory, org.apache.nifi.logging.ComponentLog logger)

Method Summary

Modifier and Type	Method	Description
void	addToListing(Map<String,String> tableInfo, String transitUri)
void	beginListing()
private Record	createRecordForListing(Map<String,String> tableInfo)
void	finishListing()
void	finishListingExceptionally(Exception cause)

Methods inherited from class java.lang.Object

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

Field Details

TABLE_NAME

public static final String TABLE_NAME

See Also:

• Constant Field Values

TABLE_CATALOG

public static final String TABLE_CATALOG

See Also:

• Constant Field Values

TABLE_SCHEMA

public static final String TABLE_SCHEMA

See Also:

• Constant Field Values

TABLE_FULLNAME

public static final String TABLE_FULLNAME

See Also:

• Constant Field Values

TABLE_TYPE

public static final String TABLE_TYPE

See Also:

• Constant Field Values

TABLE_REMARKS

public static final String TABLE_REMARKS

See Also:

• Constant Field Values

TABLE_ROW_COUNT

public static final String TABLE_ROW_COUNT

See Also:

• Constant Field Values

RECORD_SCHEMA

private static final RecordSchema RECORD_SCHEMA

session

private final org.apache.nifi.processor.ProcessSession session

writerFactory

private final RecordSetWriterFactory writerFactory

logger

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

recordWriter

private RecordSetWriter recordWriter

flowFile

private org.apache.nifi.flowfile.FlowFile flowFile

transitUri

private String transitUri

Constructor Details

RecordTableListingWriter

public RecordTableListingWriter(org.apache.nifi.processor.ProcessSession session,
 RecordSetWriterFactory writerFactory,
 org.apache.nifi.logging.ComponentLog logger)

Method Details

beginListing

public void beginListing()
                  throws IOException,
SchemaNotFoundException

Specified by:

beginListing in interface ListDatabaseTables.TableListingWriter

Throws:

IOException

SchemaNotFoundException

addToListing

public void addToListing(Map<String,String> tableInfo,
 String transitUri)
                  throws IOException

Specified by:

addToListing in interface ListDatabaseTables.TableListingWriter

Throws:

IOException

finishListing

public void finishListing()
                   throws IOException

Specified by:

finishListing in interface ListDatabaseTables.TableListingWriter

Throws:

IOException

finishListingExceptionally

public void finishListingExceptionally(Exception cause)

Specified by:

finishListingExceptionally in interface ListDatabaseTables.TableListingWriter

createRecordForListing

private Record createRecordForListing(Map<String,String> tableInfo)