List of fetchLatestVersionedSchemaBySourceName() Examples

Examples of fetchLatestVersionedSchemaBySourceName()

com.linkedin.databus2.schemas.FileSystemSchemaRegistryService.fetchLatestVersionedSchemaBySourceName()
Fetch latest event schema object for a given event type @param databusSourceName Source name @return Latest event schema object
com.linkedin.databus2.schemas.SchemaRegistryService.fetchLatestVersionedSchemaBySourceName()
Fetch latest event schema object for a given event type @param databusSourceName Source name @return Latest event schema object

Examples of com.linkedin.databus2.schemas.FileSystemSchemaRegistryService.fetchLatestVersionedSchemaBySourceName()

    config.setName(dbName);
    config.setUri(uri);
    for (String srcName : srcNames)
    {
      VersionedSchema schema = null;
      schema = s.fetchLatestVersionedSchemaBySourceName(srcName);


      String dbObjectName = SchemaHelper.getMetaField(schema.getSchema(), "dbFieldName");


      LogicalSourceConfig c = new LogicalSourceConfig();
      c.setId(manager.getSrcId(srcName));

View Full Code Here

Examples of com.linkedin.databus2.schemas.SchemaRegistryService.fetchLatestVersionedSchemaBySourceName()

              pairs.getKey(), s, null);
          vSchemaSet.add(vs);
        }


        /* Try and identify the schema key */
        VersionedSchema vschema = schemaRegistry
            .fetchLatestVersionedSchemaBySourceName(source.getSourceName());
        Schema schema = Schema.parse(vschema.getSchema().toString());
        LOG.info("Schema =" + vschema.getSchema() + "version="
            + vschema.getVersion() + " name=" + vschema.getSchemaBaseName());

View Full Code Here

Examples of com.linkedin.databus2.schemas.SchemaRegistryService.fetchLatestVersionedSchemaBySourceName()

    VersionedSchema vs =
        new VersionedSchema(new VersionedSchemaId("source1", (short) 3), s, null);


    // mock for schema registry
    SchemaRegistryService srs = EasyMock.createMock(SchemaRegistryService.class);
    EasyMock.expect(srs.fetchLatestVersionedSchemaBySourceName("source1"))
            .andReturn(vs)
            .anyTimes();
    EasyMock.expect(srs.fetchLatestVersionedSchemaBySourceName("source2"))
            .andReturn(vs)
            .anyTimes();

View Full Code Here

Examples of com.linkedin.databus2.schemas.SchemaRegistryService.fetchLatestVersionedSchemaBySourceName()

    // mock for schema registry
    SchemaRegistryService srs = EasyMock.createMock(SchemaRegistryService.class);
    EasyMock.expect(srs.fetchLatestVersionedSchemaBySourceName("source1"))
            .andReturn(vs)
            .anyTimes();
    EasyMock.expect(srs.fetchLatestVersionedSchemaBySourceName("source2"))
            .andReturn(vs)
            .anyTimes();
    EasyMock.expect(srs.fetchLatestVersionedSchemaBySourceName(null)).andReturn(vs);


    // mock for MaxSCNReadWriter

View Full Code Here

Examples of com.linkedin.databus2.schemas.SchemaRegistryService.fetchLatestVersionedSchemaBySourceName()

            .andReturn(vs)
            .anyTimes();
    EasyMock.expect(srs.fetchLatestVersionedSchemaBySourceName("source2"))
            .andReturn(vs)
            .anyTimes();
    EasyMock.expect(srs.fetchLatestVersionedSchemaBySourceName(null)).andReturn(vs);


    // mock for MaxSCNReadWriter
    MaxSCNReaderWriter mscn = EasyMock.createMock(MaxSCNReaderWriter.class);
    EasyMock.expect(mscn.getMaxScn()).andReturn((long) -2).atLeastOnce();
    mscn.saveMaxScn(EasyMock.anyLong());

View Full Code Here

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.