This is an automated email from the ASF dual-hosted git repository.
pvillard pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
from dd117413e47 NIFI-15780 Bump Groovy to 5.0.5, ActiveMQ to 6.2.3, Ant to
1.10.16, and others (#11089)
add a658c3335ed NIFI-15775 Refactor Snowflake Snowpipe Ingest without SDK
(#11090)
No new revisions were added by this update.
Summary of changes:
.../nifi-snowflake-processors/pom.xml | 5 -
.../snowflake/GetSnowflakeIngestStatus.java | 53 ++--
.../processors/snowflake/StartSnowflakeIngest.java | 19 +-
.../src/main/resources/META-INF/NOTICE | 9 -
.../nifi-snowflake-services-api/pom.xml | 4 -
.../SnowflakeIngestManagerProviderService.java | 20 +-
.../processors/snowflake/snowpipe/InsertFile.java} | 13 +-
.../snowflake/snowpipe/InsertFileStatus.java | 25 +-
.../processors/snowflake/snowpipe/InsertFiles.java | 9 +-
.../snowflake/snowpipe/InsertReport.java | 16 +-
.../nifi-snowflake-services/pom.xml | 9 +-
.../service/RSAKeyAuthorizationProvider.java | 203 +++++++++++++++
.../snowflake/service/RequestAuthorization.java | 11 +-
.../snowflake/service/SnowpipeIngestClient.java | 185 ++++++++++++++
.../service/SnowpipeResponseException.java | 26 +-
...ndardSnowflakeIngestManagerProviderService.java | 63 +++--
.../service/RSAKeyAuthorizationProviderTest.java | 155 ++++++++++++
.../service/SnowpipeIngestClientTest.java | 272 +++++++++++++++++++++
...ndardSnowflakeIngestManagerProviderService.java | 157 ++++++++++++
.../nifi-snowflake-bundle/pom.xml | 29 ---
20 files changed, 1114 insertions(+), 169 deletions(-)
copy
nifi-extension-bundles/{nifi-extension-utils/nifi-event-transport/src/main/java/org/apache/nifi/event/transport/EventServerFactory.java
=>
nifi-snowflake-bundle/nifi-snowflake-services-api/src/main/java/org/apache/nifi/processors/snowflake/snowpipe/InsertFile.java}
(78%)
copy
nifi-framework-api/src/main/java/org/apache/nifi/controller/metrics/ComponentMetricContext.java
=>
nifi-extension-bundles/nifi-snowflake-bundle/nifi-snowflake-services-api/src/main/java/org/apache/nifi/processors/snowflake/snowpipe/InsertFileStatus.java
(55%)
copy
nifi-commons/nifi-calcite-utils/src/main/java/org/apache/nifi/sql/NiFiTableSchema.java
=>
nifi-extension-bundles/nifi-snowflake-bundle/nifi-snowflake-services-api/src/main/java/org/apache/nifi/processors/snowflake/snowpipe/InsertFiles.java
(76%)
copy
nifi-framework-bundle/nifi-framework/nifi-file-authorizer/src/main/java/org/apache/nifi/authorization/AuthorizedUserGroups.java
=>
nifi-extension-bundles/nifi-snowflake-bundle/nifi-snowflake-services-api/src/main/java/org/apache/nifi/processors/snowflake/snowpipe/InsertReport.java
(70%)
create mode 100644
nifi-extension-bundles/nifi-snowflake-bundle/nifi-snowflake-services/src/main/java/org/apache/nifi/snowflake/service/RSAKeyAuthorizationProvider.java
copy
nifi-commons/nifi-calcite-utils/src/main/java/org/apache/nifi/sql/NiFiTableSchema.java
=>
nifi-extension-bundles/nifi-snowflake-bundle/nifi-snowflake-services/src/main/java/org/apache/nifi/snowflake/service/RequestAuthorization.java
(69%)
create mode 100644
nifi-extension-bundles/nifi-snowflake-bundle/nifi-snowflake-services/src/main/java/org/apache/nifi/snowflake/service/SnowpipeIngestClient.java
copy
nifi-commons/nifi-security-ssl/src/main/java/org/apache/nifi/security/ssl/ReadEntityException.java
=>
nifi-extension-bundles/nifi-snowflake-bundle/nifi-snowflake-services/src/main/java/org/apache/nifi/snowflake/service/SnowpipeResponseException.java
(57%)
create mode 100644
nifi-extension-bundles/nifi-snowflake-bundle/nifi-snowflake-services/src/test/java/org/apache/nifi/snowflake/service/RSAKeyAuthorizationProviderTest.java
create mode 100644
nifi-extension-bundles/nifi-snowflake-bundle/nifi-snowflake-services/src/test/java/org/apache/nifi/snowflake/service/SnowpipeIngestClientTest.java
