Apache/nifi
1
0
Fork 0
mirror of https://github.com/apache/nifi.git synced 2025-02-07 10:38:33 +00:00
Code Issues Packages Projects Releases Wiki Activity
1,383 Commits 147 Branches 203 Tags
Commit Graph

1383 Commits

This Branch
This Branch
All Branches
Author SHA1 Message Date
Matt Gilman
a872403831 NIFI-730: 
- Updating the styling of the drop request status dialog.
- Rendering any errors that may have occurred.
 2015-10-16 09:37:57 -04:00
Mark Payne
2b4999c018 NIFI-730: do not interrupt swap thread if drop flowfiles is canceled 2015-10-16 09:06:13 -04:00
Mark Payne
b8dbd1018c NIFI-730: Updated details of Provenance Event for when a queue is emptied 2015-10-16 08:53:40 -04:00
Matt Gilman
39a050d2fd NIFI-730: 
- Adding emptying a queue when clustered.
 2015-10-14 17:47:06 -04:00
Mark Payne
09a3f6dadd NIFI-730: reordered states for drop flowfile request 2015-10-14 16:32:39 -04:00
Mark Payne
98a04eec74 NIFI-730: Set current queue size on drop flowfile request immediately when creating request 2015-10-14 13:48:59 -04:00
Matt Gilman
cad0e7cf0f NIFI-730: 
- Adding progress bar for showing current status of drop request.
- Allowing the user to cancel the current drop request.
 2015-10-14 12:39:19 -04:00
Mark Payne
a2ae99f899 NIFI-730: Make cancel request actually cancel 2015-10-14 11:11:48 -04:00
Mark Payne
5867193bc1 NIFI-730: Added additional testing logic to unit tests 2015-10-14 09:56:52 -04:00
Mark Payne
0af1acaafa NIFI-730: Return DropFlowFileStatus object when calling cancel 2015-10-14 09:46:21 -04:00
Mark Payne
77f7d7524c NIFI-730: bug fixes and code cleanup for swap manager and flowfile queue 2015-10-14 09:14:15 -04:00
Mark Payne
afb76afcd0 NIFI-730: Added error messages if we fail to drop FlowFiles from queue 2015-10-13 15:57:18 -04:00
Mark Payne
72ff2a25d5 NIFI-730: Updated queue sizes appropriately during dropping of flowfiles 2015-10-13 15:46:56 -04:00
Matt Gilman
4b41aaab02 NIFI-730: 
- Fixing checkstyle violations.
- Wiring endpoints and framework model.
- Lowering the max delay while polling from 8 seconds to 4 seconds.
 2015-10-13 13:43:10 -04:00
Mark Payne
af78354d84 NIFI-730: Added additional parameters to dropFlowFiles 2015-10-13 12:20:18 -04:00
Matt Gilman
09d6fe5cdb NIFI-730: 
- Fixing checkstyle violations.
- Renaming context menu item for emptying a queue.
 2015-10-13 10:12:58 -04:00
Mark Payne
ad6af95d07 NIFI-730: Fixed checkstyle violations 2015-10-13 10:09:21 -04:00
Mark Payne
9be37914dd Merge branch 'NIFI-730' of https://git-wip-us.apache.org/repos/asf/nifi into NIFI-730 2015-10-13 10:03:31 -04:00
Mark Payne
49a781df2d NIFI-730: Implemented swapping in and out on-demand by the FlowFileQueue rather than in a background thread 2015-10-13 10:03:03 -04:00
Matt Gilman
e0ac7cde37 NIFI-730: 
- Starting to add support for deleting flow files from a queue by creating endpoints and starting to wire everything together.
- Adding context menu item for initiating the request to drop flow files.
 2015-10-12 10:00:54 -04:00
Mark Payne
b8c51dc35d NIFI-730: Added methods for dropping queued flowfiles; refactored swap manager but have not yet started swapping flowfiles in or out from within the flowfile queue 2015-10-11 10:27:07 -04:00
Joseph Percivall
b4bfcc1f21 NIFI-1030 made InvokeHttp basic auth password a sensitive value 
Signed-off-by: Aldrin Piri <aldrin@apache.org>
 2015-10-08 15:46:12 -04:00
Matt Gilman
2583d7869a NIFI-442: 
NIFI-828:
- Always selecting the first item in the new component table.
- Enabling adding the selected component by typing Enter.
- Removing the 'filter by' in the new component dialogs and instead just searching every field.
 2015-10-07 19:11:55 -04:00
Randy Gelhausen
31fba6b333 Bumped nifi-kafka-processors Kafka version 
This closes #99.

Signed-off-by: Aldrin Piri <aldrin@apache.org>
 2015-10-05 10:39:22 -04:00
Bryan Bende
6b2f5ad1f5 NIFI-992 Adding NOTICE to nifi-couchbase-nar 2015-10-01 16:56:49 -04:00
Bryan Bende
883333cb00 Previous commits for NIFI-992 provide the functionality as specified in Github PR. 
This closes #96.
 2015-10-01 15:12:22 -04:00
ijokarumawak
033a1553ab nifi-992 Improvements based on code review part II. 
- Penalize or Yield based on ErrorHandlingStrategy.Penalty
- Add Retry relationship to PutCouchbaseKey
- Remove unnecessary try/catch and let the framework handle it
- Change CouchbaseException relation mapping for Fatal from Failure to Retry

Signed-off-by: Bryan Bende <bbende@apache.org>
 2015-10-01 14:13:20 -04:00
ijokarumawak
72eb64e8a4 nifi-992 Improvements based on code review. 
- Removed checkstyle and contrib-check profile since it's inherit from
  top-level pom.
- Consolidate DOC_ID and DOC_ID_EXP into a single DOC_ID property.
- Add capability description on GetCouchbaseKey.
- Fixed documentation spell misses.
- Handle Exceptions accordingly.
- Add 'retry' relationship.

Signed-off-by: Bryan Bende <bbende@apache.org>
 2015-09-29 13:48:13 -04:00
ijokarumawak
2466a24530 nifi-992 Adding nifi-couchbase-bundle. 
- new CouchbaseClusterControllerService
- new Processors
  - GetCouchbaseKey
  - PutCouchbaseKey

Signed-off-by: Bryan Bende <bbende@apache.org>
 2015-09-28 11:21:42 -04:00
Mark Payne
96764ed6a1 Merge branch 'master' of http://git-wip-us.apache.org/repos/asf/nifi 2015-09-25 09:15:34 -04:00
Mark Payne
eb94dab00c NIFI-604: Fixed checkstyle violation 2015-09-24 11:51:44 -04:00
Joe Skora
e53ab391fa NIFI-641 Add delete capability to the UpdateAttributes processor. 
Signed-off-by: Bryan Bende <bbende@apache.org>
 2015-09-24 10:46:10 -04:00
Aldrin Piri
a414f1d514 Previous commit for NIFI-985 provides the functionality as specified in Github PR. 
This closes #90.
 2015-09-24 10:37:08 -04:00
Joe
e12da7c9a3 NIFI-985: Custom log prefix for LogAttribute processor 
The LogAttribute processor evaluates the log prefix EL using the current flow file.

Log prefix helps to distinguish the log output of multiple LogAttribute processors and identify the right processor. Log prefix appears in the first and the last log line, followed by the original 50 dashes. If you configure log prefix 'STEP 1: ' the log output looks like this:

STEP 1 :  --------------------------------------------------
Standard FlowFile Attributes
Key: 'entryDate'
        Value: 'Tue Sep 22 15:13:02 CEST 2015'
Key: 'lineageStartDate'
        Value: 'Tue Sep 22 15:13:02 CEST 2015'
Key: 'fileSize'
        Value: '9'
FlowFile Attribute Map Content
Key: 'customAttribute'
        Value: 'custom value'
STEP 1 :  --------------------------------------------------

flow file content...

Signed-off-by: Aldrin Piri <aldrin@apache.org>
 2015-09-24 10:31:04 -04:00
Mark Payne
24c080788f NIFI-604: Removed unused import, as it caused checkstyle violation 2015-09-24 10:06:39 -04:00
Mark Payne
193dbe6533 Merge branch 'NIFI-604' of https://github.com/rickysaltzer/nifi into NIFI-604 2015-09-23 16:03:46 -04:00
Mark Payne
26f80095b7 Merge branch 'master' of http://git-wip-us.apache.org/repos/asf/nifi 2015-09-23 15:31:19 -04:00
Mark Payne
f884086fc2 NIFI-713: Fixed checkstyle issue 2015-09-23 15:20:25 -04:00
Mark Payne
da56b49b88 Merge branch 'NIFI-713' of https://github.com/rickysaltzer/nifi into NIFI-713 2015-09-23 12:06:50 -04:00
Bryan Bende
8615941c89 NIFI-959 Fixing incorrect evaluation for getting the collection and adding a unit test to prevent regression 2015-09-22 15:38:53 -04:00
Bryan Bende
5764e89293 NIFI-975 Fixing NullPointerException when one of the delimiters is not provided when using the Text strategy 2015-09-22 13:19:15 -04:00
Joe
14eaeeb1ee NIFI-984: Bad class used for logging in TestDetectDuplicate 
Using TestListenUDP instead of TestDetectDuplicate when creating the logger.

This closes #89

Signed-off-by: Aldrin Piri <aldrin@apache.org>
 2015-09-22 08:51:58 -04:00
Matt Gilman
d75c7b54e8 NIFI-934: 
- Added a content viewer for image files.
 2015-09-18 18:17:12 -04:00
Bryan Bende
600f91a262 NIFI-932 Adding hasIncomingConnection() and hasConnection(Relationship) to ProcessContext and updating ExecuteSQL 2015-09-18 17:05:31 -04:00
Matt Gilman
1fd45958d3 NIFI-876: 
- Merge branch 'release-nifi-0.3.0-rc1'
 2015-09-18 08:48:48 -04:00
Matt Gilman
624bb5dd74 NIFI-876: 
- Merge branch 'release-nifi-0.3.0-rc1'
 2015-09-18 08:48:40 -04:00
Bryan Bende
b36841e213 NIFI-919 Adding SplitAvro processor that splits binary datafiles into smaller datafiles, or bare records. 
- Adding documentation about bare record use, renaming Split Size to Output Size, and adding a test case with 0 records
- Removing validators on properties that have allowable values, using positive integer validator for Output Size, and fixing type on processor description
 2015-09-16 10:11:30 -04:00
Bryan Bende
1007999415 NIFI-912 Initial version of ExtractAvroMetadata processor. 
- Adding optional ability to extract record count
- Renaming record.count to item.count for clarity, and updating documentation
- Adding a test case with 0 records
- Removing validators from properties that use allowable values
 2015-09-16 09:59:50 -04:00
Matt Gilman
ded74ec94c NIFI-876 prepare for next development iteration 2015-09-14 21:48:11 -04:00
Matt Gilman
2ec735e350 NIFI-876 prepare release nifi-0.3.0-RC1 nifi-0.3.0-RC1 2015-09-14 21:48:00 -04:00