[jira] [Commented] (MINIFI-255) Upgrade to NiFi 1.2.0 dependencies when released
[ https://issues.apache.org/jira/browse/MINIFI-255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003975#comment-16003975 ] Joseph Witt commented on MINIFI-255: all the updates were pulled in from a squashed version of aldrin's PR https://github.com/apache/nifi-minifi/commit/b556187701f38c9d1f8232913f2ba9ae64db3956 > Upgrade to NiFi 1.2.0 dependencies when released > > > Key: MINIFI-255 > URL: https://issues.apache.org/jira/browse/MINIFI-255 > Project: Apache NiFi MiNiFi > Issue Type: Task > Components: Core Framework >Reporter: Aldrin Piri >Assignee: Aldrin Piri >Priority: Blocker > Fix For: 0.2.0 > > > At minimum, to solve the build issues around the casing change of jBCrypt but > will also provide the Site to Site configuration for attaching to an > interface for sending. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (MINIFI-255) Upgrade to NiFi 1.2.0 dependencies when released
[ https://issues.apache.org/jira/browse/MINIFI-255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003971#comment-16003971 ] ASF GitHub Bot commented on MINIFI-255: --- Github user asfgit closed the pull request at: https://github.com/apache/nifi-minifi/pull/84 > Upgrade to NiFi 1.2.0 dependencies when released > > > Key: MINIFI-255 > URL: https://issues.apache.org/jira/browse/MINIFI-255 > Project: Apache NiFi MiNiFi > Issue Type: Task > Components: Core Framework >Reporter: Aldrin Piri >Assignee: Aldrin Piri >Priority: Blocker > Fix For: 0.2.0 > > > At minimum, to solve the build issues around the casing change of jBCrypt but > will also provide the Site to Site configuration for attaching to an > interface for sending. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Resolved] (MINIFI-308) Update logback.conf to reflect new logback version requirements
[ https://issues.apache.org/jira/browse/MINIFI-308?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Joseph Witt resolved MINIFI-308. Resolution: Fixed resolved in commit for parent ticket > Update logback.conf to reflect new logback version requirements > --- > > Key: MINIFI-308 > URL: https://issues.apache.org/jira/browse/MINIFI-308 > Project: Apache NiFi MiNiFi > Issue Type: Sub-task > Components: Build, Core Framework >Reporter: Joseph Witt >Assignee: Joseph Witt > Fix For: 0.2.0 > > > Need the commit to reflect the changes we did in nifi just like > https://github.com/apache/nifi/pull/1678/commits/2ec695caf625b8c1c6d3844f0d90e7cc6cd36be4#diff-1fc20c14727b9d39d726a70e5842f9f4 -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[3/4] nifi-minifi git commit: MINIFI-255 This closes #84. Update codebase to incorporate NiFi 1.2.0 handling of NARs and required dependencies MINIFI-256 Support Site to Site attaching to an interface
http://git-wip-us.apache.org/repos/asf/nifi-minifi/blob/b5561877/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-nar-utils/src/main/java/org/apache/nifi/nar/ExtensionManager.java -- diff --git a/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-nar-utils/src/main/java/org/apache/nifi/nar/ExtensionManager.java b/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-nar-utils/src/main/java/org/apache/nifi/nar/ExtensionManager.java index 9fd9e66..b80207b 100644 --- a/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-nar-utils/src/main/java/org/apache/nifi/nar/ExtensionManager.java +++ b/minifi-nar-bundles/minifi-framework-bundle/minifi-framework/minifi-nar-utils/src/main/java/org/apache/nifi/nar/ExtensionManager.java @@ -19,14 +19,22 @@ package org.apache.nifi.nar; import org.apache.nifi.annotation.behavior.RequiresInstanceClassLoading; import org.apache.nifi.authentication.LoginIdentityProvider; import org.apache.nifi.authorization.Authorizer; +import org.apache.nifi.bundle.Bundle; +import org.apache.nifi.bundle.BundleCoordinate; +import org.apache.nifi.components.ConfigurableComponent; +import org.apache.nifi.components.PropertyDescriptor; +import org.apache.nifi.components.state.StateProvider; import org.apache.nifi.controller.ControllerService; import org.apache.nifi.controller.repository.ContentRepository; import org.apache.nifi.controller.repository.FlowFileRepository; import org.apache.nifi.controller.repository.FlowFileSwapManager; import org.apache.nifi.controller.status.history.ComponentStatusRepository; import org.apache.nifi.flowfile.FlowFilePrioritizer; +import org.apache.nifi.init.ConfigurableComponentInitializer; +import org.apache.nifi.init.ConfigurableComponentInitializerFactory; import org.apache.nifi.processor.Processor; import org.apache.nifi.provenance.ProvenanceRepository; +import org.apache.nifi.reporting.InitializationException; import org.apache.nifi.reporting.ReportingTask; import org.apache.nifi.util.StringUtils; import org.slf4j.Logger; @@ -35,13 +43,17 @@ import org.slf4j.LoggerFactory; import java.io.IOException; import java.net.URL; import java.net.URLClassLoader; +import java.util.ArrayList; import java.util.Collections; import java.util.HashMap; import java.util.HashSet; +import java.util.LinkedHashSet; +import java.util.List; import java.util.Map; import java.util.ServiceLoader; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; +import java.util.stream.Collectors; /** * Scans through the classpath to load all FlowFileProcessors, FlowFileComparators, and ReportingTasks using the service provider API and running through all classloaders (root, NARs). @@ -56,10 +68,13 @@ public class ExtensionManager { // Maps a service definition (interface) to those classes that implement the interface private static final MapdefinitionMap = new HashMap<>(); -private static final Map extensionClassloaderLookup = new HashMap<>(); +private static final Map classNameBundleLookup = new HashMap<>(); +private static final Map bundleCoordinateBundleLookup = new HashMap<>(); +private static final Map classLoaderBundleLookup = new HashMap<>(); +private static final Map tempComponentLookup = new HashMap<>(); -private static final Set requiresInstanceClassLoading = new HashSet<>(); -private static final Map instanceClassloaderLookup = new ConcurrentHashMap<>(); +private static final Map requiresInstanceClassLoading = new HashMap<>(); +private static final Map instanceClassloaderLookup = new ConcurrentHashMap<>(); static { definitionMap.put(Processor.class, new HashSet<>()); @@ -73,28 +88,33 @@ public class ExtensionManager { definitionMap.put(FlowFileRepository.class, new HashSet<>()); definitionMap.put(FlowFileSwapManager.class, new HashSet<>()); definitionMap.put(ContentRepository.class, new HashSet<>()); +definitionMap.put(StateProvider.class, new HashSet<>()); } /** * Loads all FlowFileProcessor, FlowFileComparator, ReportingTask class types that can be found on the bootstrap classloader and by creating classloaders for all NARs found within the classpath. - * @param extensionLoaders the loaders to scan through in search of extensions + * + * @param narBundles the bundles to scan through in search of extensions */ -public static void discoverExtensions(final Set extensionLoaders) { -final ClassLoader systemClassLoader = ClassLoader.getSystemClassLoader(); - +public static void discoverExtensions(final Bundle systemBundle, final Set narBundles) { //
[jira] [Commented] (MINIFI-255) Upgrade to NiFi 1.2.0 dependencies when released
[ https://issues.apache.org/jira/browse/MINIFI-255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003969#comment-16003969 ] Joseph Witt commented on MINIFI-255: [~aldrin] i've gone ahead and fixed the logback.conf and updated the jetty, logback, and log4j deps just as we did in nifi. This solves the errors/info that spews when starting minifi. Otherwise, full clean build w/contrib check is solid. Ran a test flow from the minifi cpp config and it worked perfectly. +1 will merge to master and close. Now, having said all this there is clearly a tremendous amount of work required to align with the latest nifi releases. Makes me wonder if we're swimming upstream a bit on the current approach to minifi java development. Perhaps we should consider alternatives like having minifi -java just be a stripped down assembly in nifi and plugging in more optimized implementations of things like the flowcontroller/etc.. At least worth a good discussion. > Upgrade to NiFi 1.2.0 dependencies when released > > > Key: MINIFI-255 > URL: https://issues.apache.org/jira/browse/MINIFI-255 > Project: Apache NiFi MiNiFi > Issue Type: Task > Components: Core Framework >Reporter: Aldrin Piri >Assignee: Aldrin Piri >Priority: Blocker > Fix For: 0.2.0 > > > At minimum, to solve the build issues around the casing change of jBCrypt but > will also provide the Site to Site configuration for attaching to an > interface for sending. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[1/4] nifi-minifi git commit: MINIFI-255 This closes #84. Update codebase to incorporate NiFi 1.2.0 handling of NARs and required dependencies MINIFI-256 Support Site to Site attaching to an interface
Repository: nifi-minifi Updated Branches: refs/heads/master b5313503f -> b55618770 http://git-wip-us.apache.org/repos/asf/nifi-minifi/blob/b5561877/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/MiNiFiPersistentProvenanceRepositoryTest.java -- diff --git a/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/MiNiFiPersistentProvenanceRepositoryTest.java b/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/MiNiFiPersistentProvenanceRepositoryTest.java index 08d5fc6..780c691 100644 --- a/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/MiNiFiPersistentProvenanceRepositoryTest.java +++ b/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/test/java/org/apache/nifi/provenance/MiNiFiPersistentProvenanceRepositoryTest.java @@ -16,39 +16,51 @@ */ package org.apache.nifi.provenance; +import org.apache.lucene.index.IndexWriter; import org.apache.lucene.queryparser.classic.ParseException; +import org.apache.nifi.authorization.user.NiFiUser; import org.apache.nifi.events.EventReporter; import org.apache.nifi.flowfile.FlowFile; -import org.apache.nifi.provenance.MiNiFiPersistentProvenanceRepository.MethodNotSupportedException; +import org.apache.nifi.provenance.lucene.IndexingAction; import org.apache.nifi.provenance.serialization.RecordReader; import org.apache.nifi.provenance.serialization.RecordReaders; import org.apache.nifi.provenance.serialization.RecordWriter; +import org.apache.nifi.provenance.serialization.RecordWriters; import org.apache.nifi.reporting.Severity; -import org.apache.nifi.stream.io.DataOutputStream; +import org.apache.nifi.util.NiFiProperties; import org.apache.nifi.util.file.FileUtils; import org.junit.After; import org.junit.Assert; import org.junit.Before; import org.junit.BeforeClass; +import org.junit.ClassRule; import org.junit.Rule; import org.junit.Test; +import org.junit.rules.TemporaryFolder; import org.junit.rules.TestName; import java.io.File; +import java.io.FileInputStream; import java.io.FileOutputStream; import java.io.IOException; +import java.lang.reflect.Field; +import java.lang.reflect.InvocationTargetException; +import java.lang.reflect.Method; import java.util.ArrayList; +import java.util.Arrays; import java.util.Collections; import java.util.HashMap; +import java.util.HashSet; import java.util.List; import java.util.Map; +import java.util.Set; import java.util.UUID; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; +import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; -import java.util.zip.GZIPOutputStream; import static org.apache.nifi.provenance.TestUtil.createFlowFile; import static org.junit.Assert.assertEquals; @@ -61,16 +73,23 @@ public class MiNiFiPersistentProvenanceRepositoryTest { @Rule public TestName name = new TestName(); +@ClassRule +public static TemporaryFolder tempFolder = new TemporaryFolder(); + private MiNiFiPersistentProvenanceRepository repo; -private RepositoryConfiguration config; +private static RepositoryConfiguration config; public static final int DEFAULT_ROLLOVER_MILLIS = 2000; private EventReporter eventReporter; private List reportedEvents = Collections.synchronizedList(new ArrayList()); +private static int headerSize; +private static int recordSize; +private static int recordSize2; + private RepositoryConfiguration createConfiguration() { config = new RepositoryConfiguration(); -config.addStorageDirectory(new File("target/storage/" + UUID.randomUUID().toString())); +config.addStorageDirectory("1", new File("target/storage/" + UUID.randomUUID().toString())); config.setCompressOnRollover(true); config.setMaxEventFileLife(2000L, TimeUnit.SECONDS); config.setCompressionBlockBytes(100); @@ -82,6 +101,44 @@ public class MiNiFiPersistentProvenanceRepositoryTest { System.setProperty("org.slf4j.simpleLogger.log.org.apache.nifi.provenance", "DEBUG"); } +@BeforeClass +public static void findJournalSizes() throws IOException { +// determine header and record size + +final Mapattributes = new HashMap<>(); +final ProvenanceEventBuilder builder = new StandardProvenanceEventRecord.Builder(); +builder.setEventTime(System.currentTimeMillis()); +builder.setEventType(ProvenanceEventType.RECEIVE); +
[4/4] nifi-minifi git commit: MINIFI-255 This closes #84. Update codebase to incorporate NiFi 1.2.0 handling of NARs and required dependencies MINIFI-256 Support Site to Site attaching to an interface
MINIFI-255 This closes #84. Update codebase to incorporate NiFi 1.2.0 handling of NARs and required dependencies MINIFI-256 Support Site to Site attaching to an interface in config Signed-off-by: joewittProject: http://git-wip-us.apache.org/repos/asf/nifi-minifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi-minifi/commit/b5561877 Tree: http://git-wip-us.apache.org/repos/asf/nifi-minifi/tree/b5561877 Diff: http://git-wip-us.apache.org/repos/asf/nifi-minifi/diff/b5561877 Branch: refs/heads/master Commit: b556187701f38c9d1f8232913f2ba9ae64db3956 Parents: b531350 Author: Aldrin Piri Authored: Tue May 9 21:14:48 2017 -0400 Committer: joewitt Committed: Tue May 9 23:16:24 2017 -0400 -- NOTICE |2 + minifi-assembly/pom.xml |4 + .../src/main/assembly/dependencies.xml |2 - .../bootstrap/util/ConfigTransformer.java |3 +- minifi-bootstrap/src/test/resources/config.yml |1 + .../schema/RemoteProcessGroupSchema.java| 15 + .../schema/RemoteProcessGroupSchemaTest.java| 12 + .../init/ConfigurableComponentInitializer.java | 45 + ...ConfigurableComponentInitializerFactory.java | 44 + .../nifi/init/ControllerServiceInitializer.java | 59 + .../apache/nifi/init/ProcessorInitializer.java | 58 + .../org/apache/nifi/init/ReflectionUtils.java | 133 +++ .../nifi/init/ReportingTaskingInitializer.java | 57 + .../apache/nifi/mock/MockComponentLogger.java | 258 + .../nifi/mock/MockConfigurationContext.java | 48 + ...kControllerServiceInitializationContext.java | 68 ++ .../nifi/mock/MockControllerServiceLookup.java | 63 ++ .../apache/nifi/mock/MockNodeTypeProvider.java | 40 + .../apache/nifi/mock/MockProcessContext.java| 116 ++ .../MockProcessorInitializationContext.java | 68 ++ .../MockReportingInitializationContext.java | 83 ++ .../org/apache/nifi/nar/ExtensionManager.java | 445 ++-- .../apache/nifi/nar/InstanceClassLoader.java| 139 +-- .../java/org/apache/nifi/nar/NarBundleUtil.java | 74 ++ .../org/apache/nifi/nar/NarClassLoaders.java| 199 ++-- .../java/org/apache/nifi/nar/NarCloseable.java | 22 +- .../org/apache/nifi/nar/NarManifestEntry.java | 48 + .../nifi/nar/NarThreadContextClassLoader.java | 21 +- .../java/org/apache/nifi/nar/SystemBundle.java | 57 + .../src/main/resources/conf/logback.xml |2 +- .../java/org/apache/nifi/minifi/MiNiFi.java | 28 +- .../MiNiFiPersistentProvenanceRepository.java | 1013 +- ...iNiFiPersistentProvenanceRepositoryTest.java | 638 +-- .../dto/RemoteProcessGroupSchemaFunction.java |1 + .../toolkit/configuration/ConfigMainTest.java |7 +- .../dto/RemoteProcessGroupSchemaTest.java | 16 + .../resources/InvokeHttpMiNiFiTemplateTest.xml |1 + .../resources/InvokeHttpMiNiFiTemplateTest.yml |1 + .../ProcessGroupsAndRemoteProcessGroups.xml |2 + .../ProcessGroupsAndRemoteProcessGroups.yml |2 + .../test/resources/SimpleRPGToLogAttributes.yml |1 + .../src/test/resources/SimpleTailFileToRPG.xml |1 + .../src/test/resources/SimpleTailFileToRPG.yml |1 + pom.xml | 15 +- 44 files changed, 3204 insertions(+), 709 deletions(-) -- http://git-wip-us.apache.org/repos/asf/nifi-minifi/blob/b5561877/NOTICE -- diff --git a/NOTICE b/NOTICE index c1edd0c..6ee6948 100644 --- a/NOTICE +++ b/NOTICE @@ -3,3 +3,5 @@ Copyright 2014-2017 The Apache Software Foundation This product includes software developed at The Apache Software Foundation (http://www.apache.org/). + +This includes derived works from the Apache NiFi (ASLv2) project including numerous source files from the core framework API.ââ http://git-wip-us.apache.org/repos/asf/nifi-minifi/blob/b5561877/minifi-assembly/pom.xml -- diff --git a/minifi-assembly/pom.xml b/minifi-assembly/pom.xml index 1ce48a7..f28ee89 100644 --- a/minifi-assembly/pom.xml +++ b/minifi-assembly/pom.xml @@ -187,6 +187,10 @@ limitations under the License. org.apache.nifi nifi-persistent-provenance-repository + +org.apache.nifi +nifi-distributed-cache-client-service-api + http://git-wip-us.apache.org/repos/asf/nifi-minifi/blob/b5561877/minifi-assembly/src/main/assembly/dependencies.xml -- diff --git a/minifi-assembly/src/main/assembly/dependencies.xml
[2/4] nifi-minifi git commit: MINIFI-255 This closes #84. Update codebase to incorporate NiFi 1.2.0 handling of NARs and required dependencies MINIFI-256 Support Site to Site attaching to an interface
http://git-wip-us.apache.org/repos/asf/nifi-minifi/blob/b5561877/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/MiNiFiPersistentProvenanceRepository.java -- diff --git a/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/MiNiFiPersistentProvenanceRepository.java b/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/MiNiFiPersistentProvenanceRepository.java index 5ce83a6..cba2d45 100644 --- a/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/MiNiFiPersistentProvenanceRepository.java +++ b/minifi-nar-bundles/minifi-provenance-repository-bundle/minifi-persistent-provenance-repository/src/main/java/org/apache/nifi/provenance/MiNiFiPersistentProvenanceRepository.java @@ -16,27 +16,47 @@ */ package org.apache.nifi.provenance; -import org.apache.commons.lang3.StringUtils; +import org.apache.nifi.authorization.AuthorizationResult; +import org.apache.nifi.authorization.AuthorizationResult.Result; import org.apache.nifi.authorization.Authorizer; +import org.apache.nifi.authorization.RequestAction; +import org.apache.nifi.authorization.resource.Authorizable; import org.apache.nifi.authorization.user.NiFiUser; import org.apache.nifi.events.EventReporter; -import org.apache.nifi.processor.DataUnit; import org.apache.nifi.provenance.expiration.ExpirationAction; import org.apache.nifi.provenance.expiration.FileRemovalAction; +import org.apache.nifi.provenance.index.EventIndexWriter; import org.apache.nifi.provenance.lineage.ComputeLineageSubmission; +import org.apache.nifi.provenance.lucene.IndexManager; +import org.apache.nifi.provenance.lucene.IndexingAction; +import org.apache.nifi.provenance.lucene.LuceneUtil; +import org.apache.nifi.provenance.lucene.SimpleIndexManager; +import org.apache.nifi.provenance.lucene.UpdateMinimumEventId; import org.apache.nifi.provenance.search.Query; +import org.apache.nifi.provenance.search.QueryResult; import org.apache.nifi.provenance.search.QuerySubmission; import org.apache.nifi.provenance.search.SearchableField; import org.apache.nifi.provenance.serialization.RecordReader; import org.apache.nifi.provenance.serialization.RecordReaders; import org.apache.nifi.provenance.serialization.RecordWriter; import org.apache.nifi.provenance.serialization.RecordWriters; +import org.apache.nifi.provenance.serialization.StorageSummary; import org.apache.nifi.provenance.toc.TocReader; import org.apache.nifi.provenance.toc.TocUtil; +import org.apache.nifi.provenance.util.NamedThreadFactory; import org.apache.nifi.reporting.Severity; import org.apache.nifi.util.FormatUtils; import org.apache.nifi.util.NiFiProperties; +import org.apache.nifi.util.RingBuffer; +import org.apache.nifi.util.RingBuffer.ForEachEvaluator; import org.apache.nifi.util.StopWatch; +import org.apache.nifi.util.Tuple; +import org.apache.nifi.util.timebuffer.CountSizeEntityAccess; +import org.apache.nifi.util.timebuffer.LongEntityAccess; +import org.apache.nifi.util.timebuffer.TimedBuffer; +import org.apache.nifi.util.timebuffer.TimedCountSize; +import org.apache.nifi.util.timebuffer.TimestampedLong; +import org.apache.nifi.web.ResourceNotFoundException; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -44,10 +64,10 @@ import java.io.EOFException; import java.io.File; import java.io.FileFilter; import java.io.FileNotFoundException; +import java.io.FilenameFilter; import java.io.IOException; import java.nio.file.Files; import java.nio.file.Path; -import java.nio.file.Paths; import java.util.ArrayList; import java.util.Collection; import java.util.Collections; @@ -61,8 +81,15 @@ import java.util.Map; import java.util.Set; import java.util.SortedMap; import java.util.TreeMap; +import java.util.concurrent.BlockingQueue; +import java.util.concurrent.Callable; +import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; +import java.util.concurrent.ExecutionException; +import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; +import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.ThreadFactory; import java.util.concurrent.TimeUnit; @@ -72,25 +99,24 @@ import java.util.concurrent.atomic.AtomicLong; import java.util.concurrent.atomic.AtomicReference; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReadWriteLock; -import java.util.concurrent.locks.ReentrantLock; import java.util.concurrent.locks.ReentrantReadWriteLock; import java.util.regex.Pattern; +import
[jira] [Created] (MINIFI-308) Update logback.conf to reflect new logback version requirements
Joseph Witt created MINIFI-308: -- Summary: Update logback.conf to reflect new logback version requirements Key: MINIFI-308 URL: https://issues.apache.org/jira/browse/MINIFI-308 Project: Apache NiFi MiNiFi Issue Type: Sub-task Components: Build, Core Framework Reporter: Joseph Witt Assignee: Joseph Witt Fix For: 0.2.0 Need the commit to reflect the changes we did in nifi just like https://github.com/apache/nifi/pull/1678/commits/2ec695caf625b8c1c6d3844f0d90e7cc6cd36be4#diff-1fc20c14727b9d39d726a70e5842f9f4 -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Resolved] (MINIFI-300) Update license and notice as needed for Jolt dependencies
[ https://issues.apache.org/jira/browse/MINIFI-300?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aldrin Piri resolved MINIFI-300. Resolution: Not A Problem > Update license and notice as needed for Jolt dependencies > - > > Key: MINIFI-300 > URL: https://issues.apache.org/jira/browse/MINIFI-300 > Project: Apache NiFi MiNiFi > Issue Type: Bug > Components: Documentation >Reporter: Aldrin Piri >Priority: Blocker > Fix For: 0.2.0 > > > Jolt is brought in via the standard bundle and included in our binary > assemblies. We need to capture his information where appropriate in L as it > is currently absent. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (MINIFI-300) Update license and notice as needed for Jolt dependencies
[ https://issues.apache.org/jira/browse/MINIFI-300?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003927#comment-16003927 ] Aldrin Piri commented on MINIFI-300: Looks like this is actually covered from the standpoint of the binary inclusion via https://github.com/apache/nifi-minifi/blob/master/minifi-nar-bundles/minifi-standard-nar/src/main/resources/META-INF/NOTICE#L151 > Update license and notice as needed for Jolt dependencies > - > > Key: MINIFI-300 > URL: https://issues.apache.org/jira/browse/MINIFI-300 > Project: Apache NiFi MiNiFi > Issue Type: Bug > Components: Documentation >Reporter: Aldrin Piri >Priority: Blocker > Fix For: 0.2.0 > > > Jolt is brought in via the standard bundle and included in our binary > assemblies. We need to capture his information where appropriate in L as it > is currently absent. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (MINIFI-255) Upgrade to NiFi 1.2.0 dependencies when released
[ https://issues.apache.org/jira/browse/MINIFI-255?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16003871#comment-16003871 ] ASF GitHub Bot commented on MINIFI-255: --- GitHub user apiri opened a pull request: https://github.com/apache/nifi-minifi/pull/84 MINIFI-255 Update to NiFi 1.2.0 | MINIFI-256 support site to site interface config MINIFI-255 Update codebase to incorporate NiFi 1.2.0 handling of NARs and required dependencies MINIFI-256 Support Site to Site attaching to an interface in config You can merge this pull request into a Git repository by running: $ git pull https://github.com/apiri/nifi-minifi minifi-255-nifi1.2.0-deps Alternatively you can review and apply these changes as the patch at: https://github.com/apache/nifi-minifi/pull/84.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #84 commit 82a9a64acf1267b8a78e6e4f14845a2b9b45ab77 Author: Aldrin PiriDate: 2017-05-10T01:14:48Z MINIFI-255 Update codebase to incorporate NiFi 1.2.0 handling of NARs and required dependencies MINIFI-256 Support Site to Site attaching to an interface in config > Upgrade to NiFi 1.2.0 dependencies when released > > > Key: MINIFI-255 > URL: https://issues.apache.org/jira/browse/MINIFI-255 > Project: Apache NiFi MiNiFi > Issue Type: Task > Components: Core Framework >Reporter: Aldrin Piri >Assignee: Aldrin Piri >Priority: Blocker > Fix For: 0.2.0 > > > At minimum, to solve the build issues around the casing change of jBCrypt but > will also provide the Site to Site configuration for attaching to an > interface for sending. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Updated] (MINIFI-307) Break apart documentation so that it is easier ro follow.
[ https://issues.apache.org/jira/browse/MINIFI-307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Aldrin Piri updated MINIFI-307: --- Component/s: Documentation > Break apart documentation so that it is easier ro follow. > -- > > Key: MINIFI-307 > URL: https://issues.apache.org/jira/browse/MINIFI-307 > Project: Apache NiFi MiNiFi > Issue Type: Task > Components: Documentation >Reporter: marco polo >Priority: Trivial > Labels: docs > > Documentation is all in an uber readme. we should break this up so that it's > easier to follow and more clear on the GH and apache websites. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
nifi git commit: NIFI-3832: Fixed AvroRecordSetWriter validation NPE.
Repository: nifi Updated Branches: refs/heads/master 3af53419a -> 744ecc3d8 NIFI-3832: Fixed AvroRecordSetWriter validation NPE. This closes #1768. Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/744ecc3d Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/744ecc3d Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/744ecc3d Branch: refs/heads/master Commit: 744ecc3d83a203db67cc8e99aa97bf1985e16470 Parents: 3af5341 Author: Koji KawamuraAuthored: Tue May 9 12:13:19 2017 +0900 Committer: Mark Payne Committed: Tue May 9 14:11:43 2017 -0400 -- .../main/java/org/apache/nifi/avro/AvroRecordSetWriter.java | 4 ++-- .../nifi/serialization/SchemaRegistryRecordSetWriter.java | 7 ++- 2 files changed, 8 insertions(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/nifi/blob/744ecc3d/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/AvroRecordSetWriter.java -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/AvroRecordSetWriter.java b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/AvroRecordSetWriter.java index 121d1ec..a4476f9 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/AvroRecordSetWriter.java +++ b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/avro/AvroRecordSetWriter.java @@ -60,7 +60,7 @@ public class AvroRecordSetWriter extends SchemaRegistryRecordSetWriter implement @Override public RecordSetWriter createWriter(final ComponentLog logger, final FlowFile flowFile, final InputStream in) throws IOException { -final String strategyValue = getConfigurationContext().getProperty(SCHEMA_WRITE_STRATEGY).getValue(); +final String strategyValue = getConfigurationContext().getProperty(getSchemaWriteStrategyDescriptor()).getValue(); try { final RecordSchema recordSchema = getSchema(flowFile, in); @@ -130,7 +130,7 @@ public class AvroRecordSetWriter extends SchemaRegistryRecordSetWriter implement @Override protected Set getRequiredSchemaFields(final ValidationContext validationContext) { -final String writeStrategyValue = validationContext.getProperty(SCHEMA_WRITE_STRATEGY).getValue(); +final String writeStrategyValue = validationContext.getProperty(getSchemaWriteStrategyDescriptor()).getValue(); if (writeStrategyValue.equalsIgnoreCase(AVRO_EMBEDDED.getValue())) { return requiredSchemaFields; } http://git-wip-us.apache.org/repos/asf/nifi/blob/744ecc3d/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/serialization/SchemaRegistryRecordSetWriter.java -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/serialization/SchemaRegistryRecordSetWriter.java b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/serialization/SchemaRegistryRecordSetWriter.java index 3c7fd55..36fe605 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/serialization/SchemaRegistryRecordSetWriter.java +++ b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/serialization/SchemaRegistryRecordSetWriter.java @@ -58,7 +58,12 @@ public abstract class SchemaRegistryRecordSetWriter extends SchemaRegistryServic "The FlowFile will be given a set of 3 attributes to describe the schema: 'schema.identifier', 'schema.version', and 'schema.protocol.version'. Note that if " + "the schema for a record does not contain the necessary identifier and version, an Exception will be thrown when attempting to write the data."); -protected static final PropertyDescriptor SCHEMA_WRITE_STRATEGY = new PropertyDescriptor.Builder() +/** + * This constant is just a
[jira] [Updated] (MINIFI-307) Break apart documentation so that it is easier ro follow.
[ https://issues.apache.org/jira/browse/MINIFI-307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] marco polo updated MINIFI-307: -- Labels: docs (was: ) > Break apart documentation so that it is easier ro follow. > -- > > Key: MINIFI-307 > URL: https://issues.apache.org/jira/browse/MINIFI-307 > Project: Apache NiFi MiNiFi > Issue Type: Task >Reporter: marco polo >Priority: Trivial > Labels: docs > > Documentation is all in an uber readme. we should break this up so that it's > easier to follow and more clear on the GH and apache websites. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (MINIFI-307) Break apart documentation so that it is easier ro follow.
marco polo created MINIFI-307: - Summary: Break apart documentation so that it is easier ro follow. Key: MINIFI-307 URL: https://issues.apache.org/jira/browse/MINIFI-307 Project: Apache NiFi MiNiFi Issue Type: Task Reporter: marco polo Priority: Trivial Documentation is all in an uber readme. we should break this up so that it's easier to follow and more clear on the GH and apache websites. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Commented] (MINIFI-304) Test Failures manifested by logger initialization failures.
[ https://issues.apache.org/jira/browse/MINIFI-304?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16002908#comment-16002908 ] ASF GitHub Bot commented on MINIFI-304: --- GitHub user phrocker opened a pull request: https://github.com/apache/nifi-minifi-cpp/pull/96 MINIFI-304: Update testing strategy MINIFI-306: Move Docs and Docker cmake code into a separate module. this will clean-up the end of the file. We will continue to do cleanup but this has a great impact to improve the readability of the root cmake Thank you for submitting a contribution to Apache NiFi - MiNiFi C++. In order to streamline the review of the contribution we ask you to ensure the following steps have been taken: ### For all changes: - [ ] Is there a JIRA ticket associated with this PR? Is it referenced in the commit message? - [ ] Does your PR title start with MINIFI- where is the JIRA number you are trying to resolve? Pay particular attention to the hyphen "-" character. - [ ] Has your PR been rebased against the latest commit within the target branch (typically master)? - [ ] Is your initial contribution a single, squashed commit? ### For code changes: - [ ] If adding new dependencies to the code, are these dependencies licensed in a way that is compatible for inclusion under [ASF 2.0](http://www.apache.org/legal/resolved.html#category-a)? - [ ] If applicable, have you updated the LICENSE file? - [ ] If applicable, have you updated the NOTICE file? ### For documentation related changes: - [ ] Have you ensured that format looks appropriate for the output in which it is rendered? ### Note: Please ensure that once the PR is submitted, you check travis-ci for build issues and submit an update to your PR as soon as possible. You can merge this pull request into a Git repository by running: $ git pull https://github.com/phrocker/nifi-minifi-cpp MINIFI-304 Alternatively you can review and apply these changes as the patch at: https://github.com/apache/nifi-minifi-cpp/pull/96.patch To close this pull request, make a commit to your master/trunk branch with (at least) the following in the commit message: This closes #96 commit d4947cda45ee5eeb204148759121a3919224e017 Author: Marc ParisiDate: 2017-05-08T23:13:00Z MINIFI-304: Update testing strategy MINIFI-306: Move Docs and Docker cmake code into a separate module. this will clean-up the end of the file. We will continue to do cleanup but this has a great impact to improve the readability of the root cmake > Test Failures manifested by logger initialization failures. > > > Key: MINIFI-304 > URL: https://issues.apache.org/jira/browse/MINIFI-304 > Project: Apache NiFi MiNiFi > Issue Type: Bug > Components: C++ >Reporter: marco polo >Assignee: marco polo > > statics within spdlog would not be initialized in time depending on the order > of execution. As a result it is better to use no logging unless necessary. > There are examples which use logging, but unless explicitly needed ( and > captured into strings, for example ) we should instead turn logging off. > Breaking this out into separate executables would be idea. This ticket will > involve editing the cmake file to move tests into a separate file. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Created] (MINIFI-306) Move docs into a separate module.
marco polo created MINIFI-306: - Summary: Move docs into a separate module. Key: MINIFI-306 URL: https://issues.apache.org/jira/browse/MINIFI-306 Project: Apache NiFi MiNiFi Issue Type: Sub-task Reporter: marco polo Assignee: marco polo MINIFI-304 will move tests into a separate cmake module. we can move docs into a separate cmake module to clean up the cmake file a bit. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
[jira] [Updated] (MINIFI-304) Test Failures manifested by logger initialization failures.
[ https://issues.apache.org/jira/browse/MINIFI-304?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] marco polo updated MINIFI-304: -- Description: statics within spdlog would not be initialized in time depending on the order of execution. As a result it is better to use no logging unless necessary. There are examples which use logging, but unless explicitly needed ( and captured into strings, for example ) we should instead turn logging off. Breaking this out into separate executables would be idea. This ticket will involve editing the cmake file to move tests into a separate file. was: statics within spdlog would not be initialized in time depending on the order of execution. As a result it is better to use no logging unless necessary. There are examples which use logging, but unless explicitly needed ( and captured into strings, for example ) we should instead turn logging off. Breaking this out into separate executables would be idea. > Test Failures manifested by logger initialization failures. > > > Key: MINIFI-304 > URL: https://issues.apache.org/jira/browse/MINIFI-304 > Project: Apache NiFi MiNiFi > Issue Type: Bug > Components: C++ >Reporter: marco polo >Assignee: marco polo > > statics within spdlog would not be initialized in time depending on the order > of execution. As a result it is better to use no logging unless necessary. > There are examples which use logging, but unless explicitly needed ( and > captured into strings, for example ) we should instead turn logging off. > Breaking this out into separate executables would be idea. This ticket will > involve editing the cmake file to move tests into a separate file. -- This message was sent by Atlassian JIRA (v6.3.15#6346)
svn commit: r1794596 [11/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-kafka-0-9-nar/1.2.0/org.apache.nifi.processors.kafka.pubsub.PublishKafka/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-kafka-0-9-nar/1.2.0/org.apache.nifi.processors.kafka.pubsub.PublishKafka/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-kafka-0-9-nar/1.2.0/org.apache.nifi.processors.kafka.pubsub.PublishKafka/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-kafka-0-9-nar/1.2.0/org.apache.nifi.processors.kafka.pubsub.PublishKafka/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +PublishKafkawindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }PublishKafkaDescription: Sends the contents of a FlowFile as a message to Apache Kafka using the Kafka 0.9.x Producer. The messages to send may be individual FlowFiles or may be delimited, using a user-specified delimiter, such as a new-line. Please note there are cases where the publisher can get into an indefinite stuck state. We are closely monitoring how this evolves in the Kafka community and will take advantage of those fixes as soon as we can. In the mean time it is possible to enter states where the only resolution will be to restart the JVM NiFi runs on. The complementa ry NiFi processor for fetching messages is ConsumeKafka.Additional Details...Tags: Apache, Kafka, Put, Send, Message, PubSub, 0.9.xProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescriptionKafka Brokerslocalhost:9092A comma-separated list of known Kafka Brokers in the format host:portSupports Expression Language: trueSecurity ProtocolPLAINTEXTPLAINTEXT SSL SASL_PLAINTEXT SASL_SSL Protocol used to communicate with brokers. Corresponds to Kafka's 'security.protocol' property.Kerberos Service NameThe Kerberos principal name that Kafka runs as. This can be defined either in Kafka's JAAS config or in Kafka's config. Corresponds to Kafka's 'security.protocol' property.It is ignored unless one of the SASL options of the ;Security Protocol are selected.SSL Context ServiceController Service API: SSLContextServiceImplementation:StandardSSLContextServiceSpecifies the SSL Context Service to use for communicating with Kafka.Topic NameThe name of the Kafka Topic to publish to.Supports Expression Language: trueDelivery Guarantee0Best Effort Guarantee Single Node Delivery Guarantee Replicated Delivery Specifies the requirement for guaranteeing that a message is sent to Kafka. Corresponds to Kafka's 'acks' property.Kafka KeyThe Key to use for the Message. If not specified, the flow file attribute 'kafka.key' is used as the message key, if it is present and we're not demarcating.Supports Expression Language: trueKey Attribute Encodingutf-8UTF-8 Encoded Hex Encoded FlowFiles that are emitted have an attribute named 'kafka.key'. This property dictates how the value of the attribute should be encoded.Message DemarcatorSpecifies the string (interpreted as UTF-8) to use for demarcating multiple messages within a single FlowFile. If not specified, the entire content of the FlowFile will be used as a single message. If specified, the contents of the FlowFile will be split on this delimi ter and each section sent as a separate Kafka message. To enter special character such as 'new line' use CTRL+Enter or Shift+Enter, depending on your OS.Supports Expression Language: trueMax Request Size1 MBThe maximum size of a request in bytes. Corresponds to Kafka's 'max.request.size' property and defaults to 1 MB (1048576).Acknowledgment Wait Time5 secsAfter sending a message to Kafka, this indicates the amount of time that we are willing to wait for a response from Kafka. If Kafka does not acknowledge the message within this time period, the FlowFile will be routed to 'failure'.Max Metadata Wait Time5 secThe amount of time publisher will wait to obtain metadata or wait for the buffer to flush during the 'send' call before failing the entire 'send' call. Corresponds to Kafka's 'max.block.ms' propertySupports Expression Language: truePartitioner classorg.apache.kafka.clients.producer.internals.DefaultPartitionerRoundRobinPartitioner DefaultPartitioner Specifies which class to use to compute a partition id for a message. Corresponds to Kafka's 'partitioner.class' property.Compression Typenonenonegzipsnappylz4This parameter allows you to specify the compression codec for all data generated by this producer.Dynamic Properties: Dynamic Properties allow the user to specify both the name
svn commit: r1794596 [31/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/html/user-guide.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/user-guide.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/html/user-guide.html (added) +++ nifi/site/trunk/docs/nifi-docs/html/user-guide.html Tue May 9 15:27:39 2017 @@ -0,0 +1,3484 @@ + + + + + + + + +Apache NiFi User Guide + +/* Asciidoctor default stylesheet | MIT License | http://asciidoctor.org */ +/* Copyright (C) 2012-2015 Dan Allen, Ryan Waldron and the Asciidoctor Project + +Permission is hereby granted, free of charge, to any person obtaining a copy +of this software and associated documentation files (the "Software"), to deal +in the Software without restriction, including without limitation the rights +to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +copies of the Software, and to permit persons to whom the Software is +furnished to do so, subject to the following conditions: + +The above copyright notice and this permission notice shall be included in +all copies or substantial portions of the Software. + +THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +THE SOFTWARE. */ +/* Remove the comments around the @import statement below when using this as a custom stylesheet */ +@import "https://fonts.googleapis.com/css?family=Open+Sans:300,300italic,400,400italic,600,600italic%7CNoto+Serif:400,400italic,700,700italic%7CDroid+Sans+Mono:400"; +article,aside,details,figcaption,figure,footer,header,hgroup,main,nav,section,summary{display:block} +audio,canvas,video{display:inline-block} +audio:not([controls]){display:none;height:0} +[hidden],template{display:none} +script{display:none!important} +html{font-family:sans-serif;-ms-text-size-adjust:100%;-webkit-text-size-adjust:100%} +body{margin:0} +a{background:transparent} +a:focus{outline:thin dotted} +a:active,a:hover{outline:0} +h1{font-size:2em;margin:.67em 0} +abbr[title]{border-bottom:1px dotted} +b,strong{font-weight:bold} +dfn{font-style:italic} +hr{-moz-box-sizing:content-box;box-sizing:content-box;height:0} +mark{background:#ff0;color:#000} +code,kbd,pre,samp{font-family:monospace;font-size:1em} +pre{white-space:pre-wrap} +q{quotes:"\201C" "\201D" "\2018" "\2019"} +small{font-size:80%} +sub,sup{font-size:75%;line-height:0;position:relative;vertical-align:baseline} +sup{top:-.5em} +sub{bottom:-.25em} +img{border:0} +svg:not(:root){overflow:hidden} +figure{margin:0} +fieldset{border:1px solid silver;margin:0 2px;padding:.35em .625em .75em} +legend{border:0;padding:0} +button,input,select,textarea{font-family:inherit;font-size:100%;margin:0} +button,input{line-height:normal} +button,select{text-transform:none} +button,html input[type="button"],input[type="reset"],input[type="submit"]{-webkit-appearance:button;cursor:pointer} +button[disabled],html input[disabled]{cursor:default} +input[type="checkbox"],input[type="radio"]{box-sizing:border-box;padding:0} +input[type="search"]{-webkit-appearance:textfield;-moz-box-sizing:content-box;-webkit-box-sizing:content-box;box-sizing:content-box} +input[type="search"]::-webkit-search-cancel-button,input[type="search"]::-webkit-search-decoration{-webkit-appearance:none} +button::-moz-focus-inner,input::-moz-focus-inner{border:0;padding:0} +textarea{overflow:auto;vertical-align:top} +table{border-collapse:collapse;border-spacing:0} +*,*:before,*:after{-moz-box-sizing:border-box;-webkit-box-sizing:border-box;box-sizing:border-box} +html,body{font-size:100%} +body{background:#fff;color:rgba(0,0,0,.8);padding:0;margin:0;font-family:"Noto Serif","DejaVu Serif",serif;font-weight:400;font-style:normal;line-height:1;position:relative;cursor:auto} +a:hover{cursor:pointer} +img,object,embed{max-width:100%;height:auto} +object,embed{height:100%} +img{-ms-interpolation-mode:bicubic} +#map_canvas img,#map_canvas embed,#map_canvas object,.map_canvas img,.map_canvas embed,.map_canvas object{max-width:none!important} +.left{float:left!important} +.right{float:right!important} +.text-left{text-align:left!important} +.text-right{text-align:right!important} +.text-center{text-align:center!important} +.text-justify{text-align:justify!important} +.hide{display:none} +.antialiased,body{-webkit-font-smoothing:antialiased}
svn commit: r1794596 [32/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/images/bgBannerFoot.png URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/images/bgBannerFoot.png?rev=1794596=auto == Binary file - no diff available. Propchange: nifi/site/trunk/docs/nifi-docs/images/bgBannerFoot.png -- svn:mime-type = application/octet-stream Added: nifi/site/trunk/docs/nifi-docs/images/bgHeader.png URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/images/bgHeader.png?rev=1794596=auto == Binary file - no diff available. Propchange: nifi/site/trunk/docs/nifi-docs/images/bgHeader.png -- svn:mime-type = application/octet-stream
svn commit: r1794596 [36/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi/assets/jquery/dist/jquery.min.js URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi/assets/jquery/dist/jquery.min.js?rev=1794596=auto == --- nifi/site/trunk/docs/nifi/assets/jquery/dist/jquery.min.js (added) +++ nifi/site/trunk/docs/nifi/assets/jquery/dist/jquery.min.js Tue May 9 15:27:39 2017 @@ -0,0 +1,4 @@ +/*! jQuery v3.1.1 | (c) jQuery Foundation | jquery.org/license */ +!function(a,b){"use strict";"object"==typeof module&&"object"==typeof module.exports?module.exports=a.document?b(a,!0):function(a){if(!a.document)throw new Error("jQuery requires a window with a document");return b(a)}:b(a)}("undefined"!=typeof window?window:this,function(a,b){"use strict";var c=[],d=a.document,e=Object.getPrototypeOf,f=c.slice,g=c.concat,h=c.push,i=c.indexOf,j={},k=j.toString,l=j.hasOwnProperty,m=l.toString,n=m.call(Object),o={};function p(a,b){b=b||d;var c=b.createElement("script");c.text=a,b.head.appendChild(c).parentNode.removeChild(c)}var q="3.1.1",r=function(a,b){return new r.fn.init(a,b)},s=/^[\s\uFEFF\xA0]+|[\s\uFEFF\xA0]+$/g,t=/^-ms-/,u=/-([a-z])/g,v=function(a,b){return b.toUpperCase()};r.fn=r.prototype={jquery:q,constructor:r,length:0,toArray:function(){return f.call(this)},get:function(a){return null==a?f.call(this):a<0?this[a+this.length]:this[a]},pushStack:function(a){var b=r.merge(this.constructor(),a);return b.prevObject=this,b},each:function(a){retu rn r.each(this,a)},map:function(a){return this.pushStack(r.map(this,function(b,c){return a.call(b,c,b)}))},slice:function(){return this.pushStack(f.apply(this,arguments))},first:function(){return this.eq(0)},last:function(){return this.eq(-1)},eq:function(a){var b=this.length,c=+a+(a<0?b:0);return this.pushStack(c>=0&0& in a)}var x=function(a){var b,c,d,e,f,g,h,i,j,k,l,m,n,o,p,q,r,s,t,u="sizzle"+1*new Date,v=a.document,w=0,x=0,y=ha(),z=ha(),A=ha(),B=function(a,b){return a===b&&(l=!0),0},C={}.hasOwnProperty,D=[],E=D.pop,F=D.push,G=D.push,H=D.slice,I=function(a,b){for(var c=0,d=a.length;c
svn commit: r1794596 [24/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/html/administration-guide.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/administration-guide.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/html/administration-guide.html (added) +++ nifi/site/trunk/docs/nifi-docs/html/administration-guide.html Tue May 9 15:27:39 2017 @@ -0,0 +1,5747 @@ + + + + + + + + +NiFi System Administrators Guide + +/* Asciidoctor default stylesheet | MIT License | http://asciidoctor.org */ +/* Copyright (C) 2012-2015 Dan Allen, Ryan Waldron and the Asciidoctor Project + +Permission is hereby granted, free of charge, to any person obtaining a copy +of this software and associated documentation files (the "Software"), to deal +in the Software without restriction, including without limitation the rights +to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +copies of the Software, and to permit persons to whom the Software is +furnished to do so, subject to the following conditions: + +The above copyright notice and this permission notice shall be included in +all copies or substantial portions of the Software. + +THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +THE SOFTWARE. */ +/* Remove the comments around the @import statement below when using this as a custom stylesheet */ +@import "https://fonts.googleapis.com/css?family=Open+Sans:300,300italic,400,400italic,600,600italic%7CNoto+Serif:400,400italic,700,700italic%7CDroid+Sans+Mono:400"; +article,aside,details,figcaption,figure,footer,header,hgroup,main,nav,section,summary{display:block} +audio,canvas,video{display:inline-block} +audio:not([controls]){display:none;height:0} +[hidden],template{display:none} +script{display:none!important} +html{font-family:sans-serif;-ms-text-size-adjust:100%;-webkit-text-size-adjust:100%} +body{margin:0} +a{background:transparent} +a:focus{outline:thin dotted} +a:active,a:hover{outline:0} +h1{font-size:2em;margin:.67em 0} +abbr[title]{border-bottom:1px dotted} +b,strong{font-weight:bold} +dfn{font-style:italic} +hr{-moz-box-sizing:content-box;box-sizing:content-box;height:0} +mark{background:#ff0;color:#000} +code,kbd,pre,samp{font-family:monospace;font-size:1em} +pre{white-space:pre-wrap} +q{quotes:"\201C" "\201D" "\2018" "\2019"} +small{font-size:80%} +sub,sup{font-size:75%;line-height:0;position:relative;vertical-align:baseline} +sup{top:-.5em} +sub{bottom:-.25em} +img{border:0} +svg:not(:root){overflow:hidden} +figure{margin:0} +fieldset{border:1px solid silver;margin:0 2px;padding:.35em .625em .75em} +legend{border:0;padding:0} +button,input,select,textarea{font-family:inherit;font-size:100%;margin:0} +button,input{line-height:normal} +button,select{text-transform:none} +button,html input[type="button"],input[type="reset"],input[type="submit"]{-webkit-appearance:button;cursor:pointer} +button[disabled],html input[disabled]{cursor:default} +input[type="checkbox"],input[type="radio"]{box-sizing:border-box;padding:0} +input[type="search"]{-webkit-appearance:textfield;-moz-box-sizing:content-box;-webkit-box-sizing:content-box;box-sizing:content-box} +input[type="search"]::-webkit-search-cancel-button,input[type="search"]::-webkit-search-decoration{-webkit-appearance:none} +button::-moz-focus-inner,input::-moz-focus-inner{border:0;padding:0} +textarea{overflow:auto;vertical-align:top} +table{border-collapse:collapse;border-spacing:0} +*,*:before,*:after{-moz-box-sizing:border-box;-webkit-box-sizing:border-box;box-sizing:border-box} +html,body{font-size:100%} +body{background:#fff;color:rgba(0,0,0,.8);padding:0;margin:0;font-family:"Noto Serif","DejaVu Serif",serif;font-weight:400;font-style:normal;line-height:1;position:relative;cursor:auto} +a:hover{cursor:pointer} +img,object,embed{max-width:100%;height:auto} +object,embed{height:100%} +img{-ms-interpolation-mode:bicubic} +#map_canvas img,#map_canvas embed,#map_canvas object,.map_canvas img,.map_canvas embed,.map_canvas object{max-width:none!important} +.left{float:left!important} +.right{float:right!important} +.text-left{text-align:left!important} +.text-right{text-align:right!important} +.text-center{text-align:center!important} +.text-justify{text-align:justify!important} +.hide{display:none}
svn commit: r1794596 [34/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/js/application.js URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/js/application.js?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/js/application.js (added) +++ nifi/site/trunk/docs/nifi-docs/js/application.js Tue May 9 15:27:39 2017 @@ -0,0 +1,400 @@ +/* + * 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. + */ + +/* global top */ + +$(document).ready(function () { + +var isUndefined = function (obj) { +return typeof obj === 'undefined'; +}; + +var isNull = function (obj) { +return obj === null; +}; + +var isDefinedAndNotNull = function (obj) { +return !isUndefined(obj) && !isNull(obj); +}; + +/** + * Get the filter text. + * + * @returns {unresolved} + */ +var getFilterText = function () { +var filter = ''; +var ruleFilter = $('#component-filter'); +if (!ruleFilter.hasClass('component-filter-list')) { +filter = ruleFilter.val(); +} +return filter; +}; + +var applyComponentFilter = function (componentContainer) { +var matchingComponents = 0; +var componentLinks = $(componentContainer).find('a.component-link, a.document-link'); + +if (componentLinks.length === 0) { +return matchingComponents; +} + +// get the filter text +var filter = getFilterText(); +if (filter !== '') { +var filterExp = new RegExp(filter, 'i'); + +// update the displayed rule count +$.each(componentLinks, function (_, componentLink) { +var a = $(componentLink); +var li = a.closest('li.component-item'); + +// get the rule text for matching +var componentName = a.text(); + +// see if any of the text from this rule matches +var componentMatches = componentName.search(filterExp) >= 0; + +// handle whether the rule matches +if (componentMatches === true) { +li.show(); +matchingComponents++; +} else { +// hide the rule +li.hide(); +} +}); +} else { +// ensure every rule is visible +componentLinks.closest('li.component-item').show(); + +// set the number of displayed rules +matchingComponents = componentLinks.length; +} + +// show whether there are status if appropriate +var noMatching = componentContainer.find('span.no-matching'); +if (matchingComponents === 0) { +noMatching.show(); +} else { +noMatching.hide(); +} + +return matchingComponents; +}; + +var applyFilter = function () { +var matchingGeneral = applyComponentFilter($('#general-links')); +var matchingProcessors = applyComponentFilter($('#processor-links')); +var matchingControllerServices = applyComponentFilter($('#controller-service-links')); +var matchingReportingTasks = applyComponentFilter($('#reporting-task-links')); +var matchingDeveloper = applyComponentFilter($('#developer-links')); + +// update the rule count +$('#displayed-components').text(matchingGeneral + matchingProcessors + matchingControllerServices + matchingReportingTasks + matchingDeveloper); +}; + +var selectComponent = function (selectedExtension, selectedBundleGroup, selectedBundleArtifact, selectedArtifactVersion) { +var componentLinks = $('a.component-link'); + +// consider each link +$.each(componentLinks, function () { +var componentLink = $(this); +var item = componentLink.closest('li.component-item'); +var extension = item.find('span.extension-class').text(); +var group = item.find('span.bundle-group').text(); +var artifact = item.find('span.bundle-artifact').text(); +var version = item.find('span.bundle-version').text(); + +if
svn commit: r1794596 [10/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-kafka-0-10-nar/1.2.0/org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_0_10/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-kafka-0-10-nar/1.2.0/org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_0_10/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-kafka-0-10-nar/1.2.0/org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_0_10/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-kafka-0-10-nar/1.2.0/org.apache.nifi.processors.kafka.pubsub.ConsumeKafka_0_10/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +ConsumeKafka_0_10window.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }ConsumeKafka_0_10Description: Consumes messages from Apache Kafka specifically built against the Kafka 0.10.x Consumer API. Please note there are cases where the publisher can get into an indefinite stuck state. We are closely monitoring how this evolves in the Kafka community and will take advantage of those fixes as soon as we can. In the meantime it is possible to enter states where the only resolution will be to restart the JVM NiFi runs on. The complementary NiFi processor for sending messages is PublishKafka_0_10.Additional Deta ils...Tags: Kafka, Get, Ingest, Ingress, Topic, PubSub, Consume, 0.10.xProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescriptionKafka Brokerslocalhost:9092A comma-separated list of known Kafka Brokers in the format host:portSupports Expression Language: trueSecurity ProtocolPLAINTEXTPLAINTEXT SSL SASL_PLAINTEXT SASL_SSL Protocol used to communicate with brokers. Corresponds to Kafka's 'security.protocol' property.Kerberos Service NameThe Kerberos principal name that Kafka runs as. This can be defined either in Kafka's JAAS config or in Kafka's config. Corresponds to Kafka's 'security.protocol' property.It is ignored unless one of the SASL options of the Security Protocol are selected.Kerberos PrincipalThe Kerberos principal that will be used to connect to brokers. If not set, it is expected to set a JAAS configuration file in the JVM properties defined in the bootstrap.conf file. This principal will be set into 'sasl.jaas.config' Kafka's property.Kerberos KeytabThe Kerberos keytab that will be used to connect to brokers. If not set, it is expected to set a JAAS configuration file in the JVM properties defined in the bootstrap.conf file. This principal will be set into 'sasl.jaas.config' Kafka's property.SSL Context ServiceController Service API: SSLContextServiceImplementation:StandardSSLContextServiceSpecifies the SSL Context Service to use for communicating with Kafka.Topic Name(s)The name of the Kafka Topic(s) to pull from. More than one can be supplied if comma separated.Supports Expression Language: trueTopic Name Formatnamesnames pattern Specifies whe ther the Topic(s) provided are a comma separated list of names or a single regular expressionGroup IDA Group ID is used to identify consumers that are within the same consumer group. Corresponds to Kafka's 'group.id' property.Offset Resetlatestearliest latest none Allows you to manage the condition when there is no initial offset in Kafka or if the current offset does not exist any more on the server (e.g. because that data has been deleted). Corresponds to Kafka's 'auto.offset.reset' property.Key Attribute Encodingutf-8UTF-8 Encoded Hex Encoded FlowFiles that are emitted have an attribute named 'kafka.key'. This property dictates how the value of the attribute should be encoded.Message DemarcatorSince KafkaConsumer receives messages in batches, you have an option to output FlowFiles which contains all Kafka messages in a single batch for a given topic and partition and this property allows you to provide a string (interpreted as UTF-8) to use for demarcating apart multiple Kafka messages. This is an optional property and if not provided each Kafka message received will result in a single FlowFile which time it is triggered. To enter special character such as 'new line' use CTRL+Enter or Shift+Enter depending on the OSSupports Expression Language: trueMax Poll Records1Specifies the maximum number of records Kafka should return in a single poll.Max Uncommitted Time1 secsSpecifies the maximum amount of time allowed to pass before offsets must be committed. This value impacts how often offsets will be committed. Committing offsets less often increases throughput but also increases the window of potential
svn commit: r1794596 [16/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ConvertRecord/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ConvertRecord/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ConvertRecord/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ConvertRecord/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +ConvertRecordwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }ConvertRecordDescription: Converts records from one data format to another using configured Record Reader and Record Write Controller Services. The Reader and Writer must be configured with "matching" schemas. By this, we mean the schemas must have the same field names. The types of the fields do not have to be the same if a field value can be coerced from one type to another. For instance, if the input schema has a field named "balance" of type double, the output schema can have a field named "balance" with a type of string, double, or float. If any field is present in the input that is not present in the output, the field will be left out of the output. If any field is specified in the output schema but is not present in the input data/schema, then the field will not be present in the output or will have a null value, depending on the writer.Tags: convert, generic, schema, json, csv, avro, log, logs, freeform, textProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values.NameDefault ValueAllowable ValuesDescriptionRecord ReaderController Service API: RecordReaderFactoryImplementations: JsonTreeReaderScriptedReaderCSVReaderAvroReaderGrokReaderJsonPathReaderSpecifies the Controller Service to use for reading incoming dataRecord WriterController Service API: RecordSetWriterFactoryImplementations: ScriptedRecordSetWriterFreeFormTextRecordSetWriterAvroRecordSetWriterJsonRecordSetWriterCSVRecordSetWriterSpecifies the Controller Service to use for writing out the recordsRelationships: NameDescriptionsuccessFlowFiles that are successfully transformed will b e routed to this relationshipfailureIf a FlowFile cannot be transformed from the configured input format to the configured output format, the unchanged FlowFile will be routed to this relationshipReads Attributes: None specified.Writes Attributes: NameDescriptionmime.typeSets the mime.type attribute to the MIME Type specified by the Record Writerrecord.countThe number of records in the FlowFileState management: This component does not store state.Restricted: This component is not restricted. \ No newline at end of file Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.DebugFlow/additionalDetails.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.DebugFlow/additionalDetails.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.DebugFlow/additionalDetails.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.DebugFlow/additionalDetails.html Tue May 9 15:27:39 2017 @@ -0,0 +1,48 @@ + + + + + +DebugFlow + + + + + + +When triggered, the processor loops through the appropriate response list (based on whether or not it +received a FlowFile). A response is produced the configured number of times for each pass through its +response list, as long as the processor is running. + +Triggered by a FlowFile, the processor can produce the following responses. + +transfer FlowFile to success relationship. +transfer FlowFile to failure relationship. +rollback the FlowFile without penalty. +rollback the FlowFile and yield the context. +rollback the FlowFile with penalty. +throw an exception. + + +Triggered without a FlowFile, the processor can produce the following responses. + +do nothing and return. +throw an
svn commit: r1794596 [21/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.PutSQL/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.PutSQL/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.PutSQL/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.PutSQL/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +PutSQLwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }PutSQLDescription: Executes a SQL UPDATE or INSERT command. The content of an incoming FlowFile is expected to be the SQL command to execute. The SQL command may use the ? to escape parameters. In this case, the parameters to use must exist as FlowFile attributes with the naming convention sql.args.N.type and sql.args.N.value, where N is a positive integer. The sql.args.N.type is expected to be a number indicating the JDBC Type. The content of the FlowFile is expected to be in UTF-8 format.Tags: sql, put, rdbms, database, update, insert, relationalProperties: In the list below, the names of required properties appear in >bold. Any other properties (not in bold) are considered >optional. The table also indicates any default values.id="properties">NameDefault ValueAllowable >ValuesDescriptionJDBC Connection >Poolid="allowable-values">Controller Service API: >DBCPServiceImplementations: href="../../../nifi-hive-nar/1.2.0/org.apache.nifi.dbcp.hive.HiveConnectionPool/index.html">HiveConnectionPool >href="../../../nifi-dbcp-service-nar/1.2.0/org.apache.nifi.dbcp.DBCPConnectionPool/index.html">DBCPConnectionPool id="description">Specifies the JDBC Connection Pool to use in order to >convert the JSON message to a SQL statement. The Connection Pool is necessary >in order to determine the appropriate database column types.Support Fragmented Transactionsid="default-value">trueid="allowable-values">truefalseid="description">If true, when a FlowFile is consumed by this Processor, the >Processor will first check the fragment.identifier and fragment.count >attributes of that FlowFile. If the fragment.count value is greater than 1, >the Processor will not process any FlowFile with that fragment.identifier >until all are available; at that point, it will process all FlowFiles with >that fragment.identifier as a single transaction, in the order specified by >the FlowFiles' fragment.index attributes. This Provides atomicity of those >SQL statements. If this value is false, these attributes will be ignored and >the updates will occur independent of one another.id="name">Transaction Timeoutid="allowable-values">If the Support Fragmented >Transactions property is se t to true, specifies how long to wait for all FlowFiles for a particular fragment.identifier attribute to arrive before just transferring all of the FlowFiles with that identifier to the 'failure' relationshipBatch Size100The preferred number of FlowFiles to put to the database in a single transactionObtain Generated KeysfalsetruefalseIf true, any key that is automatically generated by the database will be added to the FlowFile that generated it using the sql.generate.key attribute. This may result in slightly slower performance and is not supported by all databases.Rollback On Failurefalsetruefalse Specify how to handle error. By default (false), if an error occurs while processing a FlowFile, the FlowFile will be routed to 'failure' or 'retry' relationship based on error type, and processor can continue with next FlowFile. Instead, you may want to rollback currently processed FlowFiles and stop further processing immediately. In that case, you can do so by enabling this 'Rollback On Failure' property. If enabled, failed FlowFiles will stay in the input relationship without penalizing it and being processed repeatedly until it gets processed successfully or removed by other means. It is important to set adequate 'Yield Duration' to avoid retrying too frequently.Relationships: NameDescriptionretryA FlowFile is routed to this relationship if the database cannot be updated but attempting the operation again may succeedsuccess A FlowFile is routed to this relationship after the database is successfully updatedfailureA FlowFile is routed to this relationship if the database cannot be updated and retrying the operation will also fail, such as an invalid query or an integrity constraint violationReads Attributes: NameDescriptionfragment.identifierIf the Support Fragment Transactions property is true, this attribute is used to determine whether or not two
svn commit: r1794596 [19/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ListDatabaseTables/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ListDatabaseTables/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ListDatabaseTables/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ListDatabaseTables/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +ListDatabaseTableswindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }ListDatabaseTablesDescription: Generates a set of flow files, each containing attributes corresponding to metadata about a table from a database connection. Once metadata about a table has been fetched, it will not be fetched again until the Refresh Interval (if set) has elapsed, or until state has been manually cleared.Tags: sql, list, jdbc, table, databaseProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any defa ult values.NameDefault ValueAllowable ValuesDescriptionDatabase Connection Pooling ServiceController Service API: DBCPServiceImplementations: HiveConnectionPoolDBCPConnectionPoolThe Controller Service that is used to obtain connection to databaseCatalogThe name of a catalog from which to list database tables. The name must match the catalog name as it is stored in the database. If the property is not set, the catalog name will not be used to narrow the search for tables. If the property is set to an empty string, tables without a catalog will be listed.Schema PatternA pattern for matching schemas in the database. Within a pattern, "%" means match any substring of 0 or more characters, and "_" means match any one character. The pattern must match the schema name as it is stored in the database. If the property is not set, the schema name will not be used to narrow the search for tables. If the property is set to an empty string, tables without a schema will be listed.Table Name PatternA pattern for matching tables in the database. Within a pattern, "%" means match any substring of 0 or more characters, and "_" means match any one character. The pattern must match the table name as it is sto red in the database. If the property is not set, all tables will be retrieved.Table TypesTABLEA comma-separated list of table types to include. For example, some databases support TABLE and VIEW types. If the property is not set, tables of all types will be returned.Include CountfalsetruefalseWhether to include the table's row count as a flow file attribute. This affects performance as a database query will be generated for each table in the retrieved list.Refresh Interval0 secThe amount of time to elapse before resetting the processor state, thereby causing all current tables to be listed. During this interval, the processor may continue to run, but tables that have already been listed will not be re-listed. However new/added tables will be listed as the processor runs. A value of zero means the state will never be automatically reset, the user must Clear State manually.Relationships: NameDescriptionsuccessAll FlowFiles that are received are routed to successReads Attributes: None specified.Writes Attributes: NameDescriptiondb.table.nameContains the name of a database table from the connectiondb.table.catalogContains the name of the catalog to which the table belongs (may be null)db.table.schemaContains the name of the schema to which the table belongs (may be null)db.table.fullnameCo ntains the fully-qualifed table name (possibly including catalog, schema, etc.)db.table.typeContains the type of the database table from the connection. Typical types are "TABLE", "VIEW", "SYSTEM TABLE", "GLOBAL TEMPORARY", "LOCAL TEMPORARY", "ALIAS", "SYNONYM"db.table.remarksContains the name of a database table from the connectiondb.table.countContains the number of rows in the tableState management: ScopeDescriptionCLUSTERAfter performing a listing of tables, the timestamp of the query is stored. This allows the Processor to not re-list tables the next time that the Processor is run. Specifying the refresh interval in the processor properties will indicate that when the processor detects the interval has elapsed, the state will be reset and tables will be re-listed as a result. This processor is meant to be ru n on the primary node only.Restricted: This component is not restricted. \ No newline at end of file Added:
svn commit: r1794596 [28/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/html/images/CopyOnWrite.png URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/images/CopyOnWrite.png?rev=1794596=auto == Binary file - no diff available. Propchange: nifi/site/trunk/docs/nifi-docs/html/images/CopyOnWrite.png -- svn:mime-type = application/octet-stream Added: nifi/site/trunk/docs/nifi-docs/html/images/DataIngress.png URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/images/DataIngress.png?rev=1794596=auto == Binary file - no diff available. Propchange: nifi/site/trunk/docs/nifi-docs/html/images/DataIngress.png -- svn:mime-type = application/octet-stream Added: nifi/site/trunk/docs/nifi-docs/html/images/Funnels.png URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/images/Funnels.png?rev=1794596=auto == Binary file - no diff available. Propchange: nifi/site/trunk/docs/nifi-docs/html/images/Funnels.png -- svn:mime-type = application/octet-stream Added: nifi/site/trunk/docs/nifi-docs/html/images/PassByReference.png URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/images/PassByReference.png?rev=1794596=auto == Binary file - no diff available. Propchange: nifi/site/trunk/docs/nifi-docs/html/images/PassByReference.png -- svn:mime-type = application/octet-stream Added: nifi/site/trunk/docs/nifi-docs/html/images/UpdatingAttributes.png URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/images/UpdatingAttributes.png?rev=1794596=auto == Binary file - no diff available. Propchange: nifi/site/trunk/docs/nifi-docs/html/images/UpdatingAttributes.png -- svn:mime-type = application/octet-stream Added: nifi/site/trunk/docs/nifi-docs/html/images/WebCrawler.png URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/images/WebCrawler.png?rev=1794596=auto == Binary file - no diff available. Propchange: nifi/site/trunk/docs/nifi-docs/html/images/WebCrawler.png -- svn:mime-type = application/octet-stream Added: nifi/site/trunk/docs/nifi-docs/html/images/access-policy-config-start.png URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/images/access-policy-config-start.png?rev=1794596=auto == Binary file - no diff available. Propchange: nifi/site/trunk/docs/nifi-docs/html/images/access-policy-config-start.png -- svn:mime-type = application/octet-stream Added: nifi/site/trunk/docs/nifi-docs/html/images/add-controller-service-window.png URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/images/add-controller-service-window.png?rev=1794596=auto == Binary file - no diff available. Propchange: nifi/site/trunk/docs/nifi-docs/html/images/add-controller-service-window.png -- svn:mime-type = application/octet-stream Added: nifi/site/trunk/docs/nifi-docs/html/images/add-processor-with-tag-cloud.png URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/images/add-processor-with-tag-cloud.png?rev=1794596=auto == Binary file - no diff available. Propchange: nifi/site/trunk/docs/nifi-docs/html/images/add-processor-with-tag-cloud.png -- svn:mime-type = application/octet-stream Added: nifi/site/trunk/docs/nifi-docs/html/images/add-processor.png URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/images/add-processor.png?rev=1794596=auto == Binary file - no diff available. Propchange: nifi/site/trunk/docs/nifi-docs/html/images/add-processor.png --
svn commit: r1794596 [7/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compon
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-flume-nar/1.2.0/org.apache.nifi.processors.flume.ExecuteFlumeSink/additionalDetails.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-flume-nar/1.2.0/org.apache.nifi.processors.flume.ExecuteFlumeSink/additionalDetails.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-flume-nar/1.2.0/org.apache.nifi.processors.flume.ExecuteFlumeSink/additionalDetails.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-flume-nar/1.2.0/org.apache.nifi.processors.flume.ExecuteFlumeSink/additionalDetails.html Tue May 9 15:27:39 2017 @@ -0,0 +1,155 @@ + + + + + +ExecuteFlumeSink + + + + +Data Model + +This processor executes an Apache Flume sink. FlowFiles are wrapped in Flume's +Event interface. The content of the FlowFile becomes the body of the Event and +the attributes of the FlowFile become Event headers. The following special +headers are also set: + + + +Flume Event Header +FlowFile Attribute + + +nifi.entry.date +FlowFile#getEntryDate() + + +nifi.id +FlowFile#getId() + + +nifi.last.queue.date +FlowFile#getLastQueueDate() + + +nifi.lineage.start.date +FlowFile#getLineageStartDate() + + +nifi.size +FlowFile#getSize() + + +Warning + +In NiFi, the contents of a FlowFile are accessed via a stream, but in Flume it is +stored in a byte array. This means the full content will be loaded into memory when +a FlowFile is processed by the ExecuteFlumeSink processor. You should consider the +typical size of the FlowFiles you'll process and the batch size, if any, your sink +is configured with when setting NiFi's heap size. + +Configuration Details + +This processor is designed to execute arbitrary Flume sinks. Most of the details +of configuring the sink is deferred to Flume's built-in configuration system. +For details on the available settings for each sink type, refer to the Flume +http://flume.apache.org/FlumeUserGuide.html#flume-sinks;>User Guide. +Configuring the Flume sink is a four step process: + + +Set the Sink Type property to a valid Flume sink type. + +Set the Agent Name property to the name of the agent in your +Flume configuration. This is the prefix of the properties in the Flume +configuration file. Example: tier1 + + +Set the Sink Name property to the name of the sink in your Flume +configuration. If Agent Name is tier1, then the Sink Name +is the value of the tier1.sinks property. Example: sink-1 + + +Copy and paste the configuration for the sink from your Flume configuration +file into the Flume Configuration property. Assuming you're using +the same Agent Name and Sink Name as in the examples above, this will be all +of the properties that start with tier1.sinks.sink-1. +Do not copy the tier1.sinks.sink-1.type or +tier1.sinks.sink-1.channel properties. + + +Usage Example + +Assuming you had the following existing Flume configuration file: + + +a1.sources = r1 +a1.sinks = k1 +a1.channels = c1 + +a1.sources.r1.type = netcat +a1.sources.r1.bind = localhost +a1.sources.r1.port = 4 + +a1.sinks.k1.type = hdfs +a1.sinks.k1.channel = c1 +a1.sinks.k1.hdfs.path = /flume/events/%y-%m-%d/%H%M/%S +a1.sinks.k1.hdfs.filePrefix = events- +a1.sinks.k1.hdfs.round = true +a1.sinks.k1.hdfs.roundValue = 10 +a1.sinks.k1.hdfs.roundUnit = minute + +a1.channels.c1.type = memory +a1.channels.c1.capacity = 1000 +a1.channels.c1.transactionCapacity = 100 + +a1.sources.r1.channels = c1 +a1.sinks.k1.channel = c1 + +Then you'd configure the ExecuteFlumeSink as follows: + + + +Property +Value + + +Sink Type +hdfs + + +Agent Name +a1 + + +Sink Name +k1 + + +Flume Configuration + + +a1.sinks.k1.hdfs.path = /flume/events/%y-%m-%d/%H%M/%S +a1.sinks.k1.hdfs.filePrefix = events- +a1.sinks.k1.hdfs.round = true +a1.sinks.k1.hdfs.roundValue = 10 +a1.sinks.k1.hdfs.roundUnit = minute + + + + + + \ No newline at end of file Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-flume-nar/1.2.0/org.apache.nifi.processors.flume.ExecuteFlumeSink/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-flume-nar/1.2.0/org.apache.nifi.processors.flume.ExecuteFlumeSink/index.html?rev=1794596=auto
svn commit: r1794596 [4/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compon
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.sqs.GetSQS/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.sqs.GetSQS/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.sqs.GetSQS/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.sqs.GetSQS/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +GetSQSwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }GetSQSDescription: Fetches messages from an Amazon Simple Queuing Service QueueTags: Amazon, AWS, SQS, Queue, Get, Fetch, PollProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, whether a property supports the NiFi Expression Language, and whether a property is considered "sensitive", meaning that its value will be encrypted. Before entering a v alue in a sensitive property, ensure that the nifi.properties file has an entry for the property nifi.sensitive.props.key.NameDefault ValueAllowable ValuesDescriptionQueue URLThe URL of the queue to act uponSupports Expression Language: trueAuto Delete MessagestruetruefalseSpecifies whether the messages should be automatically deleted by the processors once they have been received.Access KeyNo Description Provided.Sensitive Property: trueSu pports Expression Language: trueSecret KeyNo Description Provided.Sensitive Property: trueSupports Expression Language: trueCredentials FilePath to a file containing AWS access key and secret key in properties file format.AWS Credentials Provider serviceController Service API: AWSCredentialsProviderServiceImplementation:AWSCredentialsProviderControllerServiceThe Controller Service that is used to obtain aws credentials provi derRegionus-west-2us-gov-west-1 us-east-1 us-east-2 us-west-1 us-west-2 eu-west-1 eu-west-2 eu-central-1 ap-south-1 ap-southeast-1 ap-southeast-2 ap-northeast-1 ap-northeast-2 sa-east-1 cn-north-1 ca-central-1 No Description Provided.Batch Size10The maximum number of messages to send in a single network requestCommunications Timeout30 secsNo Description Provided.Character SetUTF-8Big5Big5-HKSCSCESU-8EUC-JPEUC-KRGB18030GB2312GBKIBM-ThaiIBM00858IBM01140IBM01141IBM01142IBM01143IBM01144IBM01145IBM01146IBM01147IBM01148IBM01149IBM037IBM1026IBM1047IBM273IBM277IBM278IBM280IB M284IBM285IBM290IBM297IBM420IBM424IBM437IBM500IBM775IBM850IBM852IBM855IBM857IBM860IBM861IBM862IBM863IBM864IBM865IBM866IBM868IBM869IBM870IBM871IBM918ISO-2022-CNISO-2022-JPISO-2022-JP-2ISO-2022-KRISO-8859-1ISO-8859-13ISO-8859-15ISO-8859-2ISO-8859-3ISO-8859-4ISO-8859-5ISO-8859-6ISO-8859-7ISO-8859-8ISO-8859-9JIS_X0201JIS_X0212-1990KOI8-RKOI8-UShift_JISTIS-620US-ASCIIUTF-16UTF-16BEUTF-16LEUTF-32UTF-32BEUTF-32LEUTF-8windows-1250windows-1251windows-1252windows-1253windows-1254< /li>windows-1255windows-1256windows-1257windows-1258windows-31jx-Big5-HKSCS-2001x-Big5-Solarisx-COMPOUND_TEXTx-euc-jp-linuxx-EUC-TWx-eucJP-Openx-IBM1006x-IBM1025x-IBM1046x-IBM1097x-IBM1098x-IBM1112x-IBM1122x-IBM1123x-IBM1124x-IBM1166x-IBM1364x-IBM1381x-IBM1383x-IBM300x-IBM33722x-IBM737x-IBM833x-IBM834x-IBM856x-IBM874x-IBM875x-IBM921x-IBM922x-IBM930x-IBM933x-IBM935x-IBM937x-IBM939x-IBM942x-IBM942Cx-IBM943x-IBM943Cx-IBM948x-IBM949x-IBM949Cx-IBM950x-IBM964x-IBM970x-ISCII91x-ISO-2022-CN-CNSx-ISO-2022-CN-GBx-iso-8859-11 x-JIS0208x-JISAutoDetectx-Johabx-MacArabicx-MacCentralEuropex-MacCroatianx-MacCyrillicx-MacDingbatx-MacGreekx-MacHebrewx-MacIcelandx-MacRomanx-MacRomaniax-MacSymbolx-MacThaix-MacTurkishx-MacUkrainex-MS932_0213x-MS950-HKSCSx-MS950-HKSCS-XPx-mswin-936x-PCKx-SJIS_0213x-UTF-16LE-BOMX-UTF-32BE-BOMX-UTF-32LE-BOMx-windows-50220x-windows-50221x-windows-874x-windows-949x-windows-950x-windows-iso2022jpThe Character Set that should be used to encode the textual content of the SQS messageVisibility Timeout15 minsThe amount of time after a message is rece ived but not deleted that the message is hidden from other consumersReceive Message Wait Time0 secThe maximum amount of time to wait on a long polling receive call. Setting this to a value of 1 second or greater will reduce the number of SQS requests and decrease fetch latency at the cost of a constantly active thread.Proxy HostProxy host name or IPSupports Expression Language: trueProxy Host PortProxy host portSupports Expression Language: trueRelationships: NameDescriptionsuccessFlowFiles are routed to success relationshipReads Attributes: None specified.Writes Attributes: NameDescriptionhash.valueThe MD5 sum of the
svn commit: r1794596 [9/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compon
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-hl7-nar/1.2.0/org.apache.nifi.processors.hl7.RouteHL7/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-hl7-nar/1.2.0/org.apache.nifi.processors.hl7.RouteHL7/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-hl7-nar/1.2.0/org.apache.nifi.processors.hl7.RouteHL7/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-hl7-nar/1.2.0/org.apache.nifi.processors.hl7.RouteHL7/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +RouteHL7window.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }RouteHL7Description: Routes incoming HL7 data according to user-defined queries. To add a query, add a new property to the processor. The name of the property will become a new relationship for the processor, and the value is an HL7 Query Language query. If a FlowFile matches the query, a copy of the FlowFile will be routed to the associated relationship.Tags: HL7, healthcare, route, Health Level 7Properties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. Th e table also indicates any default values, and whether a property supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescriptionCharacter EncodingUTF-8The Character Encoding that is used to encode the HL7 dataSupports Expression Language: trueDynamic Properties: Dynamic Properties allow the user to specify both the name and value of a property.NameValueDescriptionName of a RelationshipAn HL7 Query Language queryIf a FlowFile matches the query, it will be routed to a relationship with the name of the propertyRelationships: NameDescriptionfailureAny FlowFile that cannot be parsed as HL7 will be routed to this relationshiporiginalThe original FlowFile that comes into this processor will be routed to this relationship, unless it is routed to 'failure'Reads Attributes: None specified.Writes Attributes: NameDescriptionRouteHL7.RouteThe name of the relationship to which the FlowFile was routedState management: This component does not store state.Restricted: This component is not restricted. \ No newline at end of file Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-html-nar/1.2.0/org.apache.nifi.GetHTMLElement/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-html-nar/1.2.0/org.apache.nifi.GetHTMLElement/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-html-nar/1.2.0/org.apache.nifi.GetHTMLElement/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-html-nar/1.2.0/org.apache.nifi.GetHTMLElement/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +GetHTMLElementwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }GetHTMLElementDescription: Extracts HTML element values from the incoming flowfile's content using a CSS selector. The incoming HTML is first converted into a HTML Document Object Model so that HTML elements may be selected in the similar manner that CSS selectors are used to apply styles to HTML. The resulting HTML DOM is then "queried" using the user defined CSS selector string. The result of "querying" the HTML DOM may produce 0-N results. If no results are found the flowfile will be transferred to the "element not found" relationship to indicate so to the end user. If N resul ts are found a new flowfile will be created and emitted for each result. The query result will either be placed in the content of the new flowfile or as an attribute of the new flowfile. By default the result is written to an attribute. This can be controlled by the "Destination" property. Resulting query values may also have data prepended or appended to them by setting the value of property "Prepend Element Value" or "Append Element Value". Prepended and appended values are treated as string values and concatenated to the result retrieved from the HTML DOM query operation. A more thorough reference for the CSS selector syntax can be found at "http://jsoup.org/apidocs/org/jsoup/select/Selector.html;Tags: get, html, dom, css, elementProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a proper ty supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescriptionURLBase URL for the HTML page being parsed. This URL will be used to resolve an absolute URL
svn commit: r1794596 [6/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compon
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-elasticsearch-nar/1.2.0/org.apache.nifi.processors.elasticsearch.PutElasticsearchHttp/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-elasticsearch-nar/1.2.0/org.apache.nifi.processors.elasticsearch.PutElasticsearchHttp/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-elasticsearch-nar/1.2.0/org.apache.nifi.processors.elasticsearch.PutElasticsearchHttp/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-elasticsearch-nar/1.2.0/org.apache.nifi.processors.elasticsearch.PutElasticsearchHttp/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +PutElasticsearchHttpwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }PutElasticsearchHttpDescription: Writes the contents of a FlowFile to Elasticsearch, using the specified parameters such as the index to insert into and the type of the document.Tags: elasticsearch, insert, update, upsert, delete, write, put, httpProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, whether a property supports the NiFi E xpression Language, and whether a property is considered "sensitive", meaning that its value will be encrypted. Before entering a value in a sensitive property, ensure that the nifi.properties file has an entry for the property nifi.sensitive.props.key.NameDefault ValueAllowable ValuesDescriptionElasticsearch URLElasticsearch URL which will be connected to, including scheme (http, e.g.), host, and port. The default port for the REST API is 9200.Supports Expression Language: trueSSL Context ServiceController Service API: SSLContextServiceImplementation:StandardSSLContextServiceThe SSL Context Service used to provide client certificate information for TLS/SSL connections. This service only applies if the Elasticsearch endpoint(s) have been secured with TLS/SSL.UsernameUsername to access the Elasticsearch clusterSupports Expression Language: truePasswordPassword to access the Elasticsearch clusterSensitive Property: trueSupports Expression Language: trueConnection Timeout5 secsMax wait time for the connection to the Elasticsearch REST API.Supports Expression Language: trueResponse Timeout15 secsMax wait time for a response from the Elasticsearch REST API.Supports Expression Language: trueIdentifier AttributeThe name of the FlowFile attribute containing the identifier for the document. If the Index Operation is "index", this property may be left empty or evaluate to an empty value, in which case the document's identifier will be auto-generated by Elasticsearch. For all other Index Operations, the attribute must evaluate to a non-empty value.IndexThe name of the index to insert intoSuppor ts Expression Language: trueTypeThe type of this document (used by Elasticsearch for indexing and searching)Supports Expression Language: trueCharacter SetUTF-8Specifies the character set of the document data.Supports Expression Language: trueBatch Size100The preferred number of flow files to put to the database in a single transaction. Note that the contents of the flow files will be stored in memory until the bulk operation is performed. Also the results should be returned in the same order the flow files were received.Supports Expre ssion Language: trueIndex OperationindexThe type of the operation used to index (index, update, upsert, delete)Supports Expression Language: trueRelationships: NameDescriptionretryA FlowFile is routed to this relationship if the database cannot be updated but attempting the operation again may succeedsuccessAll FlowFiles that are written to Elasticsearch are routed to this relationshipfailureAll FlowFiles that cannot be written to Elasticsearch are routed to this relationshipReads Attributes: None specified.Writes Attributes: None specified.State management: This component does not store state.Restricted: This component is not restricted. \ No newline at end of file Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-elasticsearch-nar/1.2.0/org.apache.nifi.processors.elasticsearch.QueryElasticsearchHttp/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-elasticsearch-nar/1.2.0/org.apache.nifi.processors.elasticsearch.QueryElasticsearchHttp/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-elasticsearch-nar/1.2.0/org.apache.nifi.processors.elasticsearch.QueryElasticsearchHttp/index.html (added) +++
svn commit: r1794596 [18/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.GetHTTP/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.GetHTTP/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.GetHTTP/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.GetHTTP/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1,2 @@ +GetHTTPwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }GetHTTPDescription: Fetches data from an HTTP or HTTPS URL and writes the data to the content of a FlowFile. Once the content has been fetched, the ETag and Last Modified dates are remembered (if the web server supports these concepts). This allows the Processor to fetch new data only if the remote data has changed or until the state is cleared. That is, once the content has been fetched from the given URL, it will not be fetched again until the content on the remote server changes. Note that due to limitations on state management, stored "last modified" and etag fields never expire. If the URL in GetHttp uses Expression Language that is unbounded, there is the potential for Out of Memory Errors to occur.Tags: get, fetch, poll, http, https, ingest, source, inputProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, whether a property supports the NiFi Expression Language, and whether a property is considered "sensitive", meaning that its value will be encrypted. Before entering a value in a sensitive property, ensure that the nifi.properties file has an entry for the property nifi.sensitive.props.key.NameDefault ValueAllowable ValuesDescriptionURLThe URL to pull fromSupports Expression Language: trueFilenameThe filename to assign to the file when pulledSupports Expression Language: trueSSL Context ServiceController Service API: SSLContextServiceImplementation:StandardSSLContextServiceThe Controller Service to use in order to obtain an SSL ContextUsernameUsername required to access the URLPasswordid="description">Password required to access the URLSensitive >Property: trueConnection >Timeout30 secid="allowable-values">How long to wait when >attempting to connect to the remote server before giving upid="name">Data Timeout30 >secHow long to wait >between receiving segments of data from the remote server before giving up >and discarding the partial fileUser Agentid="default-value">id="description">What to report as the User Agent when we connect to the >remote serverAccept Content-Typeid="default-value">id="description">If sp ecified, requests will only accept the provided Content-TypeFollow RedirectsfalsetruefalseIf we receive a 3xx HTTP Status Code from the server, indicates whether or not we should follow the redirect that the server specifiesRedirect Cookie Policydefaultdefault standard strict netscape ignore When a HTTP server responds to a request with a redirect, this is the cookie policy used to copy cookies to the following request.Proxy HostThe fully qualified hostname or IP address of the proxy server Proxy PortThe port of the proxy serverDynamic Properties: Dynamic Properties allow the user to specify both the name and value of a property.NameValueDescriptionHeader NameThe Expression Language to be used to populate the header valueThe additional headers to be sent by the processor whenever making a new HTTP request. + Setting a dynamic property name to XYZ and value to ${attribute} will result in the header 'XYZ: attribute_value' being sent to the HTTP endpointRelationships: NameDescriptionsuccessAll files are transferred to the success relationshipReads Attributes: None specified.Writes Attributes: NameDescriptionfilenameThe filename is set to the name of the file on the remote servermime.typeThe MIME Type of the FlowFile, as reported by the HTTP Content-Type headerState management: ScopeDescriptionLOCALStores Last Modified Time and ETag headers returned by server so that the same data will not be fetched multiple times.Restricted: This compone nt is not restricted. \ No newline at end of file Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.GetJMSQueue/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.GetJMSQueue/index.html?rev=1794596=auto
svn commit: r1794596 [13/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-record-serialization-services-nar/1.2.0/org.apache.nifi.grok.GrokReader/additionalDetails.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-record-serialization-services-nar/1.2.0/org.apache.nifi.grok.GrokReader/additionalDetails.html?rev=1794596&view=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-record-serialization-services-nar/1.2.0/org.apache.nifi.grok.GrokReader/additionalDetails.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-record-serialization-services-nar/1.2.0/org.apache.nifi.grok.GrokReader/additionalDetails.html Tue May 9 15:27:39 2017 @@ -0,0 +1,405 @@ + + + + + +GrokReader + + + + ++ The GrokReader Controller Service provides a means for parsing and structuring input that is + made up of unstructured text, such as log files. Grok allows users to add a naming construct to + Regular Expressions such that they can be composed in order to create expressions that are easier + to manage and work with. This Controller Service consists of one Required Property and a few Optional + Properties. The is named
+ +Grok Pattern File
property specifies the filename of + a file that contains Grok Patterns that can be used for parsing log data. If not specified, a default + patterns file will be used. Its contents are provided below. There are also properties for specifying + the schema to use when parsing data. The schema is not required. However, when data is parsed + a Record is created that contains all of the fields present in the Grok Expression (explained below), + and all fields are of type String. If a schema is chosen, the field can be declared to be a different, + compatible type, such as number. Additionally, if the schema does not contain one of the fields in the + parsed data, that field will be ignored. This can be used to filter out fields that are not of interest. ++ The Required Property is named
+ +Grok Expression
and specifies how to parse each + incoming record. This is done by providing a Grok Expression such as: +%{TIMESTAMP_ISO8601:timestamp} %{LOGLEVEL:level} \[%{DATA:thread}\] %{DATA:class} %{GREEDYDATA:message}
. + This Expression will parse Apache NiFi log messages. This is accomplished by specifying that a line begins + with theTIMESTAMP_ISO8601
pattern (which is a Regular Expression defined in the default + Grok Patterns File). The value that matches this pattern is then given the nametimestamp
. As a result, + the value that matches this pattern will be assigned to a field namedtimestamp
in the Record that + produced by this Controller Service. ++ If a line is encountered in the FlowFile that does not match the configured Grok Expression, it is assumed that the line + is part of the previous message. If the line is the start of a stack trace, then the entire stack trace is read in and assigned + to a field named
STACK_TRACE
. Otherwise,
svn commit: r1794596 [26/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/html/expression-language-guide.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/expression-language-guide.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/html/expression-language-guide.html (added) +++ nifi/site/trunk/docs/nifi-docs/html/expression-language-guide.html Tue May 9 15:27:39 2017 @@ -0,0 +1,3922 @@ + + + + + + + + +Apache NiFi Expression Language Guide + +/* Asciidoctor default stylesheet | MIT License | http://asciidoctor.org */ +/* Copyright (C) 2012-2015 Dan Allen, Ryan Waldron and the Asciidoctor Project + +Permission is hereby granted, free of charge, to any person obtaining a copy +of this software and associated documentation files (the "Software"), to deal +in the Software without restriction, including without limitation the rights +to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +copies of the Software, and to permit persons to whom the Software is +furnished to do so, subject to the following conditions: + +The above copyright notice and this permission notice shall be included in +all copies or substantial portions of the Software. + +THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +THE SOFTWARE. */ +/* Remove the comments around the @import statement below when using this as a custom stylesheet */ +@import "https://fonts.googleapis.com/css?family=Open+Sans:300,300italic,400,400italic,600,600italic%7CNoto+Serif:400,400italic,700,700italic%7CDroid+Sans+Mono:400"; +article,aside,details,figcaption,figure,footer,header,hgroup,main,nav,section,summary{display:block} +audio,canvas,video{display:inline-block} +audio:not([controls]){display:none;height:0} +[hidden],template{display:none} +script{display:none!important} +html{font-family:sans-serif;-ms-text-size-adjust:100%;-webkit-text-size-adjust:100%} +body{margin:0} +a{background:transparent} +a:focus{outline:thin dotted} +a:active,a:hover{outline:0} +h1{font-size:2em;margin:.67em 0} +abbr[title]{border-bottom:1px dotted} +b,strong{font-weight:bold} +dfn{font-style:italic} +hr{-moz-box-sizing:content-box;box-sizing:content-box;height:0} +mark{background:#ff0;color:#000} +code,kbd,pre,samp{font-family:monospace;font-size:1em} +pre{white-space:pre-wrap} +q{quotes:"\201C" "\201D" "\2018" "\2019"} +small{font-size:80%} +sub,sup{font-size:75%;line-height:0;position:relative;vertical-align:baseline} +sup{top:-.5em} +sub{bottom:-.25em} +img{border:0} +svg:not(:root){overflow:hidden} +figure{margin:0} +fieldset{border:1px solid silver;margin:0 2px;padding:.35em .625em .75em} +legend{border:0;padding:0} +button,input,select,textarea{font-family:inherit;font-size:100%;margin:0} +button,input{line-height:normal} +button,select{text-transform:none} +button,html input[type="button"],input[type="reset"],input[type="submit"]{-webkit-appearance:button;cursor:pointer} +button[disabled],html input[disabled]{cursor:default} +input[type="checkbox"],input[type="radio"]{box-sizing:border-box;padding:0} +input[type="search"]{-webkit-appearance:textfield;-moz-box-sizing:content-box;-webkit-box-sizing:content-box;box-sizing:content-box} +input[type="search"]::-webkit-search-cancel-button,input[type="search"]::-webkit-search-decoration{-webkit-appearance:none} +button::-moz-focus-inner,input::-moz-focus-inner{border:0;padding:0} +textarea{overflow:auto;vertical-align:top} +table{border-collapse:collapse;border-spacing:0} +*,*:before,*:after{-moz-box-sizing:border-box;-webkit-box-sizing:border-box;box-sizing:border-box} +html,body{font-size:100%} +body{background:#fff;color:rgba(0,0,0,.8);padding:0;margin:0;font-family:"Noto Serif","DejaVu Serif",serif;font-weight:400;font-style:normal;line-height:1;position:relative;cursor:auto} +a:hover{cursor:pointer} +img,object,embed{max-width:100%;height:auto} +object,embed{height:100%} +img{-ms-interpolation-mode:bicubic} +#map_canvas img,#map_canvas embed,#map_canvas object,.map_canvas img,.map_canvas embed,.map_canvas object{max-width:none!important} +.left{float:left!important} +.right{float:right!important} +.text-left{text-align:left!important} +.text-right{text-align:right!important} +.text-center{text-align:center!important} +.text-justify{text-align:justify!important} +.hide{display:none}
svn commit: r1794596 [3/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compon
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.kinesis.firehose.PutKinesisFirehose/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.kinesis.firehose.PutKinesisFirehose/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.kinesis.firehose.PutKinesisFirehose/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.kinesis.firehose.PutKinesisFirehose/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +PutKinesisFirehosewindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }PutKinesisFirehoseDescription: Sends the contents to a specified Amazon Kinesis Firehose. In order to send data to firehose, the firehose delivery stream name has to be specified.Tags: amazon, aws, firehose, kinesis, put, streamProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, whether a property supports the NiFi Expression Language, and whether a property is considered "sensitive", meaning that its value >will be encrypted. Before entering a value in a sensitive property, ensure >that the nifi.properties file has an entry for the property >nifi.sensitive.props.key.id="properties">NameDefault ValueAllowable >ValuesDescriptionAmazon Kinesis >Firehose Delivery Stream Nameid="allowable-values">The name of kinesis firehose >delivery streamBatch Sizeid="default-value">250id="description">Batch size for messages (1-500).id="name">Max message buffer size1 MBid="allowable-values">Max message >bufferRegionid="default-value">us-west- 2us-gov-west-1 us-east-1 us-east-2 us-west-1 us-west-2 eu-west-1 eu-west-2 eu-central-1 ap-south-1 ap-southeast-1 ap-southeast-2 ap-northeast-1 ap-northeast-2 sa-east-1 cn-north-1 ca-central-1 No Description Provided.Access KeyNo Description Provided.Sensitive Property: trueSupports Expression Language: trueSecret KeyNo Description Provided.Sensitive Property: trueSupports Expression Language: trueCredentials FilePath to a file containing AWS access key and secret key in properties file format.AWS Credentials Provider serviceController Service API: AWSCredentialsProviderServiceImplementation:AWSCredentialsProviderControllerServiceThe Controller Service that is used to obtain aws credentials providerCommunications Timeout30 secsNo Description Provided.Proxy HostProxy host name or IPSupports Expression Language: trueProxy Host PortProxy host portSupports Expression Language: trueRelationships: NameDescriptionsuccessFlowFiles are routed to success relationshipfailureFlowFiles are routed to failure relatio nshipReads Attributes: None specified.Writes Attributes: NameDescriptionaws.kinesis.firehose.error.messageError message on posting message to AWS Kinesis Firehoseaws.kinesis.firehose.error.codeError code for the message when posting to AWS Kinesis Firehoseaws.kinesis.firehose.record.idRecord id of the message posted to Kinesis FirehoseState management: This component does not store state.Restricted: This component is not restricted. \ No newline at end of file Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.kinesis.stream.PutKinesisStream/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.kinesis.stream.PutKinesisStream/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.kinesis.stream.PutKinesisStream/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.kinesis.stream.PutKinesisStream/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +PutKinesisStreamwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }PutKinesisStreamDescription: Sends the contents to a specified Amazon Kinesis. In order to send data to Kinesis, the stream name has to be specified.Tags: amazon, aws, kinesis, put, streamProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, whether a property supports the NiFi Expression Language, and whether a property is considered "s ensitive", meaning that its
svn commit: r1794596 [12/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-mqtt-nar/1.2.0/org.apache.nifi.processors.mqtt.PublishMQTT/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-mqtt-nar/1.2.0/org.apache.nifi.processors.mqtt.PublishMQTT/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-mqtt-nar/1.2.0/org.apache.nifi.processors.mqtt.PublishMQTT/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-mqtt-nar/1.2.0/org.apache.nifi.processors.mqtt.PublishMQTT/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +PublishMQTTwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }PublishMQTTDescription: Publishes a message to an MQTT topicTags: publish, MQTT, IOTProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescriptionBro ker URIThe URI to use to connect to the MQTT broker (e.g. tcp://localhost:1883). The 'tcp' and 'ssl' schemes are supported. In order to use 'ssl', the SSL Context Service property must be set.Client IDMQTT client ID to useUsernameUsername to use when connecting to the brokerPasswordPassword to use when connecting to the brokerSSL Context ServiceController Service API: SSLContextServiceImplementation:StandardSSLContextServiceThe SSL Context Service used to provide client certificate information for TLS/SSL connections.Last Will TopicThe topic to send the client's Last Will to. If the Last Will topic and message are not set then a Last Will will not be sent.Last Will MessageThe message to send as the client's Last Will. If the Last Will topic and message are not set then a Last Will will not be sent.Last Will RetaintruefalseWhether to retain the client's Last Will. If the Last Will topic an d message are not set then a Last Will will not be sent.Last Will QoS Level0 - At most once 1 - At least once 2 - Exactly once QoS level to be used when publishing the Last Will MessageSession statetrueClean Session Resume Session Whether to start afresh or resume previous flows. See the allowable value descriptions for more details.MQTT Specification Version0AUTO v3.1.1v3.1.0The MQTT specification version when connecting with the broker. See the allowable value descriptions for more details.Connection Timeout (seconds )30Maximum time interval the client will wait for the network connection to the MQTT server to be established. The default timeout is 30 seconds. A value of 0 disables timeout processing meaning the client will wait until the network connection is made successfully or fails.Keep Alive Interval (seconds)60Defines the maximum time interval between messages sent or received. It enables the client to detect if the server is no longer available, without having to wait for the TCP/IP timeout. The client will ensure that at least one message travels across the network within each keep alive period. In the absence of a data-related message during the time period, the client sends a very small "ping" message, which the server will acknowledge. A value of 0 disables keepalive processing in the clie nt.TopicThe topic to publish the message to.Supports Expression Language: trueQuality of Service(QoS)The Quality of Service(QoS) to send the message with. Accepts three values '0', '1' and '2'; '0' for 'at most once', '1' for 'at least once', '2' for 'exactly once'. Expression language is allowed in order to support publishing messages with different QoS but the end value of the property must be either '0', '1' or '2'. Supports Expression Language: trueRetain MessageWhether or not the retain flag should be set on the MQTT message.Supports Expre ssion Language: trueRelationships: NameDescriptionsuccessFlowFiles that are sent successfully to the destination are transferred to this relationship.failureFlowFiles that failed to send to the destination are transferred to this relationship.Reads Attributes: None specified.Writes Attributes: None specified.State management: This component does not store state.Restricted: This component is not restricted.See Also:ConsumeMQTT \ No newline at end of file Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-parquet-nar/1.2.0/org.apache.nifi.processors.parquet.FetchParquet/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-parquet-nar/1.2.0/org.apache.nifi.processors.parquet.FetchParquet/index.html?rev=1794596=auto == ---
svn commit: r1794596 [8/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compon
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-hadoop-nar/1.2.0/org.apache.nifi.processors.hadoop.ListHDFS/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-hadoop-nar/1.2.0/org.apache.nifi.processors.hadoop.ListHDFS/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-hadoop-nar/1.2.0/org.apache.nifi.processors.hadoop.ListHDFS/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-hadoop-nar/1.2.0/org.apache.nifi.processors.hadoop.ListHDFS/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +ListHDFSwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }ListHDFSDescription: Retrieves a listing of files from HDFS. For each file that is listed in HDFS, creates a FlowFile that represents the HDFS file so that it can be fetched in conjunction with FetchHDFS. This Processor is designed to run on Primary Node only in a cluster. If the primary node changes, the new Primary Node will pick up where the previous node left off without duplicating all of the data. Unlike GetHDFS, this Processor does not delete any data from HDFS.Tags: hadoop, HDFS, get, list, ingest, source, filesystemProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescriptionHadoop Configuration ResourcesA file or comma separated list of files which contains the Hadoop file system configuration. Without this, Hadoop will search the classpath for a 'core-site.xml' and 'hdfs-site.xml' file or will revert to a default configuration.Kerberos PrincipalKerberos principal to authenticate as. Requires nifi.kerberos.krb5.file to be set in your nifi.propertiesKerberos KeytabKerberos keytab associated with the principal. Requires nifi.kerberos.krb5.file to be set in your nifi.propertiesKerberos Relogin Period4 hoursPeriod of time which should pass before attempting a kerberos reloginAdditional Classpath ResourcesA comma-separated list of paths to files and/or directories that will be added to the classpath. When specifying a directory, all files with in the directory will be added to the classpath, but further sub-directories will not be included.Distributed Cache ServiceController Service API: DistributedMapCacheClientImplementation:DistributedMapCacheClientServiceSpecifies the Controller Service that should be used to maintain state about what has been pulled from HDFS so that if a new node begins pulling data, it won't duplicate all of the work that has been done.DirectoryThe HDFS directory from which files should be readSupports Expression Language: trueRecurse SubdirectoriestruetruefalseIndicates whether to list files from subdirectories of the HDFS direc toryFile Filter[^\.].*Only files whose names match the given regular expression will be picked upRelationships: NameDescriptionsuccessAll FlowFiles are transferred to this relationshipReads Attributes: None specified.Writes Attributes: NameDescriptionfilenameThe name of the file that was read from HDFS.pathThe path is set to the absolute path of the file's directory on HDFS. For example, if the Directory property is set to /tmp, then files picked up from /tmp will have the path attribute set to "./". If the Recurse Subdirectories property is set to true and a file is picked up from /tmp/abc/1/2/3, then the path attribute will be set to "/tmp/abc/1/2/3".hdfs.ownerThe user that owns the file in HDFShdfs.groupThe group that owns the file in HDFShdfs.lastModifiedThe timestamp of when the file in HDFS was last modified, as milliseconds since midnight Jan 1, 1970 UTChdfs.lengthThe number of bytes in the file in HDFShdfs.replicationThe number of HDFS replicas for hte filehdfs.permissionsThe permissions for the file in HDFS. This is formatted as 3 characters for the owner, 3 for the group, and 3 for other users. For example rw-rw-r--State management: ScopeDescriptionCLUSTERAfter performing a listing of HDFS files, the timestamp of the newest file is stored, along with the filenames of all files that share that same timestamp. This allows the Processor to list on ly files that have been added or modified after this date the next time that the Processor is run. State is stored across the cluster so that this Processor can be run on Primary Node only and if a new Primary Node is selected, the new node can pick up where the previous node left off, without duplicating the data.Restricted: This component is not restricted.See Also:GetHDFS, FetchHDFS, PutHDFS \ No newline at end of file Added:
svn commit: r1794596 [30/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/html/overview.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/overview.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/html/overview.html (added) +++ nifi/site/trunk/docs/nifi-docs/html/overview.html Tue May 9 15:27:39 2017 @@ -0,0 +1,907 @@ + + + + + + + + +Apache NiFi Overview + +/* Asciidoctor default stylesheet | MIT License | http://asciidoctor.org */ +/* Copyright (C) 2012-2015 Dan Allen, Ryan Waldron and the Asciidoctor Project + +Permission is hereby granted, free of charge, to any person obtaining a copy +of this software and associated documentation files (the "Software"), to deal +in the Software without restriction, including without limitation the rights +to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +copies of the Software, and to permit persons to whom the Software is +furnished to do so, subject to the following conditions: + +The above copyright notice and this permission notice shall be included in +all copies or substantial portions of the Software. + +THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +THE SOFTWARE. */ +/* Remove the comments around the @import statement below when using this as a custom stylesheet */ +@import "https://fonts.googleapis.com/css?family=Open+Sans:300,300italic,400,400italic,600,600italic%7CNoto+Serif:400,400italic,700,700italic%7CDroid+Sans+Mono:400"; +article,aside,details,figcaption,figure,footer,header,hgroup,main,nav,section,summary{display:block} +audio,canvas,video{display:inline-block} +audio:not([controls]){display:none;height:0} +[hidden],template{display:none} +script{display:none!important} +html{font-family:sans-serif;-ms-text-size-adjust:100%;-webkit-text-size-adjust:100%} +body{margin:0} +a{background:transparent} +a:focus{outline:thin dotted} +a:active,a:hover{outline:0} +h1{font-size:2em;margin:.67em 0} +abbr[title]{border-bottom:1px dotted} +b,strong{font-weight:bold} +dfn{font-style:italic} +hr{-moz-box-sizing:content-box;box-sizing:content-box;height:0} +mark{background:#ff0;color:#000} +code,kbd,pre,samp{font-family:monospace;font-size:1em} +pre{white-space:pre-wrap} +q{quotes:"\201C" "\201D" "\2018" "\2019"} +small{font-size:80%} +sub,sup{font-size:75%;line-height:0;position:relative;vertical-align:baseline} +sup{top:-.5em} +sub{bottom:-.25em} +img{border:0} +svg:not(:root){overflow:hidden} +figure{margin:0} +fieldset{border:1px solid silver;margin:0 2px;padding:.35em .625em .75em} +legend{border:0;padding:0} +button,input,select,textarea{font-family:inherit;font-size:100%;margin:0} +button,input{line-height:normal} +button,select{text-transform:none} +button,html input[type="button"],input[type="reset"],input[type="submit"]{-webkit-appearance:button;cursor:pointer} +button[disabled],html input[disabled]{cursor:default} +input[type="checkbox"],input[type="radio"]{box-sizing:border-box;padding:0} +input[type="search"]{-webkit-appearance:textfield;-moz-box-sizing:content-box;-webkit-box-sizing:content-box;box-sizing:content-box} +input[type="search"]::-webkit-search-cancel-button,input[type="search"]::-webkit-search-decoration{-webkit-appearance:none} +button::-moz-focus-inner,input::-moz-focus-inner{border:0;padding:0} +textarea{overflow:auto;vertical-align:top} +table{border-collapse:collapse;border-spacing:0} +*,*:before,*:after{-moz-box-sizing:border-box;-webkit-box-sizing:border-box;box-sizing:border-box} +html,body{font-size:100%} +body{background:#fff;color:rgba(0,0,0,.8);padding:0;margin:0;font-family:"Noto Serif","DejaVu Serif",serif;font-weight:400;font-style:normal;line-height:1;position:relative;cursor:auto} +a:hover{cursor:pointer} +img,object,embed{max-width:100%;height:auto} +object,embed{height:100%} +img{-ms-interpolation-mode:bicubic} +#map_canvas img,#map_canvas embed,#map_canvas object,.map_canvas img,.map_canvas embed,.map_canvas object{max-width:none!important} +.left{float:left!important} +.right{float:right!important} +.text-left{text-align:left!important} +.text-right{text-align:right!important} +.text-center{text-align:center!important} +.text-justify{text-align:justify!important} +.hide{display:none} +.antialiased,body{-webkit-font-smoothing:antialiased}
svn commit: r1794596 [33/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1,4520 @@ + + + + +http://www.w3.org/1999/xhtml;> + + + + +NiFi Documentation + + + + + + + + + + + + + + + + + + + + +- + +NiFi Documentation +1.2.0 + + + + + + + +General + + +Overview +Getting Started +User Guide +Expression Language Guide +Admin Guide + +No matching guides + + + +Processors + + + + + + + +org.apache.nifi +nifi-stateful-analysis-nar +1.2.0 +org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow + + + + + AttributeRollingWindow 1.2.0 + + + + + + + + +org.apache.nifi +nifi-standard-nar +1.2.0 +org.apache.nifi.processors.standard.AttributesToJSON + + + + +AttributesToJSON 1.2.0 + + + + + + + + +org.apache.nifi +nifi-standard-nar +1.2.0 +org.apache.nifi.processors.standard.Base64EncodeContent + + + + + Base64EncodeContent 1.2.0 + + + + + + + + +org.apache.nifi +nifi-cdc-mysql-nar +1.2.0 +org.apache.nifi.cdc.mysql.processors.CaptureChangeMySQL + + +
svn commit: r1794596 [35/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/rest-api/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/rest-api/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/rest-api/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/rest-api/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1,48381 @@ + + + + +NiFi Rest Api-1.2.0 + + + + +if (typeof window.jQuery === 'undefined') { +document.write(unescape('%3Cscript src="https://code.jquery.com/jquery-3.1.1.min.js" type="text/javascript" %3E%3C/script%3E')); +} + + +@import "https://fonts.googleapis.com/css?family=Open+Sans:300,300italic,400,400italic,600,600italic|Noto+Serif:400,400italic,700,700italic|Droid+Sans+Mono:400"; + +html { +overflow-y: scroll; +} + +html, html a { +-webkit-font-smoothing: antialiased; +text-shadow: 1px 1px 1px rgba(0,0,0,0.004); +} + +body { +width: 62.5em; +margin: 0 auto; +display: block; +font-family: "Open Sans", "DejaVu Sans", sans-serif; +} + +div.header { +margin-top: 10px; +} + +img.logo { +float: left; +margin-right: 10px; +} + +div.header > div.title { +font-size: 30px; +height: 50px; +line-height: 50px; +} + +.sub-title { +font-style: italic; +color: #aaa; +} + +div.overview { +margin-top: 10px; +margin-bottom: 15px; +} + +div.endpoint { +margin-bottom: 10px; +} + +/* get */ + +div.endpoint.get { +border: 1px solid #174961; +} + +div.get div.operation-handle { +background-color: rgba(23, 73, 97, .15); +} + +div.get div.method { +background-color: #174961; +} + +div.get div.operation { +border-top: 1px solid #174961; +} + +/* post */ + +div.endpoint.post { +border: 1px solid #7298AC; +} + +div.post div.operation-handle { +background-color: rgba(114, 152, 172, .15); +} + +div.post div.method { +background-color: #7298AC; +} + +div.post div.operation { +border-top: 1px solid #7298AC; +} + +/* put */ + +div.endpoint.put { +border: 1px solid #063046; +} + +div.put div.operation-handle { +background-color: rgba(6, 48, 70, .15); +} + +div.put div.method { +background-color: #063046; +} + +div.put div.operation { +border-top: 1px solid #063046; +} + +/* delete */ + +div.endpoint.delete { +border: 1px solid #47758E; +} + +div.delete div.operation-handle { +background-color: rgba(71, 117, 142, .15); +} + +div.delete div.method { +background-color: #47758E; +} + +div.delete div.operation { +border-top: 1px solid #47758E; +} + +/* operations */ + +div.operation-handle { +cursor: pointer; +padding-right: 5px; +height: 22px; +} + +div.method { +float: left; +width: 75px; +color: #fff; +text-align: center; +background-color: #7098ad; +margin-right: 10px; +font-weight: bold; +} + +div.endpoint div.path { +float: left; +line-height: 22px; +} + +div.summary { +float: right; +font-size: 12px; +
svn commit: r1794596 [15/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-splunk-nar/1.2.0/org.apache.nifi.processors.splunk.GetSplunk/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-splunk-nar/1.2.0/org.apache.nifi.processors.splunk.GetSplunk/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-splunk-nar/1.2.0/org.apache.nifi.processors.splunk.GetSplunk/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-splunk-nar/1.2.0/org.apache.nifi.processors.splunk.GetSplunk/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +GetSplunkwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }GetSplunkDescription: Retrieves data from Splunk Enterprise.Tags: get, splunk, logsProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property is considered "sensitive", meaning that its value will be encrypted. Before entering a value in a sensitive property, ensure that the nifi.properties file has an entry for the property nifi.sensitive.props.key.NameDefault ValueAllowable ValuesDescriptionSchemehttpshttpshttpThe scheme for connecting to Splunk.HostnamelocalhostThe ip address or hostname of the Splunk server.Port8089The port of the Splunk server.Querysearch * | head 100The query to execute. Typically beginning with a search command followed by a search clause, such as search source="tcp:7689" to search for messages rec eived on TCP port 7689.Time Field StrategyEvent TimeEvent Time Index Time Indicates whether to search by the time attached to the event, or by the time the event was indexed in Splunk.Time Range StrategyProvidedManaged from Beginning Managed from Current Provided Indicates how to apply time ranges to each execution of the query. Selecting a managed option allows the processor to apply a time range from the last execution time to the current execution time. Whe n using Managed from Beginning, an earliest time will not be applied on the first execution, and thus all records searched. When using Managed from Current the earliest time of the first execution will be the initial execution time. When using Provided, the time range will come from the Earliest Time and Latest Time properties, or no time range will be applied if these properties are left blank.Earliest TimeThe value to use for the earliest time when querying. Only used with a Time Range Strategy of Provided. See Splunk's documentation on Search Time Modifiers for guidance in populating this field.Latest TimeThe value to use for the latest time when querying. Only used with a Time Range Strategy of Provided. See Splunk's documentation on Search Time Modifiers for guidance in populating this field.Time ZoneUTCAfrica/AbidjanAfrica/AccraAfrica/Addis_AbabaAfrica/AlgiersAfrica/AsmaraAfrica/AsmeraAfrica/BamakoAfrica/BanguiAfrica/BanjulAfrica/BissauAfrica/BlantyreAfrica/BrazzavilleAfrica/BujumburaAfrica/CairoAfrica/CasablancaAfrica/CeutaAfrica/ConakryAfrica/DakarAfrica/Dar_es_SalaamAfrica/DjiboutiAfrica/DoualaAfrica/El_AaiunAfrica/FreetownAfrica/GaboroneAfrica/HarareAfrica/JohannesburgAfrica/JubaAfrica/KampalaAfrica/KhartoumAfrica/KigaliAfrica/KinshasaAfrica/LagosAfrica/LibrevilleAfrica/LomeAfrica/LuandaAfrica/LubumbashiAfrica/LusakaAfrica/MalaboAfrica/MaputoAfrica/MaseruAfrica/MbabaneAfrica/MogadishuAfrica/MonroviaAfrica/NairobiAfrica/NdjamenaAfrica/NiameyAfrica/NouakchottAfrica/OuagadougouAfrica/Porto-NovoAfrica/Sao_TomeAfrica/TimbuktuAfrica/TripoliAfrica/TunisAfrica/WindhoekAmerica/AdakAmerica/AnchorageAmerica/AnguillaAmerica/AntiguaAmerica/AraguainaAmerica/Argentina/Buenos_AiresAmerica/Argentina/CatamarcaAmerica/Argentina/ComodRivadaviaAmerica/Argentina/CordobaAmerica/Argentina/JujuyAmerica/Argentina/La_RiojaAmerica/Argentina/MendozaAmerica/Argentina/Rio_GallegosAmerica/Argentina/SaltaAmerica/Argentina/San_JuanAmerica/Argentina/San_LuisAmerica/Argentina/TucumanAmerica/Argentina/UshuaiaAmerica/ArubaAmerica/AsuncionAmerica/AtikokanAmerica/AtkaAmerica/BahiaAmerica/Bahia_BanderasAmerica/BarbadosAmerica/BelemAmerica/BelizeAmerica/Blanc-SablonAmerica/Boa_VistaAmerica/BogotaAmerica/BoiseAmerica/Buenos_AiresAmerica/Cambridge_BayAmerica/Campo_GrandeAmerica/CancunAmerica/CaracasAmerica/CatamarcaAmerica/CayenneAmerica/CaymanAmerica/ChicagoAmerica/ChihuahuaAmerica/Coral_HarbourAmerica/CordobaAmerica/Costa_RicaAmerica/CrestonAmerica/CuiabaAmerica/CuracaoAmerica/DanmarkshavnAmerica/DawsonAmerica/Dawson_CreekAmerica/DenverAmerica/DetroitAmerica/DominicaAmerica/EdmontonAmerica/EirunepeAmerica/El_SalvadorAmer
svn commit: r1794596 [1/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compon
Author: bbende Date: Tue May 9 15:27:39 2017 New Revision: 1794596 URL: http://svn.apache.org/viewvc?rev=1794596=rev Log: Adding 1.2.0 docs Added: nifi/site/trunk/docs/ nifi/site/trunk/docs/nifi/ nifi/site/trunk/docs/nifi-docs/ nifi/site/trunk/docs/nifi-docs/components/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-ambari-nar/1.2.0/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-ambari-nar/1.2.0/org.apache.nifi.reporting.ambari.AmbariReportingTask/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-ambari-nar/1.2.0/org.apache.nifi.reporting.ambari.AmbariReportingTask/additionalDetails.html nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-ambari-nar/1.2.0/org.apache.nifi.reporting.ambari.AmbariReportingTask/index.html nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-amqp-nar/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-amqp-nar/1.2.0/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-amqp-nar/1.2.0/org.apache.nifi.amqp.processors.ConsumeAMQP/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-amqp-nar/1.2.0/org.apache.nifi.amqp.processors.ConsumeAMQP/additionalDetails.html nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-amqp-nar/1.2.0/org.apache.nifi.amqp.processors.ConsumeAMQP/index.html nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-amqp-nar/1.2.0/org.apache.nifi.amqp.processors.PublishAMQP/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-amqp-nar/1.2.0/org.apache.nifi.amqp.processors.PublishAMQP/additionalDetails.html nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-amqp-nar/1.2.0/org.apache.nifi.amqp.processors.PublishAMQP/index.html nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-avro-nar/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-avro-nar/1.2.0/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-avro-nar/1.2.0/org.apache.nifi.processors.avro.ConvertAvroToJSON/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-avro-nar/1.2.0/org.apache.nifi.processors.avro.ConvertAvroToJSON/index.html nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-avro-nar/1.2.0/org.apache.nifi.processors.avro.ExtractAvroMetadata/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-avro-nar/1.2.0/org.apache.nifi.processors.avro.ExtractAvroMetadata/index.html nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-avro-nar/1.2.0/org.apache.nifi.processors.avro.SplitAvro/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-avro-nar/1.2.0/org.apache.nifi.processors.avro.SplitAvro/index.html nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.cloudwatch.PutCloudWatchMetric/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.cloudwatch.PutCloudWatchMetric/index.html nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.credentials.provider.service.AWSCredentialsProviderControllerService/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.credentials.provider.service.AWSCredentialsProviderControllerService/index.html nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.dynamodb.DeleteDynamoDB/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.dynamodb.DeleteDynamoDB/index.html nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.dynamodb.GetDynamoDB/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.dynamodb.GetDynamoDB/index.html nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.dynamodb.PutDynamoDB/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.dynamodb.PutDynamoDB/index.html nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.kinesis.firehose.PutKinesisFirehose/ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-aws-nar/1.2.0/org.apache.nifi.processors.aws.kinesis.firehose.PutKinesisFirehose/index.html
svn commit: r1794596 [27/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/html/getting-started.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/getting-started.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/html/getting-started.html (added) +++ nifi/site/trunk/docs/nifi-docs/html/getting-started.html Tue May 9 15:27:39 2017 @@ -0,0 +1,1614 @@ + + + + + + + + +Getting Started with Apache NiFi + +/* Asciidoctor default stylesheet | MIT License | http://asciidoctor.org */ +/* Copyright (C) 2012-2015 Dan Allen, Ryan Waldron and the Asciidoctor Project + +Permission is hereby granted, free of charge, to any person obtaining a copy +of this software and associated documentation files (the "Software"), to deal +in the Software without restriction, including without limitation the rights +to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +copies of the Software, and to permit persons to whom the Software is +furnished to do so, subject to the following conditions: + +The above copyright notice and this permission notice shall be included in +all copies or substantial portions of the Software. + +THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +THE SOFTWARE. */ +/* Remove the comments around the @import statement below when using this as a custom stylesheet */ +@import "https://fonts.googleapis.com/css?family=Open+Sans:300,300italic,400,400italic,600,600italic%7CNoto+Serif:400,400italic,700,700italic%7CDroid+Sans+Mono:400"; +article,aside,details,figcaption,figure,footer,header,hgroup,main,nav,section,summary{display:block} +audio,canvas,video{display:inline-block} +audio:not([controls]){display:none;height:0} +[hidden],template{display:none} +script{display:none!important} +html{font-family:sans-serif;-ms-text-size-adjust:100%;-webkit-text-size-adjust:100%} +body{margin:0} +a{background:transparent} +a:focus{outline:thin dotted} +a:active,a:hover{outline:0} +h1{font-size:2em;margin:.67em 0} +abbr[title]{border-bottom:1px dotted} +b,strong{font-weight:bold} +dfn{font-style:italic} +hr{-moz-box-sizing:content-box;box-sizing:content-box;height:0} +mark{background:#ff0;color:#000} +code,kbd,pre,samp{font-family:monospace;font-size:1em} +pre{white-space:pre-wrap} +q{quotes:"\201C" "\201D" "\2018" "\2019"} +small{font-size:80%} +sub,sup{font-size:75%;line-height:0;position:relative;vertical-align:baseline} +sup{top:-.5em} +sub{bottom:-.25em} +img{border:0} +svg:not(:root){overflow:hidden} +figure{margin:0} +fieldset{border:1px solid silver;margin:0 2px;padding:.35em .625em .75em} +legend{border:0;padding:0} +button,input,select,textarea{font-family:inherit;font-size:100%;margin:0} +button,input{line-height:normal} +button,select{text-transform:none} +button,html input[type="button"],input[type="reset"],input[type="submit"]{-webkit-appearance:button;cursor:pointer} +button[disabled],html input[disabled]{cursor:default} +input[type="checkbox"],input[type="radio"]{box-sizing:border-box;padding:0} +input[type="search"]{-webkit-appearance:textfield;-moz-box-sizing:content-box;-webkit-box-sizing:content-box;box-sizing:content-box} +input[type="search"]::-webkit-search-cancel-button,input[type="search"]::-webkit-search-decoration{-webkit-appearance:none} +button::-moz-focus-inner,input::-moz-focus-inner{border:0;padding:0} +textarea{overflow:auto;vertical-align:top} +table{border-collapse:collapse;border-spacing:0} +*,*:before,*:after{-moz-box-sizing:border-box;-webkit-box-sizing:border-box;box-sizing:border-box} +html,body{font-size:100%} +body{background:#fff;color:rgba(0,0,0,.8);padding:0;margin:0;font-family:"Noto Serif","DejaVu Serif",serif;font-weight:400;font-style:normal;line-height:1;position:relative;cursor:auto} +a:hover{cursor:pointer} +img,object,embed{max-width:100%;height:auto} +object,embed{height:100%} +img{-ms-interpolation-mode:bicubic} +#map_canvas img,#map_canvas embed,#map_canvas object,.map_canvas img,.map_canvas embed,.map_canvas object{max-width:none!important} +.left{float:left!important} +.right{float:right!important} +.text-left{text-align:left!important} +.text-right{text-align:right!important} +.text-center{text-align:center!important} +.text-justify{text-align:justify!important} +.hide{display:none}
svn commit: r1794596 [22/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.SegmentContent/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.SegmentContent/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.SegmentContent/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.SegmentContent/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +SegmentContentwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }SegmentContentDescription: Segments a FlowFile into multiple smaller segments on byte boundaries. Each segment is given the following attributes: fragment.identifier, fragment.index, fragment.count, segment.original.filename; these attributes can then be used by the MergeContent processor in order to reconstitute the original FlowFileTags: segment, splitProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default valu es.NameDefault ValueAllowable ValuesDescriptionSegment SizeThe maximum data size in bytes for each segmentRelationships: NameDescriptionsegmentsAll segments will be sent to this relationship. If the file was small enough that it was not segmented, a copy of the original is sent to this relationship as well as originaloriginalThe original FlowFile will be sent to this relationshipReads Attributes: None specified.Writes Attributes: NameDescriptionsegment.identifierAll segments produced from the same parent FlowFile will have the same randomly generated UUID added for this attribute. This attribute is added to maintain backward compatibility, but the fragment.identifier is preferred, as it is designed to work in conjunction with the MergeContent Processorsegment.indexA one-up number that indicates the ordering of the segments that were created from a single parent FlowFile. This attribute is added to maintain backward compatibility, but the fragment.index is preferred, as it is designed to work in conjunction with the MergeContent Processorsegment.countThe number of segments generated from the parent FlowFile. This attribute is added to maintain backward compatibility, but the fragment.count is preferred, as it is designed to work in conjunction with the MergeContent Processorfragment.identifierAll segments produced from the same parent FlowFile will have the same randomly generated UUID added for this attributefragment.indexA one-up numbe r that indicates the ordering of the segments that were created from a single parent FlowFilefragment.countThe number of segments generated from the parent FlowFilesegment.original.filename The filename of the parent FlowFilesegment.original.filename The filename will be updated to include the parent's filename, the segment index, and the segment countState management: This component does not store state.Restricted: This component is not restricted.See Also:MergeContent \ No newline at end of file Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.SplitContent/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.SplitContent/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.SplitContent/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.SplitContent/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +SplitContentwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }SplitContentDescription: Splits incoming FlowFiles by a specified byte sequenceTags: content, split, binaryProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values.NameDefault ValueAllowable ValuesDescriptionByte Sequence FormatHexadecimalHexadecimal title="The Byte Sequence will be interpreted as a hexadecimal representation >of bytes">Text src="../../../../../html/images/iconInfo.png" alt="The Byte Sequence will be >interpreted as UTF-8 Encoded text" title="The Byte Sequence will be >interpreted as UTF-8 Encoded
svn commit: r1794596 [23/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-stateful-analysis-nar/1.2.0/org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-stateful-analysis-nar/1.2.0/org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-stateful-analysis-nar/1.2.0/org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-stateful-analysis-nar/1.2.0/org.apache.nifi.processors.stateful.analysis.AttributeRollingWindow/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +AttributeRollingWindowwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }AttributeRollingWindowDescription: Track a Rolling Window based on evaluating an Expression Language expression on each FlowFile and add that value to the processor's state. Each FlowFile will be emitted with the count of FlowFiles and total aggregate value of values processed in the current time window.Tags: Attribute Expression Language, state, data science, rolling, windowProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table a lso indicates any default values, and whether a property supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescriptionValue to trackThe expression on which to evaluate each FlowFile. The result of the expression will be added to the rolling window value.Supports Expression Language: trueTime windowThe time window on which to calculate the rolling window.Sub-window lengthWhen set, values will be batched into sub-windows of the set length. This allows for much larger length total windows to be set but sacrifices some precision. If this is not set (or is 0) then each value is stored in state with the timestamp of when it was received. After the length of time stated in Time window elaspes the value will be removed. If this is set, values will be batched together every X amount of time (where X is the time period set for this property) and removed all at once.Relationships: NameDescriptionset state failWhen state fails to save when processing a FlowFile, the FlowFile is routed here.successAll FlowFiles are successfully processed are routed herefailureWhen a FlowFile fails for a reason other than failing to set state it is routed here.Reads Attributes: None specified.Writes Attributes: NameDescriptionrolling_window_valueThe rolling window value (sum of all the values stored).rolling_window_countThe count of the number of FlowFiles seen in the rolling window.rolling_window_meanThe mean of the FlowFiles seen in the rolling window.State management: ScopeDescriptionLOCALStore the values backing the rolling window. This includes storing the individual values and their time-stamps or the batches of values and their counts.Restricted: This component is not restricted. \ No newline at end of file Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-tcp-nar/1.2.0/org.apache.nifi.processors.gettcp.GetTCP/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-tcp-nar/1.2.0/org.apache.nifi.processors.gettcp.GetTCP/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-tcp-nar/1.2.0/org.apache.nifi.processors.gettcp.GetTCP/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-tcp-nar/1.2.0/org.apache.nifi.processors.gettcp.GetTCP/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +GetTCPwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }GetTCPDescription: Connects over TCP to the provided endpoint(s). Received data will be written as content to the FlowFileTags: get, fetch, poll, tcp, ingest, source, inputProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values.NameDefault ValueAllowable ValuesDescriptionEndpoint ListA comma delimited list of the endpoints to connect to. The format should be server_address:port. Only one server will be connected to at a time, the others will be used as fail overs.Connection Attempt Count3The number of times to try and establish a connection, before using a backup host if available. This same attempt count would be used for a backup host as well.Reconnect interval5 secThe number of seconds to wait
svn commit: r1794596 [25/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/html/developer-guide.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/developer-guide.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/html/developer-guide.html (added) +++ nifi/site/trunk/docs/nifi-docs/html/developer-guide.html Tue May 9 15:27:39 2017 @@ -0,0 +1,3414 @@ + + + + + + + + +NiFi Developers Guide + +/* Asciidoctor default stylesheet | MIT License | http://asciidoctor.org */ +/* Copyright (C) 2012-2015 Dan Allen, Ryan Waldron and the Asciidoctor Project + +Permission is hereby granted, free of charge, to any person obtaining a copy +of this software and associated documentation files (the "Software"), to deal +in the Software without restriction, including without limitation the rights +to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +copies of the Software, and to permit persons to whom the Software is +furnished to do so, subject to the following conditions: + +The above copyright notice and this permission notice shall be included in +all copies or substantial portions of the Software. + +THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +THE SOFTWARE. */ +/* Remove the comments around the @import statement below when using this as a custom stylesheet */ +@import "https://fonts.googleapis.com/css?family=Open+Sans:300,300italic,400,400italic,600,600italic%7CNoto+Serif:400,400italic,700,700italic%7CDroid+Sans+Mono:400"; +article,aside,details,figcaption,figure,footer,header,hgroup,main,nav,section,summary{display:block} +audio,canvas,video{display:inline-block} +audio:not([controls]){display:none;height:0} +[hidden],template{display:none} +script{display:none!important} +html{font-family:sans-serif;-ms-text-size-adjust:100%;-webkit-text-size-adjust:100%} +body{margin:0} +a{background:transparent} +a:focus{outline:thin dotted} +a:active,a:hover{outline:0} +h1{font-size:2em;margin:.67em 0} +abbr[title]{border-bottom:1px dotted} +b,strong{font-weight:bold} +dfn{font-style:italic} +hr{-moz-box-sizing:content-box;box-sizing:content-box;height:0} +mark{background:#ff0;color:#000} +code,kbd,pre,samp{font-family:monospace;font-size:1em} +pre{white-space:pre-wrap} +q{quotes:"\201C" "\201D" "\2018" "\2019"} +small{font-size:80%} +sub,sup{font-size:75%;line-height:0;position:relative;vertical-align:baseline} +sup{top:-.5em} +sub{bottom:-.25em} +img{border:0} +svg:not(:root){overflow:hidden} +figure{margin:0} +fieldset{border:1px solid silver;margin:0 2px;padding:.35em .625em .75em} +legend{border:0;padding:0} +button,input,select,textarea{font-family:inherit;font-size:100%;margin:0} +button,input{line-height:normal} +button,select{text-transform:none} +button,html input[type="button"],input[type="reset"],input[type="submit"]{-webkit-appearance:button;cursor:pointer} +button[disabled],html input[disabled]{cursor:default} +input[type="checkbox"],input[type="radio"]{box-sizing:border-box;padding:0} +input[type="search"]{-webkit-appearance:textfield;-moz-box-sizing:content-box;-webkit-box-sizing:content-box;box-sizing:content-box} +input[type="search"]::-webkit-search-cancel-button,input[type="search"]::-webkit-search-decoration{-webkit-appearance:none} +button::-moz-focus-inner,input::-moz-focus-inner{border:0;padding:0} +textarea{overflow:auto;vertical-align:top} +table{border-collapse:collapse;border-spacing:0} +*,*:before,*:after{-moz-box-sizing:border-box;-webkit-box-sizing:border-box;box-sizing:border-box} +html,body{font-size:100%} +body{background:#fff;color:rgba(0,0,0,.8);padding:0;margin:0;font-family:"Noto Serif","DejaVu Serif",serif;font-weight:400;font-style:normal;line-height:1;position:relative;cursor:auto} +a:hover{cursor:pointer} +img,object,embed{max-width:100%;height:auto} +object,embed{height:100%} +img{-ms-interpolation-mode:bicubic} +#map_canvas img,#map_canvas embed,#map_canvas object,.map_canvas img,.map_canvas embed,.map_canvas object{max-width:none!important} +.left{float:left!important} +.right{float:right!important} +.text-left{text-align:left!important} +.text-right{text-align:right!important} +.text-center{text-align:center!important} +.text-justify{text-align:justify!important} +.hide{display:none} +.antialiased,body{-webkit-font-smoothing:antialiased}
svn commit: r1794596 [14/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-scripting-nar/1.2.0/org.apache.nifi.processors.script.ExecuteScript/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-scripting-nar/1.2.0/org.apache.nifi.processors.script.ExecuteScript/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-scripting-nar/1.2.0/org.apache.nifi.processors.script.ExecuteScript/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-scripting-nar/1.2.0/org.apache.nifi.processors.script.ExecuteScript/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +ExecuteScriptwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }ExecuteScriptDescription: Experimental - Executes a script given the flow file and a process session. The script is responsible for handling the incoming flow file (transfer to SUCCESS or remove, e.g.) as well as any flow files created by the script. If the handling is incomplete or incorrect, the session will be rolled back. Experimental: Impact of sustained usage not yet verified.Tags: script, execute, groovy, python, jython, jruby, ruby, javascript, js, lua, luaj, clojure, restrictedProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescriptionScript EngineClojureClojureECMAScriptGroovyluapythonrubyThe engine to execute scriptsScript FilePath to script file to execute. Only one of Script File or Script Body may be usedSupports Expression Language: trueScript BodyBody of script to execute. Only one of Script File or Script Body may be usedModule DirectoryComma-separated list of paths to files and/or directories which contain modules required by the script.Supports Expression Language: trueDynamic Properties: Dynamic Properties allow the user to specify both the name and value of a property.NameValueDescriptionA script engine property to updateThe value to set it toUpdates a script engine property specified by the Dynamic Property's key with the value specified by the Dynamic Property's valueSupports Expression Language: trueRelationships: NameDescriptionsuccessFlowFiles that were successfully processedfailureFlowFiles that failed to be processedReads Attributes: None specified.Writes Attributes: None specified.State management: ScopeDescriptionLOCAL, CLUSTERScripts can store and retrieve state using the State Management APIs. Consult the State Manager section of the Developer's Guide for more details.Restricted: Provides operator the ability to execute arbitrary code assuming all permissions that NiFi has.See Also:InvokeScriptedProcessor \ No newline at end of file Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-scripting-nar/1.2.0/org.apache.nifi.processors.script.InvokeScriptedProcessor/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-scripting-nar/1.2.0/org.apache.nifi.processors.script.InvokeScriptedProcessor/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-scripting-nar/1.2.0/org.apache.nifi.processors.script.InvokeScriptedProcessor/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-scripting-nar/1.2.0/org.apache.nifi.processors.script.InvokeScriptedProcessor/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +InvokeScriptedProcessorwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }InvokeScriptedProcessorDescription: Experimental - Invokes a script engine for a Processor defined in the given script. The script must define a valid class that implements the Processor interface, and it must set a variable 'processor' to an instance of the class. Processor methods such as onTrigger() will be delegated to the scripted Processor instance. Also any Relationships or PropertyDescriptors defined by the scripted processor will be added to the configuration dialog. Experimental: Impact of sustained usage not yet verified.Tags: script, invoke, groovy, python, jython, jruby, ruby, javascript, js, lua, luaj, restrictedProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescriptionScript
svn commit: r1794596 [29/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/html/nifi-in-depth.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/html/nifi-in-depth.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/html/nifi-in-depth.html (added) +++ nifi/site/trunk/docs/nifi-docs/html/nifi-in-depth.html Tue May 9 15:27:39 2017 @@ -0,0 +1,856 @@ + + + + + + + + +Apache NiFi In Depth + +/* Asciidoctor default stylesheet | MIT License | http://asciidoctor.org */ +/* Copyright (C) 2012-2015 Dan Allen, Ryan Waldron and the Asciidoctor Project + +Permission is hereby granted, free of charge, to any person obtaining a copy +of this software and associated documentation files (the "Software"), to deal +in the Software without restriction, including without limitation the rights +to use, copy, modify, merge, publish, distribute, sublicense, and/or sell +copies of the Software, and to permit persons to whom the Software is +furnished to do so, subject to the following conditions: + +The above copyright notice and this permission notice shall be included in +all copies or substantial portions of the Software. + +THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR +IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, +FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE +AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER +LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, +OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN +THE SOFTWARE. */ +/* Remove the comments around the @import statement below when using this as a custom stylesheet */ +@import "https://fonts.googleapis.com/css?family=Open+Sans:300,300italic,400,400italic,600,600italic%7CNoto+Serif:400,400italic,700,700italic%7CDroid+Sans+Mono:400"; +article,aside,details,figcaption,figure,footer,header,hgroup,main,nav,section,summary{display:block} +audio,canvas,video{display:inline-block} +audio:not([controls]){display:none;height:0} +[hidden],template{display:none} +script{display:none!important} +html{font-family:sans-serif;-ms-text-size-adjust:100%;-webkit-text-size-adjust:100%} +body{margin:0} +a{background:transparent} +a:focus{outline:thin dotted} +a:active,a:hover{outline:0} +h1{font-size:2em;margin:.67em 0} +abbr[title]{border-bottom:1px dotted} +b,strong{font-weight:bold} +dfn{font-style:italic} +hr{-moz-box-sizing:content-box;box-sizing:content-box;height:0} +mark{background:#ff0;color:#000} +code,kbd,pre,samp{font-family:monospace;font-size:1em} +pre{white-space:pre-wrap} +q{quotes:"\201C" "\201D" "\2018" "\2019"} +small{font-size:80%} +sub,sup{font-size:75%;line-height:0;position:relative;vertical-align:baseline} +sup{top:-.5em} +sub{bottom:-.25em} +img{border:0} +svg:not(:root){overflow:hidden} +figure{margin:0} +fieldset{border:1px solid silver;margin:0 2px;padding:.35em .625em .75em} +legend{border:0;padding:0} +button,input,select,textarea{font-family:inherit;font-size:100%;margin:0} +button,input{line-height:normal} +button,select{text-transform:none} +button,html input[type="button"],input[type="reset"],input[type="submit"]{-webkit-appearance:button;cursor:pointer} +button[disabled],html input[disabled]{cursor:default} +input[type="checkbox"],input[type="radio"]{box-sizing:border-box;padding:0} +input[type="search"]{-webkit-appearance:textfield;-moz-box-sizing:content-box;-webkit-box-sizing:content-box;box-sizing:content-box} +input[type="search"]::-webkit-search-cancel-button,input[type="search"]::-webkit-search-decoration{-webkit-appearance:none} +button::-moz-focus-inner,input::-moz-focus-inner{border:0;padding:0} +textarea{overflow:auto;vertical-align:top} +table{border-collapse:collapse;border-spacing:0} +*,*:before,*:after{-moz-box-sizing:border-box;-webkit-box-sizing:border-box;box-sizing:border-box} +html,body{font-size:100%} +body{background:#fff;color:rgba(0,0,0,.8);padding:0;margin:0;font-family:"Noto Serif","DejaVu Serif",serif;font-weight:400;font-style:normal;line-height:1;position:relative;cursor:auto} +a:hover{cursor:pointer} +img,object,embed{max-width:100%;height:auto} +object,embed{height:100%} +img{-ms-interpolation-mode:bicubic} +#map_canvas img,#map_canvas embed,#map_canvas object,.map_canvas img,.map_canvas embed,.map_canvas object{max-width:none!important} +.left{float:left!important} +.right{float:right!important} +.text-left{text-align:left!important} +.text-right{text-align:right!important} +.text-center{text-align:center!important} +.text-justify{text-align:justify!important} +.hide{display:none} +.antialiased,body{-webkit-font-smoothing:antialiased}
svn commit: r1794596 [17/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ExecuteSQL/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ExecuteSQL/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ExecuteSQL/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ExecuteSQL/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +ExecuteSQLwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }ExecuteSQLDescription: Execute provided SQL select query. Query result will be converted to Avro format. Streaming is used so arbitrarily large result sets are supported. This processor can be scheduled to run on a timer, or cron expression, using the standard scheduling methods, or it can be triggered by an incoming FlowFile. If it is triggered by an incoming FlowFile, then attributes of that FlowFile will be available when evaluating the select query. FlowFile attribute 'executesql.row.count' indicates how many rows were selected.Tags: sql, select, jdbc, query, data baseProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescriptionDatabase Connection Pooling ServiceController Service API: DBCPServiceImplementations: HiveConnectionPoolDBCPConnectionPoolThe Controller Service that is used to obtain connection to databaseSQL select queryThe SQL select query to execute. The query can be empty, a constant value, or built from attributes using Expression Language. If this property is specified, it will be used regardless of the content of incoming flowfiles. If this property is empty, the content of the incoming flow file is expected to contain a valid SQL select query, to be issued by the processor to the database. Note that Expression Language is not evaluated for flow file contents.Supports Expression Language: trueMax Wait Time0 secondsThe maximum amount of time allowed for a running SQL select query , zero means there is no limit. Max time less than 1 second will be equal to zero.Normalize Table/Column NamesfalsetruefalseWhether to change non-Avro-compatible characters in column names to Avro-compatible characters. For example, colons and periods will be changed to underscores in order to build a valid Avro record.Relationships: NameDescriptionsuccessSuccessfully created FlowFile from SQL query result set.failureSQL query execution failed. Incoming FlowFile will be penalized and routed to this relationshipReads Attributes: None specified.Writes Attributes: NameDescriptionexecutesql.row.countContains the number of rows returned in the select queryState management: This com ponent does not store state.Restricted: This component is not restricted. \ No newline at end of file Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ExecuteStreamCommand/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ExecuteStreamCommand/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ExecuteStreamCommand/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ExecuteStreamCommand/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +ExecuteStreamCommandwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }ExecuteStreamCommandDescription: Executes an external command on the contents of a flow file, and creates a new flow file with the results of the command.Tags: command execution, command, stream, execute, restrictedProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.< table id="properties">NameDefault ValueAllowable ValuesDescriptionCommand ArgumentsThe arguments to supply to the executable delimited by the ';' character.Supports Expression Language: trueCommand PathSpecifies the command to be
svn commit: r1794596 [20/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compo
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ModifyBytes/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ModifyBytes/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ModifyBytes/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.ModifyBytes/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +ModifyByteswindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }ModifyBytesDescription: Discard byte range at the start and end or all content of a binary file.Tags: binary, discard, keepProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescription Start Offset0 BNumber of bytes removed at the beginning of the file.Supports Expression Language: trueEnd Offset0 BNumber of bytes removed at the end of the file.Supports Expression Language: trueRemove All ContentfalsetruefalseRemove all content from the FlowFile superseding Start Offset and End Offset properties.Relationships: NameDescriptionsuccessProcessed flowfiles.Reads Attributes: None specified.Wr ites Attributes: None specified.State management: This component does not store state.Restricted: This component is not restricted. \ No newline at end of file Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.MonitorActivity/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.MonitorActivity/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.MonitorActivity/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-standard-nar/1.2.0/org.apache.nifi.processors.standard.MonitorActivity/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +MonitorActivitywindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }MonitorActivityDescription: Monitors the flow for activity and sends out an indicator when the flow has not had any data for some specified amount of time and again when the flow's activity is restoredTags: monitor, flow, active, inactive, activity, detectionProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescriptionThreshold Duration5 minDetermines how much time must elapse before considering the flow to be inactiveContinually Send MessagesfalsetruefalseIf true, will send inactivity indicator continually every Threshold Duration amount of time until activity is restored; if false, will send an indicator only when the flow first becomes inactiveInactivity MessageLacking activity as of time: ${now():format('/MM/dd HH:mm:ss')}; flow has been inactive for ${inactivityDurationMillis:toNumber():divide(600 00)} minutesThe message that will be the content of FlowFiles that are sent to the 'inactive' relationshipSupports Expression Language: trueActivity Restored MessageActivity restored at time: ${now():format('/MM/dd HH:mm:ss')} after being inactive for ${inactivityDurationMillis:toNumber():divide(6)} minutesThe message that will be the content of FlowFiles that are sent to 'activity.restored' relationshipSupports Expression Language: trueCopy AttributesfalsetruefalseIf true, will copy all flow file attributes from the flow file that resumed activity to the newly created indicator flow fileMonitoring ScopenodenodeclusterSpecify how to determine activeness of the flow. 'node' means that activeness is examined at individual node separately. It can be useful if DFM expects each node should receive flow files in a distributed manner. With 'cluster', it defines the flow is active while at least one node receives flow files actively. If NiFi is running as standalone mode, this should be set as 'node', if it's 'cluster', NiFi logs a warning message and act as 'node' scope.Reporting NodeallallprimarySpecify
svn commit: r1794596 [5/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compon
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-couchbase-nar/1.2.0/org.apache.nifi.processors.couchbase.GetCouchbaseKey/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-couchbase-nar/1.2.0/org.apache.nifi.processors.couchbase.GetCouchbaseKey/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-couchbase-nar/1.2.0/org.apache.nifi.processors.couchbase.GetCouchbaseKey/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-couchbase-nar/1.2.0/org.apache.nifi.processors.couchbase.GetCouchbaseKey/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +GetCouchbaseKeywindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }GetCouchbaseKeyDescription: Get a document from Couchbase Server via Key/Value access. The ID of the document to fetch may be supplied by setting the Document Id property. NOTE: if the Document Id property is not set, the contents of the FlowFile will be read to determine the Document Id, which means that the contents of the entire FlowFile will be buffered in memory.Tags: nosql, couchbase, database, getProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are co nsidered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescriptionCouchbase Cluster Controller ServiceController Service API: CouchbaseClusterControllerServiceImplementation:CouchbaseClusterServiceA Couchbase Cluster Controller Service which manages connections to a Couchbase cluster.Bucket NamedefaultThe name of bucket to access.Document Typ eJsonJsonBinaryThe type of contents.Document IdA static, fixed Couchbase document id, or an expression to construct the Couchbase document id.Supports Expression Language: trueRelationships: NameDescriptionretryAll FlowFiles that cannot written to Couchbase Server but can be retried are routed to this relationship.successAll FlowFiles that are written to Couchbase Server are routed to this relationship.failureAll FlowFiles that cannot written to Couchbase Server and can't be retried are routed to this relationship.originalThe original input file will be rou ted to this destination when it has been successfully processed.Reads Attributes: None specified.Writes Attributes: NameDescriptioncouchbase.clusterCluster where the document was retrieved from.couchbase.bucketBucket where the document was retrieved from.couchbase.doc.idId of the document.couchbase.doc.casCAS of the document.couchbase.doc.expiryExpiration of the document.couchbase.exceptionIf Couchbase related error occurs the CouchbaseException class name will be captured here.State management: This component does not store state.Restricted: This component is not restricted.See Also: \ No newline at end of file Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-couchbase-nar/1.2.0/org.apache.nifi.processors.couchbase.PutCouchbaseKey/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-couchbase-nar/1.2.0/org.apache.nifi.processors.couchbase.PutCouchbaseKey/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-couchbase-nar/1.2.0/org.apache.nifi.processors.couchbase.PutCouchbaseKey/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-couchbase-nar/1.2.0/org.apache.nifi.processors.couchbase.PutCouchbaseKey/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +PutCouchbaseKeywindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }PutCouchbaseKeyDescription: Put a document to Couchbase Server via Key/Value access.Tags: nosql, couchbase, database, putProperties: In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescripti onCouchbase Cluster Controller ServiceController Service API: CouchbaseClusterControllerServiceImplementation:CouchbaseClusterServiceA Couchbase Cluster Controller Service which manages connections to a Couchbase cluster.Bucket NamedefaultThe name of bucket to access.Document TypeJsonJsonBinaryThe type of contents.Document IdA static, fix ed Couchbase document id, or an expression to construct the Couchbase document id.Supports Expression Language: truePersist ToNONEMASTERNONEONETWOTHREEFOURDurability constraint about disk
svn commit: r1794596 [2/36] - in /nifi/site/trunk/docs: ./ nifi-docs/ nifi-docs/components/ nifi-docs/components/org.apache.nifi/ nifi-docs/components/org.apache.nifi/nifi-ambari-nar/ nifi-docs/compon
Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-ambari-nar/1.2.0/org.apache.nifi.reporting.ambari.AmbariReportingTask/additionalDetails.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-ambari-nar/1.2.0/org.apache.nifi.reporting.ambari.AmbariReportingTask/additionalDetails.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-ambari-nar/1.2.0/org.apache.nifi.reporting.ambari.AmbariReportingTask/additionalDetails.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-ambari-nar/1.2.0/org.apache.nifi.reporting.ambari.AmbariReportingTask/additionalDetails.html Tue May 9 15:27:39 2017 @@ -0,0 +1,57 @@ + + + + + +AmbariReportingTask + + + + +AmbariReportingTask + +This ReportingTask sends the following metrics to Ambari: + +FlowFilesReceivedLast5Minutes +BytesReceivedLast5Minutes +FlowFilesSentLast5Minutes +BytesSentLast5Minutes +FlowFilesQueued +BytesQueued +BytesReadLast5Minutes +BytesWrittenLast5Minutes +ActiveThreads +TotalTaskDurationSeconds +jvm.uptime +jvm.heap_used +jvm.heap_usage +jvm.non_heap_usage +jvm.thread_states.runnable +jvm.thread_states.blocked +jvm.thread_states.timed_waiting +jvm.thread_states.terminated +jvm.thread_count +jvm.daemon_thread_count +jvm.file_descriptor_usage +jvm.gc.runs +jvm.gc.time + + +In order to make use of these metrics in Ambari, a NIFI service must be created and installed +in Ambari. Please consult the Ambari and NiFi documentation for further details. + + + Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-ambari-nar/1.2.0/org.apache.nifi.reporting.ambari.AmbariReportingTask/index.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-ambari-nar/1.2.0/org.apache.nifi.reporting.ambari.AmbariReportingTask/index.html?rev=1794596=auto == --- nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-ambari-nar/1.2.0/org.apache.nifi.reporting.ambari.AmbariReportingTask/index.html (added) +++ nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-ambari-nar/1.2.0/org.apache.nifi.reporting.ambari.AmbariReportingTask/index.html Tue May 9 15:27:39 2017 @@ -0,0 +1 @@ +AmbariReportingTaskwindow.onload = function(){if(self==top) { document.getElementById('nameHeader').style.display = "inherit"; } }AmbariReportingTaskDescription: Publishes metrics from NiFi to Ambari Metrics Service (AMS). Due to how the Ambari Metrics Service works, this reporting task should be scheduled to run every 60 seconds. Each iteration it will send the metrics from the previous iteration, and calculate the current metrics to be sent on next iteration. Scheduling this reporting task at a frequency other than 60 seconds may produce unexpected results.Additional Details...Tags: reporting, ambari, metricsProperties: In th e list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.NameDefault ValueAllowable ValuesDescriptionMetrics Collector URLhttp://localhost:6188/ws/v1/timeline/metricsThe URL of the Ambari Metrics Collector ServiceSupports Expression Language: trueApplication IDnifiThe Application ID to be included in the metrics sent to AmbariSupports Expression Language: true< td id="name">Hostname${hostname(true)}The Hostname of this NiFi instance to be included in the metrics sent to AmbariSupports Expression Language: trueProcess Group IDIf specified, the reporting task will send metrics about this process group only. If not, the root process group is used and global metrics are sent.Supports Expression Language: trueState management: This component does not store state.Restricted: This component is not restricted. \ No newline at end of file Added: nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-amqp-nar/1.2.0/org.apache.nifi.amqp.processors.ConsumeAMQP/additionalDetails.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/docs/nifi-docs/components/org.apache.nifi/nifi-amqp-nar/1.2.0/org.apache.nifi.amqp.processors.ConsumeAMQP/additionalDetails.html?rev=1794596=auto == ---
svn commit: r1794595 - /nifi/site/trunk/docs/
Author: bbende Date: Tue May 9 15:24:02 2017 New Revision: 1794595 URL: http://svn.apache.org/viewvc?rev=1794595=rev Log: Deleting previous docs for adding 1.2.0 docs Removed: nifi/site/trunk/docs/
svn commit: r1794594 [1/2] - in /nifi/site/trunk: assets/js/jquery.min.js download.html minifi/getting-started.html
Author: bbende Date: Tue May 9 15:04:29 2017 New Revision: 1794594 URL: http://svn.apache.org/viewvc?rev=1794594=rev Log: Updating site for 1.2.0 release Modified: nifi/site/trunk/assets/js/jquery.min.js nifi/site/trunk/download.html nifi/site/trunk/minifi/getting-started.html Modified: nifi/site/trunk/assets/js/jquery.min.js URL: http://svn.apache.org/viewvc/nifi/site/trunk/assets/js/jquery.min.js?rev=1794594=1794593=1794594=diff == --- nifi/site/trunk/assets/js/jquery.min.js (original) +++ nifi/site/trunk/assets/js/jquery.min.js Tue May 9 15:04:29 2017 @@ -1,4 +1,5 @@ -/*! jQuery v2.2.2 | (c) jQuery Foundation | jquery.org/license */ -!function(a,b){"object"==typeof module&&"object"==typeof module.exports?module.exports=a.document?b(a,!0):function(a){if(!a.document)throw new Error("jQuery requires a window with a document");return b(a)}:b(a)}("undefined"!=typeof window?window:this,function(a,b){var c=[],d=a.document,e=c.slice,f=c.concat,g=c.push,h=c.indexOf,i={},j=i.toString,k=i.hasOwnProperty,l={},m="2.2.2",n=function(a,b){return new n.fn.init(a,b)},o=/^[\s\uFEFF\xA0]+|[\s\uFEFF\xA0]+$/g,p=/^-ms-/,q=/-([\da-z])/gi,r=function(a,b){return b.toUpperCase()};n.fn=n.prototype={jquery:m,constructor:n,selector:"",length:0,toArray:function(){return e.call(this)},get:function(a){return null!=a?0>a?this[a+this.length]:this[a]:e.call(this)},pushStack:function(a){var b=n.merge(this.constructor(),a);return b.prevObject=this,b.context=this.context,b},each:function(a){return n.each(this,a)},map:function(a){return this.pushStack(n.map(this,function(b,c){return a.call(b,c,b)}))},slice:function(){return this.pushStack(e.apply(this ,arguments))},first:function(){return this.eq(0)},last:function(){return this.eq(-1)},eq:function(a){var b=this.length,c=+a+(0>a?b:0);return this.pushStack(c>=0&>c?[this[c]]:[])},end:function(){return this.prevObject||this.constructor()},push:g,sort:c.sort,splice:c.splice},n.extend=n.fn.extend=function(){var a,b,c,d,e,f,g=arguments[0]||{},h=1,i=arguments.length,j=!1;for("boolean"==typeof g&&(j=g,g=arguments[h]||{},h++),"object"==typeof g||n.isFunction(g)||(g={}),h===i&&(g=this,h--);i>h;h++)if(null!=(a=arguments[h]))for(b in a)c=g[b],d=a[b],g!==d&&(j&&&(n.isPlainObject(d)||(e=n.isArray(d)))?(e?(e=!1,f=c&(c)?c:[]):f=c&(c)?c:{},g[b]=n.extend(j,f,d)):void 0!==d&&(g[b]=d));return g},n.extend({expando:"jQuery"+(m+Math.random()).replace(/\D/g,""),isReady:!0,error:function(a){throw new Error(a)},noop:function(){},isFunction:function(a){return"function"===n.type(a)},isArray:Array.isArray,isWindow:function(a){return null!=a&===a.window},isNumeric:function(a){va r b=a&();return!n.isArray(a)&(b)+1>=0},isPlainObject:function(a){var b;if("object"!==n.type(a)||a.nodeType||n.isWindow(a))return!1;if(a.constructor&&!k.call(a,"constructor")&&!k.call(a.constructor.prototype||{},"isPrototypeOf"))return!1;for(b in a);return void 0===b||k.call(a,b)},isEmptyObject:function(a){var b;for(b in a)return!1;return!0},type:function(a){return null==a?a+"":"object"==typeof a||"function"==typeof a?i[j.call(a)]||"object":typeof a},globalEval:function(a){var b,c=eval;a=n.trim(a),a&&(1===a.indexOf("use strict")?(b=d.createElement("script"),b.text=a,d.head.appendChild(b).parentNode.removeChild(b)):c(a))},camelCase:function(a){return a.replace(p,"ms-").replace(q,r)},nodeName:function(a,b){return a.nodeName&()===b.toLowerCase()},each:function(a,b){var c,d=0;if(s(a)){for(c=a.length;c>d;d++)if(b.call(a[d],d,a[d])===!1)break}else for(d in a)if(b.call(a[d],d,a[d])===!1)break;return a},trim:function(a){return null==a?"":(a+""). replace(o,"")},makeArray:function(a,b){var c=b||[];return null!=a&&(s(Object(a))?n.merge(c,"string"==typeof a?[a]:a):g.call(c,a)),c},inArray:function(a,b,c){return null==b?-1:h.call(b,a,c)},merge:function(a,b){for(var c=+b.length,d=0,e=a.length;c>d;d++)a[e++]=b[d];return a.length=e,a},grep:function(a,b,c){for(var d,e=[],f=0,g=a.length,h=!c;g>f;f++)d=!b(a[f],f),d!==h&(a[f]);return e},map:function(a,b,c){var d,e,g=0,h=[];if(s(a))for(d=a.length;d>g;g++)e=b(a[g],g,c),null!=e&(e);else for(g in a)e=b(a[g],g,c),null!=e&(e);return f.apply([],h)},guid:1,proxy:function(a,b){var c,d,f;return"string"==typeof b&&(c=a[b],b=a,a=c),n.isFunction(a)?(d=e.call(arguments,2),f=function(){return a.apply(b||this,d.concat(e.call(arguments)))},f.guid=a.guid=a.guid||n.guid++,f):void 0},now:Date.now,support:l}),"function"==typeof Symbol&&(n.fn[Symbol.iterator]=c[Symbol.iterator]),n.each("Boolean Number String Function Array Date RegExp Object Error Symbol".split(" "),function(a,b){i["[obj ect "+b+"]"]=b.toLowerCase()});function s(a){var b=!!a&&"length"in a&,c=n.type(a);return"function"===c||n.isWindow(a)?!1:"array"===c||0===b||"number"==typeof b&>0& in a}var t=function(a){var b,c,d,e,f,g,h,i,j,k,l,m,n,o,p,q,r,s,t,u="sizzle"+1*new
svn commit: r1794594 [2/2] - in /nifi/site/trunk: assets/js/jquery.min.js download.html minifi/getting-started.html
Modified: nifi/site/trunk/download.html URL: http://svn.apache.org/viewvc/nifi/site/trunk/download.html?rev=1794594=1794593=1794594=diff == --- nifi/site/trunk/download.html (original) +++ nifi/site/trunk/download.html Tue May 9 15:04:29 2017 @@ -126,28 +126,28 @@ Releases -1.1.2 +1.2.0 Sources: -https://www.apache.org/dyn/closer.lua?path=/nifi/1.1.2/nifi-1.1.2-source-release.zip;>nifi-1.1.2-source-release.zip ( https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-source-release.zip.asc;>asc, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-source-release.zip.md5;>md5, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-source-release.zip.sha1;>sha1, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-source-release.zip.sha256;>sha256 ) +https://www.apache.org/dyn/closer.lua?path=/nifi/1.2.0/nifi-1.2.0-source-release.zip;>nifi-1.2.0-source-release.zip ( https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-source-release.zip.asc;>asc, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-source-release.zip.md5;>md5, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-source-release.zip.sha1;>sha1, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-source-release.zip.sha256;>sha256 ) Binaries -https://www.apache.org/dyn/closer.lua?path=/nifi/1.1.2/nifi-1.1.2-bin.tar.gz;>nifi-1.1.2-bin.tar.gz ( https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.tar.gz.asc;>asc, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.tar.gz.md5;>md5, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.tar.gz.sha1;>sha1, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.tar.gz.sha256;>sha256 ) +https://www.apache.org/dyn/closer.lua?path=/nifi/1.2.0/nifi-1.2.0-bin.tar.gz;>nifi-1.2.0-bin.tar.gz ( https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.tar.gz.asc;>asc, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.tar.gz.md5;>md5, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.tar.gz.sha1;>sha1, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.tar.gz.sha256;>sha256 ) -https://www.apache.org/dyn/closer.lua?path=/nifi/1.1.2/nifi-1.1.2-bin.zip;>nifi-1.1.2-bin.zip ( https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.zip.asc;>asc, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.zip.md5;>md5, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.zip.sha1;>sha1, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.zip.sha256;>sha256 ) +https://www.apache.org/dyn/closer.lua?path=/nifi/1.2.0/nifi-1.2.0-bin.zip;>nifi-1.2.0-bin.zip ( https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.zip.asc;>asc, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.zip.md5;>md5, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.zip.sha1;>sha1, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.zip.sha256;>sha256 ) -https://www.apache.org/dyn/closer.lua?path=/nifi/1.1.2/nifi-toolkit-1.1.2-bin.tar.gz;>nifi-toolkit-1.1.2-bin.tar.gz ( https://www.apache.org/dist/nifi/1.1.2/nifi-toolkit-1.1.2-bin.tar.gz.asc;>asc, https://www.apache.org/dist/nifi/1.1.2/nifi-toolkit-1.1.2-bin.tar.gz.md5;>md5, https://www.apache.org/dist/nifi/1.1.2/nifi-toolkit-1.1.2-bin.tar.gz.sha1;>sha1, https://www.apache.org/dist/nifi/1.1.2/nifi-toolkit-1.1.2-bin.tar.gz.sha256;>sha256 ) +https://www.apache.org/dyn/closer.lua?path=/nifi/1.2.0/nifi-toolkit-1.2.0-bin.tar.gz;>nifi-toolkit-1.2.0-bin.tar.gz ( https://www.apache.org/dist/nifi/1.2.0/nifi-toolkit-1.2.0-bin.tar.gz.asc;>asc, https://www.apache.org/dist/nifi/1.2.0/nifi-toolkit-1.2.0-bin.tar.gz.md5;>md5, https://www.apache.org/dist/nifi/1.2.0/nifi-toolkit-1.2.0-bin.tar.gz.sha1;>sha1, https://www.apache.org/dist/nifi/1.2.0/nifi-toolkit-1.2.0-bin.tar.gz.sha256;>sha256 ) -https://www.apache.org/dyn/closer.lua?path=/nifi/1.1.2/nifi-toolkit-1.1.2-bin.zip;>nifi-toolkit-1.1.2-bin.zip ( https://www.apache.org/dist/nifi/1.1.2/nifi-toolkit-1.1.2-bin.zip.asc;>asc, https://www.apache.org/dist/nifi/1.1.2/nifi-toolkit-1.1.2-bin.zip.md5;>md5, https://www.apache.org/dist/nifi/1.1.2/nifi-toolkit-1.1.2-bin.zip.sha1;>sha1, https://www.apache.org/dist/nifi/1.1.2/nifi-toolkit-1.1.2-bin.zip.sha256;>sha256 ) +https://www.apache.org/dyn/closer.lua?path=/nifi/1.2.0/nifi-toolkit-1.2.0-bin.zip;>nifi-toolkit-1.2.0-bin.zip ( https://www.apache.org/dist/nifi/1.2.0/nifi-toolkit-1.2.0-bin.zip.asc;>asc, https://www.apache.org/dist/nifi/1.2.0/nifi-toolkit-1.2.0-bin.zip.md5;>md5,
nifi-site git commit: Fixing markdown syntax error in MiNiFi getting started guide
Repository: nifi-site Updated Branches: refs/heads/master b085ed111 -> d2422dc14 Fixing markdown syntax error in MiNiFi getting started guide Project: http://git-wip-us.apache.org/repos/asf/nifi-site/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi-site/commit/d2422dc1 Tree: http://git-wip-us.apache.org/repos/asf/nifi-site/tree/d2422dc1 Diff: http://git-wip-us.apache.org/repos/asf/nifi-site/diff/d2422dc1 Branch: refs/heads/master Commit: d2422dc14929169ab279c1531a94e8bf32d1fbe8 Parents: b085ed1 Author: Bryan BendeAuthored: Tue May 9 11:03:00 2017 -0400 Committer: Bryan Bende Committed: Tue May 9 11:03:00 2017 -0400 -- src/pages/markdown/minifi/getting-started.md | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) -- http://git-wip-us.apache.org/repos/asf/nifi-site/blob/d2422dc1/src/pages/markdown/minifi/getting-started.md -- diff --git a/src/pages/markdown/minifi/getting-started.md b/src/pages/markdown/minifi/getting-started.md index c411750..5b8c438 100644 --- a/src/pages/markdown/minifi/getting-started.md +++ b/src/pages/markdown/minifi/getting-started.md @@ -1,5 +1,5 @@ --- -title: Apache NiFi MiNiFi: Getting Started +title: Apache NiFi MiNiFi Getting Started --- # Getting started with MiNiFi @@ -25,7 +25,7 @@ The C++ agent is a smaller binary (3.2MB), consumes low system memory (about 5MB ## Debian/Ubuntu: - apt install -y libleveldb-dev - apt install -y libxml2 -2. Download the relevant compressed binary from the [Downloads](download.html) page +2. Download the relevant compressed binary from the [Downloads](download.html) page 3. Copy and decompress the binary to your target deployment environment 4. Set the MINIFI_HOME environment variable to your decompressed binary directory 5. From $MINIFI_HOME, ./bin/minifi.sh {start|stop|run|restart|status|flowStatus|dump|install} @@ -50,7 +50,7 @@ While it's possible to create and modify config.yml programmatically or by hand, What follows is an illustrated walkthrough of configuring MiNiFi and NiFi to generate and collect log data. -If you're new to NiFi, watch the [NiFi introductory video series](http://nifi.apache.org/videos.html) before proceeding. If you don't already have NiFi, you can download it from [here](http://nifi.apache.org/download.html). +If you're new to NiFi, watch the [NiFi introductory video series](http://nifi.apache.org/videos.html) before proceeding. If you don't already have NiFi, you can download it from [here](http://nifi.apache.org/download.html). ## Configuring NiFi to Receive Data
nifi-site git commit: Updating downloads for 1.2.0 release
Repository: nifi-site Updated Branches: refs/heads/master ffab66bd9 -> b085ed111 Updating downloads for 1.2.0 release Project: http://git-wip-us.apache.org/repos/asf/nifi-site/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi-site/commit/b085ed11 Tree: http://git-wip-us.apache.org/repos/asf/nifi-site/tree/b085ed11 Diff: http://git-wip-us.apache.org/repos/asf/nifi-site/diff/b085ed11 Branch: refs/heads/master Commit: b085ed1113c29fff16363dedf427cd3b4777fff1 Parents: ffab66b Author: Bryan BendeAuthored: Tue May 9 10:59:53 2017 -0400 Committer: Bryan Bende Committed: Tue May 9 10:59:53 2017 -0400 -- src/pages/html/download.hbs | 14 +++--- 1 file changed, 7 insertions(+), 7 deletions(-) -- http://git-wip-us.apache.org/repos/asf/nifi-site/blob/b085ed11/src/pages/html/download.hbs -- diff --git a/src/pages/html/download.hbs b/src/pages/html/download.hbs index c5dfcf5..cde0773 100644 --- a/src/pages/html/download.hbs +++ b/src/pages/html/download.hbs @@ -23,28 +23,28 @@ title: Apache NiFi Downloads Releases -1.1.2 +1.2.0 Sources: -https://www.apache.org/dyn/closer.lua?path=/nifi/1.1.2/nifi-1.1.2-source-release.zip;>nifi-1.1.2-source-release.zip ( https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-source-release.zip.asc;>asc, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-source-release.zip.md5;>md5, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-source-release.zip.sha1;>sha1, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-source-release.zip.sha256;>sha256 ) +https://www.apache.org/dyn/closer.lua?path=/nifi/1.2.0/nifi-1.2.0-source-release.zip;>nifi-1.2.0-source-release.zip ( https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-source-release.zip.asc;>asc, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-source-release.zip.md5;>md5, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-source-release.zip.sha1;>sha1, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-source-release.zip.sha256;>sha256 ) Binaries -https://www.apache.org/dyn/closer.lua?path=/nifi/1.1.2/nifi-1.1.2-bin.tar.gz;>nifi-1.1.2-bin.tar.gz ( https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.tar.gz.asc;>asc, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.tar.gz.md5;>md5, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.tar.gz.sha1;>sha1, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.tar.gz.sha256;>sha256 ) +https://www.apache.org/dyn/closer.lua?path=/nifi/1.2.0/nifi-1.2.0-bin.tar.gz;>nifi-1.2.0-bin.tar.gz ( https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.tar.gz.asc;>asc, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.tar.gz.md5;>md5, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.tar.gz.sha1;>sha1, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.tar.gz.sha256;>sha256 ) -https://www.apache.org/dyn/closer.lua?path=/nifi/1.1.2/nifi-1.1.2-bin.zip;>nifi-1.1.2-bin.zip ( https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.zip.asc;>asc, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.zip.md5;>md5, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.zip.sha1;>sha1, https://www.apache.org/dist/nifi/1.1.2/nifi-1.1.2-bin.zip.sha256;>sha256 ) +https://www.apache.org/dyn/closer.lua?path=/nifi/1.2.0/nifi-1.2.0-bin.zip;>nifi-1.2.0-bin.zip ( https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.zip.asc;>asc, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.zip.md5;>md5, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.zip.sha1;>sha1, https://www.apache.org/dist/nifi/1.2.0/nifi-1.2.0-bin.zip.sha256;>sha256 ) -https://www.apache.org/dyn/closer.lua?path=/nifi/1.1.2/nifi-toolkit-1.1.2-bin.tar.gz;>nifi-toolkit-1.1.2-bin.tar.gz ( https://www.apache.org/dist/nifi/1.1.2/nifi-toolkit-1.1.2-bin.tar.gz.asc;>asc, https://www.apache.org/dist/nifi/1.1.2/nifi-toolkit-1.1.2-bin.tar.gz.md5;>md5, https://www.apache.org/dist/nifi/1.1.2/nifi-toolkit-1.1.2-bin.tar.gz.sha1;>sha1, https://www.apache.org/dist/nifi/1.1.2/nifi-toolkit-1.1.2-bin.tar.gz.sha256;>sha256 ) +https://www.apache.org/dyn/closer.lua?path=/nifi/1.2.0/nifi-toolkit-1.2.0-bin.tar.gz;>nifi-toolkit-1.2.0-bin.tar.gz ( https://www.apache.org/dist/nifi/1.2.0/nifi-toolkit-1.2.0-bin.tar.gz.asc;>asc,
[nifi] Git Push Summary
Repository: nifi Updated Tags: refs/tags/rel/nifi-1.2.0 [created] ade245380
[2/9] nifi git commit: NIFI-3770-RC2 prepare release nifi-1.2.0-RC2
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml index d6eeef6..47f418d 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-api/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-standard-services -1.2.0-SNAPSHOT +1.2.0 nifi-http-context-map-api http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml index 2f5f68f..411a88c 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map-nar/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-http-context-map-bundle -1.2.0-SNAPSHOT +1.2.0 nifi-http-context-map-nar http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml index 989f90e..67b0e81 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/nifi-http-context-map/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-http-context-map-bundle -1.2.0-SNAPSHOT +1.2.0 nifi-http-context-map http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml index d6edbd3..fef46b5 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-http-context-map-bundle/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-standard-services -1.2.0-SNAPSHOT +1.2.0 nifi-http-context-map-bundle http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-standard-services/nifi-hwx-schema-registry-bundle/nifi-hwx-schema-registry-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-hwx-schema-registry-bundle/nifi-hwx-schema-registry-nar/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-hwx-schema-registry-bundle/nifi-hwx-schema-registry-nar/pom.xml index 46d479d..da4edb9 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-hwx-schema-registry-bundle/nifi-hwx-schema-registry-nar/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-hwx-schema-registry-bundle/nifi-hwx-schema-registry-nar/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-hwx-schema-registry-bundle -1.2.0-SNAPSHOT +1.2.0 nifi-hwx-schema-registry-nar @@ -32,7 +32,7 @@ org.apache.nifi nifi-hwx-schema-registry-service -1.2.0-SNAPSHOT +1.2.0 http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-standard-services/nifi-hwx-schema-registry-bundle/nifi-hwx-schema-registry-service/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-hwx-schema-registry-bundle/nifi-hwx-schema-registry-service/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-hwx-schema-registry-bundle/nifi-hwx-schema-registry-service/pom.xml index d740067..42a300e 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-hwx-schema-registry-bundle/nifi-hwx-schema-registry-service/pom.xml +++
[8/9] nifi git commit: NIFI-3770-RC2 prepare for next development iteration
http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/pom.xml -- diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/pom.xml b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/pom.xml index 2b5f613..ce816e0 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/pom.xml +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-record-utils -1.2.0 +1.3.0-SNAPSHOT nifi-avro-record-utils http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-hadoop-record-utils/pom.xml -- diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-hadoop-record-utils/pom.xml b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-hadoop-record-utils/pom.xml index 75d51ad..01b4d16 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-hadoop-record-utils/pom.xml +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-hadoop-record-utils/pom.xml @@ -18,10 +18,10 @@ org.apache.nifi nifi-record-utils -1.2.0 +1.3.0-SNAPSHOT nifi-hadoop-record-utils -1.2.0 +1.3.0-SNAPSHOT jar http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/pom.xml -- diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/pom.xml b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/pom.xml index 8eb7d21..3340e81 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/pom.xml +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-record-utils -1.2.0 +1.3.0-SNAPSHOT nifi-mock-record-utils http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-standard-record-utils/pom.xml -- diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-standard-record-utils/pom.xml b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-standard-record-utils/pom.xml index 74d0929..191b9db 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-standard-record-utils/pom.xml +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-standard-record-utils/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-record-utils -1.2.0 +1.3.0-SNAPSHOT nifi-standard-record-utils http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/pom.xml -- diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/pom.xml b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/pom.xml index 7ca5cd5..d33e400 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/pom.xml +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-extension-utils -1.2.0 +1.3.0-SNAPSHOT pom nifi-record-utils http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-extension-utils/pom.xml -- diff --git a/nifi-nar-bundles/nifi-extension-utils/pom.xml b/nifi-nar-bundles/nifi-extension-utils/pom.xml index db38475..d8d20dd 100644 --- a/nifi-nar-bundles/nifi-extension-utils/pom.xml +++ b/nifi-nar-bundles/nifi-extension-utils/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-nar-bundles -1.2.0 +1.3.0-SNAPSHOT pom nifi-extension-utils http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-nar/pom.xml b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-nar/pom.xml index 59197d5..f920c6e 100644 --- a/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-nar/pom.xml +++ b/nifi-nar-bundles/nifi-flume-bundle/nifi-flume-nar/pom.xml @@ -18,10 +18,10 @@ org.apache.nifi
[4/9] nifi git commit: NIFI-3770-RC2 prepare release nifi-1.2.0-RC2
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/pom.xml -- diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/pom.xml b/nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/pom.xml index 711ddae..23eed6a 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/pom.xml +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-processor-utils/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-extension-utils -1.2.0-SNAPSHOT +1.2.0 nifi-processor-utils jar http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/pom.xml -- diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/pom.xml b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/pom.xml index dbb9318..2b5f613 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/pom.xml +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-avro-record-utils/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-record-utils -1.2.0-SNAPSHOT +1.2.0 nifi-avro-record-utils http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-hadoop-record-utils/pom.xml -- diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-hadoop-record-utils/pom.xml b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-hadoop-record-utils/pom.xml index 5b5ddaf..75d51ad 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-hadoop-record-utils/pom.xml +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-hadoop-record-utils/pom.xml @@ -18,10 +18,10 @@ org.apache.nifi nifi-record-utils -1.2.0-SNAPSHOT +1.2.0 nifi-hadoop-record-utils -1.2.0-SNAPSHOT +1.2.0 jar http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/pom.xml -- diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/pom.xml b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/pom.xml index 3a2ea85..8eb7d21 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/pom.xml +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-mock-record-utils/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-record-utils -1.2.0-SNAPSHOT +1.2.0 nifi-mock-record-utils http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-standard-record-utils/pom.xml -- diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-standard-record-utils/pom.xml b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-standard-record-utils/pom.xml index 3aa27a7..74d0929 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-standard-record-utils/pom.xml +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/nifi-standard-record-utils/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-record-utils -1.2.0-SNAPSHOT +1.2.0 nifi-standard-record-utils http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/pom.xml -- diff --git a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/pom.xml b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/pom.xml index fea0920..7ca5cd5 100644 --- a/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/pom.xml +++ b/nifi-nar-bundles/nifi-extension-utils/nifi-record-utils/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-extension-utils -1.2.0-SNAPSHOT +1.2.0 pom nifi-record-utils http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-extension-utils/pom.xml -- diff --git a/nifi-nar-bundles/nifi-extension-utils/pom.xml b/nifi-nar-bundles/nifi-extension-utils/pom.xml index 4e1a0f5..db38475 100644 --- a/nifi-nar-bundles/nifi-extension-utils/pom.xml +++ b/nifi-nar-bundles/nifi-extension-utils/pom.xml @@ -18,7 +18,7 @@
[7/9] nifi git commit: NIFI-3770-RC2 prepare for next development iteration
http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-language-translation-bundle/nifi-yandex-processors/pom.xml -- diff --git a/nifi-nar-bundles/nifi-language-translation-bundle/nifi-yandex-processors/pom.xml b/nifi-nar-bundles/nifi-language-translation-bundle/nifi-yandex-processors/pom.xml index 26d0ebd..7aad0cb 100644 --- a/nifi-nar-bundles/nifi-language-translation-bundle/nifi-yandex-processors/pom.xml +++ b/nifi-nar-bundles/nifi-language-translation-bundle/nifi-yandex-processors/pom.xml @@ -19,7 +19,7 @@ org.apache.nifi nifi-language-translation-bundle -1.2.0 +1.3.0-SNAPSHOT nifi-yandex-processors http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-language-translation-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-language-translation-bundle/pom.xml b/nifi-nar-bundles/nifi-language-translation-bundle/pom.xml index b94f4ea..34ce03b 100644 --- a/nifi-nar-bundles/nifi-language-translation-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-language-translation-bundle/pom.xml @@ -19,7 +19,7 @@ org.apache.nifi nifi-nar-bundles -1.2.0 +1.3.0-SNAPSHOT nifi-language-translation-bundle http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers-nar/pom.xml b/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers-nar/pom.xml index ae4aae1..471acb5 100644 --- a/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers-nar/pom.xml +++ b/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers-nar/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-ldap-iaa-providers-bundle -1.2.0 +1.3.0-SNAPSHOT nifi-ldap-iaa-providers-nar nar http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers/pom.xml -- diff --git a/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers/pom.xml b/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers/pom.xml index 4a5b979..1a141dd 100644 --- a/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers/pom.xml +++ b/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-ldap-iaa-providers-bundle -1.2.0 +1.3.0-SNAPSHOT nifi-ldap-iaa-providers jar http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/pom.xml b/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/pom.xml index 0713e53..110d74e 100644 --- a/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-nar-bundles -1.2.0 +1.3.0-SNAPSHOT nifi-ldap-iaa-providers-bundle pom @@ -31,7 +31,7 @@ org.apache.nifi nifi-ldap-iaa-providers -1.2.0 +1.3.0-SNAPSHOT http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-nar/pom.xml b/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-nar/pom.xml index b9a4e35..c10add9 100644 --- a/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-nar/pom.xml +++ b/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-nar/pom.xml @@ -19,18 +19,18 @@ org.apache.nifi nifi-lumberjack-bundle -1.2.0 +1.3.0-SNAPSHOT nifi-lumberjack-nar -1.2.0 +1.3.0-SNAPSHOT nar org.apache.nifi nifi-lumberjack-processors -1.2.0 +1.3.0-SNAPSHOT org.apache.nifi http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/pom.xml -- diff --git a/nifi-nar-bundles/nifi-lumberjack-bundle/nifi-lumberjack-processors/pom.xml
[6/9] nifi git commit: NIFI-3770-RC2 prepare for next development iteration
http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-standard-services/nifi-hwx-schema-registry-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-hwx-schema-registry-bundle/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-hwx-schema-registry-bundle/pom.xml index df3477e..b9ca9af 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-hwx-schema-registry-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-hwx-schema-registry-bundle/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-standard-services -1.2.0 +1.3.0-SNAPSHOT nifi-hwx-schema-registry-bundle http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml index b2a7e06..22eba28 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-load-distribution-service-api/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-standard-services -1.2.0 +1.3.0-SNAPSHOT nifi-load-distribution-service-api jar http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-service-api/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-service-api/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-service-api/pom.xml index cf383d5..5d73523 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-service-api/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-service-api/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-standard-services -1.2.0 +1.3.0-SNAPSHOT nifi-record-serialization-service-api http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services-nar/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services-nar/pom.xml index 7f4774a..5c79119 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services-nar/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services-nar/pom.xml @@ -17,7 +17,7 @@ org.apache.nifi nifi-record-serialization-services-bundle -1.2.0 +1.3.0-SNAPSHOT nifi-record-serialization-services-nar nar @@ -34,7 +34,7 @@ org.apache.nifi nifi-record-serialization-services -1.2.0 +1.3.0-SNAPSHOT compile http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/pom.xml index 79e2a74..1fdcaf7 100644 --- a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/pom.xml +++ b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/pom.xml @@ -13,7 +13,7 @@ org.apache.nifi nifi-record-serialization-services-bundle -1.2.0 +1.3.0-SNAPSHOT nifi-record-serialization-services http://git-wip-us.apache.org/repos/asf/nifi/blob/3af53419/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/pom.xml b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/pom.xml index
[5/9] nifi git commit: NIFI-3770-RC2 prepare release nifi-1.2.0-RC2
NIFI-3770-RC2 prepare release nifi-1.2.0-RC2 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/3a605af8 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/3a605af8 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/3a605af8 Branch: refs/heads/master Commit: 3a605af8e0ac024fb0ba67262d49dab2727b2576 Parents: f4f174b Author: Bryan BendeAuthored: Fri May 5 20:50:14 2017 -0400 Committer: Bryan Bende Committed: Fri May 5 20:50:14 2017 -0400 -- nifi-api/pom.xml| 2 +- nifi-assembly/pom.xml | 5 +- nifi-bootstrap/pom.xml | 2 +- nifi-commons/nifi-data-provenance-utils/pom.xml | 2 +- nifi-commons/nifi-expression-language/pom.xml | 2 +- nifi-commons/nifi-flowfile-packager/pom.xml | 2 +- nifi-commons/nifi-hl7-query-language/pom.xml| 2 +- nifi-commons/nifi-logging-utils/pom.xml | 2 +- nifi-commons/nifi-properties/pom.xml| 2 +- nifi-commons/nifi-record/pom.xml| 2 +- nifi-commons/nifi-schema-utils/pom.xml | 2 +- nifi-commons/nifi-security-utils/pom.xml| 2 +- nifi-commons/nifi-site-to-site-client/pom.xml | 4 +- nifi-commons/nifi-socket-utils/pom.xml | 2 +- nifi-commons/nifi-utils/pom.xml | 4 +- nifi-commons/nifi-web-utils/pom.xml | 2 +- nifi-commons/nifi-write-ahead-log/pom.xml | 2 +- nifi-commons/pom.xml| 2 +- nifi-docker/pom.xml | 4 +- nifi-docs/pom.xml | 2 +- .../nifi-nifi-example-nar/pom.xml | 2 +- .../nifi-nifi-example-processors/pom.xml| 2 +- nifi-external/nifi-example-bundle/pom.xml | 4 +- nifi-external/nifi-spark-receiver/pom.xml | 2 +- nifi-external/nifi-storm-spout/pom.xml | 2 +- nifi-external/pom.xml | 2 +- nifi-framework-api/pom.xml | 2 +- .../nifi-processor-bundle-archetype/pom.xml | 2 +- .../nifi-service-bundle-archetype/pom.xml | 2 +- nifi-maven-archetypes/pom.xml | 2 +- nifi-mock/pom.xml | 2 +- .../nifi-ambari-bundle/nifi-ambari-nar/pom.xml | 4 +- .../nifi-ambari-reporting-task/pom.xml | 2 +- nifi-nar-bundles/nifi-ambari-bundle/pom.xml | 2 +- .../nifi-amqp-bundle/nifi-amqp-nar/pom.xml | 4 +- .../nifi-amqp-processors/pom.xml| 2 +- nifi-nar-bundles/nifi-amqp-bundle/pom.xml | 6 +- .../nifi-avro-bundle/nifi-avro-nar/pom.xml | 6 +- .../nifi-avro-processors/pom.xml| 2 +- nifi-nar-bundles/nifi-avro-bundle/pom.xml | 4 +- .../nifi-aws-bundle/nifi-aws-nar/pom.xml| 4 +- .../nifi-aws-bundle/nifi-aws-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-aws-bundle/pom.xml| 2 +- .../nifi-azure-bundle/nifi-azure-nar/pom.xml| 4 +- .../nifi-azure-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-azure-bundle/pom.xml | 2 +- .../nifi-beats-bundle/nifi-beats-nar/pom.xml| 6 +- .../nifi-beats-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-beats-bundle/pom.xml | 4 +- .../nifi-cassandra-nar/pom.xml | 2 +- .../nifi-cassandra-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-cassandra-bundle/pom.xml | 4 +- .../nifi-ccda-bundle/nifi-ccda-nar/pom.xml | 2 +- .../nifi-ccda-processors/pom.xml| 2 +- nifi-nar-bundles/nifi-ccda-bundle/pom.xml | 4 +- nifi-nar-bundles/nifi-cdc/nifi-cdc-api/pom.xml | 2 +- .../nifi-cdc-mysql-nar/pom.xml | 2 +- .../nifi-cdc-mysql-processors/pom.xml | 6 +- .../nifi-cdc/nifi-cdc-mysql-bundle/pom.xml | 4 +- nifi-nar-bundles/nifi-cdc/pom.xml | 2 +- .../nifi-couchbase-nar/pom.xml | 6 +- .../nifi-couchbase-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-couchbase-bundle/pom.xml | 4 +- .../nifi-cybersecurity-nar/pom.xml | 6 +- .../nifi-cybersecurity-processors/pom.xml | 2 +- .../nifi-cybersecurity-bundle/pom.xml | 4 +- .../nifi-datadog-nar/pom.xml| 2 +- .../nifi-datadog-reporting-task/pom.xml | 2 +- nifi-nar-bundles/nifi-datadog-bundle/pom.xml| 4 +- .../nifi-elasticsearch-5-nar/pom.xml| 2 +- .../nifi-elasticsearch-5-processors/pom.xml | 2 +- .../nifi-elasticsearch-nar/pom.xml | 2 +- .../nifi-elasticsearch-processors/pom.xml | 2 +- .../nifi-elasticsearch-bundle/pom.xml | 6 +- .../nifi-email-bundle/nifi-email-nar/pom.xml| 2 +-
[9/9] nifi git commit: NIFI-3770-RC2 prepare for next development iteration
NIFI-3770-RC2 prepare for next development iteration Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/3af53419 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/3af53419 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/3af53419 Branch: refs/heads/master Commit: 3af53419afe415cb02743a60e4d3cc5fa8ca068d Parents: 3a605af Author: Bryan BendeAuthored: Fri May 5 20:50:28 2017 -0400 Committer: Bryan Bende Committed: Fri May 5 20:50:28 2017 -0400 -- nifi-api/pom.xml| 2 +- nifi-assembly/pom.xml | 2 +- nifi-bootstrap/pom.xml | 2 +- nifi-commons/nifi-data-provenance-utils/pom.xml | 2 +- nifi-commons/nifi-expression-language/pom.xml | 2 +- nifi-commons/nifi-flowfile-packager/pom.xml | 2 +- nifi-commons/nifi-hl7-query-language/pom.xml| 2 +- nifi-commons/nifi-logging-utils/pom.xml | 2 +- nifi-commons/nifi-properties/pom.xml| 2 +- nifi-commons/nifi-record/pom.xml| 2 +- nifi-commons/nifi-schema-utils/pom.xml | 2 +- nifi-commons/nifi-security-utils/pom.xml| 2 +- nifi-commons/nifi-site-to-site-client/pom.xml | 4 +- nifi-commons/nifi-socket-utils/pom.xml | 2 +- nifi-commons/nifi-utils/pom.xml | 4 +- nifi-commons/nifi-web-utils/pom.xml | 2 +- nifi-commons/nifi-write-ahead-log/pom.xml | 2 +- nifi-commons/pom.xml| 2 +- nifi-docker/pom.xml | 4 +- nifi-docs/pom.xml | 2 +- .../nifi-nifi-example-nar/pom.xml | 2 +- .../nifi-nifi-example-processors/pom.xml| 2 +- nifi-external/nifi-example-bundle/pom.xml | 4 +- nifi-external/nifi-spark-receiver/pom.xml | 2 +- nifi-external/nifi-storm-spout/pom.xml | 2 +- nifi-external/pom.xml | 2 +- nifi-framework-api/pom.xml | 2 +- .../nifi-processor-bundle-archetype/pom.xml | 2 +- .../nifi-service-bundle-archetype/pom.xml | 2 +- nifi-maven-archetypes/pom.xml | 2 +- nifi-mock/pom.xml | 2 +- .../nifi-ambari-bundle/nifi-ambari-nar/pom.xml | 4 +- .../nifi-ambari-reporting-task/pom.xml | 2 +- nifi-nar-bundles/nifi-ambari-bundle/pom.xml | 2 +- .../nifi-amqp-bundle/nifi-amqp-nar/pom.xml | 4 +- .../nifi-amqp-processors/pom.xml| 2 +- nifi-nar-bundles/nifi-amqp-bundle/pom.xml | 6 +- .../nifi-avro-bundle/nifi-avro-nar/pom.xml | 6 +- .../nifi-avro-processors/pom.xml| 2 +- nifi-nar-bundles/nifi-avro-bundle/pom.xml | 4 +- .../nifi-aws-bundle/nifi-aws-nar/pom.xml| 4 +- .../nifi-aws-bundle/nifi-aws-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-aws-bundle/pom.xml| 2 +- .../nifi-azure-bundle/nifi-azure-nar/pom.xml| 4 +- .../nifi-azure-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-azure-bundle/pom.xml | 2 +- .../nifi-beats-bundle/nifi-beats-nar/pom.xml| 6 +- .../nifi-beats-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-beats-bundle/pom.xml | 4 +- .../nifi-cassandra-nar/pom.xml | 2 +- .../nifi-cassandra-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-cassandra-bundle/pom.xml | 4 +- .../nifi-ccda-bundle/nifi-ccda-nar/pom.xml | 2 +- .../nifi-ccda-processors/pom.xml| 2 +- nifi-nar-bundles/nifi-ccda-bundle/pom.xml | 4 +- nifi-nar-bundles/nifi-cdc/nifi-cdc-api/pom.xml | 2 +- .../nifi-cdc-mysql-nar/pom.xml | 2 +- .../nifi-cdc-mysql-processors/pom.xml | 6 +- .../nifi-cdc/nifi-cdc-mysql-bundle/pom.xml | 4 +- nifi-nar-bundles/nifi-cdc/pom.xml | 2 +- .../nifi-couchbase-nar/pom.xml | 6 +- .../nifi-couchbase-processors/pom.xml | 2 +- nifi-nar-bundles/nifi-couchbase-bundle/pom.xml | 4 +- .../nifi-cybersecurity-nar/pom.xml | 6 +- .../nifi-cybersecurity-processors/pom.xml | 2 +- .../nifi-cybersecurity-bundle/pom.xml | 4 +- .../nifi-datadog-nar/pom.xml| 2 +- .../nifi-datadog-reporting-task/pom.xml | 2 +- nifi-nar-bundles/nifi-datadog-bundle/pom.xml| 4 +- .../nifi-elasticsearch-5-nar/pom.xml| 2 +- .../nifi-elasticsearch-5-processors/pom.xml | 2 +- .../nifi-elasticsearch-nar/pom.xml | 2 +- .../nifi-elasticsearch-processors/pom.xml | 2 +- .../nifi-elasticsearch-bundle/pom.xml | 6 +- .../nifi-email-bundle/nifi-email-nar/pom.xml| 2 +-
[3/9] nifi git commit: NIFI-3770-RC2 prepare release nifi-1.2.0-RC2
http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-kite-bundle/nifi-kite-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-kite-bundle/nifi-kite-nar/pom.xml b/nifi-nar-bundles/nifi-kite-bundle/nifi-kite-nar/pom.xml index 71b7157..9e83488 100644 --- a/nifi-nar-bundles/nifi-kite-bundle/nifi-kite-nar/pom.xml +++ b/nifi-nar-bundles/nifi-kite-bundle/nifi-kite-nar/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-kite-bundle -1.2.0-SNAPSHOT +1.2.0 nifi-kite-nar http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-kite-bundle/nifi-kite-processors/pom.xml -- diff --git a/nifi-nar-bundles/nifi-kite-bundle/nifi-kite-processors/pom.xml b/nifi-nar-bundles/nifi-kite-bundle/nifi-kite-processors/pom.xml index 74289fd..02d69cf 100644 --- a/nifi-nar-bundles/nifi-kite-bundle/nifi-kite-processors/pom.xml +++ b/nifi-nar-bundles/nifi-kite-bundle/nifi-kite-processors/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-kite-bundle -1.2.0-SNAPSHOT +1.2.0 nifi-kite-processors http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-kite-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-kite-bundle/pom.xml b/nifi-nar-bundles/nifi-kite-bundle/pom.xml index a7b5bee..1019d2b 100644 --- a/nifi-nar-bundles/nifi-kite-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-kite-bundle/pom.xml @@ -18,7 +18,7 @@ org.apache.nifi nifi-nar-bundles -1.2.0-SNAPSHOT +1.2.0 nifi-kite-bundle @@ -36,7 +36,7 @@ org.apache.nifi nifi-kite-processors -1.2.0-SNAPSHOT +1.2.0 http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-language-translation-bundle/nifi-language-translation-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-language-translation-bundle/nifi-language-translation-nar/pom.xml b/nifi-nar-bundles/nifi-language-translation-bundle/nifi-language-translation-nar/pom.xml index b213905..f5f7683 100644 --- a/nifi-nar-bundles/nifi-language-translation-bundle/nifi-language-translation-nar/pom.xml +++ b/nifi-nar-bundles/nifi-language-translation-bundle/nifi-language-translation-nar/pom.xml @@ -19,7 +19,7 @@ org.apache.nifi nifi-language-translation-bundle -1.2.0-SNAPSHOT +1.2.0 nifi-language-translation-nar @@ -33,7 +33,7 @@ org.apache.nifi nifi-yandex-processors -1.2.0-SNAPSHOT +1.2.0 http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-language-translation-bundle/nifi-yandex-processors/pom.xml -- diff --git a/nifi-nar-bundles/nifi-language-translation-bundle/nifi-yandex-processors/pom.xml b/nifi-nar-bundles/nifi-language-translation-bundle/nifi-yandex-processors/pom.xml index 309876a..26d0ebd 100644 --- a/nifi-nar-bundles/nifi-language-translation-bundle/nifi-yandex-processors/pom.xml +++ b/nifi-nar-bundles/nifi-language-translation-bundle/nifi-yandex-processors/pom.xml @@ -19,7 +19,7 @@ org.apache.nifi nifi-language-translation-bundle -1.2.0-SNAPSHOT +1.2.0 nifi-yandex-processors http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-language-translation-bundle/pom.xml -- diff --git a/nifi-nar-bundles/nifi-language-translation-bundle/pom.xml b/nifi-nar-bundles/nifi-language-translation-bundle/pom.xml index d5e1498..b94f4ea 100644 --- a/nifi-nar-bundles/nifi-language-translation-bundle/pom.xml +++ b/nifi-nar-bundles/nifi-language-translation-bundle/pom.xml @@ -19,7 +19,7 @@ org.apache.nifi nifi-nar-bundles -1.2.0-SNAPSHOT +1.2.0 nifi-language-translation-bundle http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers-nar/pom.xml -- diff --git a/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers-nar/pom.xml b/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers-nar/pom.xml index c5f7811..ae4aae1 100644 --- a/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers-nar/pom.xml +++ b/nifi-nar-bundles/nifi-ldap-iaa-providers-bundle/nifi-ldap-iaa-providers-nar/pom.xml @@ -18,7 +18,7 @@
[1/9] nifi git commit: NIFI-3770-RC2 prepare release nifi-1.2.0-RC2
Repository: nifi Updated Branches: refs/heads/master f4f174b89 -> 3af53419a http://git-wip-us.apache.org/repos/asf/nifi/blob/3a605af8/pom.xml -- diff --git a/pom.xml b/pom.xml index 9ddaf53..5ea7369 100644 --- a/pom.xml +++ b/pom.xml @@ -9,8 +9,7 @@ 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. --> -http://maven.apache.org/POM/4.0.0; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; -xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd;> +http://maven.apache.org/POM/4.0.0; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd;> 4.0.0 org.apache @@ -20,7 +19,7 @@ org.apache.nifi nifi -1.2.0-SNAPSHOT +1.2.0 pom Apache NiFi is an easy to use, powerful, and reliable system to process and distribute data. @@ -78,7 +77,7 @@ scm:git:git://git.apache.org/nifi.git scm:git:https://git-wip-us.apache.org/repos/asf/nifi.git https://git-wip-us.apache.org/repos/asf?p=nifi.git -HEAD +nifi-1.2.0-RC2 JIRA @@ -844,112 +843,112 @@ org.apache.nifi nifi-api -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-framework-api -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-utils -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-site-to-site-client -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-web-utils -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-expression-language -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-flowfile-repo-serialization -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-repository-models -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-custom-ui-utilities -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-ui-extension -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-flowfile-packager -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-socket-utils -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-data-provenance-utils -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-runtime -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-bootstrap -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-toolkit-tls -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-toolkit-encrypt-config -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-toolkit-s2s -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-toolkit-zookeeper-migrator -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-toolkit-admin -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-registry-service -1.2.0-SNAPSHOT +1.2.0 org.apache.nifi nifi-resources -1.2.0-SNAPSHOT +1.2.0 resources runtime zip @@ -957,7 +956,7 @@ org.apache.nifi nifi-docs -
[jira] [Created] (MINIFI-305) cmake/iOS.cmake needs apache license header
marco polo created MINIFI-305: - Summary: cmake/iOS.cmake needs apache license header Key: MINIFI-305 URL: https://issues.apache.org/jira/browse/MINIFI-305 Project: Apache NiFi MiNiFi Issue Type: Bug Components: C++ Affects Versions: cpp-0.2.0 Reporter: marco polo Priority: Minor cmake/iOS.cmake needs apache license header. cmake/FindUUID.cmake is an example -- This message was sent by Atlassian JIRA (v6.3.15#6346)