List of addToMetadata() Examples

Examples of addToMetadata()

com.ikanow.infinit.e.data_model.store.document.DocumentPojo.addToMetadata()

Examples of com.ikanow.infinit.e.data_model.store.document.DocumentPojo.addToMetadata()

          @SuppressWarnings("unchecked")
          LinkedHashMap<String, Object[]> meta = (LinkedHashMap<String, Object[]>) docObj.get(DocumentPojo.metadata_);
          if (null != meta) {
            Object metaJson = meta.get("json");
            if (metaJson instanceof Object[]) { // (in this case ... non-cached, need to recopy in, I forget why)
              doc.addToMetadata("json", (Object[])metaJson);
            }
          }          
          toAdd.add(doc);
        }
        // (currently can't run harvest source federated query)

View Full Code Here

Examples of com.ikanow.infinit.e.data_model.store.document.DocumentPojo.addToMetadata()

          }
        } 
        catch (JSONException e) {} // (do nothing just carry on)
      }
      if (!fms.isEmpty()) {
        doc.addToMetadata("_FEED_METADATA_", XmlToMetadataParser.convertJsonObjectToLinkedHashMap(rssMetadata));
      }
    }//TESTED (longs converted to string, eg edgar:assistantDirector from "http.www.sec.gov.archives.edgar.usgaap.rss.xml")


    return doc;
  }

View Full Code Here

Examples of com.ikanow.infinit.e.data_model.store.document.DocumentPojo.addToMetadata()

        if (  (column != null) && (value != null) ) 
        {
          if (!source.getDatabaseConfig().getPreserveCase()) {
            column = column.toLowerCase();
          }
          doc.addToMetadata(column, value);
        }
          }      
    }
    catch (SQLException e) 
    {

View Full Code Here

Examples of com.ikanow.infinit.e.data_model.store.document.DocumentPojo.addToMetadata()

        for (JsonElement je: meta.getAsJsonArray()) {
          if (je.isJsonObject()) {
            metaArray.add(convertJsonObjectToLinkedHashMap(je.getAsJsonObject(), _memUsage));
          }
        }
        doc.addToMetadata("json", metaArray.toArray());
      }
      else if (meta.isJsonObject()) {
        doc.addToMetadata("json", convertJsonObjectToLinkedHashMap(meta.getAsJsonObject(), _memUsage));
      }      
    }

View Full Code Here

Examples of com.ikanow.infinit.e.data_model.store.document.DocumentPojo.addToMetadata()

          }
        }
        doc.addToMetadata("json", metaArray.toArray());
      }
      else if (meta.isJsonObject()) {
        doc.addToMetadata("json", convertJsonObjectToLinkedHashMap(meta.getAsJsonObject(), _memUsage));
      }      
    }
    return doc;
    
  } //TESTED

View Full Code Here

Examples of com.ikanow.infinit.e.data_model.store.document.DocumentPojo.addToMetadata()

            }
            if (textOnly) {
              doc.setFullText(meta.toString());
            }
            else {
              doc.addToMetadata("json", convertJsonObjectToLinkedHashMap(meta.getAsJsonObject(), _memUsage));
            }
            docList.add(doc);
            if (++nCurrDocs >= nMaxDocs) {
              while (reader.hasNext()) {
                reader.skipValue();

View Full Code Here

Examples of com.ikanow.infinit.e.data_model.store.document.DocumentPojo.addToMetadata()

              }
              if (textOnly) {
                doc.setFullText(meta2.toString());
              }
              else {
                doc.addToMetadata("json", convertJsonObjectToLinkedHashMap(meta2.getAsJsonObject(), _memUsage));
              }
              docList.add(doc);            
              if (++nCurrDocs >= nMaxDocs) {
                while (reader.hasNext()) {
                  reader.skipValue();

View Full Code Here

Examples of com.ikanow.infinit.e.data_model.store.document.DocumentPojo.addToMetadata()

            long count = DbManager.getCollection("ingest", requestId.toString()).count();
            if (count > 0) {
              DBCursor dbc = DbManager.getCollection("ingest", requestId.toString()).find().limit(context.getStandaloneMaxDocs());
              for (Object o: dbc) {
                DocumentPojo doc = new DocumentPojo();
                doc.addToMetadata("logstash_record", o);
                toAdd.add(doc);
              }
              error = logStashDbo.getString("error", "no info");
              context.getHarvestStatus().update(source,new Date(),HarvestEnum.success, "Logstash service info: " + error, false, false);          
              break;

View Full Code Here

Examples of com.ikanow.infinit.e.data_model.store.document.DocumentPojo.addToMetadata()

                  JSONObject rec = null;
                  JSONArray jarray = null;
    
                  try {
                    jarray = json.getJSONArray(names);
                    doc.addToMetadata(names, handleJsonArray(jarray, false));
                  } catch (JSONException e) {
                    try {
                      rec = json.getJSONObject(names);
                      doc.addToMetadata(names, convertJsonObjectToLinkedHashMap(rec));
                    } catch (JSONException e2) {

View Full Code Here

Examples of com.ikanow.infinit.e.data_model.store.document.DocumentPojo.addToMetadata()

                    jarray = json.getJSONArray(names);
                    doc.addToMetadata(names, handleJsonArray(jarray, false));
                  } catch (JSONException e) {
                    try {
                      rec = json.getJSONObject(names);
                      doc.addToMetadata(names, convertJsonObjectToLinkedHashMap(rec));
                    } catch (JSONException e2) {
                      try {
                        Object[] val = {json.getString(names)};
                        doc.addToMetadata(names,val);
                      } catch (JSONException e1) {

View Full Code Here

0 1

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.