本文整理汇总了Java中org.knime.core.node.ExecutionMonitor类的典型用法代码示例。如果您正苦于以下问题：Java ExecutionMonitor类的具体用法？Java ExecutionMonitor怎么用？Java ExecutionMonitor使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
ExecutionMonitor类属于org.knime.core.node包，在下文中一共展示了ExecutionMonitor类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: loadInternals
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
/**
* {@inheritDoc}
*/
@Override
protected void loadInternals(final File internDir,
final ExecutionMonitor exec) throws IOException,
CanceledExecutionException {
// TODO load internal data.
// Everything handed to output ports is loaded automatically (data
// returned by the execute method, models loaded in loadModelContent,
// and user settings set through loadSettingsFrom - is all taken care
// of). Load here only the other internals that need to be restored
// (e.g. data used by the views).
logger.info("---------------- ENTRANDO NO MÉTODO loadInternals()-----------------------");
logger.info("String m_selStr: " + m_selStr.toString());
}
开发者ID:daniacs，项目名称:knime_brtagger，代码行数:19，代码来源:BrTaggerNodeModel.java
示例2: loadInternals
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
/**
* {@inheritDoc}
*/
@Override
protected void loadInternals(final File nodeInternDir,
final ExecutionMonitor exec)
throws IOException, CanceledExecutionException {
final String path = nodeInternDir.getAbsolutePath();
final File file = new File(path + "LoopEndNode.intern");
final DataInputStream is =
new DataInputStream(new FileInputStream(file));
final int numClasses = is.readInt();
for (int i = 0; i < numClasses; i++) {
m_classModel.addClass(is.readUTF());
}
is.close();
}
开发者ID:knime，项目名称:knime-activelearning，代码行数:23，代码来源:ActiveLearnLoopEndNodeModel.java
示例3: saveInternals
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
/**
* {@inheritDoc}
*/
@Override
protected void saveInternals(final File nodeInternDir,
final ExecutionMonitor exec)
throws IOException, CanceledExecutionException {
final String path = nodeInternDir.getAbsolutePath();
final File file = new File(path + "LoopEndNode.intern");
// save the defined classes
final DataOutputStream os =
new DataOutputStream(new FileOutputStream(file));
os.writeInt(m_classModel.getSize());
for (final String clsName : m_classModel.getDefinedClasses()) {
os.writeUTF(clsName);
}
os.close();
}
开发者ID:knime，项目名称:knime-activelearning，代码行数:24，代码来源:ActiveLearnLoopEndNodeModel.java
示例4: createCellFactory
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
/**
* Creates a CellFactory for the class column.
*
* @param colName
* the name of the class column
* @return CellFactory for the class column.
*/
private CellFactory createCellFactory(final String colName) {
return new CellFactory() {
@Override
public void setProgress(final int curRowNr, final int rowCount,
final RowKey lastKey, final ExecutionMonitor exec) {
exec.setProgress((double) curRowNr / rowCount);
}
@Override
public DataColumnSpec[] getColumnSpecs() {
return new DataColumnSpec[] {
new DataColumnSpecCreator(colName, StringCell.TYPE)
.createSpec() };
}
@Override
public DataCell[] getCells(final DataRow row) {
throw new IllegalStateException(
new IllegalAccessException("This shouldn't be called"));
}
};
}
开发者ID:knime，项目名称:knime-activelearning，代码行数:31，代码来源:ActiveLearnLoopStartNodeModel.java
示例5: createResRearranger
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
private ColumnRearranger createResRearranger(final DataTableSpec inSpec) {
final ColumnRearranger rearranger = new ColumnRearranger(inSpec);
rearranger.append(new CellFactory() {
@Override
public void setProgress(final int curRowNr, final int rowCount,
final RowKey lastKey, final ExecutionMonitor exec) {
exec.setProgress((double) curRowNr / rowCount);
}
@Override
public DataColumnSpec[] getColumnSpecs() {
return new DataColumnSpec[] {
new DataColumnSpecCreator("Graph Density Score",
DoubleCell.TYPE).createSpec() };
}
@Override
public DataCell[] getCells(final DataRow row) {
return new DataCell[] { new DoubleCell(
m_dataPoints.get(row.getKey()).getDensity()) };
}
});
return rearranger;
}
开发者ID:knime，项目名称:knime-activelearning，代码行数:27，代码来源:GraphDensityScorerNodeModel.java
示例6: testWithoutWeights
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
@Test
public void testWithoutWeights() throws PersistenceException, CanceledExecutionException {
Mockito.when(view.getEdgeWeight(e12)).thenReturn(1.0);
Mockito.when(view.getEdgeWeight(e13)).thenReturn(1.0);
Mockito.when(view.getEdgeWeight(e14)).thenReturn(1.0);
Mockito.when(view.getEdgeWeight(e15)).thenReturn(1.0);
Mockito.when(view.getEdgeWeight(e23)).thenReturn(1.0);
Mockito.when(view.getEdgeWeight(e34)).thenReturn(1.0);
ClosenessAnalyzerType analyzer = new ClosenessAnalyzerType();
analyzer.initializeInternal(view, new ExecutionMonitor());
assertEquals(1.0 / 4.0, analyzer.numericAnalyzeInternal(new ExecutionMonitor(), view, n1)[0], 0.0);
assertEquals(1.0 / 6.0, analyzer.numericAnalyzeInternal(new ExecutionMonitor(), view, n2)[0], 0.0);
assertEquals(1.0 / 5.0, analyzer.numericAnalyzeInternal(new ExecutionMonitor(), view, n3)[0], 0.0);
assertEquals(1.0 / 6.0, analyzer.numericAnalyzeInternal(new ExecutionMonitor(), view, n4)[0], 0.0);
assertEquals(1.0 / 7.0, analyzer.numericAnalyzeInternal(new ExecutionMonitor(), view, n5)[0], 0.0);
}
开发者ID:SiLeBAT，项目名称:BfROpenLab，代码行数:20，代码来源:ClosenessAnalyzerTypeTest.java
示例7: testWithWeights
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
@Test
public void testWithWeights() throws PersistenceException, CanceledExecutionException {
Mockito.when(view.getEdgeWeight(e12)).thenReturn(2.0);
Mockito.when(view.getEdgeWeight(e13)).thenReturn(2.0);
Mockito.when(view.getEdgeWeight(e14)).thenReturn(2.0);
Mockito.when(view.getEdgeWeight(e15)).thenReturn(2.0);
Mockito.when(view.getEdgeWeight(e23)).thenReturn(1.0);
Mockito.when(view.getEdgeWeight(e34)).thenReturn(1.0);
ClosenessAnalyzerType analyzer = new ClosenessAnalyzerType();
analyzer.initializeInternal(view, new ExecutionMonitor());
assertEquals(1.0 / 8.0, analyzer.numericAnalyzeInternal(new ExecutionMonitor(), view, n1)[0], 0.0);
assertEquals(1.0 / 9.0, analyzer.numericAnalyzeInternal(new ExecutionMonitor(), view, n2)[0], 0.0);
assertEquals(1.0 / 8.0, analyzer.numericAnalyzeInternal(new ExecutionMonitor(), view, n3)[0], 0.0);
assertEquals(1.0 / 9.0, analyzer.numericAnalyzeInternal(new ExecutionMonitor(), view, n4)[0], 0.0);
assertEquals(1.0 / 14.0, analyzer.numericAnalyzeInternal(new ExecutionMonitor(), view, n5)[0], 0.0);
}
开发者ID:SiLeBAT，项目名称:BfROpenLab，代码行数:20，代码来源:ClosenessAnalyzerTypeTest.java
示例8: initializeInternal
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
@Override
protected void initializeInternal(KPartiteGraphView<PersistentObject, Partition> view, ExecutionMonitor exec)
throws PersistenceException, CanceledExecutionException {
super.initializeInternal(view, exec);
numberOfNodes = (int) view.getNoOfNodes();
numberOfEdges = (int) view.getNoOfEdges();
edgeWeights.clear();
incidentNodes.clear();
outgoingEdges.clear();
for (PersistentObject edge : view.getEdges()) {
edgeWeights.put(edge.getId(), view.getEdgeWeight(edge));
incidentNodes.put(edge.getId(),
view.getIncidentNodes(edge).stream().map(o -> o.getId()).collect(Collectors.toList()));
}
if (edgeWeights.values().stream().allMatch(v -> v == 1.0)) {
edgeWeights.clear();
}
for (PersistentObject node : view.getNodes()) {
outgoingEdges.put(node.getId(),
view.getOutgoingEdges(node).stream().map(o -> o.getId()).collect(Collectors.toList()));
}
}
开发者ID:SiLeBAT，项目名称:BfROpenLab，代码行数:26，代码来源:ClosenessAnalyzerType.java
示例9: saveInternals
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
/**
* {@inheritDoc}
*/
@Override
protected void saveInternals(final File internDir,
final ExecutionMonitor exec) throws IOException,
CanceledExecutionException {
// TODO save internal models.
// Everything written to output ports is saved automatically (data
// returned by the execute method, models saved in the saveModelContent,
// and user settings saved through saveSettingsTo - is all taken care
// of). Save here only the other internals that need to be preserved
// (e.g. data used by the views).
logger.info("---------------- ENTRANDO NO MÉTODO saveInternals()-----------------------");
logger.info("String m_selStr: " + m_selStr.toString());
}
开发者ID:daniacs，项目名称:knime_brtagger，代码行数:18，代码来源:BrTaggerNodeModel.java
示例10: loadInternals
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
/**
* {@inheritDoc}
*/
@Override
protected void loadInternals(final File nodeInternDir,
final ExecutionMonitor exec)
throws IOException, CanceledExecutionException {
//
}
开发者ID:knime，项目名称:knime-activelearning，代码行数:10，代码来源:ActiveLearnLoopStartNodeModel.java
示例11: saveInternals
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
/**
* {@inheritDoc}
*/
@Override
protected void saveInternals(final File nodeInternDir,
final ExecutionMonitor exec)
throws IOException, CanceledExecutionException {
//
}
开发者ID:knime，项目名称:knime-activelearning，代码行数:10，代码来源:ActiveLearnLoopStartNodeModel.java
示例12: createResRearranger
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
private ColumnRearranger createResRearranger(final DataTableSpec inSpec) {
final ColumnRearranger rearranger = new ColumnRearranger(inSpec);
rearranger.append(new CellFactory() {
@Override
public void setProgress(final int curRowNr, final int rowCount,
final RowKey lastKey, final ExecutionMonitor exec) {
exec.setProgress((double) curRowNr / rowCount);
}
@Override
public DataColumnSpec[] getColumnSpecs() {
return new DataColumnSpec[] {
new DataColumnSpecCreator("Potential", DoubleCell.TYPE)
.createSpec(),
new DataColumnSpecCreator("Entropy", DoubleCell.TYPE)
.createSpec(),
new DataColumnSpecCreator("Score", DoubleCell.TYPE)
.createSpec() };
}
@Override
public DataCell[] getCells(final DataRow row) {
return new DataCell[] {
new DoubleCell(
m_dataPoints.get(row.getKey()).getPotential()),
new DoubleCell(
m_dataPoints.get(row.getKey()).getEntropy()),
new DoubleCell(
m_dataPoints.get(row.getKey()).getScore()) };
}
});
return rearranger;
}
开发者ID:knime，项目名称:knime-activelearning，代码行数:37，代码来源:PBACScorerNodeModel.java
示例13: loadInternals
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
/**
* {@inheritDoc}
*/
@Override
protected void loadInternals(final File nodeInternDir,
final ExecutionMonitor exec)
throws IOException, CanceledExecutionException {
// Nothing to do here
}
开发者ID:knime，项目名称:knime-activelearning，代码行数:10，代码来源:PBACScorerNodeModel.java
示例14: saveInternals
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
/**
* {@inheritDoc}
*/
@Override
protected void saveInternals(final File nodeInternDir,
final ExecutionMonitor exec)
throws IOException, CanceledExecutionException {
// Nothing to do here
}
开发者ID:knime，项目名称:knime-activelearning，代码行数:10，代码来源:PBACScorerNodeModel.java
示例15: createResRearranger
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
private ColumnRearranger createResRearranger(final DataTableSpec inSpec) {
final ColumnRearranger rearranger = new ColumnRearranger(inSpec);
rearranger.append(new CellFactory() {
@Override
public void setProgress(final int curRowNr, final int rowCount,
final RowKey lastKey, final ExecutionMonitor exec) {
exec.setProgress((double) curRowNr / rowCount);
}
@Override
public DataColumnSpec[] getColumnSpecs() {
return new DataColumnSpec[] {
new DataColumnSpecCreator("Node Potential Score",
DoubleCell.TYPE).createSpec() };
}
@Override
public DataCell[] getCells(final DataRow row) {
return new DataCell[] { new DoubleCell(
m_dataPoints.get(row.getKey()).getPotential()) };
}
});
return rearranger;
}
开发者ID:knime，项目名称:knime-activelearning，代码行数:29，代码来源:NodePotentialScorerNodeModel.java
示例16: LocalNoveltyScorer
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
public LocalNoveltyScorer(final ExecutionMonitor executionMonitor,
final RealMatrix m_globalKernelMatrix,
final RealMatrix m_trainingKernelMatrix, final String[] m_labels,
final int m_numNeighbors, final boolean m_normalize) {
super();
m_exec = executionMonitor;
this.m_globalKernelMatrix = m_globalKernelMatrix;
this.m_trainingKernelMatrix = m_trainingKernelMatrix;
this.m_labels = m_labels;
this.m_numNeighbors = m_numNeighbors;
this.m_normalize = m_normalize;
}
开发者ID:knime，项目名称:knime-activelearning，代码行数:13，代码来源:LocalNoveltyScorer.java
示例17: load
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
@Override
protected void load(final PortObjectZipInputStream in,
final PortObjectSpec spec, final ExecutionMonitor exec)
throws IOException, CanceledExecutionException {
ObjectInputStream oi = null;
KNFST knfst = null;
try {
// load classifier
final ZipEntry zentry = in.getNextEntry();
assert zentry.getName().equals("knfst.objectout");
oi = new ObjectInputStream(new NonClosableInputStream.Zip(in));
knfst = (KNFST) Class.forName(oi.readUTF()).newInstance();
knfst.readExternal(oi);
} catch (final IOException ioe) {
} catch (final ClassNotFoundException cnf) {
} catch (final InstantiationException | IllegalAccessException e) {
e.printStackTrace();
} finally {
if (oi != null) {
try {
oi.close();
} catch (final Exception e) {
}
}
}
m_knfstModel = knfst;
m_spec = (KNFSTPortObjectSpec) spec;
}
开发者ID:knime，项目名称:knime-activelearning，代码行数:32，代码来源:KNFSTPortObject.java
示例18: loadInternals
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
/**
* {@inheritDoc}
*/
@Override
protected void loadInternals(final File internDir,
final ExecutionMonitor exec) throws IOException,
CanceledExecutionException {
// TODO load internal data.
// Everything handed to output ports is loaded automatically (data
// returned by the execute method, models loaded in loadModelContent,
// and user settings set through loadSettingsFrom - is all taken care
// of). Load here only the other internals that need to be restored
// (e.g. data used by the views).
}
开发者ID:knime，项目名称:knime-sdk-setup，代码行数:17，代码来源:MyExampleNodeNodeModel.java
示例19: saveInternals
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
/**
* {@inheritDoc}
*/
@Override
protected void saveInternals(final File internDir,
final ExecutionMonitor exec) throws IOException,
CanceledExecutionException {
// TODO save internal models.
// Everything written to output ports is saved automatically (data
// returned by the execute method, models saved in the saveModelContent,
// and user settings saved through saveSettingsTo - is all taken care
// of). Save here only the other internals that need to be preserved
// (e.g. data used by the views).
}
开发者ID:knime，项目名称:knime-sdk-setup，代码行数:17，代码来源:MyExampleNodeNodeModel.java
示例20: setProgress
import org.knime.core.node.ExecutionMonitor; //导入依赖的package包/类
/**
* {@inheritDoc}
*/
@Override
public void setProgress(final int curRowNr, final int rowCount,
final RowKey lastKey,
final ExecutionMonitor exec) {
exec.setProgress(curRowNr / (double)rowCount, "Processed row "
+ curRowNr + " (\"" + lastKey + "\")");
}
开发者ID:pavloff-de，项目名称:spark4knime，代码行数:11，代码来源:JavaSnippetCellFactory.java
注：本文中的org.knime.core.node.ExecutionMonitor类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论