This is an automated email from the ASF dual-hosted git repository.
markap14 pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git.
from 93a5823 NIFI-7890 - Added record support to ConsumeMQTT processor
add 525e410 NIFI-8095: Created StatelessNiFi Sink Connector and Source
Connector. Minor updates to stateless nifi api to accommodate.
No new revisions were added by this update.
Summary of changes:
nifi-external/nifi-kafka-connect/README.md | 478 +++++++++++++++++++++
.../nifi-kafka-connector-assembly}/LICENSE | 0
.../nifi-kafka-connector-assembly/NOTICE | 152 +++++++
.../nifi-kafka-connector-assembly/pom.xml | 172 ++++++++
.../src/main/assembly/dependencies.xml | 95 ++++
.../nifi-kafka-connector-tests/pom.xml | 110 +++++
.../src/main/assembly/dependencies.xml | 67 +++
.../kafka/connect/StatelessNiFiSinkTaskIT.java | 142 ++++++
.../kafka/connect/StatelessNiFiSourceTaskIT.java | 291 +++++++++++++
.../src/test/resources/flows/Generate_Data.json | 167 +++++++
.../src/test/resources/flows/Write_To_File.json | 312 ++++++++++++++
.../nifi-kafka-connector/pom.xml | 140 ++++++
.../kafka/connect/StatelessKafkaConnectorUtil.java | 355 +++++++++++++++
.../kafka/connect/StatelessNiFiSinkConnector.java | 87 ++++
.../nifi/kafka/connect/StatelessNiFiSinkTask.java | 275 ++++++++++++
.../connect/StatelessNiFiSourceConnector.java | 104 +++++
.../kafka/connect/StatelessNiFiSourceTask.java | 276 ++++++++++++
.../ConnectDirectoryExistsValidator.java | 51 +++
.../validators/ConnectHttpUrlValidator.java | 46 ++
.../ConnectRegularExpressionValidator.java | 43 ++
.../connect/validators/FlowSnapshotValidator.java | 54 +++
nifi-external/{ => nifi-kafka-connect}/pom.xml | 21 +-
nifi-external/pom.xml | 1 +
.../repository/StandardProcessSession.java | 6 +-
.../manager/StandardStateManagerProvider.java | 33 +-
.../apache/nifi/groups/StandardProcessGroup.java | 2 +-
.../apache/nifi/controller/ProcessScheduler.java | 17 +-
.../org/apache/nifi/controller/FlowController.java | 13 +-
.../scheduling/StandardProcessScheduler.java | 19 +
.../java/org/apache/nifi/nar/NarClassLoaders.java | 8 -
.../nifi/stateless/config/ParameterOverride.java | 4 +
.../nifi/stateless/flow/DataflowDefinition.java | 2 +
.../stateless/flow/DataflowDefinitionParser.java | 3 +
.../nifi/stateless/flow/StatelessDataflow.java | 17 +-
.../apache/nifi/stateless/flow/TriggerResult.java | 2 +-
.../bootstrap/BootstrapConfiguration.java | 17 +-
.../stateless/bootstrap/StatelessBootstrap.java | 19 +-
.../nifi-stateless-engine/pom.xml | 3 +
.../components/state/HashMapStateProvider.java | 12 +
.../state/StatelessStateManagerProvider.java | 46 ++
.../scheduling}/StatelessProcessScheduler.java | 37 +-
.../org/apache/nifi/extensions/DownloadQueue.java | 28 +-
.../extensions/FileSystemExtensionRepository.java | 14 +-
.../stateless/bootstrap/ExtensionDiscovery.java | 5 +-
.../config/PropertiesFileFlowDefinitionParser.java | 163 +++++--
.../engine/StandardExecutionProgress.java | 6 +-
.../stateless/engine/StandardStatelessEngine.java | 54 ++-
.../nifi/stateless/flow/CanceledTriggerResult.java | 2 +-
.../stateless/flow/ExceptionalTriggerResult.java | 6 +-
.../stateless/flow/StandardDataflowDefinition.java | 13 +
.../flow/StandardStatelessDataflowFactory.java | 19 +-
.../nifi/stateless/flow/StandardStatelessFlow.java | 200 ++++++++-
.../stateless/queue/StatelessFlowFileQueue.java | 8 +-
.../apache/nifi/stateless/StatelessSystemIT.java | 5 +
.../stateless/basics/CancelFlowExecutionIT.java | 3 +-
.../nifi/stateless/basics/CreatesFlowFileIT.java | 2 +-
.../nifi/stateless/basics/InputOutputIT.java | 7 +-
.../stateless/basics/RollbackOnExceptionIT.java | 5 +-
.../processors/tests/system/GenerateFlowFile.java | 44 +-
.../resources/conf/clustered/node2/bootstrap.conf | 2 +-
.../src/test/resources/conf/default/bootstrap.conf | 2 +-
61 files changed, 4094 insertions(+), 193 deletions(-)
create mode 100644 nifi-external/nifi-kafka-connect/README.md
copy
{nifi-nar-bundles/nifi-framework-bundle/nifi-stateless-bundle/nifi-stateless-nar/src/main/resources/META-INF
=> nifi-external/nifi-kafka-connect/nifi-kafka-connector-assembly}/LICENSE
(100%)
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector-assembly/NOTICE
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector-assembly/pom.xml
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector-assembly/src/main/assembly/dependencies.xml
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector-tests/pom.xml
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector-tests/src/main/assembly/dependencies.xml
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector-tests/src/test/java/org/apache/nifi/kafka/connect/StatelessNiFiSinkTaskIT.java
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector-tests/src/test/java/org/apache/nifi/kafka/connect/StatelessNiFiSourceTaskIT.java
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector-tests/src/test/resources/flows/Generate_Data.json
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector-tests/src/test/resources/flows/Write_To_File.json
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector/pom.xml
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessKafkaConnectorUtil.java
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSinkConnector.java
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSinkTask.java
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSourceConnector.java
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/StatelessNiFiSourceTask.java
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/validators/ConnectDirectoryExistsValidator.java
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/validators/ConnectHttpUrlValidator.java
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/validators/ConnectRegularExpressionValidator.java
create mode 100644
nifi-external/nifi-kafka-connect/nifi-kafka-connector/src/main/java/org/apache/nifi/kafka/connect/validators/FlowSnapshotValidator.java
copy nifi-external/{ => nifi-kafka-connect}/pom.xml (68%)
create mode 100644
nifi-nar-bundles/nifi-framework-bundle/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/components/state/StatelessStateManagerProvider.java
rename
nifi-nar-bundles/nifi-framework-bundle/nifi-stateless-bundle/nifi-stateless-engine/src/main/java/org/apache/nifi/{stateless/engine
=> controller/scheduling}/StatelessProcessScheduler.java (82%)
