Member since
11-21-2016
7
Posts
2
Kudos Received
0
Solutions
02-16-2017
01:19 PM
I am using below scan statement in Hbase to obtain data from a table wherein the column A30 should be between the given date range.How can this be achieved, as below query pulls up record beyond range of 01-JUN-2011 and 30-JUN-2011. scan 'mytable',{FILTER => "SingleColumnValueFilter('cf1','A15',=, 'binary:10') AND SingleColumnValueFilter('cf1','F49' ,=, 'binary:6') AND SingleColumnValueFilter('cf1','A30',>=, 'binary:01-JUN-2011') AND SingleColumnValueFilter('cf1','A30',<=, 'binary:30-JUN-2011')"} Data in hbase table ;- column=cf1:A30, timestamp=1487080632072, value=15-JAN-14
... View more
Labels:
- Labels:
-
Apache HBase
02-11-2017
11:56 AM
In Nifi , I need to load a csv file to hbase and as a rowkey I want to provide a running number (like oracle sequence) to each record as the rowkey. can this be done using Nifi existing processors and not putting down any custom processor.
... View more
Labels:
- Labels:
-
Apache NiFi
12-08-2016
12:34 PM
I have a data migration from Oracle to Kafka via GoldenGate. I need to identify the records coming in from Oracle say with a source_identifier like say AA ...which is not present as field in Oracle tab. How can I get this value of source identifier in Kafka json file eg we have gg.handler.hdfs.format.insertOpKey=I Similary is there any config that can be set to , put tag souce_identifier as AA in kafka.
... View more
Labels:
- Labels:
-
Apache Kafka