B C D F G I K L M N O P R S T V

B

buildFlow(FlowDef) - Method in class cascading.flow.local.planner.LocalPlanner

buildGraph() - Method in class cascading.flow.local.stream.LocalStepStreamGraph

C

call() - Method in class cascading.flow.local.planner.LocalStepRunner

captureDetail() - Method in class cascading.stats.local.LocalStepStats

cascading.flow.local - package cascading.flow.local

cascading.flow.local.planner - package cascading.flow.local.planner

cascading.flow.local.stream - package cascading.flow.local.stream

cascading.platform.local - package cascading.platform.local

cascading.scheme.local - package cascading.scheme.local

cascading.stats.local - package cascading.stats.local

cascading.tap.local - package cascading.tap.local

cascading.tap.local.io - package cascading.tap.local.io

clean(Properties) - Method in class cascading.flow.local.LocalFlowStep

commitResource(Properties) - Method in class cascading.tap.local.FileTap

complete(Duct) - Method in class cascading.flow.local.stream.LocalGroupByGate

copyConfig(Properties) - Method in class cascading.flow.local.LocalFlowProcess

copyFromLocal(String) - Method in class cascading.platform.local.LocalPlatform

copyToLocal(String) - Method in class cascading.platform.local.LocalPlatform

copyWith(Properties) - Method in class cascading.flow.local.LocalFlowProcess

createCoGroupGate(CoGroup) - Method in class cascading.flow.local.stream.LocalStepStreamGraph

createFlow(FlowDef) - Method in class cascading.flow.local.planner.LocalPlanner

createFlowPlanner() - Method in class cascading.flow.local.LocalFlowConnector

createFlowStep(String, int) - Method in class cascading.flow.local.planner.LocalStepGraph

createFlowStepJob(FlowProcess<Properties>, Properties) - Method in class cascading.flow.local.LocalFlowStep

createFlowThread(String) - Method in class cascading.flow.local.LocalFlow

createGroupByGate(GroupBy) - Method in class cascading.flow.local.stream.LocalStepStreamGraph

createInput(InputStream) - Method in class cascading.scheme.local.TextDelimited

createInput(InputStream) - Method in class cascading.scheme.local.TextLine

createMergeStage(Merge) - Method in class cascading.flow.local.stream.LocalStepStreamGraph

createOutput(OutputStream) - Method in class cascading.scheme.local.TextDelimited

createOutput(OutputStream) - Method in class cascading.scheme.local.TextLine

createResource(Properties) - Method in class cascading.tap.local.FileTap

createResource(Properties) - Method in class cascading.tap.local.StdErrTap

createResource(Properties) - Method in class cascading.tap.local.StdOutTap

createSinkStage(Tap) - Method in class cascading.flow.local.stream.LocalStepStreamGraph

createStepStats(ClientState) - Method in class cascading.flow.local.planner.LocalFlowStepJob

createTupleEntrySchemeCollector(FlowProcess<Properties>, Tap, String, long) - Method in class cascading.tap.local.PartitionTap

createTupleEntrySchemeCollector(FlowProcess<Properties>, Tap, String) - Method in class cascading.tap.local.TemplateTap

Deprecated.

createTupleEntrySchemeIterator(FlowProcess<Properties>, Tap, String, InputStream) - Method in class cascading.tap.local.PartitionTap

D

DEFAULT_CHARSET - Static variable in class cascading.scheme.local.TextDelimited

DEFAULT_CHARSET - Static variable in class cascading.scheme.local.TextLine

deleteResource(Properties) - Method in class cascading.tap.local.FileTap

deleteResource(Properties) - Method in class cascading.tap.local.PartitionTap

deleteResource(Properties) - Method in class cascading.tap.local.StdErrTap

deleteResource(Properties) - Method in class cascading.tap.local.StdOutTap

diffConfigIntoMap(Properties, Properties) - Method in class cascading.flow.local.LocalFlowProcess

dumpDebugInfo() - Method in class cascading.flow.local.planner.LocalFlowStepJob

F

FileTap - Class in cascading.tap.local

Class FileTap is a Tap sub-class that allows for direct local file access.

FileTap(Scheme<Properties, InputStream, OutputStream, ?, ?>, String) - Constructor for class cascading.tap.local.FileTap

Constructor FileTap creates a new FileTap instance using the given Scheme and file path.

FileTap(Scheme<Properties, InputStream, OutputStream, ?, ?>, String, SinkMode) - Constructor for class cascading.tap.local.FileTap

Constructor FileTap creates a new FileTap instance using the given Scheme, file path, and SinkMode.

G

getCharsetName() - Method in class cascading.scheme.local.TextDelimited

getCharsetName() - Method in class cascading.scheme.local.TextLine

getChildIdentifiers(Properties) - Method in class cascading.tap.local.FileTap

getChildIdentifiers(Properties, int, boolean) - Method in class cascading.tap.local.FileTap

getChildren() - Method in class cascading.stats.local.LocalStepStats

getConfig() - Method in class cascading.flow.local.LocalFlow

getConfig() - Method in class cascading.flow.local.planner.LocalFlowStepJob

getConfig() - Method in class cascading.flow.local.planner.LocalPlanner

getConfigAsProperties() - Method in class cascading.flow.local.LocalFlow

getConfigCopy() - Method in class cascading.flow.local.LocalFlow

getConfigCopy() - Method in class cascading.flow.local.LocalFlowProcess

getCounterGroups() - Method in class cascading.stats.local.LocalStepStats

getCounterGroupsMatching(String) - Method in class cascading.stats.local.LocalStepStats

getCountersFor(String) - Method in class cascading.stats.local.LocalStepStats

getCounterValue(Enum) - Method in class cascading.stats.local.LocalStepStats

getCounterValue(String, String) - Method in class cascading.stats.local.LocalStepStats

getCurrentIdentifier(FlowProcess<Properties>) - Method in class cascading.tap.local.PartitionTap

getCurrentSliceNum() - Method in class cascading.flow.local.LocalFlowProcess

getDefaultIntermediateSchemeClass() - Method in class cascading.flow.local.LocalFlowConnector

getDelimitedFile(Fields, boolean, String, String, Class[], String, SinkMode) - Method in class cascading.platform.local.LocalPlatform

getDelimitedFile(Fields, boolean, boolean, String, String, Class[], String, SinkMode) - Method in class cascading.platform.local.LocalPlatform

getDelimitedFile(String, String, FieldTypeResolver, String, SinkMode) - Method in class cascading.platform.local.LocalPlatform

getDelimiter() - Method in class cascading.scheme.local.TextDelimited

Method getDelimiter returns the delimiter used to parse fields from the current line of text.

getFlowConnector(Map<Object, Object>) - Method in class cascading.platform.local.LocalPlatform

getFlowProcess() - Method in class cascading.flow.local.LocalFlow

getFlowProcess() - Method in class cascading.flow.local.planner.LocalStepRunner

getFlowProcess() - Method in class cascading.platform.local.LocalPlatform

getFullIdentifier(Properties) - Method in class cascading.tap.local.FileTap

getHiddenTemporaryPath() - Method in class cascading.platform.local.LocalPlatform

getIdentifier() - Method in class cascading.tap.local.FileTap

getIdentifier() - Method in class cascading.tap.local.StdErrTap

getIdentifier() - Method in class cascading.tap.local.StdInTap

getIdentifier() - Method in class cascading.tap.local.StdOutTap

getInitializedConfig(FlowProcess<Properties>, Properties) - Method in class cascading.flow.local.LocalFlowStep

getLongComparator(boolean) - Method in class cascading.platform.local.LocalPlatform

getMaxNumParallelSteps() - Method in class cascading.flow.local.LocalFlow

getModifiedTime(Properties) - Method in class cascading.tap.local.FileTap

getModifiedTime(Properties) - Method in class cascading.tap.local.StdErrTap

getModifiedTime(Properties) - Method in class cascading.tap.local.StdInTap

getModifiedTime(Properties) - Method in class cascading.tap.local.StdOutTap

getNumProcessSlices() - Method in class cascading.flow.local.LocalFlowProcess

getPartitionTap(Tap, Partition, int) - Method in class cascading.platform.local.LocalPlatform

getPlatformInfo() - Method in class cascading.flow.local.planner.LocalPlanner

getProperties() - Method in class cascading.platform.local.LocalPlatform

getPropertiesMap() - Method in class cascading.flow.local.LocalFlowStep

getProperty(String) - Method in class cascading.flow.local.LocalFlow

getProperty(String) - Method in class cascading.flow.local.LocalFlowProcess

getPropertyKeys() - Method in class cascading.flow.local.LocalFlowProcess

getQuote() - Method in class cascading.scheme.local.TextDelimited

Method getQuote returns the quote string, if any, used to encapsulate each field in a line to delimited text.

getSize(Properties) - Method in class cascading.tap.local.FileTap

getStringComparator(boolean) - Method in class cascading.platform.local.LocalPlatform

getTap(Scheme, String, SinkMode) - Method in class cascading.platform.local.LocalPlatform

getTemplateTap(Tap, String, int) - Method in class cascading.platform.local.LocalPlatform

getTemplateTap(Tap, String, Fields, int) - Method in class cascading.platform.local.LocalPlatform

getTestConfigDefScheme() - Method in class cascading.platform.local.LocalPlatform

getTestFailScheme() - Method in class cascading.platform.local.LocalPlatform

getTextFile(Fields, Fields, String, SinkMode) - Method in class cascading.platform.local.LocalPlatform

getThrowable() - Method in class cascading.flow.local.planner.LocalFlowStepJob

getThrowable() - Method in class cascading.flow.local.planner.LocalStepRunner

getTrap(String) - Method in class cascading.flow.local.LocalFlowStep

getTrapMap() - Method in class cascading.flow.local.LocalFlowStep

getTraps() - Method in class cascading.flow.local.LocalFlowStep

I

increment(Enum, long) - Method in class cascading.flow.local.LocalFlowProcess

increment(String, String, long) - Method in class cascading.flow.local.LocalFlowProcess

increment(Enum, long) - Method in class cascading.stats.local.LocalStepStats

increment(String, String, long) - Method in class cascading.stats.local.LocalStepStats

initConfig(Map<Object, Object>, Properties) - Method in class cascading.flow.local.LocalFlow

initialize(FlowConnector, Map<Object, Object>) - Method in class cascading.flow.local.planner.LocalPlanner

initTaps(FlowProcess<Properties>, Properties, Set<Tap>, boolean) - Method in class cascading.flow.local.LocalFlowStep

internalBlockOnStop() - Method in class cascading.flow.local.planner.LocalFlowStepJob

internalClean(boolean) - Method in class cascading.flow.local.LocalFlow

internalIsStarted() - Method in class cascading.flow.local.planner.LocalFlowStepJob

internalJobId() - Method in class cascading.flow.local.planner.LocalFlowStepJob

internalNonBlockingIsComplete() - Method in class cascading.flow.local.planner.LocalFlowStepJob

internalNonBlockingIsSuccessful() - Method in class cascading.flow.local.planner.LocalFlowStepJob

internalNonBlockingStart() - Method in class cascading.flow.local.planner.LocalFlowStepJob

internalShutdown() - Method in class cascading.flow.local.LocalFlow

internalStart() - Method in class cascading.flow.local.LocalFlow

isBlockingStreamed() - Method in class cascading.flow.local.stream.LocalGroupByGate

isComplete() - Method in class cascading.flow.local.planner.LocalStepRunner

isCounterStatusInitialized() - Method in class cascading.flow.local.LocalFlowProcess

isDirectory(Properties) - Method in class cascading.tap.local.FileTap

isRemoteExecution() - Method in class cascading.flow.local.planner.LocalFlowStepJob

isSuccessful() - Method in class cascading.flow.local.planner.LocalStepRunner

isSymmetrical() - Method in class cascading.scheme.local.TextDelimited

K

keepAlive() - Method in class cascading.flow.local.LocalFlowProcess

L

LocalFlow - Class in cascading.flow.local

Class LocalFlow is the local mode specific implementation of a Flow.

LocalFlow(PlatformInfo, Map<Object, Object>, Properties, FlowDef) - Constructor for class cascading.flow.local.LocalFlow

LocalFlowConnector - Class in cascading.flow.local

Use the LocalFlowConnector to link source and sink Tap instances with an assembly of Pipe instances into an executable LocalFlow for execution in local memory.

LocalFlowConnector() - Constructor for class cascading.flow.local.LocalFlowConnector

Constructor LocalFlowConnector creates a default instance.

LocalFlowConnector(Map<Object, Object>) - Constructor for class cascading.flow.local.LocalFlowConnector

Constructor LocalFlowConnector creates a new instance using any of the given properties.

LocalFlowProcess - Class in cascading.flow.local

Class LocalFlowProcess is the local mode implementation of FlowProcess.

LocalFlowProcess() - Constructor for class cascading.flow.local.LocalFlowProcess

LocalFlowProcess(Properties) - Constructor for class cascading.flow.local.LocalFlowProcess

LocalFlowProcess(FlowSession, Properties) - Constructor for class cascading.flow.local.LocalFlowProcess

LocalFlowProcess(LocalFlowProcess, Properties) - Constructor for class cascading.flow.local.LocalFlowProcess

LocalFlowStep - Class in cascading.flow.local

Class LocalFlowStep is the local mode implementation of FlowStep.

LocalFlowStep(String, int) - Constructor for class cascading.flow.local.LocalFlowStep

LocalFlowStepJob - Class in cascading.flow.local.planner

LocalFlowStepJob(ClientState, LocalFlowProcess, LocalFlowStep) - Constructor for class cascading.flow.local.planner.LocalFlowStepJob

LocalGroupByGate - Class in cascading.flow.local.stream

LocalGroupByGate(FlowProcess, Splice) - Constructor for class cascading.flow.local.stream.LocalGroupByGate

LocalPlanner - Class in cascading.flow.local.planner

LocalPlanner() - Constructor for class cascading.flow.local.planner.LocalPlanner

LocalPlatform - Class in cascading.platform.local

Class LocalPlatform is automatically loaded and injected into a PlatformTestCase instance so that all *PlatformTest classes can be tested against the Cascading local mode planner.

LocalPlatform() - Constructor for class cascading.platform.local.LocalPlatform

LocalStepGraph - Class in cascading.flow.local.planner

LocalStepGraph(String, ElementGraph) - Constructor for class cascading.flow.local.planner.LocalStepGraph

LocalStepRunner - Class in cascading.flow.local.planner

LocalStepRunner(FlowProcess<Properties>, LocalFlowStep) - Constructor for class cascading.flow.local.planner.LocalStepRunner

LocalStepStats - Class in cascading.stats.local

LocalStepStats(FlowStep<Properties>, ClientState) - Constructor for class cascading.stats.local.LocalStepStats

Constructor CascadingStats creates a new CascadingStats instance.

LocalStepStreamGraph - Class in cascading.flow.local.stream

LocalStepStreamGraph(FlowProcess<Properties>, LocalFlowStep) - Constructor for class cascading.flow.local.stream.LocalStepStreamGraph

M

makeStepGraph(String, ElementGraph) - Method in class cascading.flow.local.planner.LocalStepGraph

makeTempTap(String, String) - Method in class cascading.flow.local.planner.LocalPlanner

mergeMapIntoConfig(Properties, Map<String, String>) - Method in class cascading.flow.local.LocalFlowProcess

N

newConfig(Properties) - Method in class cascading.flow.local.LocalFlow

newInstance(String) - Method in class cascading.flow.local.LocalFlowProcess

O

openForRead(FlowProcess<Properties>, InputStream) - Method in class cascading.tap.local.FileTap

openForRead(FlowProcess<Properties>, InputStream) - Method in class cascading.tap.local.StdInTap

openForWrite(FlowProcess<Properties>, OutputStream) - Method in class cascading.tap.local.FileTap

openForWrite(FlowProcess<Properties>, OutputStream) - Method in class cascading.tap.local.StdErrTap

openForWrite(FlowProcess<Properties>, OutputStream) - Method in class cascading.tap.local.StdOutTap

openSystemIntermediateForWrite() - Method in class cascading.flow.local.LocalFlowProcess

openTapForRead(Tap) - Method in class cascading.flow.local.LocalFlowProcess

openTapForWrite(Tap) - Method in class cascading.flow.local.LocalFlowProcess

openTrapForWrite(Tap) - Method in class cascading.flow.local.LocalFlowProcess

P

PartitionTap - Class in cascading.tap.local

Class PartitionTap can be used to write tuple streams out to files and sub-directories based on the values in the current Tuple instance.

PartitionTap(FileTap, Partition) - Constructor for class cascading.tap.local.PartitionTap

Constructor PartitionTap creates a new PartitionTap instance using the given parent FileTap Tap as the base path and default Scheme, and the partition.

PartitionTap(FileTap, Partition, int) - Constructor for class cascading.tap.local.PartitionTap

Constructor PartitionTap creates a new PartitionTap instance using the given parent FileTap Tap as the base path and default Scheme, and the partition.

PartitionTap(FileTap, Partition, SinkMode) - Constructor for class cascading.tap.local.PartitionTap

Constructor PartitionTap creates a new PartitionTap instance using the given parent FileTap Tap as the base path and default Scheme, and the partition.

PartitionTap(FileTap, Partition, SinkMode, boolean) - Constructor for class cascading.tap.local.PartitionTap

Constructor PartitionTap creates a new PartitionTap instance using the given parent FileTap Tap as the base path and default Scheme, and the partition.

PartitionTap(FileTap, Partition, SinkMode, boolean, int) - Constructor for class cascading.tap.local.PartitionTap

Constructor PartitionTap creates a new PartitionTap instance using the given parent FileTap Tap as the base path and default Scheme, and the partition.

prepare() - Method in class cascading.flow.local.stream.LocalGroupByGate

presentSinkFields(FlowProcess<Properties>, Tap, Fields) - Method in class cascading.scheme.local.TextDelimited

presentSinkFields(FlowProcess<Properties>, Tap, Fields) - Method in class cascading.scheme.local.TextLine

presentSourceFields(FlowProcess<Properties>, Tap, Fields) - Method in class cascading.scheme.local.TextDelimited

presentSourceFields(FlowProcess<Properties>, Tap, Fields) - Method in class cascading.scheme.local.TextLine

R

receive(Duct, TupleEntry) - Method in class cascading.flow.local.stream.LocalGroupByGate

receive(Duct, TupleEntry) - Method in class cascading.flow.local.stream.SyncMergeStage

synchronized, as by default, each source gets its turn, no concurrent threads.

recordChildStats() - Method in class cascading.stats.local.LocalStepStats

remoteExists(String) - Method in class cascading.platform.local.LocalPlatform

remoteRemove(String, boolean) - Method in class cascading.platform.local.LocalPlatform

resourceExists(Properties) - Method in class cascading.tap.local.FileTap

resourceExists(Properties) - Method in class cascading.tap.local.StdErrTap

resourceExists(Properties) - Method in class cascading.tap.local.StdInTap

resourceExists(Properties) - Method in class cascading.tap.local.StdOutTap

retrieveSourceFields(FlowProcess<Properties>, Tap) - Method in class cascading.scheme.local.TextDelimited

S

setConfigProperty(Properties, Object, Object) - Method in class cascading.flow.local.LocalFlow

setSinkFields(Fields) - Method in class cascading.scheme.local.TextDelimited

setSourceFields(Fields) - Method in class cascading.scheme.local.TextDelimited

setStatus(String) - Method in class cascading.flow.local.LocalFlowProcess

setStepStats(LocalStepStats) - Method in class cascading.flow.local.LocalFlowProcess

setUp() - Method in class cascading.platform.local.LocalPlatform

sink(FlowProcess<Properties>, SinkCall<PrintWriter, OutputStream>) - Method in class cascading.scheme.local.TextDelimited

sink(FlowProcess<Properties>, SinkCall<PrintWriter, OutputStream>) - Method in class cascading.scheme.local.TextLine

sinkCleanup(FlowProcess<Properties>, SinkCall<PrintWriter, OutputStream>) - Method in class cascading.scheme.local.TextDelimited

sinkCleanup(FlowProcess<Properties>, SinkCall<PrintWriter, OutputStream>) - Method in class cascading.scheme.local.TextLine

sinkConfInit(FlowProcess<Properties>, Tap<Properties, InputStream, OutputStream>, Properties) - Method in class cascading.scheme.local.TextDelimited

sinkConfInit(FlowProcess<Properties>, Tap<Properties, InputStream, OutputStream>, Properties) - Method in class cascading.scheme.local.TextLine

sinkPrepare(FlowProcess<Properties>, SinkCall<PrintWriter, OutputStream>) - Method in class cascading.scheme.local.TextDelimited

sinkPrepare(FlowProcess<Properties>, SinkCall<PrintWriter, OutputStream>) - Method in class cascading.scheme.local.TextLine

source(FlowProcess<Properties>, SourceCall<LineNumberReader, InputStream>) - Method in class cascading.scheme.local.TextDelimited

source(FlowProcess<Properties>, SourceCall<LineNumberReader, InputStream>) - Method in class cascading.scheme.local.TextLine

sourceCleanup(FlowProcess<Properties>, SourceCall<LineNumberReader, InputStream>) - Method in class cascading.scheme.local.TextDelimited

sourceCleanup(FlowProcess<Properties>, SourceCall<LineNumberReader, InputStream>) - Method in class cascading.scheme.local.TextLine

sourceConfInit(FlowProcess<Properties>, Tap<Properties, InputStream, OutputStream>, Properties) - Method in class cascading.scheme.local.TextDelimited

sourceConfInit(FlowProcess<Properties>, Tap<Properties, InputStream, OutputStream>, Properties) - Method in class cascading.scheme.local.TextLine

sourcePrepare(FlowProcess<Properties>, SourceCall<LineNumberReader, InputStream>) - Method in class cascading.scheme.local.TextDelimited

sourcePrepare(FlowProcess<Properties>, SourceCall<LineNumberReader, InputStream>) - Method in class cascading.scheme.local.TextLine

start(Duct) - Method in class cascading.flow.local.stream.LocalGroupByGate

StdErrTap - Class in cascading.tap.local

Class StdErrTap provides a local mode tap for writing data to the stderr stream.

StdErrTap(Scheme<Properties, ?, OutputStream, ?, ?>) - Constructor for class cascading.tap.local.StdErrTap

StdInTap - Class in cascading.tap.local

Class StdInTap provides a local mode tap for reading data from the stdin stream.

StdInTap(Scheme<Properties, InputStream, ?, ?, ?>) - Constructor for class cascading.tap.local.StdInTap

StdOutTap - Class in cascading.tap.local

Class StdOutTap provides a local mode tap for writing data to the stdout stream.

StdOutTap(Scheme<Properties, ?, OutputStream, ?, ?>) - Constructor for class cascading.tap.local.StdOutTap

stepsAreLocal() - Method in class cascading.flow.local.LocalFlow

stopOnElement(FlowElement, List<FlowElement>) - Method in class cascading.flow.local.stream.LocalStepStreamGraph

SyncMergeStage - Class in cascading.flow.local.stream

A version of Merge that synchronizes the receives for local mode

SyncMergeStage(FlowProcess, FlowElement) - Constructor for class cascading.flow.local.stream.SyncMergeStage

T

TapFileOutputStream - Class in cascading.tap.local.io

TapFileOutputStream(String, boolean) - Constructor for class cascading.tap.local.io.TapFileOutputStream

TapFileOutputStream(Tap, String, boolean) - Constructor for class cascading.tap.local.io.TapFileOutputStream

tearDown() - Method in class cascading.platform.local.LocalPlatform

TemplateTap - Class in cascading.tap.local

Deprecated. see PartitionTap

TemplateTap(FileTap, String) - Constructor for class cascading.tap.local.TemplateTap

Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent FileTap Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.

TemplateTap(FileTap, String, int) - Constructor for class cascading.tap.local.TemplateTap

Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent FileTap Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.

TemplateTap(FileTap, String, SinkMode) - Constructor for class cascading.tap.local.TemplateTap

Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent FileTap Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.

TemplateTap(FileTap, String, SinkMode, boolean) - Constructor for class cascading.tap.local.TemplateTap

Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent FileTap Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.

TemplateTap(FileTap, String, SinkMode, boolean, int) - Constructor for class cascading.tap.local.TemplateTap

Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent FileTap Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.

TemplateTap(FileTap, String, Fields) - Constructor for class cascading.tap.local.TemplateTap

Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent FileTap Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.

TemplateTap(FileTap, String, Fields, int) - Constructor for class cascading.tap.local.TemplateTap

Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent FileTap Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.

TemplateTap(FileTap, String, Fields, SinkMode) - Constructor for class cascading.tap.local.TemplateTap

Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent FileTap Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.

TemplateTap(FileTap, String, Fields, SinkMode, boolean) - Constructor for class cascading.tap.local.TemplateTap

Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent FileTap Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.

TemplateTap(FileTap, String, Fields, SinkMode, boolean, int) - Constructor for class cascading.tap.local.TemplateTap

Deprecated. Constructor TemplateTap creates a new TemplateTap instance using the given parent FileTap Tap as the base path and default Scheme, and the pathTemplate as the Formatter format String.

TextDelimited - Class in cascading.scheme.local

Class TextDelimited provides direct support for delimited text files, like TAB (\t) or COMMA (,) delimited files.

TextDelimited() - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using TAB as the default delimiter.

TextDelimited(boolean, String) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using TAB as the default delimiter.

TextDelimited(boolean, String, String) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using TAB as the default delimiter.

TextDelimited(boolean, DelimitedParser) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using the given delimitedParser instance for parsing.

TextDelimited(DelimitedParser) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance sourcing Fields.UNKNOWN, sinking Fields.ALL and using the given delimitedParser instance for parsing.

TextDelimited(Fields) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance with TAB as the default delimiter.

TextDelimited(Fields, String) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, String) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, boolean, String) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, String, Class[]) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, String, Class[]) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, boolean, String, Class[]) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, String, String, Class[]) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, String, String, Class[]) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, boolean, String, String, Class[]) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, String, String, Class[], boolean) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, String, String, Class[], boolean) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, String, String, Class[], boolean, String) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, boolean, String, String, Class[], boolean) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, String, String) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, String, String) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, String, String, String) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, boolean, String, boolean, String, Class[], boolean) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, boolean, String, boolean, String, Class[], boolean, String) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, boolean, DelimitedParser) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, DelimitedParser) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, boolean, boolean, String, DelimitedParser) - Constructor for class cascading.scheme.local.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextLine - Class in cascading.scheme.local

A TextLine is a type of Scheme for plain text files.

TextLine() - Constructor for class cascading.scheme.local.TextLine

Creates a new TextLine instance that sources "num" and "line" fields, and sinks all incoming fields, where "num" is the line number of the line in the input file.

TextLine(Fields) - Constructor for class cascading.scheme.local.TextLine

Creates a new TextLine instance.

TextLine(Fields, String) - Constructor for class cascading.scheme.local.TextLine

Creates a new TextLine instance.

TextLine(Fields, Fields) - Constructor for class cascading.scheme.local.TextLine

Creates a new TextLine instance.

TextLine(Fields, Fields, String) - Constructor for class cascading.scheme.local.TextLine

Creates a new TextLine instance.

V

verify(Fields) - Method in class cascading.scheme.local.TextLine

B C D F G I K L M N O P R S T V