water.parser
Class SVMLightDParseTask

java.lang.Object
  jsr166y.ForkJoinTask<java.lang.Void>
      jsr166y.CountedCompleter
          water.H2O.H2OCountedCompleter
              water.DTask<T>
                  water.DRemoteTask<T>
                      water.MRTask<DParseTask>
                          water.parser.DParseTask
                              water.parser.SVMLightDParseTask

All Implemented Interfaces:

java.io.Serializable, java.lang.Cloneable, java.util.concurrent.Future<java.lang.Void>, Freezable, CustomParser.DataOut

public class SVMLightDParseTask
extends DParseTask

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class water.parser.DParseTask

DParseTask.AtomicUnion

Field Summary

Fields inherited from class water.parser.DParseTask

_map, powers10i

Fields inherited from class water.MRTask

_hi, _lo

Fields inherited from class water.DRemoteTask

_fs, _is_local, _keys

Fields inherited from class water.DTask

_cls, _eFromNode, _exception, _fname, _lineNum, _msg, _mth

Constructor Summary

SVMLightDParseTask()

Method Summary

void	addColumns(int ncols)
void	addInvalidCol(int colIdx) Adds invalid value to the column.
void	addNumCol(int colIdx, long number, int exp)
void	addStrCol(int colIdx, ValueString str) Adds string (enum) value to the column.
protected void	createEnums()
void	createValueArrayHeader() Creates the value header based on the calculated columns.
void	newLine() Advances to new line.
void	reduce(DParseTask dpt)

Methods inherited from class water.parser.DParseTask

addNumCol, clone2, createPassOne, createPassTwo, createRecords, fitsIntoInt, init, invalidLine, invalidValue, isString, makePhase2Clone, map, memOverheadPerChunk, normalizeSigma, passOne, passTwo, phaseOneInitialize, phaseTwoInitialize, pow10, pow10i, rollbackLine, setColumnNames

Methods inherited from class water.MRTask

hi, lcompute, lo, lonCompletion, onExceptionalCompletion

Methods inherited from class water.DRemoteTask

alsoBlockFor, alsoBlockFor, clone, compute2, dfork, getFutures, invoke, invokeOnAllNodes, keys, merge, merge, merge, onCompletion, reduceAlsoBlock

Methods inherited from class water.DTask

copyOver, dinvoke, frozenType, getDException, hasException, logVerbose, newInstance, onAck, onAckAck, read, setException, toDocField, write, writeJSONFields

Methods inherited from class water.H2O.H2OCountedCompleter

compute, priority

Methods inherited from class jsr166y.CountedCompleter

addToPendingCount, compareAndSetPendingCount, complete, exec, getCompleter, getPendingCount, getRawResult, setCompleter, setPendingCount, setRawResult, tryComplete

Methods inherited from class jsr166y.ForkJoinTask

adapt, adapt, adapt, cancel, compareAndSetForkJoinTaskTag, completeExceptionally, fork, get, get, getException, getForkJoinTaskTag, getPool, getQueuedTaskCount, getSurplusQueuedTaskCount, helpQuiesce, inForkJoinPool, invoke, invokeAll, invokeAll, invokeAll, isCancelled, isCompletedAbnormally, isCompletedNormally, isDone, join, peekNextLocalTask, pollNextLocalTask, pollTask, quietlyComplete, quietlyInvoke, quietlyJoin, reinitialize, setForkJoinTaskTag, tryUnfork

Methods inherited from class java.lang.Object

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

Methods inherited from interface water.Freezable

frozenType, newInstance, read, toDocField, write, writeJSONFields

Constructor Detail

SVMLightDParseTask

public SVMLightDParseTask()

Method Detail

newLine

public void newLine()

Description copied from class: DParseTask

Advances to new line. In phase two it also must make sure that the

Specified by:

newLine in interface CustomParser.DataOut

Overrides:

newLine in class DParseTask

addColumns

public void addColumns(int ncols)

Overrides:

addColumns in class DParseTask

addNumCol

public void addNumCol(int colIdx,
                      long number,
                      int exp)

Specified by:

addNumCol in interface CustomParser.DataOut

Overrides:

addNumCol in class DParseTask

addInvalidCol

public void addInvalidCol(int colIdx)

Description copied from class: DParseTask

Adds invalid value to the column.

Specified by:

addInvalidCol in interface CustomParser.DataOut

Overrides:

addInvalidCol in class DParseTask

addStrCol

public void addStrCol(int colIdx,
                      ValueString str)

Description copied from class: DParseTask

Adds string (enum) value to the column.

Specified by:

addStrCol in interface CustomParser.DataOut

Overrides:

addStrCol in class DParseTask

reduce

public void reduce(DParseTask dpt)

Overrides:

reduce in class DParseTask

createValueArrayHeader

public void createValueArrayHeader()

Description copied from class: DParseTask

Creates the value header based on the calculated columns. Also stores the header to its appropriate key. This will be the VA header of the parsed dataset.

Overrides:

createValueArrayHeader in class DParseTask

createEnums

protected void createEnums()

Overrides:

createEnums in class DParseTask