mirror of https://github.com/apache/nifi.git
NIFI-11201 Added include-iotdb Maven build profile
This closes #6975 - Corrected Fetch Size property evaluation in QueryIoTDBRecord for FlowFile attributes Signed-off-by: Mike Thomsen <mthomsen@apache.org>
This commit is contained in:
exceptionfactory
Mike Thomsen
parent
a0ef378a42
commit
85f2162021
|
|
@ -1044,6 +1044,23 @@ language governing permissions and limitations under the License. -->
|
|||
</dependency>
|
||||
</dependencies>
|
||||
</profile>
|
||||
<profile>
|
||||
<id>include-iotdb</id>
|
||||
<activation>
|
||||
<activeByDefault>false</activeByDefault>
|
||||
<property>
|
||||
<name>allProfiles</name>
|
||||
</property>
|
||||
</activation>
|
||||
<dependencies>
|
||||
<dependency>
|
||||
<groupId>org.apache.nifi</groupId>
|
||||
<artifactId>nifi-iotdb-nar</artifactId>
|
||||
<version>2.0.0-SNAPSHOT</version>
|
||||
<type>nar</type>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
</profile>
|
||||
<profile>
|
||||
<id>include-media</id>
|
||||
<!-- This profile includes the NiFi Media Bundle which is a large package that exposes Apache Tika functionality
|
||||
|
|
|
|||
|
|
@ -2721,20 +2721,20 @@ deprecationLogger.warn(
|
|||
|
||||
[options="header,footer"]
|
||||
|==================================================================================================================================================
|
||||
| Package | Maven Profile | Description
|
||||
| Apache Accumulo Bundle | include-accumulo | Adds support for https://accumulo.apache.org[Apache Accumulo].
|
||||
| Apache Atlas Bundle | include-atlas | Adds support for the Apache Atlas data governance tool. The functionality from this bundle is based around reporting tasks that integrate with https://atlas.apache.org[Apache Atlas].
|
||||
| Apache Hive 1.1 Bundle | include-hive1_1 | Adds support for Apache Hive 1.1.X.
|
||||
| Apache Hive 3 Bundle | include-hive3 | Adds support for Apache Hive 3.X
|
||||
| Apache Ranger Bundle | include-ranger | Adds support for https://ranger.apache.org[Apache Ranger].
|
||||
| ASN1 Support | include-asn1 | Adds support for ASN1
|
||||
| Contribution Check | contrib-check | Runs various quality checks that are required to be accepted before a contribution can be accepted into the core NiFi code base.
|
||||
| Graph Database Bundle | include-graph | Adds support for various common graph database scenarios. Support is currently for https://neo4j.com/developer/cypher[Cypher] and https://tinkerpop.apache.org/gremlin.html[Gremlin]-compatible databases such as Neo4J and JanusGraph. Includes controller services that provide driver functionality and a suite of processors for ingestion and querying.
|
||||
| GRPC Bundle | include-grpc | **This profile is active in official builds and should be active** Provides support for the GRPC protocol.
|
||||
| Media Bundle | include-media | The media bundle provides functionality based on https://tika.apache.org[Apache Tika] for extracting content and metadata from various types of binary formats supported by Apache Tika (ex. PDF, Microsoft Office).
|
||||
| Rules Engine Bundle | include-rules | Adds support for creating scripted rules engines that can be integrated into existing flows. These rules engines can provide flexibility to people who need more complex flow logic or are more comfortable with flow decision-making using custom code.
|
||||
| Snowflake Bundle | include-snowflake | Adds support for integration with the https://www.snowflake.com[Snowflake platform].
|
||||
| SQL Reporting Bundle | include-sql-reporting | Adds reporting tasks that are designed to use SQL to update a RDBMS with metrics and other related data from Apache NiFi.
|
||||
| Package | Maven Profile | Description
|
||||
| Apache Accumulo Bundle | include-accumulo | Adds support for https://accumulo.apache.org[Apache Accumulo].
|
||||
| Apache Atlas Bundle | include-atlas | Adds support for the Apache Atlas data governance tool. The functionality from this bundle is based around reporting tasks that integrate with https://atlas.apache.org[Apache Atlas].
|
||||
| Apache Hive 3 Bundle | include-hive3 | Adds support for Apache Hive 3.X
|
||||
| Apache IoTDB Bundle | include-iotdb | Adds support for Apache IoTDB
|
||||
| Apache Ranger Bundle | include-ranger | Adds support for https://ranger.apache.org[Apache Ranger].
|
||||
| ASN.1 Support | include-asn1 | Adds support for ASN.1
|
||||
| Contribution Check | contrib-check | Runs various quality checks that are required to be accepted before a contribution can be accepted into the core NiFi code base.
|
||||
| Graph Database Bundle | include-graph | Adds support for various common graph database scenarios. Support is currently for https://neo4j.com/developer/cypher[Cypher] and https://tinkerpop.apache.org/gremlin.html[Gremlin]-compatible databases such as Neo4J and JanusGraph. Includes controller services that provide driver functionality and a suite of processors for ingestion and querying.
|
||||
| GRPC Bundle | include-grpc | **This profile is active in official builds and should be active** Provides support for the GRPC protocol.
|
||||
| Media Bundle | include-media | The media bundle provides functionality based on https://tika.apache.org[Apache Tika] for extracting content and metadata from various types of binary formats supported by Apache Tika (ex. PDF, Microsoft Office).
|
||||
| Rules Engine Bundle | include-rules | Adds support for creating scripted rules engines that can be integrated into existing flows. These rules engines can provide flexibility to people who need more complex flow logic or are more comfortable with flow decision-making using custom code.
|
||||
| Snowflake Bundle | include-snowflake | Adds support for integration with the https://www.snowflake.com[Snowflake platform].
|
||||
| SQL Reporting Bundle | include-sql-reporting | Adds reporting tasks that are designed to use SQL to update a RDBMS with metrics and other related data from Apache NiFi.
|
||||
|==================================================================================================================================================
|
||||
|
||||
=== Standard Build Instructions
|
||||
|
|
|
|||
|
|
@ -109,7 +109,7 @@ public class QueryIoTDBRecord extends AbstractIoTDB {
|
|||
}
|
||||
|
||||
final String query = context.getProperty(QUERY).evaluateAttributeExpressions(flowFile).getValue();
|
||||
final int fetchSize = context.getProperty(FETCH_SIZE).asInteger();
|
||||
final int fetchSize = context.getProperty(FETCH_SIZE).evaluateAttributeExpressions(flowFile).asInteger();
|
||||
final RecordSetWriterFactory recordSetWriterFactory = context.getProperty(RECORD_WRITER_FACTORY).asControllerService(RecordSetWriterFactory.class);
|
||||
|
||||
try (
|
||||
|
|
|
|||
Loading…
Reference in New Issue