Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
24 commits
Select commit Hold shift + click to select a range
f43e904
Initial commit of a CLI tool to help with NiFi flow migrations
lfrancke Oct 8, 2025
487462e
Fix Justfile to properly quote filenames
lfrancke Oct 8, 2025
63a492b
Fix pre-commit warnings and make sure pre-commit shows the same warni…
lfrancke Oct 8, 2025
594c6cb
Add a format-only mode
lfrancke Oct 9, 2025
bbb13f5
Update .yamllint.yaml
lfrancke Oct 9, 2025
ff9190f
Update .cargo/config.toml
lfrancke Oct 9, 2025
a4497a2
Add periods to end of comments
lfrancke Oct 9, 2025
8b172b3
Address review comments
lfrancke Oct 9, 2025
3e214b8
Address review comments
lfrancke Oct 9, 2025
74b18e6
Update Cargo.toml
lfrancke Oct 10, 2025
b4d49de
Update Cargo.toml
lfrancke Oct 10, 2025
fb06a67
Move migration module to the new standard without mod.rs files
lfrancke Oct 10, 2025
5bb9e7b
Change CLI to take positional arguments for input & output
lfrancke Oct 10, 2025
f1e4426
README cleanup
lfrancke Oct 10, 2025
fb2b0a1
Support for migration of Jolt* properties as well
lfrancke Oct 10, 2025
3003db8
Initial commit of a CLI tool to help with NiFi flow migrations
lfrancke Oct 8, 2025
552cea0
Add a format-only mode
lfrancke Oct 9, 2025
37a35cc
Add periods to end of comments
lfrancke Oct 9, 2025
f99f4e0
Address review comments
lfrancke Oct 9, 2025
9fbf0ac
Address review comments
lfrancke Oct 9, 2025
4d7fe26
Move migration module to the new standard without mod.rs files
lfrancke Oct 10, 2025
922a612
Support for migration of Jolt* properties as well
lfrancke Oct 10, 2025
838c031
Merge remote-tracking branch 'origin/feat/more-migrations' into feat/…
lfrancke Oct 13, 2025
622c0fd
Revert accidental changes
lfrancke Oct 13, 2025
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
4 changes: 2 additions & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -13,14 +13,14 @@ A Rust CLI tool for migrating Apache NiFi flow.json files between versions.

- **Type**: `org.apache.nifi.processors.standard.JoltTransformJSON` → `org.apache.nifi.processors.jolt.JoltTransformJSON`
- **Bundle artifact**: `nifi-standard-nar` → `nifi-jolt-nar`
- **Reason**: In NiFi 2.x, Jolt processors were moved to a separate bundle
- **Reason**: In NiFi 2.x, Jolt processors were moved to a separate bundle and properties were renamed
- **Reference**: [NIFI-12554](https://issues.apache.org/jira/browse/NIFI-12554)

### JoltTransformRecord Processor

- **Type**: `org.apache.nifi.processors.jolt.record.JoltTransformRecord` → `org.apache.nifi.processors.jolt.JoltTransformRecord`
- **Bundle artifact**: `nifi-jolt-record-nar` → `nifi-jolt-nar`
- **Reason**: Consolidated into the main jolt bundle
- **Reason**: In NiFi 2.x, Jolt processors were moved to a separate bundle and properties were renamed
- **Reference**: [NIFI-12554](https://issues.apache.org/jira/browse/NIFI-12554)

## Build
Expand Down
6 changes: 3 additions & 3 deletions src/migration.rs
Original file line number Diff line number Diff line change
Expand Up @@ -4,7 +4,7 @@
mod rules;

use anyhow::{Context, Result};
use rules::{JoltTransformMigration, JoltTransformRecordMigration, MigrationRule};
use rules::{JoltTransformJsonMigration, JoltTransformRecordMigration, MigrationRule};
use serde_json::Value;
use std::fs;
use std::path::Path;
Expand All @@ -26,7 +26,7 @@ impl Default for Migrator {
fn default() -> Self {
Self {
rules: vec![
Box::new(JoltTransformMigration),
Box::new(JoltTransformJsonMigration),
Box::new(JoltTransformRecordMigration),
],
}
Expand Down Expand Up @@ -192,7 +192,7 @@ mod tests {
}
});

let rule = JoltTransformMigration;
let rule = JoltTransformJsonMigration;
assert!(rule.applies(&processor));
assert!(rule.apply(&mut processor));

Expand Down
4 changes: 2 additions & 2 deletions src/migration/rules.rs
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
// SPDX-FileCopyrightText: 2025 Stackable GmbH
// SPDX-License-Identifier: Apache-2.0

mod jolt_transform;
mod jolt_transform_json;
mod jolt_transform_record;

pub use jolt_transform::JoltTransformMigration;
pub use jolt_transform_json::JoltTransformJsonMigration;
pub use jolt_transform_record::JoltTransformRecordMigration;

use serde_json::Value;
Expand Down
217 changes: 0 additions & 217 deletions src/migration/rules/jolt_transform.rs

This file was deleted.

Loading
Loading