Scan the given table and writes result in a flowfile. Value will be represented as UTF-8 Encoded String.
hadoop, accumulo, scan, record
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.
| Display Name | API Name | Default Value | Allowable Values | Description |
|---|---|---|---|---|
| Accumulo Connector Service | accumulo-connector-service | Controller Service API: BaseAccumuloService Implementation: AccumuloService | Specifies the Controller Service to use for accessing Accumulo. | |
| Table Name | Table Name | The name of the Accumulo Table into which data will be placed Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) | ||
| Create Table | Create Table | False |
| Creates a table if it does not exist. This property will only be used when EL is not present in 'Table Name' |
| Threads | Threads | 10 | Number of threads used for reading and writing | |
| Accumulo Timeout | accumulo-timeout | 30 sec | Max amount of time to wait for an unresponsive server. Set to 0 sec for no timeout. Entered value less than 1 second may be converted to 0 sec. | |
| Start key | start-key | Start row key Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) | ||
| Start key Inclusive | start-key-inclusive | True |
| Determines if the start key is inclusive |
| End key | end-key | End row key for this. If not specified or empty this will be infinite Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) | ||
| Start Column Family | column-family | The column family that is part of the start key. If no column key is defined only this column family will be selected Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) | ||
| End Column Family | column-family-end | The column family to select is part of end key Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) | ||
| End key Inclusive | end-key-inclusive | False |
| Determines if the end key is inclusive |
| Value Included in Result | accumulo-value-inclusive | True |
| Beside keys and their values, accumulo value field will also be included in the result as UTF-8 Encoded String. |
| Record Writer | record-writer | Controller Service API: RecordSetWriterFactory Implementations: JsonRecordSetWriter ParquetRecordSetWriter CSVRecordSetWriter ScriptedRecordSetWriter XMLRecordSetWriter FreeFormTextRecordSetWriter AvroRecordSetWriter RecordSetWriterLookup | Specifies the Controller Service to use for writing out the records | |
| Authorizations | accumulo-authorizations | The comma separated list of authorizations to pass to the scanner. Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
| Name | Description |
|---|---|
| success | A FlowFile is routed to this relationship after it has been successfully retrieved from Accumulo |
| failure | A FlowFile is routed to this relationship if it cannot be retrieved fromAccumulo |