List of addDataSource() Examples

Examples of addDataSource()

gov.nysenate.openleg.model.Agenda.addDataSource()
gov.nysenate.openleg.model.Bill.addDataSource()
gov.nysenate.openleg.model.Calendar.addDataSource()
gov.nysenate.openleg.model.Transcript.addDataSource()
nexj.core.meta.xml.XMLMetadata.addDataSource()
Adds a new data source to the metadata. @param dataSource The data source to add. @throws MetadataException if a data sourcewith the same name already exists.
no.priv.garshol.duke.ConfigurationImpl.addDataSource()
Adds a data source to the configuration. If in deduplication mode groupno == 0, otherwise it gives the number of the group to which the data source belongs.
org.apache.tez.dag.api.Vertex.addDataSource()
Specifies an external data source for a Vertex. This is meant to be used when a Vertex reads Input directly from an external source
For vertices which read data generated by another vertex - use the {@link DAG addEdge} method.If a vertex needs to use data generated by another vertex in the DAG and also from an external source, a combination of this API and the DAG.addEdge API can be used.
Note: If more than one RootInput exists on a vertex, which generates events which need to be routed, or generates information to set parallelism, a custom vertex manager should be setup to handle this. Not using a custom vertex manager for such a scenario will lead to a runtime failure. @param inputName the name of the input. This will be used when accessing the input in the {@link LogicalIOProcessor} @param dataSourceDescriptor the @{link DataSourceDescriptor} for this input. @return this Vertex
org.gudy.azureus2.ui.swt.views.table.TableViewSWT.addDataSource()
org.jboss.portal.identity.metadata.config.DatasourcesMetaData.addDatasource()
org.jrobin.core.RrdDef.addDatasource()
Adds single datasource definition represented with object of class DsDef. @param dsDef Datasource definition. @throws RrdException Thrown if new datasource definition uses already used datasource name.
org.jrobin.data.DataProcessor.addDatasource()

Adds a custom, {@link org.jrobin.data.Plottable plottable} datasource (PDEF).The datapoints should be made available by a class extending {@link org.jrobin.data.Plottable Plottable} class.
@param name source name. @param plottable class that extends Plottable class and is suited for graphing.
org.mortbay.jetty.plus.DefaultDataSourceService.addDataSource()
org.rrd4j.core.RrdDef.addDatasource()
se.sics.mspsim.extutil.jfreechart.DataChart.addDataSource()

Examples of gov.nysenate.openleg.model.Agenda.addDataSource()

        for(Object next : senateData.getSenagendaOrSenagendavote()) {
            if (next instanceof XMLSenagenda) {
                Agenda agenda = handleXMLSenagenda(storage,(XMLSenagenda)next);


                if (agenda != null) {
                    agenda.addDataSource(file.getName());
                    agenda.setModifiedDate(modifiedDate);
                    if (agenda.getPublishDate() == null) {
                        agenda.setPublishDate(modifiedDate);
                    }
                    storage.set(agenda);

View Full Code Here

Examples of gov.nysenate.openleg.model.Agenda.addDataSource()


            } else if (next instanceof XMLSenagendavote) {
                Agenda agenda = handleXMLSenagendavote(storage, (XMLSenagendavote)next);


                if (agenda != null) {
                    agenda.addDataSource(file.getName());
                    agenda.setModifiedDate(modifiedDate);
                    if (agenda.getPublishDate() == null) {
                        agenda.setPublishDate(modifiedDate);
                    }
                    storage.set(agenda);

View Full Code Here

Examples of gov.nysenate.openleg.model.Bill.addDataSource()

                    case 'R': // Resolution text - handled by applyText
                    case 'T': applyText(data, bill, date); break;
                    case 'V': applyVoteMemo(data, bill, date); break;
                    default: throw new ParseError("Invalid Line Code "+block.getType() );
                }
                bill.addDataSource(sobiFile.getName());
                saveBill(bill, storage);
            }
            catch (ParseError e) {
                logger.error("ParseError at "+block.getLocation(), e);
            }

View Full Code Here

Examples of gov.nysenate.openleg.model.Calendar.addDataSource()

                } else {
                    logger.warn("Unknown calendar subdocument found: "+obj);
                }
            }


            calendar.addDataSource(file.getName());
            calendar.setModifiedDate(modifiedDate);
            if (calendar.getPublishDate() == null) {
                calendar.setPublishDate(modifiedDate);
            }
            storage.set(calendar);

View Full Code Here

Examples of gov.nysenate.openleg.model.Transcript.addDataSource()

        transcript.setTranscriptTextProcessed(fullTextProcessed.toString());
        String oid = transcript.getType().replaceAll(" ",  "-")+"-"+new SimpleDateFormat("MM-dd-yyyy_HH:mm").format(transcript.getTimeStamp());
        transcript.setId(oid);
        transcript.setModifiedDate(transcript.getTimeStamp());
        transcript.setPublishDate(transcript.getTimeStamp());
        transcript.addDataSource(file.getName());


        // Save the transcript
        String key = transcript.getYear()+"/transcript/"+transcript.getId();
        storage.set(transcript);

View Full Code Here

Examples of nexj.core.meta.xml.XMLMetadata.addDataSource()

      DataSourceType dstype = new DataSourceType("RelationalDatabase");


      dstype.setMetadata(metadata);
      dstype.setExporter(XMLRelationalMetadataExporter.class);
      m_database.setType(dstype);
      metadata.addDataSource(m_database);
      ((RelationalSchema)m_database.getSchema()).generateMetaclasses(getProperty("meta.prefix"), properties, null);


      for (Iterator itr = metadata.getMetaclassIterator(); itr.hasNext();)
      {
         Metaclass metaclass = (Metaclass)itr.next();

View Full Code Here

Examples of nexj.core.meta.xml.XMLMetadata.addDataSource()

      ds.setType(new DataSourceType("DataSourceType"));
      ds.getType().setMetadata(metadata);
      ds.getType().addAdapter(ds.getAdapter());
      ds.getType().addAdapter(invalid);
      ((RelationalDatabaseFragment)ds.getDefaultFragment()).setDatabase("Database");
      metadata.addDataSource(ds);
      manager.setSQLAppender(manager.new SQLWriterAppender(buf));
      schema.setVersionTable(new Table(schema));
      schema.getVersionTable().setName("VersionTable");
      schema.addTable(schema.getVersionTable());
      upgrade.setMetadata(metadata);

View Full Code Here

Examples of no.priv.garshol.duke.ConfigurationImpl.addDataSource()

    csv.addColumn(new Column("name", null, null, null));
    csv.addColumn(new Column("age", null, null, null));


    ConfigurationImpl cfg = new ConfigurationImpl();
    cfg.addDatabase(new InMemoryDatabase());
    cfg.addDataSource(0, csv);


    Comparator cmp = new ExactComparator();


    List<Property> props = new ArrayList();
    props.add(new PropertyImpl("id"));

View Full Code Here

Examples of org.apache.tez.dag.api.Vertex.addDataSource()

        for (POLoad ld : tezOp.getLoaderInfo().getLoads()) {


            // TODO: These should get the globalConf, or a merged version that
            // keeps settings like pig.maxCombinedSplitSize
            vertex.setLocationHint(VertexLocationHint.create(tezOp.getLoaderInfo().getInputSplitInfo().getTaskLocationHints()));
            vertex.addDataSource(ld.getOperatorKey().toString(),
                    DataSourceDescriptor.create(InputDescriptor.create(MRInput.class.getName())
                          .setUserPayload(UserPayload.create(MRRuntimeProtos.MRInputUserPayloadProto.newBuilder()
                          .setConfigurationBytes(TezUtils.createByteStringFromConf(payloadConf))
                          .setSplits(tezOp.getLoaderInfo().getInputSplitInfo().getSplitsProto()).build().toByteString().asReadOnlyByteBuffer())),
                    InputInitializerDescriptor.create(MRInputSplitDistributor.class.getName()), dag.getCredentials()));

View Full Code Here

Examples of org.apache.tez.dag.api.Vertex.addDataSource()

    UserPayload vertexUserPayload = TezUtils.createUserPayloadFromConf(stageConf);
    Vertex vertex = Vertex.create(vertexName,
        ProcessorDescriptor.create(processorName).setUserPayload(vertexUserPayload),
        numTasks, taskResource);
    if (isMap) {
      vertex.addDataSource("MRInput",
          configureMRInputWithLegacySplitsGenerated(stageConf, true));
    }
    // Map only jobs.
    if (stageNum == totalStages -1) {
      OutputDescriptor od = OutputDescriptor.create(MROutputLegacy.class.getName())

View Full Code Here

0 1 2 3 4

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.