NIFI-272: minor tweaks to archetype to be more consistent with existing poms and java code style

This commit is contained in:
Mark Payne 2015-01-22 10:18:55 -05:00
parent db2072ed8a
commit a0b70fa9c6
4 changed files with 9 additions and 19 deletions

View File

@ -26,8 +26,6 @@
<version>${version}</version> <version>${version}</version>
<packaging>nar</packaging> <packaging>nar</packaging>
<name>${artifactId}</name>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>${groupId}</groupId> <groupId>${groupId}</groupId>

View File

@ -25,13 +25,6 @@
<artifactId>${artifactId}</artifactId> <artifactId>${artifactId}</artifactId>
<packaging>jar</packaging> <packaging>jar</packaging>
<name>${artifactId}</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<dependencies> <dependencies>
<dependency> <dependency>
<groupId>org.apache.nifi</groupId> <groupId>org.apache.nifi</groupId>

View File

@ -18,6 +18,7 @@ package org.apache.nifi.processors;
import org.apache.nifi.components.PropertyDescriptor; import org.apache.nifi.components.PropertyDescriptor;
import org.apache.nifi.components.PropertyValue; import org.apache.nifi.components.PropertyValue;
import org.apache.nifi.flowfile.FlowFile;
import org.apache.nifi.processor.*; import org.apache.nifi.processor.*;
import org.apache.nifi.processor.annotation.CapabilityDescription; import org.apache.nifi.processor.annotation.CapabilityDescription;
import org.apache.nifi.processor.annotation.OnScheduled; import org.apache.nifi.processor.annotation.OnScheduled;
@ -48,7 +49,7 @@ public class MyProcessor extends AbstractProcessor {
private Set<Relationship> relationships; private Set<Relationship> relationships;
@Override @Override
protected void init(ProcessorInitializationContext context) { protected void init(final ProcessorInitializationContext context) {
final List<PropertyDescriptor> descriptors = new ArrayList<PropertyDescriptor>(); final List<PropertyDescriptor> descriptors = new ArrayList<PropertyDescriptor>();
descriptors.add(MY_PROPERTY); descriptors.add(MY_PROPERTY);
this.descriptors = Collections.unmodifiableList(descriptors); this.descriptors = Collections.unmodifiableList(descriptors);
@ -74,9 +75,14 @@ public class MyProcessor extends AbstractProcessor {
} }
@Override @Override
public void onTrigger(ProcessContext context, ProcessSession session) throws ProcessException { public void onTrigger(final ProcessContext context, final ProcessSession session) throws ProcessException {
PropertyValue propertyValue = context.getProperty(MY_PROPERTY); FlowFile flowFile = session.get();
if ( flowFile == null ) {
return;
}
// TODO implement // TODO implement
} }
} }

View File

@ -27,13 +27,6 @@
<version>${version}</version> <version>${version}</version>
<packaging>pom</packaging> <packaging>pom</packaging>
<name>nifi-${artifactId}-bundle</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
</properties>
<modules> <modules>
<module>nifi-${rootArtifactId}-processors</module> <module>nifi-${rootArtifactId}-processors</module>
<module>nifi-${rootArtifactId}-nar</module> <module>nifi-${rootArtifactId}-nar</module>