Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
 /*
  * Copyright (c) 2013, Cloudera, Inc. All Rights Reserved.
  *
  * Cloudera, Inc. licenses this file to you under the Apache License,
  * Version 2.0 (the "License"). You may not use this file except in
  * compliance with the License. You may obtain a copy of the License at
  *
  *     http://www.apache.org/licenses/LICENSE-2.0
  *
 * This software is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR
 * CONDITIONS OF ANY KIND, either express or implied. See the License for
 * the specific language governing permissions and limitations under the
 * License.
 */
package com.cloudera.oryx.kmeans.serving.generation;
public final class KMeansGenerationManager extends GenerationManager {
  private static final Logger log = LoggerFactory.getLogger(KMeansGenerationManager.class);
  private int modelGeneration;
  public KMeansGenerationManager(File appendTempDirthrows IOException {
    super(appendTempDir);
  }

  

Returns:
an instance of the latest Generation that has been made available by the implementation.
    return ;
  }
  protected void loadRecentModel(int mostRecentModelGenerationthrows IOException {
    if (mostRecentModelGeneration <= ) {
      return;
    }
    if ( == ) {
      .info("Most recent generation {} is the first available one"mostRecentModelGeneration);
    } else {
      .info("Most recent generation {} is newer than current {}"mostRecentModelGeneration);
    }
    File modelPMMLFile = File.createTempFile("model-"".pmml.gz");
    modelPMMLFile.deleteOnExit();
    IOUtils.delete(modelPMMLFile);
    String instanceDir = ConfigUtils.getDefaultConfig().getString("model.instance-dir");
    String generationPrefix = Namespaces.getInstanceGenerationPrefix(instanceDirmostRecentModelGeneration);
    String modelPMMLKey = generationPrefix + "model.pmml.gz";
    Store.get().download(modelPMMLKeymodelPMMLFile);
    .info("Loading model description from {}"modelPMMLKey);
    PMML pmmlModel = KMeansPMML.read(modelPMMLFile);
    IOUtils.delete(modelPMMLFile);
    .info("Loaded model description");
     = mostRecentModelGeneration;
    //TODO: handle multi-cluster case
     = new Generation((ClusteringModelpmmlModel.getModels().get(0));
  }
  public synchronized void append(CharSequence examplethrows IOException {
    Writer appender = getAppender();
    if (appender != null) {
      appender.append(example + "\n");
    }
  }
New to GrepCode? Check out our FAQ X