svn commit: r1646686 - in /oodt/trunk/tools/pdi_plugin: ivy.xml src/org/apache/oodt/filemgringest/FilemgrIngestStep.java src/org/apache/oodt/filemgringest/OODTProcesses.java

[magicaltrout]

Author: magicaltrout
Date: Fri Dec 19 11:51:10 2014
New Revision: 1646686

URL: http://svn.apache.org/r1646686
Log:
Add some PDI stuff

Modified:
    oodt/trunk/tools/pdi_plugin/ivy.xml
    
oodt/trunk/tools/pdi_plugin/src/org/apache/oodt/filemgringest/FilemgrIngestStep.java
    
oodt/trunk/tools/pdi_plugin/src/org/apache/oodt/filemgringest/OODTProcesses.java

Modified: oodt/trunk/tools/pdi_plugin/ivy.xml
URL: 
http://svn.apache.org/viewvc/oodt/trunk/tools/pdi_plugin/ivy.xml?rev=1646686&r1=1646685&r2=1646686&view=diff
==============================================================================
Binary files - no diff available.

Modified: 
oodt/trunk/tools/pdi_plugin/src/org/apache/oodt/filemgringest/FilemgrIngestStep.java
URL: 
http://svn.apache.org/viewvc/oodt/trunk/tools/pdi_plugin/src/org/apache/oodt/filemgringest/FilemgrIngestStep.java?rev=1646686&r1=1646685&r2=1646686&view=diff
==============================================================================
--- 
oodt/trunk/tools/pdi_plugin/src/org/apache/oodt/filemgringest/FilemgrIngestStep.java
 (original)
+++ 
oodt/trunk/tools/pdi_plugin/src/org/apache/oodt/filemgringest/FilemgrIngestStep.java
 Fri Dec 19 11:51:10 2014
@@ -162,13 +162,15 @@ public class FilemgrIngestStep extends B
         }*/
 
         try {
-            Metadata m = oodtproc.getMetadata((String)r[idx2]);
-            oodtproc.ingest(oodt, new File((String)r[idx]), m);
+
+                 
System.setProperty("org.apache.oodt.cas.filemgr.mime.type.repository", 
"/tmp/mime-types.xml");
+                 Metadata m = oodtproc.getMetadata((String)r[idx2]);
+          String productid = oodtproc.ingest(oodt, new File((String)r[idx]), 
m);
 
 
         // safely add the string "Hello World!" at the end of the output row
                // the row array will be resized if necessary
-                   Object[] outputRow = RowDataUtil.addValueData(r, 
data.outputRowMeta.size() - 1, "Hello World!");
+                   Object[] outputRow = RowDataUtil.addValueData(r, 
data.outputRowMeta.size() - 1, productid);
 
                // put the row to the output row stream
                putRow(data.outputRowMeta, outputRow);

Modified: 
oodt/trunk/tools/pdi_plugin/src/org/apache/oodt/filemgringest/OODTProcesses.java
URL: 
http://svn.apache.org/viewvc/oodt/trunk/tools/pdi_plugin/src/org/apache/oodt/filemgringest/OODTProcesses.java?rev=1646686&r1=1646685&r2=1646686&view=diff
==============================================================================
--- 
oodt/trunk/tools/pdi_plugin/src/org/apache/oodt/filemgringest/OODTProcesses.java
 (original)
+++ 
oodt/trunk/tools/pdi_plugin/src/org/apache/oodt/filemgringest/OODTProcesses.java
 Fri Dec 19 11:51:10 2014
@@ -66,7 +66,7 @@ public class OODTProcesses {
 
     }
 
-    boolean ingest(OODTConfig config, File product, Metadata productMetdata) 
throws IngestException {
+    String ingest(OODTConfig config, File product, Metadata productMetdata) 
throws IngestException {
        // try {
             String productId = config.getIngester().ingest(config.getFmUrl(),
                     product, productMetdata);
@@ -79,7 +79,7 @@ public class OODTProcesses {
                             + ": attempting to continue crawling", e);
             return false;
         }*/
-        return true;
+        return productId;
     }