import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.cloudera.oryx.api.speed.SpeedModelManager;
import com.cloudera.oryx.api.TopicProducer;
import com.cloudera.oryx.lambda.TopicProducerImpl;
<BUG>public final class SpeedLayerUpdate<K,M,U> implements Function<JavaPairRDD<K,M>,Void> {
private static final Logger log = LoggerFactory.getLogger(SpeedLayerUpdate.class);</BUG>
private final SpeedModelManager<K,M,U> modelManager;
private final String updateBroker;
<BUG>private final String updateTopic;
public SpeedLayerUpdate(SpeedModelManager<K,M,U> modelManager,
String updateBroker,
String updateTopic) {</BUG>
this.modelManager = modelManager;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import com.cloudera.oryx.api.speed.SpeedModelManager;
import com.cloudera.oryx.api.TopicProducer;
import com.cloudera.oryx.lambda.TopicProducerImpl;
final class SpeedLayerUpdate<K,M,U> implements Function<JavaPairRDD<K,M>,Void> {
private static final Logger log = LoggerFactory.getLogger(SpeedLayerUpdate.class);
private final SpeedModelManager<K,M,U> modelManager;
private final String updateBroker;
private final String updateTopic;
SpeedLayerUpdate(SpeedModelManager<K,M,U> modelManager, String updateBroker, String updateTopic) {
this.modelManager = modelManager;
