Package io.outofprintmagazine.corpus.batch

Class ThreadedCorpusBatchStep

java.lang.Object

io.outofprintmagazine.corpus.batch.CorpusBatchStep

io.outofprintmagazine.corpus.batch.ThreadedCorpusBatchStep

All Implemented Interfaces:

ICorpusBatchStep

public class ThreadedCorpusBatchStep
extends CorpusBatchStep
implements ICorpusBatchStep

Field Summary

Fields

Modifier and Type	Field	Description
protected int	maxThreads
protected String	taskClass
protected Map<com.fasterxml.jackson.databind.node.ObjectNode,ThreadedCorpusBatchStepTask>	tasks
protected List<Thread>	threads

Fields inherited from class io.outofprintmagazine.corpus.batch.CorpusBatchStep

dictionaryPOS

Constructor Summary

Constructors

Constructor	Description
ThreadedCorpusBatchStep()

Method Summary

Modifier and Type	Method	Description
protected void	execute()
com.fasterxml.jackson.databind.node.ArrayNode	pop(com.fasterxml.jackson.databind.node.ArrayNode input)
protected void	push(com.fasterxml.jackson.databind.node.ArrayNode input)
com.fasterxml.jackson.databind.node.ArrayNode	run(com.fasterxml.jackson.databind.node.ArrayNode input)
com.fasterxml.jackson.databind.node.ArrayNode	runOne(com.fasterxml.jackson.databind.node.ObjectNode input)

Methods inherited from class io.outofprintmagazine.corpus.batch.CorpusBatchStep

copyInputToOutput, copyInputToOutput, getAuthor, getAuthor, getData, getDate, getDate, getDateFormat, getDefaultProperties, getDocID, getExtensionFromMimeType, getJsonNodeFromStorage, getJsonNodeFromStorage, getJsoupDocumentFromStorage, getJsoupDocumentFromStorageNormalized, getLink, getMapper, getMimeTypeFromExtension, getOutputScratchFilePath, getOutputScratchFilePath, getOutputScratchFilePathFromInput, getParameterStore, getStorage, getStorageLink, getText, getText, getTextDocumentFromStorage, getTextDocumentFromStorage, getTextWithSelector, getThumbnail, getTitle, getTitle, isDictionaryWord, setAuthor, setAuthor, setData, setDate, setDate, setDate, setDocID, setLink, setParameterStore, setStorage, setStorageLink, setThumbnail, setThumbnail, setTitle, setTitle

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.outofprintmagazine.corpus.batch.ICorpusBatchStep

getData, getDefaultProperties, setData, setParameterStore, setStorage

Field Detail

maxThreads

protected int maxThreads

taskClass

protected String taskClass

threads

protected List<Thread> threads

tasks

protected Map<com.fasterxml.jackson.databind.node.ObjectNode,ThreadedCorpusBatchStepTask> tasks

Constructor Detail

ThreadedCorpusBatchStep

public ThreadedCorpusBatchStep()

Method Detail

runOne

public com.fasterxml.jackson.databind.node.ArrayNode runOne(com.fasterxml.jackson.databind.node.ObjectNode input)
                                                     throws Exception

Specified by:

runOne in interface ICorpusBatchStep

Specified by:

runOne in class CorpusBatchStep

Throws:

Exception

run

public com.fasterxml.jackson.databind.node.ArrayNode run(com.fasterxml.jackson.databind.node.ArrayNode input)

Specified by:

run in interface ICorpusBatchStep

Overrides:

run in class CorpusBatchStep

execute

protected void execute()

push

protected void push(com.fasterxml.jackson.databind.node.ArrayNode input)

pop

public com.fasterxml.jackson.databind.node.ArrayNode pop(com.fasterxml.jackson.databind.node.ArrayNode input)