You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by tk...@apache.org on 2015/12/02 04:51:30 UTC
[24/24] nifi git commit: NIFI-1054: Fixed DOS line endings in xml,
java and js source files
NIFI-1054: Fixed DOS line endings in xml, java and js source files
Signed-off-by: joewitt <jo...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/nifi/repo
Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/3a7ddc6a
Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/3a7ddc6a
Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/3a7ddc6a
Branch: refs/heads/master
Commit: 3a7ddc6a35f143c1d4a735226fe7467a83d04583
Parents: 0f15f26
Author: Tony Kurc <tr...@gmail.com>
Authored: Tue Dec 1 21:00:04 2015 -0500
Committer: Tony Kurc <tr...@gmail.com>
Committed: Tue Dec 1 22:49:51 2015 -0500
----------------------------------------------------------------------
.../annotation/behavior/DynamicProperties.java | 74 +-
.../annotation/behavior/DynamicProperty.java | 92 +-
.../behavior/DynamicRelationship.java | 90 +-
.../annotation/behavior/ReadsAttribute.java | 82 +-
.../annotation/behavior/ReadsAttributes.java | 78 +-
.../annotation/behavior/WritesAttribute.java | 82 +-
.../annotation/behavior/WritesAttributes.java | 78 +-
.../nifi/annotation/documentation/SeeAlso.java | 88 +-
.../notification/OnPrimaryNodeStateChange.java | 88 +-
.../notification/PrimaryNodeState.java | 66 +-
.../repository/claim/ResourceClaim.java | 108 +-
.../org/apache/nifi/logging/ComponentLog.java | 208 +-
.../apache/nifi/reporting/ComponentType.java | 116 +-
.../bootstrap/NotificationServiceManager.java | 860 +--
.../NotificationServicePropertyValue.java | 240 +-
.../AbstractNotificationService.java | 74 +-
.../notification/NotificationContext.java | 88 +-
.../NotificationFailedException.java | 66 +-
.../NotificationInitializationContext.java | 78 +-
.../notification/NotificationService.java | 112 +-
.../notification/NotificationType.java | 46 +-
.../NotificationValidationContext.java | 210 +-
.../email/EmailNotificationService.java | 578 +-
.../evaluation/literals/ToLiteralEvaluator.java | 86 +-
.../selection/IteratingEvaluator.java | 66 +-
.../apache/nifi/util/NiFiPropertiesTest.java | 254 +-
.../org/apache/nifi/remote/Communicant.java | 92 +-
.../org/apache/nifi/remote/PeerDescription.java | 160 +-
.../nifi/remote/TransactionCompletion.java | 128 +-
.../apache/nifi/remote/client/KeystoreType.java | 48 +-
.../remote/client/SiteToSiteClientConfig.java | 296 +-
.../SocketClientTransactionCompletion.java | 114 +-
.../nifi/remote/util/NiFiRestApiUtil.java | 200 +-
.../client/socket/TestSiteToSiteClient.java | 206 +-
.../SynchronizedByteCountingOutputStream.java | 132 +-
.../nifi/processors/WriteResourceToStream.java | 212 +-
.../processors/WriteResourceToStreamTest.java | 94 +-
.../org/apache/nifi/spark/NiFiDataPacket.java | 78 +-
.../org/apache/nifi/spark/NiFiReceiver.java | 394 +-
.../nifi/spark/StandardNiFiDataPacket.java | 86 +-
.../nifi-__artifactBaseName__-nar/pom.xml | 74 +-
.../pom.xml | 108 +-
.../main/resources/archetype-resources/pom.xml | 70 +-
.../nifi-__artifactBaseName__-api-nar/pom.xml | 84 +-
.../nifi-__artifactBaseName__-api/pom.xml | 70 +-
.../nifi-__artifactBaseName__-nar/pom.xml | 86 +-
.../nifi-__artifactBaseName__/pom.xml | 118 +-
.../main/resources/archetype-resources/pom.xml | 74 +-
.../nifi/util/TestMockProcessContext.java | 252 +-
.../processors/aws/AbstractAWSProcessor.java | 478 +-
.../processors/aws/s3/AbstractS3Processor.java | 384 +-
.../nifi/processors/aws/s3/DeleteS3Object.java | 208 +-
.../nifi/processors/aws/s3/FetchS3Object.java | 318 +-
.../nifi/processors/aws/s3/PutS3Object.java | 428 +-
.../aws/sns/AbstractSNSProcessor.java | 116 +-
.../apache/nifi/processors/aws/sns/PutSNS.java | 318 +-
.../aws/sqs/AbstractSQSProcessor.java | 102 +-
.../nifi/processors/aws/sqs/DeleteSQS.java | 204 +-
.../apache/nifi/processors/aws/sqs/GetSQS.java | 438 +-
.../apache/nifi/processors/aws/sqs/PutSQS.java | 300 +-
.../processors/aws/s3/TestDeleteS3Object.java | 218 +-
.../processors/aws/s3/TestFetchS3Object.java | 196 +-
.../nifi/processors/aws/s3/TestPutS3Object.java | 278 +-
.../nifi/processors/aws/sns/TestPutSNS.java | 102 +-
.../nifi/processors/aws/sqs/TestGetSQS.java | 98 +-
.../nifi/processors/aws/sqs/TestPutSQS.java | 104 +-
.../nifi/web/api/dto/ReportingTaskDTO.java | 506 +-
.../ConfigurableComponentInitializer.java | 90 +-
.../apache/nifi/documentation/DocGenerator.java | 360 +-
.../nifi/documentation/DocumentationWriter.java | 66 +-
.../html/HtmlDocumentationWriter.java | 1228 ++--
.../html/HtmlProcessorDocumentationWriter.java | 512 +-
.../init/ControllerServiceInitializer.java | 114 +-
.../init/ProcessorInitializer.java | 110 +-
.../init/ReportingTaskingInitializer.java | 108 +-
.../mock/MockConfigurationContext.java | 96 +-
...kControllerServiceInitializationContext.java | 92 +-
.../mock/MockControllerServiceLookup.java | 130 +-
.../documentation/mock/MockProcessContext.java | 204 +-
.../MockProcessorInitializationContext.java | 90 +-
.../documentation/mock/MockProcessorLogger.java | 338 +-
.../MockReportingInitializationContext.java | 134 +-
.../documentation/util/ReflectionUtils.java | 278 +-
.../nifi/documentation/DocGeneratorTest.java | 192 +-
.../example/ControllerServiceWithLogger.java | 62 +-
.../FullyDocumentedControllerService.java | 206 +-
.../example/FullyDocumentedProcessor.java | 344 +-
.../example/FullyDocumentedReportingTask.java | 188 +-
.../documentation/example/NakedProcessor.java | 62 +-
.../example/ProcessorWithLogger.java | 74 +-
.../example/ReportingTaskWithLogger.java | 72 +-
.../documentation/example/SampleService.java | 50 +-
.../html/HtmlDocumentationWriterTest.java | 312 +-
.../html/ProcessorDocumentationWriterTest.java | 264 +-
.../nifi/documentation/html/XmlValidator.java | 106 +-
.../reporting/ReportingTaskProvider.java | 222 +-
.../service/ControllerServiceState.java | 86 +-
.../repository/claim/StandardResourceClaim.java | 268 +-
.../logging/ControllerServiceLogObserver.java | 92 +-
.../nifi/logging/ReportingTaskLogObserver.java | 90 +-
.../controller/scheduling/NoStartService.java | 46 +-
.../scheduling/NoStartServiceImpl.java | 58 +-
.../TestStandardProcessScheduler.java | 318 +-
.../StandardControllerServiceProviderTest.java | 142 +-
.../TestStandardControllerServiceProvider.java | 914 +--
.../controller/service/mock/DummyProcessor.java | 96 +-
.../nifi/controller/service/mock/ServiceA.java | 96 +-
.../nifi/controller/service/mock/ServiceB.java | 46 +-
.../service/util/TestControllerService.java | 122 +-
.../org/apache/nifi/nar/NarUnpackerTest.java | 426 +-
.../conf/bootstrap-notification-services.xml | 90 +-
.../webapp/js/jquery/slickgrid/slick.grid.js | 6844 +++++++++---------
.../nifi/processors/hadoop/FetchHDFS.java | 262 +-
.../apache/nifi/processors/hadoop/ListHDFS.java | 974 +--
.../processors/hadoop/util/HDFSListing.java | 166 +-
.../nifi/processors/hadoop/util/LongSerDe.java | 96 +-
.../processors/hadoop/util/StringSerDe.java | 88 +-
.../nifi/processors/hadoop/TestListHDFS.java | 714 +-
.../nifi/provenance/lucene/IndexManager.java | 1024 +--
.../nifi/provenance/toc/StandardTocReader.java | 310 +-
.../nifi/provenance/toc/StandardTocWriter.java | 240 +-
.../apache/nifi/provenance/toc/TocReader.java | 142 +-
.../org/apache/nifi/provenance/toc/TocUtil.java | 80 +-
.../apache/nifi/provenance/toc/TocWriter.java | 106 +-
.../TestStandardRecordReaderWriter.java | 378 +-
.../org/apache/nifi/provenance/TestUtil.java | 164 +-
.../provenance/toc/TestStandardTocReader.java | 236 +-
.../provenance/toc/TestStandardTocWriter.java | 84 +-
.../processors/standard/ConvertJSONToSQL.java | 1368 ++--
.../processors/standard/DuplicateFlowFile.java | 168 +-
.../processors/standard/EncryptContent.java | 612 +-
.../apache/nifi/processors/standard/PutSQL.java | 1846 ++---
.../standard/util/OpenPGPKeyBasedEncryptor.java | 566 +-
.../util/OpenPGPPasswordBasedEncryptor.java | 350 +-
.../standard/util/PasswordBasedEncryptor.java | 310 +-
.../processors/standard/CaptureServlet.java | 118 +-
.../standard/TestConvertJSONToSQL.java | 862 +--
.../standard/TestDuplicateFlowFile.java | 72 +-
.../processors/standard/TestEncryptContent.java | 326 +-
.../standard/TestHandleHttpRequest.java | 256 +-
.../standard/TestHandleHttpResponse.java | 360 +-
.../nifi/processors/standard/TestPostHTTP.java | 496 +-
.../nifi/processors/standard/TestPutEmail.java | 164 +-
.../nifi/processors/standard/TestPutSQL.java | 1400 ++--
144 files changed, 21078 insertions(+), 21078 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a7ddc6a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicProperties.java
----------------------------------------------------------------------
diff --git a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicProperties.java b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicProperties.java
index 902f5e9..b936ff0 100644
--- a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicProperties.java
+++ b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicProperties.java
@@ -1,37 +1,37 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.nifi.annotation.behavior;
-
-import java.lang.annotation.Documented;
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Inherited;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-/**
- * Indicates that a component has more than one dynamic property
- *
- */
-@Documented
-@Target({ElementType.TYPE})
-@Retention(RetentionPolicy.RUNTIME)
-@Inherited
-public @interface DynamicProperties {
-
- public DynamicProperty[] value();
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.annotation.behavior;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Inherited;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * Indicates that a component has more than one dynamic property
+ *
+ */
+@Documented
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Inherited
+public @interface DynamicProperties {
+
+ public DynamicProperty[] value();
+}
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a7ddc6a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicProperty.java
----------------------------------------------------------------------
diff --git a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicProperty.java b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicProperty.java
index dbb34b6..d5f0511 100644
--- a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicProperty.java
+++ b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicProperty.java
@@ -1,46 +1,46 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.nifi.annotation.behavior;
-
-import java.lang.annotation.Documented;
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Inherited;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-import org.apache.nifi.components.ConfigurableComponent;
-
-/**
- * An annotation that may be placed on a {@link ConfigurableComponent} to
- * indicate that it supports a dynamic property.
- *
- */
-@Documented
-@Target({ElementType.TYPE})
-@Retention(RetentionPolicy.RUNTIME)
-@Inherited
-public @interface DynamicProperty {
-
- public String name();
-
- public boolean supportsExpressionLanguage() default false;
-
- public String value();
-
- public String description();
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.annotation.behavior;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Inherited;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+import org.apache.nifi.components.ConfigurableComponent;
+
+/**
+ * An annotation that may be placed on a {@link ConfigurableComponent} to
+ * indicate that it supports a dynamic property.
+ *
+ */
+@Documented
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Inherited
+public @interface DynamicProperty {
+
+ public String name();
+
+ public boolean supportsExpressionLanguage() default false;
+
+ public String value();
+
+ public String description();
+}
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a7ddc6a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicRelationship.java
----------------------------------------------------------------------
diff --git a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicRelationship.java b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicRelationship.java
index 4129201..88d3b1d 100644
--- a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicRelationship.java
+++ b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/DynamicRelationship.java
@@ -1,45 +1,45 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.nifi.annotation.behavior;
-
-import java.lang.annotation.Documented;
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Inherited;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-import org.apache.nifi.components.PropertyDescriptor;
-import org.apache.nifi.processor.Processor;
-import org.apache.nifi.processor.Relationship;
-
-/**
- * Annotation to indicate that a {@link Processor} supports dynamic
- * relationship. A dynamic {@link Relationship} is one where the relationship is
- * generated based on a user defined {@link PropertyDescriptor}
- *
- */
-@Documented
-@Target({ElementType.TYPE})
-@Retention(RetentionPolicy.RUNTIME)
-@Inherited
-public @interface DynamicRelationship {
-
- public String name();
-
- public String description();
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.annotation.behavior;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Inherited;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+import org.apache.nifi.components.PropertyDescriptor;
+import org.apache.nifi.processor.Processor;
+import org.apache.nifi.processor.Relationship;
+
+/**
+ * Annotation to indicate that a {@link Processor} supports dynamic
+ * relationship. A dynamic {@link Relationship} is one where the relationship is
+ * generated based on a user defined {@link PropertyDescriptor}
+ *
+ */
+@Documented
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Inherited
+public @interface DynamicRelationship {
+
+ public String name();
+
+ public String description();
+}
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a7ddc6a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/ReadsAttribute.java
----------------------------------------------------------------------
diff --git a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/ReadsAttribute.java b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/ReadsAttribute.java
index fb9e2ab..0584f83 100644
--- a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/ReadsAttribute.java
+++ b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/ReadsAttribute.java
@@ -1,41 +1,41 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.nifi.annotation.behavior;
-
-import java.lang.annotation.Documented;
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Inherited;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-/**
- * Annotation that may be placed on a
- * {@link org.apache.nifi.processor.Processor Processor} indicating that this
- * processor reads a specific FlowFile attribute.
- *
- */
-@Documented
-@Target({ElementType.TYPE})
-@Retention(RetentionPolicy.RUNTIME)
-@Inherited
-public @interface ReadsAttribute {
-
- public String attribute();
-
- public String description() default "";
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.annotation.behavior;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Inherited;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * Annotation that may be placed on a
+ * {@link org.apache.nifi.processor.Processor Processor} indicating that this
+ * processor reads a specific FlowFile attribute.
+ *
+ */
+@Documented
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Inherited
+public @interface ReadsAttribute {
+
+ public String attribute();
+
+ public String description() default "";
+}
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a7ddc6a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/ReadsAttributes.java
----------------------------------------------------------------------
diff --git a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/ReadsAttributes.java b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/ReadsAttributes.java
index 2610e1c..e65746c 100644
--- a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/ReadsAttributes.java
+++ b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/ReadsAttributes.java
@@ -1,39 +1,39 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.nifi.annotation.behavior;
-
-import java.lang.annotation.Documented;
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Inherited;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-/**
- * Annotation that may be placed on a
- * {@link org.apache.nifi.processor.Processor Processor} indicating that this
- * processor reads specific FlowFile attributes.
- *
- */
-@Documented
-@Target({ElementType.TYPE})
-@Retention(RetentionPolicy.RUNTIME)
-@Inherited
-public @interface ReadsAttributes {
-
- public ReadsAttribute[] value();
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.annotation.behavior;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Inherited;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * Annotation that may be placed on a
+ * {@link org.apache.nifi.processor.Processor Processor} indicating that this
+ * processor reads specific FlowFile attributes.
+ *
+ */
+@Documented
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Inherited
+public @interface ReadsAttributes {
+
+ public ReadsAttribute[] value();
+}
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a7ddc6a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/WritesAttribute.java
----------------------------------------------------------------------
diff --git a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/WritesAttribute.java b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/WritesAttribute.java
index 841cf40..b2e1c48 100644
--- a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/WritesAttribute.java
+++ b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/WritesAttribute.java
@@ -1,41 +1,41 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.nifi.annotation.behavior;
-
-import java.lang.annotation.Documented;
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Inherited;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-/**
- * Annotation that may be placed on a
- * {@link org.apache.nifi.processor.Processor Processor} indicating that this
- * processor writes/updates a specific FlowFile attribute.
- *
- */
-@Documented
-@Target({ElementType.TYPE})
-@Retention(RetentionPolicy.RUNTIME)
-@Inherited
-public @interface WritesAttribute {
-
- public String attribute();
-
- public String description() default "";
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.annotation.behavior;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Inherited;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * Annotation that may be placed on a
+ * {@link org.apache.nifi.processor.Processor Processor} indicating that this
+ * processor writes/updates a specific FlowFile attribute.
+ *
+ */
+@Documented
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Inherited
+public @interface WritesAttribute {
+
+ public String attribute();
+
+ public String description() default "";
+}
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a7ddc6a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/WritesAttributes.java
----------------------------------------------------------------------
diff --git a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/WritesAttributes.java b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/WritesAttributes.java
index 3537e72..ad3e401 100644
--- a/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/WritesAttributes.java
+++ b/nifi-api/src/main/java/org/apache/nifi/annotation/behavior/WritesAttributes.java
@@ -1,39 +1,39 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.nifi.annotation.behavior;
-
-import java.lang.annotation.Documented;
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Inherited;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-/**
- * Annotation that may be placed on a
- * {@link org.apache.nifi.processor.Processor Processor} indicating that this
- * processor writes/updates specific FlowFile attributes.
- *
- */
-@Documented
-@Target({ElementType.TYPE})
-@Retention(RetentionPolicy.RUNTIME)
-@Inherited
-public @interface WritesAttributes {
-
- public WritesAttribute[] value();
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.annotation.behavior;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Inherited;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * Annotation that may be placed on a
+ * {@link org.apache.nifi.processor.Processor Processor} indicating that this
+ * processor writes/updates specific FlowFile attributes.
+ *
+ */
+@Documented
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Inherited
+public @interface WritesAttributes {
+
+ public WritesAttribute[] value();
+}
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a7ddc6a/nifi-api/src/main/java/org/apache/nifi/annotation/documentation/SeeAlso.java
----------------------------------------------------------------------
diff --git a/nifi-api/src/main/java/org/apache/nifi/annotation/documentation/SeeAlso.java b/nifi-api/src/main/java/org/apache/nifi/annotation/documentation/SeeAlso.java
index 35ca3db..4b77c43 100644
--- a/nifi-api/src/main/java/org/apache/nifi/annotation/documentation/SeeAlso.java
+++ b/nifi-api/src/main/java/org/apache/nifi/annotation/documentation/SeeAlso.java
@@ -1,44 +1,44 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.nifi.annotation.documentation;
-
-import java.lang.annotation.Documented;
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Inherited;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-import org.apache.nifi.components.ConfigurableComponent;
-
-/**
- * Annotation that may be placed on a null {@link org.apache.nifi.processor.Processor Processor},
- * {@link org.apache.nifi.controller.ControllerService ControllerService}, or
- * {@link org.apache.nifi.reporting.ReportingTask ReportingTask} that indicates
- * this component is related to the components listed.
- *
- */
-@Documented
-@Target({ElementType.TYPE})
-@Retention(RetentionPolicy.RUNTIME)
-@Inherited
-public @interface SeeAlso {
-
- public Class<? extends ConfigurableComponent>[] value() default {};
-
- public String[] classNames() default {};
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.annotation.documentation;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Inherited;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+import org.apache.nifi.components.ConfigurableComponent;
+
+/**
+ * Annotation that may be placed on a null {@link org.apache.nifi.processor.Processor Processor},
+ * {@link org.apache.nifi.controller.ControllerService ControllerService}, or
+ * {@link org.apache.nifi.reporting.ReportingTask ReportingTask} that indicates
+ * this component is related to the components listed.
+ *
+ */
+@Documented
+@Target({ElementType.TYPE})
+@Retention(RetentionPolicy.RUNTIME)
+@Inherited
+public @interface SeeAlso {
+
+ public Class<? extends ConfigurableComponent>[] value() default {};
+
+ public String[] classNames() default {};
+}
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a7ddc6a/nifi-api/src/main/java/org/apache/nifi/annotation/notification/OnPrimaryNodeStateChange.java
----------------------------------------------------------------------
diff --git a/nifi-api/src/main/java/org/apache/nifi/annotation/notification/OnPrimaryNodeStateChange.java b/nifi-api/src/main/java/org/apache/nifi/annotation/notification/OnPrimaryNodeStateChange.java
index 4ea2170..e3ff401 100644
--- a/nifi-api/src/main/java/org/apache/nifi/annotation/notification/OnPrimaryNodeStateChange.java
+++ b/nifi-api/src/main/java/org/apache/nifi/annotation/notification/OnPrimaryNodeStateChange.java
@@ -1,44 +1,44 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.nifi.annotation.notification;
-
-import java.lang.annotation.Documented;
-import java.lang.annotation.ElementType;
-import java.lang.annotation.Inherited;
-import java.lang.annotation.Retention;
-import java.lang.annotation.RetentionPolicy;
-import java.lang.annotation.Target;
-
-/**
- * <p>
- * Marker annotation that a component can use to indicate that a method should be
- * called whenever the state of the Primary Node in a cluster has changed.
- * </p>
- *
- * <p>
- * Methods with this annotation should take either no arguments or one argument of type
- * {@link PrimaryNodeState}. The {@link PrimaryNodeState} provides context about what changed
- * so that the component can take appropriate action.
- * </p>
- */
-@Documented
-@Target({ElementType.METHOD})
-@Retention(RetentionPolicy.RUNTIME)
-@Inherited
-public @interface OnPrimaryNodeStateChange {
-
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.annotation.notification;
+
+import java.lang.annotation.Documented;
+import java.lang.annotation.ElementType;
+import java.lang.annotation.Inherited;
+import java.lang.annotation.Retention;
+import java.lang.annotation.RetentionPolicy;
+import java.lang.annotation.Target;
+
+/**
+ * <p>
+ * Marker annotation that a component can use to indicate that a method should be
+ * called whenever the state of the Primary Node in a cluster has changed.
+ * </p>
+ *
+ * <p>
+ * Methods with this annotation should take either no arguments or one argument of type
+ * {@link PrimaryNodeState}. The {@link PrimaryNodeState} provides context about what changed
+ * so that the component can take appropriate action.
+ * </p>
+ */
+@Documented
+@Target({ElementType.METHOD})
+@Retention(RetentionPolicy.RUNTIME)
+@Inherited
+public @interface OnPrimaryNodeStateChange {
+
+}
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a7ddc6a/nifi-api/src/main/java/org/apache/nifi/annotation/notification/PrimaryNodeState.java
----------------------------------------------------------------------
diff --git a/nifi-api/src/main/java/org/apache/nifi/annotation/notification/PrimaryNodeState.java b/nifi-api/src/main/java/org/apache/nifi/annotation/notification/PrimaryNodeState.java
index 0d65b65..539e5f0 100644
--- a/nifi-api/src/main/java/org/apache/nifi/annotation/notification/PrimaryNodeState.java
+++ b/nifi-api/src/main/java/org/apache/nifi/annotation/notification/PrimaryNodeState.java
@@ -1,33 +1,33 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.nifi.annotation.notification;
-
-/**
- * Represents a state change that occurred for the Primary Node of a NiFi cluster.
- */
-public enum PrimaryNodeState {
- /**
- * The node receiving this state has been elected the Primary Node of the NiFi cluster.
- */
- ELECTED_PRIMARY_NODE,
-
- /**
- * The node receiving this state was the Primary Node but has now had its Primary Node
- * role revoked.
- */
- PRIMARY_NODE_REVOKED;
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.annotation.notification;
+
+/**
+ * Represents a state change that occurred for the Primary Node of a NiFi cluster.
+ */
+public enum PrimaryNodeState {
+ /**
+ * The node receiving this state has been elected the Primary Node of the NiFi cluster.
+ */
+ ELECTED_PRIMARY_NODE,
+
+ /**
+ * The node receiving this state was the Primary Node but has now had its Primary Node
+ * role revoked.
+ */
+ PRIMARY_NODE_REVOKED;
+}
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a7ddc6a/nifi-api/src/main/java/org/apache/nifi/controller/repository/claim/ResourceClaim.java
----------------------------------------------------------------------
diff --git a/nifi-api/src/main/java/org/apache/nifi/controller/repository/claim/ResourceClaim.java b/nifi-api/src/main/java/org/apache/nifi/controller/repository/claim/ResourceClaim.java
index d448632..77e7f84 100644
--- a/nifi-api/src/main/java/org/apache/nifi/controller/repository/claim/ResourceClaim.java
+++ b/nifi-api/src/main/java/org/apache/nifi/controller/repository/claim/ResourceClaim.java
@@ -1,54 +1,54 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.nifi.controller.repository.claim;
-
-import org.apache.nifi.controller.repository.ContentRepository;
-
-/**
- * <p>
- * Represents a resource that can be provided by a {@link ContentRepository}
- * </p>
- *
- * <p>
- * MUST BE THREAD-SAFE!
- * </p>
- */
-public interface ResourceClaim extends Comparable<ResourceClaim> {
-
- /**
- * @return the unique identifier for this claim
- */
- String getId();
-
- /**
- * @return the container identifier in which this claim is held
- */
- String getContainer();
-
- /**
- * @return the section within a given container the claim is held
- */
- String getSection();
-
- /**
- * @return Indicates whether or not the Claim is loss-tolerant. If so, we will
- * attempt to keep the content but will not sacrifice a great deal of
- * performance to do so
- */
- boolean isLossTolerant();
-
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.controller.repository.claim;
+
+import org.apache.nifi.controller.repository.ContentRepository;
+
+/**
+ * <p>
+ * Represents a resource that can be provided by a {@link ContentRepository}
+ * </p>
+ *
+ * <p>
+ * MUST BE THREAD-SAFE!
+ * </p>
+ */
+public interface ResourceClaim extends Comparable<ResourceClaim> {
+
+ /**
+ * @return the unique identifier for this claim
+ */
+ String getId();
+
+ /**
+ * @return the container identifier in which this claim is held
+ */
+ String getContainer();
+
+ /**
+ * @return the section within a given container the claim is held
+ */
+ String getSection();
+
+ /**
+ * @return Indicates whether or not the Claim is loss-tolerant. If so, we will
+ * attempt to keep the content but will not sacrifice a great deal of
+ * performance to do so
+ */
+ boolean isLossTolerant();
+
+}
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a7ddc6a/nifi-api/src/main/java/org/apache/nifi/logging/ComponentLog.java
----------------------------------------------------------------------
diff --git a/nifi-api/src/main/java/org/apache/nifi/logging/ComponentLog.java b/nifi-api/src/main/java/org/apache/nifi/logging/ComponentLog.java
index b4b3c6a..1710b19 100644
--- a/nifi-api/src/main/java/org/apache/nifi/logging/ComponentLog.java
+++ b/nifi-api/src/main/java/org/apache/nifi/logging/ComponentLog.java
@@ -1,104 +1,104 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.nifi.logging;
-
-/**
- * <p>
- * The ComponentLog provides a mechanism to ensure that all NiFi components are
- * logging and reporting information in a consistent way. When messages are
- * logged to the ComponentLog, each message has the following characteristics:
- * </p>
- *
- * <ul>
- * <li>
- * The <code>toString()</code> of the component is automatically prepended to
- * the message so that it is clear which component is providing the information.
- * This is important, since a single component may have many different instances
- * within the same NiFi instance.
- * </li>
- * <li>
- * If the last value in an Object[] argument that is passed to the logger is a
- * Throwable, then the logged message will include a <code>toString()</code> of
- * the Throwable; in addition, if the component's logger is set to DEBUG level
- * via the logback configuration, the Stacktrace will also be logged. This
- * provides a mechanism to easily enable stacktraces in the logs when they are
- * desired without filling the logs with unneeded stack traces for messages that
- * end up occurring often.
- * </li>
- * <li>
- * Any message that is logged with a Severity level that meets or exceeds the
- * configured Bulletin Level for that component will also cause a Bulletin to be
- * generated, so that the message is visible in the UI, allowing Dataflow
- * Managers to understand that a problem exists and what the issue is.
- * </li>
- * </ul>
- *
- */
-public interface ComponentLog {
-
- void warn(String msg, Throwable t);
-
- void warn(String msg, Object[] os);
-
- void warn(String msg, Object[] os, Throwable t);
-
- void warn(String msg);
-
- void trace(String msg, Throwable t);
-
- void trace(String msg, Object[] os);
-
- void trace(String msg);
-
- void trace(String msg, Object[] os, Throwable t);
-
- boolean isWarnEnabled();
-
- boolean isTraceEnabled();
-
- boolean isInfoEnabled();
-
- boolean isErrorEnabled();
-
- boolean isDebugEnabled();
-
- void info(String msg, Throwable t);
-
- void info(String msg, Object[] os);
-
- void info(String msg);
-
- void info(String msg, Object[] os, Throwable t);
-
- String getName();
-
- void error(String msg, Throwable t);
-
- void error(String msg, Object[] os);
-
- void error(String msg);
-
- void error(String msg, Object[] os, Throwable t);
-
- void debug(String msg, Throwable t);
-
- void debug(String msg, Object[] os);
-
- void debug(String msg, Object[] os, Throwable t);
-
- void debug(String msg);
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.logging;
+
+/**
+ * <p>
+ * The ComponentLog provides a mechanism to ensure that all NiFi components are
+ * logging and reporting information in a consistent way. When messages are
+ * logged to the ComponentLog, each message has the following characteristics:
+ * </p>
+ *
+ * <ul>
+ * <li>
+ * The <code>toString()</code> of the component is automatically prepended to
+ * the message so that it is clear which component is providing the information.
+ * This is important, since a single component may have many different instances
+ * within the same NiFi instance.
+ * </li>
+ * <li>
+ * If the last value in an Object[] argument that is passed to the logger is a
+ * Throwable, then the logged message will include a <code>toString()</code> of
+ * the Throwable; in addition, if the component's logger is set to DEBUG level
+ * via the logback configuration, the Stacktrace will also be logged. This
+ * provides a mechanism to easily enable stacktraces in the logs when they are
+ * desired without filling the logs with unneeded stack traces for messages that
+ * end up occurring often.
+ * </li>
+ * <li>
+ * Any message that is logged with a Severity level that meets or exceeds the
+ * configured Bulletin Level for that component will also cause a Bulletin to be
+ * generated, so that the message is visible in the UI, allowing Dataflow
+ * Managers to understand that a problem exists and what the issue is.
+ * </li>
+ * </ul>
+ *
+ */
+public interface ComponentLog {
+
+ void warn(String msg, Throwable t);
+
+ void warn(String msg, Object[] os);
+
+ void warn(String msg, Object[] os, Throwable t);
+
+ void warn(String msg);
+
+ void trace(String msg, Throwable t);
+
+ void trace(String msg, Object[] os);
+
+ void trace(String msg);
+
+ void trace(String msg, Object[] os, Throwable t);
+
+ boolean isWarnEnabled();
+
+ boolean isTraceEnabled();
+
+ boolean isInfoEnabled();
+
+ boolean isErrorEnabled();
+
+ boolean isDebugEnabled();
+
+ void info(String msg, Throwable t);
+
+ void info(String msg, Object[] os);
+
+ void info(String msg);
+
+ void info(String msg, Object[] os, Throwable t);
+
+ String getName();
+
+ void error(String msg, Throwable t);
+
+ void error(String msg, Object[] os);
+
+ void error(String msg);
+
+ void error(String msg, Object[] os, Throwable t);
+
+ void debug(String msg, Throwable t);
+
+ void debug(String msg, Object[] os);
+
+ void debug(String msg, Object[] os, Throwable t);
+
+ void debug(String msg);
+}
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a7ddc6a/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
----------------------------------------------------------------------
diff --git a/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java b/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
index 97f3538..f5b76e1 100644
--- a/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
+++ b/nifi-api/src/main/java/org/apache/nifi/reporting/ComponentType.java
@@ -1,58 +1,58 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.nifi.reporting;
-
-/**
- * An Enumeration for indicating which type of component a Bulletin is associated with
- */
-public enum ComponentType {
-
- /**
- * Bulletin is associated with a Processor
- */
- PROCESSOR,
-
- /**
- * Bulletin is associated with a Remote Process Group
- */
- REMOTE_PROCESS_GROUP,
-
- /**
- * Bulletin is associated with an Input Port
- */
- INPUT_PORT,
-
- /**
- * Bulletin is associated with an Output Port
- */
- OUTPUT_PORT,
-
- /**
- * Bulletin is associated with a Reporting Task
- */
- REPORTING_TASK,
-
- /**
- * Bulletin is associated with a Controller Service
- */
- CONTROLLER_SERVICE,
-
- /**
- * Bulletin is a system-level bulletin, associated with the Flow Controller
- */
- FLOW_CONTROLLER;
-}
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+package org.apache.nifi.reporting;
+
+/**
+ * An Enumeration for indicating which type of component a Bulletin is associated with
+ */
+public enum ComponentType {
+
+ /**
+ * Bulletin is associated with a Processor
+ */
+ PROCESSOR,
+
+ /**
+ * Bulletin is associated with a Remote Process Group
+ */
+ REMOTE_PROCESS_GROUP,
+
+ /**
+ * Bulletin is associated with an Input Port
+ */
+ INPUT_PORT,
+
+ /**
+ * Bulletin is associated with an Output Port
+ */
+ OUTPUT_PORT,
+
+ /**
+ * Bulletin is associated with a Reporting Task
+ */
+ REPORTING_TASK,
+
+ /**
+ * Bulletin is associated with a Controller Service
+ */
+ CONTROLLER_SERVICE,
+
+ /**
+ * Bulletin is a system-level bulletin, associated with the Flow Controller
+ */
+ FLOW_CONTROLLER;
+}