Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
18 commits
Select commit Hold shift + click to select a range
a761ed1
NIFI-15258: Initial API for Connectors
sfc-gh-mpayne Jul 24, 2025
34e0a02
NIFI-15259: Adding web context interface for custom Connector UIs.
mcgilman Dec 9, 2025
1d40638
NIFI-15322: Require all property descriptors within a PropertyGroup /…
markap14 Dec 10, 2025
2a88f22
NIFI-15326: Adding support for connector configuration step documenta…
mcgilman Dec 11, 2025
b390ec4
NIFI-15312: Moved SecretsProvider / SecretsManager to framework inste…
markap14 Dec 12, 2025
81a78a4
NIFI-15343: Adding providerId to Secret. (#30)
mcgilman Dec 15, 2025
b9a8815
NIFI-15258: Enable Custom UI to retrieve connector with flow contexts…
bobpaulin Dec 16, 2025
e7000ae
NIFI-15352: Added getFullyQualifiedName to secret, to encapsulate the…
markap14 Dec 17, 2025
8b20ea8
NIFI-15315 Add support for assets in Connectors (#31)
bbende Dec 17, 2025
e15cf73
NIFI-15361: Removing documentation from ConfigurationStep. (#38)
mcgilman Dec 18, 2025
ce524ac
NIFI-15369: Allow ConfigurationStep to depend on another (Configurati…
markap14 Dec 19, 2025
0020d5a
NIFI-15356: Introducing the ConnectorWebMethod. (#37)
mcgilman Dec 21, 2025
4a552ac
NIFI-15353: Adding documentation writers for connectors. (#40)
mcgilman Dec 23, 2025
ca54e76
NIFI-15428: If non-existent property value is set, connector should b…
markap14 Jan 6, 2026
8fda9f1
NIFI-15427: Added drainFlowFiles(FlowContext) method to Connector (#42)
markap14 Jan 9, 2026
5b9a59b
NIFI-15440: Implementation of ConnectorActions (#47)
markap14 Jan 12, 2026
860daf9
NIFI-15446: Updated JavaDocs to clarify how invocations of Connector …
markap14 Jan 15, 2026
fca1d3e
NIFI-15485: Include provider name when providing fqn for secrets
markap14 Jan 19, 2026
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
1 change: 0 additions & 1 deletion checkstyle.xml
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,6 @@
<module name="SimplifyBooleanReturn"/>
<module name="InterfaceIsType"/>
<module name="ArrayTypeStyle"/>
<module name="TodoComment"/>
<module name="UpperEll"/>
<module name="UnusedLocalVariable"/>
</module>
Expand Down
4 changes: 3 additions & 1 deletion src/main/java/org/apache/nifi/action/Component.java
Original file line number Diff line number Diff line change
Expand Up @@ -38,5 +38,7 @@ public enum Component {
AccessPolicy,
User,
UserGroup,
Label;
Label,
Connector;

}
Original file line number Diff line number Diff line change
Expand Up @@ -29,9 +29,10 @@
* {@link org.apache.nifi.controller.ControllerService ControllerService},
* {@link org.apache.nifi.registry.flow.FlowRegistryClient FlowRegistryClient},
* {@link org.apache.nifi.parameter.ParameterProvider ParameterProvider},
* {@link org.apache.nifi.flowanalysis.FlowAnalysisRule FlowAnalysisRule}, or
* {@link org.apache.nifi.reporting.ReportingTask ReportingTask} implementation
* can use to indicate a method should be called whenever the component is added
* {@link org.apache.nifi.flowanalysis.FlowAnalysisRule FlowAnalysisRule},
* {@link org.apache.nifi.reporting.ReportingTask ReportingTask}, or
* {@link org.apache.nifi.components.connector.Connector Connector}
* implementation can use to indicate a method should be called whenever the component is added
* to the flow. This method will be called once for the entire life of a
* component instance.
* </p>
Expand Down
9 changes: 9 additions & 0 deletions src/main/java/org/apache/nifi/asset/Asset.java
Original file line number Diff line number Diff line change
Expand Up @@ -37,9 +37,18 @@ public interface Asset {
* Returns the identifier of the parameter context the Asset belongs to
*
* @return Parameter Context Identifier
* @deprecated Use {@link #getOwnerIdentifier()} instead
*/
@Deprecated
String getParameterContextIdentifier();

/**
* Returns the identifier of the resource the Asset belongs to
*
* @return Owner Identifier
*/
String getOwnerIdentifier();

/**
* Returns the name of the Asset
*
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,11 +20,13 @@
public class ConfigVerificationResult {
private final Outcome outcome;
private final String verificationStepName;
private final String subject;
private final String explanation;

private ConfigVerificationResult(final Builder builder) {
outcome = builder.outcome;
verificationStepName = builder.verificationStepName;
subject = builder.subject;
explanation = builder.explanation;
}

Expand All @@ -36,6 +38,10 @@ public String getVerificationStepName() {
return verificationStepName;
}

public String getSubject() {
return subject;
}

public String getExplanation() {
return explanation;
}
Expand All @@ -44,13 +50,15 @@ public String getExplanation() {
public String toString() {
return "ConfigVerificationResult[" +
"outcome=" + outcome +
", subject=" + (subject == null ? "null" : "'" + subject + "'") +
", verificationStepName='" + verificationStepName + "'" +
", explanation='" + explanation + "']";
}

public static class Builder {
private Outcome outcome = Outcome.SKIPPED;
private String verificationStepName = "Unknown Step Name";
private String subject;
private String explanation;

public Builder outcome(final Outcome outcome) {
Expand All @@ -63,6 +71,11 @@ public Builder verificationStepName(final String verificationStepName) {
return this;
}

public Builder subject(final String subject) {
this.subject = subject;
return this;
}

public Builder explanation(final String explanation) {
this.explanation = explanation;
return this;
Expand Down
19 changes: 18 additions & 1 deletion src/main/java/org/apache/nifi/components/DescribedValue.java
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,24 @@ public interface DescribedValue {
String getDisplayName();

/**
* @return the proeprty description as a string
* @return the property description as a string
*/
String getDescription();

DescribedValue NULL = new DescribedValue() {
@Override
public String getValue() {
return null;
}

@Override
public String getDisplayName() {
return "NULL";
}

@Override
public String getDescription() {
return "A null value";
}
};
}
Loading