@Test public void testValidConfigsInPushMode_withTopologyPicker() throws Exception{ Config c = ConfigFactory.parseResources(getClass().getClassLoader(), "replicationConfigTest/validCompleteDataset_PushMode2.conf").resolve(); ReplicationConfiguration rc = ReplicationConfiguration.buildFromConfig(c); this.checkReplicationConfig_Push(rc); }
public static ReplicationConfiguration buildFromConfig(Config input) throws InstantiationException, IllegalAccessException, ClassNotFoundException { Preconditions.checkArgument(input != null, "can not build ReplicationConfig from null"); Config config = input.resolve(); return new Builder().withReplicationMetaData(ReplicationMetaData.buildMetaData(config)) .withReplicationCopyMode(ReplicationCopyMode.getReplicationCopyMode(config)) .withSelectionConfig(config.getConfig("gobblin.selected.policy")) .withReplicationSource(config) .withReplicationReplica(config) .withDefaultDataFlowTopologyConfig_PullMode(config) .withDefaultDataFlowTopologyConfig_PushMode(config) .withDataFlowTopologyConfig(config) .withCopyRouteGenerator(config) .withDeleteTarget(config) .withVersionStrategyFromConfigStore(config) .withEnforceFileSizeMatchFromConfigStore(config) .withSchemaCheckEnabled(config) .build(); }
ReplicationConfiguration { public static ReplicationConfiguration buildFromConfig(Config input) throws InstantiationException, IllegalAccessException, ClassNotFoundException { Preconditions.checkArgument(input != null, "can not build ReplicationConfig from null"); Config config = input.resolve(); return new Builder().withReplicationMetaData(ReplicationMetaData.buildMetaData(config)) .withReplicationCopyMode(ReplicationCopyMode.getReplicationCopyMode(config)) .withSelectionConfig(config.getConfig("gobblin.selected.policy")) .withReplicationSource(config) .withReplicationReplica(config) .withDefaultDataFlowTopologyConfig_PullMode(config) .withDefaultDataFlowTopologyConfig_PushMode(config) .withDataFlowTopologyConfig(config) .withCopyRouteGenerator(config) .withDeleteTarget(config) .withVersionStrategyFromConfigStore(config) .withEnforceFileSizeMatchFromConfigStore(config) .withSchemaCheckEnabled(config) .build(); } }
ReplicationConfiguration { public static ReplicationConfiguration buildFromConfig(Config input) throws InstantiationException, IllegalAccessException, ClassNotFoundException { Preconditions.checkArgument(input != null, "can not build ReplicationConfig from null"); Config config = input.resolve(); return new Builder().withReplicationMetaData(ReplicationMetaData.buildMetaData(config)) .withReplicationCopyMode(ReplicationCopyMode.getReplicationCopyMode(config)) .withSelectionConfig(config.getConfig("gobblin.selected.policy")) .withReplicationSource(config) .withReplicationReplica(config) .withDefaultDataFlowTopologyConfig_PullMode(config) .withDefaultDataFlowTopologyConfig_PushMode(config) .withDataFlowTopologyConfig(config) .withCopyRouteGenerator(config) .withDeleteTarget(config) .withVersionStrategyFromConfigStore(config) .withEnforceFileSizeMatchFromConfigStore(config) .withSchemaCheckEnabled(config) .build(); } private  ReplicationConfiguration(Builder builder); }
ReplicationConfiguration { public static ReplicationConfiguration buildFromConfig(Config input) throws InstantiationException, IllegalAccessException, ClassNotFoundException { Preconditions.checkArgument(input != null, "can not build ReplicationConfig from null"); Config config = input.resolve(); return new Builder().withReplicationMetaData(ReplicationMetaData.buildMetaData(config)) .withReplicationCopyMode(ReplicationCopyMode.getReplicationCopyMode(config)) .withSelectionConfig(config.getConfig("gobblin.selected.policy")) .withReplicationSource(config) .withReplicationReplica(config) .withDefaultDataFlowTopologyConfig_PullMode(config) .withDefaultDataFlowTopologyConfig_PushMode(config) .withDataFlowTopologyConfig(config) .withCopyRouteGenerator(config) .withDeleteTarget(config) .withVersionStrategyFromConfigStore(config) .withEnforceFileSizeMatchFromConfigStore(config) .withSchemaCheckEnabled(config) .build(); } private  ReplicationConfiguration(Builder builder); static ReplicationConfiguration buildFromConfig(Config input); }
ReplicationConfiguration { public static ReplicationConfiguration buildFromConfig(Config input) throws InstantiationException, IllegalAccessException, ClassNotFoundException { Preconditions.checkArgument(input != null, "can not build ReplicationConfig from null"); Config config = input.resolve(); return new Builder().withReplicationMetaData(ReplicationMetaData.buildMetaData(config)) .withReplicationCopyMode(ReplicationCopyMode.getReplicationCopyMode(config)) .withSelectionConfig(config.getConfig("gobblin.selected.policy")) .withReplicationSource(config) .withReplicationReplica(config) .withDefaultDataFlowTopologyConfig_PullMode(config) .withDefaultDataFlowTopologyConfig_PushMode(config) .withDataFlowTopologyConfig(config) .withCopyRouteGenerator(config) .withDeleteTarget(config) .withVersionStrategyFromConfigStore(config) .withEnforceFileSizeMatchFromConfigStore(config) .withSchemaCheckEnabled(config) .build(); } private  ReplicationConfiguration(Builder builder); static ReplicationConfiguration buildFromConfig(Config input); static final String REPLICATION_COPY_MODE; static final String METADATA; static final String METADATA_JIRA; static final String METADATA_OWNER; static final String METADATA_NAME; static final String REPLICATION_SOURCE; static final String REPLICATION_REPLICAS; static final String REPLICATOIN_REPLICAS_LIST; static final String DATA_FLOW_TOPOLOGY; static final String DATA_FLOW_TOPOLOGY_ROUTES; static final String DEFAULT_DATA_FLOW_TOPOLOGIES_PUSHMODE; static final String DEFAULT_DATA_FLOW_TOPOLOGIES_PULLMODE; static final String REPLICATION_DATA_CATETORY_TYPE; static final String REPLICATION_DATA_FINITE_INSTANCE; static final String COPY_SCHEMA_CHECK_ENABLED; static final boolean DEFAULT_COPY_SCHEMA_CHECK_ENABLED; static final String DELETE_TARGET_IFNOT_ON_SOURCE; static final String DATA_FLOW_TOPOLOGY_PICKER_CLASS; static final String DEFAULT_DATA_FLOW_TOPOLOGY_PICKER_CLASS; static final ClassAliasResolver<DataFlowTopologyPickerBySource> dataFlowTopologyPickerResolver; static final String END_POINT_FACTORY_CLASS; static final String DEFAULT_END_POINT_FACTORY_CLASS; static final ClassAliasResolver<EndPointFactory> endPointFactoryResolver; static final String COPYROUTE_OPTIMIZER_CLASS; static final String DEFAULT_COPYROUTE_OPTIMIZER_CLASS; static final ClassAliasResolver<CopyRouteGenerator> copyRouteGeneratorResolver; }