ndevroy
1/24/2019 - 3:54 PM

Java Data Ingestion Cassandra Query

TRUNCATE c360_java_ingest_v10_alpha_2.ingest_host_node_table;
TRUNCATE c360_java_ingest_v10_alpha_2.file_progress_list;
TRUNCATE c360_java_ingest_v10_alpha_2.exception_list;

TRUNCATE c360_java_ingest_v10_alpha_2.sftp_poll_table;

UPDATE c360_java_ingest_v10_alpha_2.sftp_poll_table SET isProcessed = 0 WHERE id=ac5cfa2d-8c97-4c29-8364-fd3316e0a1ee;

INSERT INTO c360_java_ingest_v10_alpha_2.sftp_poll_table (id, changedate, createdate, csvfilecontents, csvfilename,isprocessed) VALUES (uuid(),'2018-09-17 22:05:05:000331','2018-09-17 22:05:05:000331',{'MDM,/mapr/datalake/ODM/mleccm/tst_631/cr3_mdm/nate-test/,150,32,442986', 'Source,FolderName,PartFileSize,NumberOfPartFiles,NumberOfRecords'}, 'CIRRUS_20181005-10:00:02.csv',0);

DELETE FROM c360_java_ingest_v10_alpha_2.sftp_poll_table WHERE id=ad5591f6-4f9d-4b67-857c-e63c40957ddb;

INSERT INTO c360_java_ingest_v10_alpha_2.sftp_poll_table (id, changedate, createdate, csvfilecontents, csvfilename,isprocessed) VALUES (uuid(),'2018-09-17 22:05:05:000331','2018-09-17 22:05:05:000331',{'MDM,/mapr/datalake/ODM/mleccm/tst_631/cr3_mdm/test-load/IMDM-150-VERSION-7/,150,32,442986', 'Source,FolderName,PartFileSize,NumberOfPartFiles,NumberOfRecords'}, 'CIRRUS_20180905-10:00:02.csv',0);

select * from c360_java_ingest_v10_alpha_2.ingest_host_node_table;
select * from c360_java_ingest_v10_alpha_2.sftp_poll_table;