Package org.apache.nifi.processors.standard

Class ListDatabaseTables.AttributeTableListingWriter

java.lang.Object

org.apache.nifi.processors.standard.ListDatabaseTables.AttributeTableListingWriter

All Implemented Interfaces:

ListDatabaseTables.TableListingWriter

Enclosing class:

ListDatabaseTables

private static class ListDatabaseTables.AttributeTableListingWriter
extends Object
implements ListDatabaseTables.TableListingWriter

Field Summary

Fields

Modifier and Type	Field	Description
private final org.apache.nifi.processor.ProcessSession	session

Constructor Summary

Constructors

Constructor	Description
AttributeTableListingWriter(org.apache.nifi.processor.ProcessSession session)

Method Summary

Modifier and Type	Method	Description
void	addToListing(Map<String,String> tableInformation, String transitUri)
void	beginListing()
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

session

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

Constructor Details

AttributeTableListingWriter

public AttributeTableListingWriter(org.apache.nifi.processor.ProcessSession session)

Method Details

beginListing

public void beginListing()

Specified by:

beginListing in interface ListDatabaseTables.TableListingWriter

addToListing

public void addToListing(Map<String,String> tableInformation,
 String transitUri)

Specified by:

addToListing in interface ListDatabaseTables.TableListingWriter

finishListing

public void finishListing()

Specified by:

finishListing in interface ListDatabaseTables.TableListingWriter

finishListingExceptionally

public void finishListingExceptionally(Exception cause)

Specified by:

finishListingExceptionally in interface ListDatabaseTables.TableListingWriter