Index

A B C D E F G H I K L M N O P R S T U V W
All Classes and Interfaces|All Packages

A

addTable(NiFiTable) - Method in class org.apache.nifi.sql.CalciteDatabase

Adds the given table to the database

addUserDefinedFunction(String, Class<?>, String) - Method in class org.apache.nifi.sql.CalciteDatabase

Adds a user-defined function (UDF) to the database with the given name.

addUserDefinedFunction(String, Method) - Method in class org.apache.nifi.sql.CalciteDatabase

Adds a user-defined function (UDF) to the database with the given name.

ArrayType - Record Class in org.apache.nifi.sql

ArrayType(ColumnType) - Constructor for record class org.apache.nifi.sql.ArrayType

Creates an instance of a ArrayType record class.

asQueryable(QueryProvider, SchemaPlus, String) - Method in class org.apache.nifi.sql.internal.CalciteTable

B

BIGINT - Static variable in record class org.apache.nifi.sql.ScalarType

BOOLEAN - Static variable in record class org.apache.nifi.sql.ScalarType

BYTE - Static variable in record class org.apache.nifi.sql.ScalarType

C

CalciteDatabase - Class in org.apache.nifi.sql

A simple abstraction for creating a database facade over data.

CalciteDatabase() - Constructor for class org.apache.nifi.sql.CalciteDatabase

Creates a new database using the default connection properties

CalciteDatabase(Properties) - Constructor for class org.apache.nifi.sql.CalciteDatabase

Creates a new database with the given calcite connection properties

CalciteTable - Class in org.apache.nifi.sql.internal

An internal representation of a NiFiTable that is necessary for Apache Calcite.

CalciteTable(Function<RelDataTypeFactory, RelDataType>, Function<int[], Enumerable<Object>>) - Constructor for class org.apache.nifi.sql.internal.CalciteTable

cast(Object) - Method in class org.apache.nifi.sql.internal.NiFiTableEnumerator

CHARACTER - Static variable in record class org.apache.nifi.sql.ScalarType

close() - Method in class org.apache.nifi.sql.CalciteDatabase

close() - Method in class org.apache.nifi.sql.internal.NiFiTableEnumerator

close() - Method in class org.apache.nifi.sql.IterableRowStream

close() - Method in class org.apache.nifi.sql.NiFiTable

columns - Variable in record class org.apache.nifi.sql.NiFiTableSchema

The field for the columns record component.

columns() - Method in record class org.apache.nifi.sql.NiFiTableSchema

Returns the value of the columns record component.

ColumnSchema - Class in org.apache.nifi.sql

A schema that describes a single column in a NiFiTable

ColumnSchema(String, Class<?>, boolean) - Constructor for class org.apache.nifi.sql.ColumnSchema

Convenience method to create a schema for a column with a scalar value.

ColumnSchema(String, ColumnType, boolean) - Constructor for class org.apache.nifi.sql.ColumnSchema

Creates a column schema with the given name and type that is optionally nullable

columnType - Variable in class org.apache.nifi.sql.ColumnSchema

ColumnType - Interface in org.apache.nifi.sql

computeSelfCost(RelOptPlanner, RelMetadataQuery) - Method in class org.apache.nifi.sql.internal.NiFiTableScan

connection - Variable in class org.apache.nifi.sql.CalciteDatabase

createCalciteTable() - Method in class org.apache.nifi.sql.NiFiTable

createConnection(Properties) - Method in class org.apache.nifi.sql.CalciteDatabase

createTableDefinition(RelDataTypeFactory) - Method in class org.apache.nifi.sql.NiFiTable

current() - Method in class org.apache.nifi.sql.internal.NiFiTableEnumerator

currentRow - Variable in class org.apache.nifi.sql.internal.NiFiTableEnumerator

D

dataSource - Variable in class org.apache.nifi.sql.internal.NiFiTableEnumerator

dataSource - Variable in class org.apache.nifi.sql.NiFiTable

DATE - Static variable in record class org.apache.nifi.sql.ScalarType

DECIMAL - Static variable in record class org.apache.nifi.sql.ScalarType

DEFAULT - Static variable in interface org.apache.nifi.sql.internal.NiFiProjectTableScanRule.Config

deriveRowType() - Method in class org.apache.nifi.sql.internal.NiFiTableScan

description - Variable in class org.apache.nifi.sql.internal.NiFiProjectTableScanRule.StandardConfig

description() - Method in class org.apache.nifi.sql.internal.NiFiProjectTableScanRule.StandardConfig

DOUBLE - Static variable in record class org.apache.nifi.sql.ScalarType

E

elementType - Variable in record class org.apache.nifi.sql.ArrayType

The field for the elementType record component.

elementType() - Method in record class org.apache.nifi.sql.ArrayType

Returns the value of the elementType record component.

enumerator() - Method in class org.apache.nifi.sql.NiFiTable.NiFiTableEnumerable

enumerators - Variable in class org.apache.nifi.sql.NiFiTable

equals(Object) - Method in record class org.apache.nifi.sql.ArrayType

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in class org.apache.nifi.sql.ColumnSchema

equals(Object) - Method in record class org.apache.nifi.sql.MapType

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in class org.apache.nifi.sql.NiFiTable

equals(Object) - Method in record class org.apache.nifi.sql.NiFiTableSchema

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class org.apache.nifi.sql.ScalarType

Indicates whether some other object is "equal to" this one.

F

fieldExpression - Variable in class org.apache.nifi.sql.internal.NiFiTableScan

fields - Variable in class org.apache.nifi.sql.internal.NiFiTableEnumerator

fields - Variable in class org.apache.nifi.sql.internal.NiFiTableScan

fields - Variable in class org.apache.nifi.sql.NiFiTable.NiFiTableEnumerable

filterColumns(Object[]) - Method in class org.apache.nifi.sql.internal.NiFiTableEnumerator

FLOAT - Static variable in record class org.apache.nifi.sql.ScalarType

G

getConnection() - Method in class org.apache.nifi.sql.CalciteDatabase

The database connection that can be used for creating Statements, etc.

getElementType() - Method in class org.apache.nifi.sql.internal.CalciteTable

getExpression(SchemaPlus, String, Class) - Method in class org.apache.nifi.sql.internal.CalciteTable

getName() - Method in class org.apache.nifi.sql.ColumnSchema

getName() - Method in class org.apache.nifi.sql.NiFiTable

getProjectionFields(List<RexNode>) - Static method in class org.apache.nifi.sql.internal.NiFiProjectTableScanRule

getRecordsRead() - Method in class org.apache.nifi.sql.internal.NiFiTableEnumerator

getRecordsRead() - Method in class org.apache.nifi.sql.NiFiTable

getRelationalDataType(JavaTypeFactory) - Method in record class org.apache.nifi.sql.ArrayType

getRelationalDataType(JavaTypeFactory) - Method in interface org.apache.nifi.sql.ColumnType

Converts the column into the RelDataType that Calcite requires

getRelationalDataType(JavaTypeFactory) - Method in record class org.apache.nifi.sql.MapType

getRelationalDataType(JavaTypeFactory) - Method in record class org.apache.nifi.sql.ScalarType

getRowType(RelDataTypeFactory) - Method in class org.apache.nifi.sql.internal.CalciteTable

getSchema() - Method in interface org.apache.nifi.sql.ResettableDataSource

getTable(String) - Method in class org.apache.nifi.sql.CalciteDatabase

Retrieves the table with the given name

getTables() - Method in class org.apache.nifi.sql.CalciteDatabase

H

hashCode() - Method in record class org.apache.nifi.sql.ArrayType

Returns a hash code value for this object.

hashCode() - Method in class org.apache.nifi.sql.ColumnSchema

hashCode() - Method in record class org.apache.nifi.sql.MapType

Returns a hash code value for this object.

hashCode() - Method in class org.apache.nifi.sql.NiFiTable

hashCode() - Method in record class org.apache.nifi.sql.NiFiTableSchema

Returns a hash code value for this object.

hashCode() - Method in record class org.apache.nifi.sql.ScalarType

Returns a hash code value for this object.

I

implement(EnumerableRelImplementor, EnumerableRel.Prefer) - Method in class org.apache.nifi.sql.internal.NiFiTableScan

INTEGER - Static variable in record class org.apache.nifi.sql.ScalarType

isNullable() - Method in class org.apache.nifi.sql.ColumnSchema

IterableRowStream<T> - Class in org.apache.nifi.sql

A convenience implementation of RowStream that can be used to convert any Iterable to a RowStream.

IterableRowStream(Iterable<T>, Function<T, Object[]>) - Constructor for class org.apache.nifi.sql.IterableRowStream

Creates an IterableRowStream that is capable of iterating over the objects in the given Iterable

iterator - Variable in class org.apache.nifi.sql.IterableRowStream

K

keyType - Variable in record class org.apache.nifi.sql.MapType

The field for the keyType record component.

keyType() - Method in record class org.apache.nifi.sql.MapType

Returns the value of the keyType record component.

L

logger - Static variable in class org.apache.nifi.sql.CalciteDatabase

logger - Variable in class org.apache.nifi.sql.internal.NiFiTableEnumerator

logger - Variable in class org.apache.nifi.sql.NiFiTable

LONG - Static variable in record class org.apache.nifi.sql.ScalarType

M

MapType - Record Class in org.apache.nifi.sql

MapType(ColumnType, ColumnType) - Constructor for record class org.apache.nifi.sql.MapType

Creates an instance of a MapType record class.

maxRecordsRead - Variable in class org.apache.nifi.sql.NiFiTable

moveNext() - Method in class org.apache.nifi.sql.internal.NiFiTableEnumerator

N

name - Variable in class org.apache.nifi.sql.ColumnSchema

name - Variable in class org.apache.nifi.sql.NiFiTable

nextRow() - Method in class org.apache.nifi.sql.IterableRowStream

nextRow() - Method in interface org.apache.nifi.sql.RowStream

Returns the next row of data as an object array, or null if the stream is out of data.

NiFiProjectTableScanRule - Class in org.apache.nifi.sql.internal

NiFiProjectTableScanRule(NiFiProjectTableScanRule.Config) - Constructor for class org.apache.nifi.sql.internal.NiFiProjectTableScanRule

NiFiProjectTableScanRule.Config - Interface in org.apache.nifi.sql.internal

NiFiProjectTableScanRule.StandardConfig - Class in org.apache.nifi.sql.internal

NiFiTable - Class in org.apache.nifi.sql

A table that can be queried in a CalciteDatabase

NiFiTable(String, NiFiTableSchema, ComponentLog) - Constructor for class org.apache.nifi.sql.NiFiTable

Created a NiFi table without yet establishing the datasource.

NiFiTable(String, ResettableDataSource, ComponentLog) - Constructor for class org.apache.nifi.sql.NiFiTable

Created a NiFi table with a datasource already established.

NiFiTable.NiFiTableEnumerable - Class in org.apache.nifi.sql

NiFiTableEnumerable(int[]) - Constructor for class org.apache.nifi.sql.NiFiTable.NiFiTableEnumerable

NiFiTableEnumerator - Class in org.apache.nifi.sql.internal

NiFiTableEnumerator(ResettableDataSource, ComponentLog, int[], Runnable, Consumer<NiFiTableEnumerator>) - Constructor for class org.apache.nifi.sql.internal.NiFiTableEnumerator

NiFiTableScan - Class in org.apache.nifi.sql.internal

NiFiTableScan(RelOptCluster, RelOptTable, int[]) - Constructor for class org.apache.nifi.sql.internal.NiFiTableScan

NiFiTableSchema - Record Class in org.apache.nifi.sql

The schema for a NiFiTable

NiFiTableSchema(List<ColumnSchema>) - Constructor for record class org.apache.nifi.sql.NiFiTableSchema

Creates an instance of a NiFiTableSchema record class.

nullable - Variable in class org.apache.nifi.sql.ColumnSchema

O

OBJECT - Static variable in record class org.apache.nifi.sql.ScalarType

onCloseCallback - Variable in class org.apache.nifi.sql.internal.NiFiTableEnumerator

onFinish() - Method in class org.apache.nifi.sql.internal.NiFiTableEnumerator

onFinish() - Method in class org.apache.nifi.sql.NiFiTable.NiFiTableEnumerable

onFinishCallback - Variable in class org.apache.nifi.sql.internal.NiFiTableEnumerator

onMatch(RelOptRuleCall) - Method in class org.apache.nifi.sql.internal.NiFiProjectTableScanRule

operandSupplier() - Method in class org.apache.nifi.sql.internal.NiFiProjectTableScanRule.StandardConfig

operandTransform - Variable in class org.apache.nifi.sql.internal.NiFiProjectTableScanRule.StandardConfig

org.apache.nifi.sql - package org.apache.nifi.sql

org.apache.nifi.sql.internal - package org.apache.nifi.sql.internal

P

project(DataContext, int[]) - Method in class org.apache.nifi.sql.internal.CalciteTable

projectionFactory - Variable in class org.apache.nifi.sql.internal.CalciteTable

R

recordsRead - Variable in class org.apache.nifi.sql.internal.NiFiTableEnumerator

register(RelOptPlanner) - Method in class org.apache.nifi.sql.internal.NiFiTableScan

relBuilderFactory - Variable in class org.apache.nifi.sql.internal.NiFiProjectTableScanRule.StandardConfig

relBuilderFactory() - Method in class org.apache.nifi.sql.internal.NiFiProjectTableScanRule.StandardConfig

removeTable(String) - Method in class org.apache.nifi.sql.CalciteDatabase

Removes the table with the given name from the database

reset() - Method in class org.apache.nifi.sql.internal.NiFiTableEnumerator

reset() - Method in interface org.apache.nifi.sql.ResettableDataSource

Resets the data source and establishes a RowStream that can be used for iterating over data

ResettableDataSource - Interface in org.apache.nifi.sql

A Source of data for a database

rowStream - Variable in class org.apache.nifi.sql.internal.NiFiTableEnumerator

RowStream - Interface in org.apache.nifi.sql

An interface that is responsible for returning rows of data

S

scalarType - Variable in record class org.apache.nifi.sql.ScalarType

The field for the scalarType record component.

scalarType() - Method in record class org.apache.nifi.sql.ScalarType

Returns the value of the scalarType record component.

ScalarType - Record Class in org.apache.nifi.sql

ScalarType(Class<?>) - Constructor for record class org.apache.nifi.sql.ScalarType

Creates an instance of a ScalarType record class.

setDataSource(ResettableDataSource) - Method in class org.apache.nifi.sql.NiFiTable

Updates the datasource to use for retrieving rows of data.

SHORT - Static variable in record class org.apache.nifi.sql.ScalarType

StandardConfig() - Constructor for class org.apache.nifi.sql.internal.NiFiProjectTableScanRule.StandardConfig

STRING - Static variable in record class org.apache.nifi.sql.ScalarType

T

tableDefinitionFactory - Variable in class org.apache.nifi.sql.internal.CalciteTable

tables - Variable in class org.apache.nifi.sql.CalciteDatabase

tableSchema - Variable in class org.apache.nifi.sql.NiFiTable

TIME - Static variable in record class org.apache.nifi.sql.ScalarType

TIMESTAMP - Static variable in record class org.apache.nifi.sql.ScalarType

toRel(RelOptTable.ToRelContext, RelOptTable) - Method in class org.apache.nifi.sql.internal.CalciteTable

toRelationalDataType(JavaTypeFactory) - Method in class org.apache.nifi.sql.ColumnSchema

toRule() - Method in interface org.apache.nifi.sql.internal.NiFiProjectTableScanRule.Config

toString() - Method in record class org.apache.nifi.sql.ArrayType

Returns a string representation of this record class.

toString() - Method in class org.apache.nifi.sql.ColumnSchema

toString() - Method in record class org.apache.nifi.sql.MapType

Returns a string representation of this record class.

toString() - Method in class org.apache.nifi.sql.NiFiTable

toString() - Method in record class org.apache.nifi.sql.NiFiTableSchema

Returns a string representation of this record class.

toString() - Method in record class org.apache.nifi.sql.ScalarType

Returns a string representation of this record class.

transform - Variable in class org.apache.nifi.sql.IterableRowStream

U

UUID - Static variable in record class org.apache.nifi.sql.ScalarType

V

valueType - Variable in record class org.apache.nifi.sql.MapType

The field for the valueType record component.

valueType() - Method in record class org.apache.nifi.sql.MapType

Returns the value of the valueType record component.

W

withDescription(String) - Method in class org.apache.nifi.sql.internal.NiFiProjectTableScanRule.StandardConfig

withOperandSupplier(RelRule.OperandTransform) - Method in class org.apache.nifi.sql.internal.NiFiProjectTableScanRule.StandardConfig

withRelBuilderFactory(RelBuilderFactory) - Method in class org.apache.nifi.sql.internal.NiFiProjectTableScanRule.StandardConfig

A B C D E F G H I K L M N O P R S T U V W
All Classes and Interfaces|All Packages