Package org.apache.nifi.sql.internal

Class NiFiTableEnumerator

java.lang.Object

org.apache.nifi.sql.internal.NiFiTableEnumerator

All Implemented Interfaces:

AutoCloseable, org.apache.calcite.linq4j.Enumerator<Object>

public class NiFiTableEnumerator
extends Object
implements org.apache.calcite.linq4j.Enumerator<Object>

Field Summary

Fields

Modifier and Type	Field	Description
private Object	currentRow
private final ResettableDataSource	dataSource
private final int[]	fields
private final org.apache.nifi.logging.ComponentLog	logger
private final Consumer<NiFiTableEnumerator>	onCloseCallback
private final Runnable	onFinishCallback
private int	recordsRead
private RowStream	rowStream

Constructor Summary

Constructors

Constructor	Description
NiFiTableEnumerator(ResettableDataSource dataSource, org.apache.nifi.logging.ComponentLog logger, int[] fields, Runnable onFinishCallback, Consumer<NiFiTableEnumerator> onCloseCallback)

Method Summary

Modifier and Type	Method	Description
private Object	cast(Object toCast)
final void	close()
Object	current()
private Object	filterColumns(Object[] row)
int	getRecordsRead()
boolean	moveNext()
private void	onFinish()
void	reset()

Methods inherited from class java.lang.Object

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

Field Details

dataSource

private final ResettableDataSource dataSource

logger

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

fields

private final int[] fields

onFinishCallback

private final Runnable onFinishCallback

onCloseCallback

private final Consumer<NiFiTableEnumerator> onCloseCallback

rowStream

private RowStream rowStream

currentRow

private Object currentRow

recordsRead

private int recordsRead

Constructor Details

NiFiTableEnumerator

public NiFiTableEnumerator(ResettableDataSource dataSource,
 org.apache.nifi.logging.ComponentLog logger,
 int[] fields,
 Runnable onFinishCallback,
 Consumer<NiFiTableEnumerator> onCloseCallback)

Method Details

current

public Object current()

Specified by:

current in interface org.apache.calcite.linq4j.Enumerator<Object>

moveNext

public boolean moveNext()

Specified by:

moveNext in interface org.apache.calcite.linq4j.Enumerator<Object>

getRecordsRead

public int getRecordsRead()

onFinish

private void onFinish()

filterColumns

private Object filterColumns(Object[] row)

cast

private Object cast(Object toCast)

reset

public void reset()

Specified by:

reset in interface org.apache.calcite.linq4j.Enumerator<Object>

close

public final void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface org.apache.calcite.linq4j.Enumerator<Object>