Examples of com.linkedin.databus2.relay.config.PhysicalSourceConfig.addSource()

Package com.linkedin.databus2.relay.config

Class com.linkedin.databus2.relay.config.PhysicalSourceConfig

Examples of com.linkedin.databus2.relay.config.PhysicalSourceConfig.addSource()

com.linkedin.databus2.relay.config.PhysicalSourceConfig.addSource()

      LogicalSourceConfig lc = new LogicalSourceConfig();
      lc.setId(sourceIds[i]);
      lc.setName(sourceNames[i]);
      lc.setPartitionFunction(partitionFunction);
      lc.setUri(pPartName + "." + sourceNames[i]); // this format is expected by GG
      pc.addSource(lc);
    }




    return pc.build();
  }

View Full Code Here

      LogicalSourceConfig c = new LogicalSourceConfig();
      c.setId(manager.getSrcId(srcName));
      c.setName(srcName);
      c.setUri(dbName + "." + dbObjectName);
      c.setPartitionFunction("constant:1");
      config.addSource(c);
    }


    DatabusRelaySourcesInFiles relaySourcesInFiles = new DatabusRelaySourcesInFiles(outputDir);
    relaySourcesInFiles.add(dbName, config);
    boolean success = relaySourcesInFiles.save();

View Full Code Here

      lConf.setId(lid);
      lConf.setName(srcName);
      // this is table name in the oracle source world
      lConf.setUri(srcName);
      lConf.setPartitionFunction("constant:1");
      pConfig.addSource(lConf);
      int relayPort = Utils.getAvailablePort(11994);
      final int relayId = 666;
      HttpRelay.Config httpRelayConfig = new HttpRelay.Config();
      ServerContainer.Config containerConfig = DatabusRelayTestUtil.createContainerConfig(relayId, relayPort);
      DbusEventBuffer.Config bufferConfig = DatabusRelayTestUtil.createBufferConfig(

View Full Code Here

    retriesConf.setInitSleep(pollIntervalMs);
    pConfig.setRetries(retriesConf);


    for(LogicalSourceConfig lConf : lSourceConfigs)
    {
      pConfig.addSource(lConf);
    }


    return pConfig;
  }

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.