weka.filters.Filter.numPendingOutput()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(7.7k)|赞(0)|评价(0)|浏览(109)

本文整理了Java中weka.filters.Filter.numPendingOutput()方法的一些代码示例,展示了Filter.numPendingOutput()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Filter.numPendingOutput()方法的具体详情如下:
包路径:weka.filters.Filter
类名称:Filter
方法名:numPendingOutput

Filter.numPendingOutput介绍

[英]Returns the number of instances pending output
[中]返回挂起输出的实例数

代码示例

代码示例来源:origin: nz.ac.waikato.cms.weka/distributedWekaBase

@Override
public int numPendingOutput() {
 return m_delegate.numPendingOutput();
}

代码示例来源:origin: nz.ac.waikato.cms.weka/distributedWekaBase

/**
 * Updates a classifier using the given instance.
 * 
 * @param instance the instance to included
 * @throws Exception if instance could not be incorporated successfully or not
 *           successfully filtered
 */
@Override
public void updateClassifier(Instance instance) throws Exception {
 if (m_Filter.numPendingOutput() > 0) {
  throw new Exception("Filter output queue not empty!");
 }
 if (!m_Filter.input(instance)) {
  if (m_Filter.numPendingOutput() > 0) {
   throw new Exception("Filter output queue not empty!");
  }
  // nothing to train on if the filter does not make an instance available
  return;
  // throw new
  // Exception("Filter didn't make the train instance immediately available!");
 }
 m_Filter.batchFinished();
 Instance newInstance = m_Filter.output();
 ((UpdateableClassifier) m_Classifier).updateClassifier(newInstance);
}

代码示例来源:origin: Waikato/weka-trunk

/**
 * Classifies a given instance after filtering.
 * 
 * @param instance the instance to be classified
 * @return the class distribution for the given instance
 * @throws Exception if instance could not be classified successfully
 */
@Override
public double[] distributionForInstance(Instance instance) throws Exception {
 if (m_Filter.numPendingOutput() > 0) {
  throw new Exception("Filter output queue not empty!");
 }
 if (!m_Filter.input(instance)) {
  throw new Exception(
   "Filter didn't make the test instance immediately available!");
 }
 m_Filter.batchFinished();
 Instance newInstance = m_Filter.output();
 return m_Clusterer.distributionForInstance(newInstance);
}

代码示例来源:origin: nz.ac.waikato.cms.weka/weka-stable

/**
 * Classifies a given instance after filtering.
 * 
 * @param instance the instance to be classified
 * @return the class distribution for the given instance
 * @throws Exception if instance could not be classified successfully
 */
@Override
public double[] distributionForInstance(Instance instance) throws Exception {
 if (m_Filter.numPendingOutput() > 0) {
  throw new Exception("Filter output queue not empty!");
 }
 if (!m_Filter.input(instance)) {
  throw new Exception(
   "Filter didn't make the test instance immediately available!");
 }
 m_Filter.batchFinished();
 Instance newInstance = m_Filter.output();
 return m_Clusterer.distributionForInstance(newInstance);
}

代码示例来源:origin: nz.ac.waikato.cms.weka/distributedWekaBase

@Override
public void updateClassifier(Instance instance) throws Exception {
 if (getPreConstructedFilter().numPendingOutput() > 0) {
  throw new Exception("Filter output queue not empty!");
 }
 if (!getPreConstructedFilter().input(instance)) {
  // throw new Exception(
  // "Can only use PreconstructedFilters that will produce an output "
  // + "Instance immediately when given an input Instance.");
  // only allow a filter to consume an instance and not buffer anything
  if (getPreConstructedFilter().numPendingOutput() > 0) {
   throw new Exception("Filter output queue not empty!");
  }
  // nothing to train on if filter does not make instance available
  return;
 }
 getPreConstructedFilter().batchFinished();
 Instance filtered = getPreConstructedFilter().output();
 ((UpdateableClassifier) getClassifier()).updateClassifier(filtered);
}

代码示例来源:origin: Waikato/weka-trunk

if (m_Filter.numPendingOutput() > 0) {
 throw new Exception("Filter output queue not empty!");

代码示例来源:origin: nz.ac.waikato.cms.weka/weka-stable

if (m_Filter.numPendingOutput() > 0) {
 throw new Exception("Filter output queue not empty!");

代码示例来源:origin: nz.ac.waikato.cms.weka/weka-stable

return (numPendingOutput() != 0);

代码示例来源:origin: Waikato/weka-trunk

return (numPendingOutput() != 0);

代码示例来源:origin: Waikato/weka-trunk

while (m_Filter.numPendingOutput() > 0) {
result.add(m_Filter.output());
  if (VERBOSE) System.err.println("Getting output instance");

代码示例来源:origin: nz.ac.waikato.cms.weka/weka-stable

while (m_Filter.numPendingOutput() > 0) {
result.add(m_Filter.output());
  if (VERBOSE) System.err.println("Getting output instance");

代码示例来源:origin: nz.ac.waikato.cms.weka/weka-stable

result = m_Filter.getOutputFormat();
while (m_Filter.numPendingOutput() > 0) {
 result.add(m_Filter.output());

代码示例来源:origin: Waikato/weka-trunk

result = m_Filter.getOutputFormat();
while (m_Filter.numPendingOutput() > 0) {
 result.add(m_Filter.output());

代码示例来源:origin: Waikato/weka-trunk

result = m_Filter.getOutputFormat();
assertNotNull("Output format defined (1. batch)", result);
assertTrue("Pending output instances (1. batch)", m_Filter.numPendingOutput() > 0);
 while (m_Filter.numPendingOutput() > 0)
result.add(m_Filter.output());
result = m_Filter.getOutputFormat();
assertNotNull("Output format defined (2. batch)", result);
assertTrue("Pending output instances (2. batch)", m_Filter.numPendingOutput() > 0);
 while (m_Filter.numPendingOutput() > 0)
result.add(m_Filter.output());

代码示例来源:origin: nz.ac.waikato.cms.weka/weka-stable

result = m_Filter.getOutputFormat();
assertNotNull("Output format defined (1. batch)", result);
assertTrue("Pending output instances (1. batch)", m_Filter.numPendingOutput() > 0);
 while (m_Filter.numPendingOutput() > 0)
result.add(m_Filter.output());
result = m_Filter.getOutputFormat();
assertNotNull("Output format defined (2. batch)", result);
assertTrue("Pending output instances (2. batch)", m_Filter.numPendingOutput() > 0);
 while (m_Filter.numPendingOutput() > 0)
result.add(m_Filter.output());

代码示例来源:origin: nz.ac.waikato.cms.weka/weka-stable

result = m_Filter.getOutputFormat();
assertNotNull("Output format defined (1. batch)", result);
assertTrue("Pending output instances (1. batch)", m_Filter.numPendingOutput() > 0);
 while (m_Filter.numPendingOutput() > 0)
result.add(m_Filter.output());
result = m_Filter.getOutputFormat();
assertNotNull("Output format defined (2. batch)", result);
assertTrue("Pending output instances (2. batch)", m_Filter.numPendingOutput() > 0);
 while (m_Filter.numPendingOutput() > 0)
result.add(m_Filter.output());

代码示例来源:origin: nz.ac.waikato.cms.weka/weka-stable

result = m_Filter.getOutputFormat();
assertNotNull("Output format defined (1. batch)", result);
assertTrue("Pending output instances (1. batch)", m_Filter.numPendingOutput() > 0);
 while (m_Filter.numPendingOutput() > 0)
result.add(m_Filter.output());
result = m_Filter.getOutputFormat();
assertNotNull("Output format defined (2. batch)", result);
assertTrue("Pending output instances (2. batch)", m_Filter.numPendingOutput() > 0);
 while (m_Filter.numPendingOutput() > 0)
result.add(m_Filter.output());

代码示例来源:origin: Waikato/weka-trunk

result = m_Filter.getOutputFormat();
assertNotNull("Output format defined (1. batch)", result);
assertTrue("Pending output instances (1. batch)", m_Filter.numPendingOutput() > 0);
 while (m_Filter.numPendingOutput() > 0)
result.add(m_Filter.output());
result = m_Filter.getOutputFormat();
assertNotNull("Output format defined (2. batch)", result);
assertTrue("Pending output instances (2. batch)", m_Filter.numPendingOutput() > 0);
 while (m_Filter.numPendingOutput() > 0)
result.add(m_Filter.output());

代码示例来源:origin: nz.ac.waikato.cms.weka/weka-stable

Instances structureCopy =
 m_streamingFilter.getOutputFormat().stringFreeStructure();
while (m_streamingFilter.numPendingOutput() > 0) {
 getStepManager().throughputUpdateStart();
 Instance filteredI = m_streamingFilter.output();

代码示例来源:origin: Waikato/weka-trunk

Instances structureCopy =
 m_streamingFilter.getOutputFormat().stringFreeStructure();
while (m_streamingFilter.numPendingOutput() > 0) {
 getStepManager().throughputUpdateStart();
 Instance filteredI = m_streamingFilter.output();

相关文章