NIFI-1054: Fixed DOS line endings in xml, java and js source files Signed-off-by: joewitt <[email protected]>
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 <[email protected]> Authored: Tue Dec 1 21:00:04 2015 -0500 Committer: Tony Kurc <[email protected]> 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; +}
