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

B

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

C

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

captureDetail(CascadingStats.Type) - 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.duct - package cascading.flow.local.stream.duct

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

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

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.duct.ParallelFork

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

copyConfig(C) - 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, IORole) - Method in class cascading.flow.local.stream.graph.LocalStepStreamGraph

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

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

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

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

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

createFork(Duct[]) - Method in class cascading.flow.local.stream.graph.LocalStepStreamGraph

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

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

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

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

createMergeStage(Merge, IORole) - Method in class cascading.flow.local.stream.graph.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.graph.LocalStepStreamGraph

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

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

createTupleEntrySchemeIterator(FlowProcess<? extends 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

DEFAULT_SOURCE_FIELDS - 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(C, C) - 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(FlowProcess<? extends Properties>) - Method in class cascading.tap.local.FileTap

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

getChildIdentifiers(FlowProcess<? extends Properties>, int, boolean) - 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.LocalFlowProcess

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

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

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.flow.local.LocalFlowProcess

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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(FlowProcess<? extends Properties>) - Method in class cascading.tap.local.FileTap

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

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

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() - Method in class cascading.flow.local.stream.duct.ParallelFork

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

internalIsStartedRunning() - 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.element.LocalGroupByGate

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

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

isDirectory(FlowProcess<? extends Properties>) - Method in class cascading.tap.local.FileTap

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.

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

Constructor LocalFlowConnector creates a default instance.

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

Constructor LocalFlowConnector creates an 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(ElementGraph, FlowNodeGraph) - 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.element

LocalGroupByGate(FlowProcess, Splice) - Constructor for class cascading.flow.local.stream.element.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

LocalRuleRegistry - Class in cascading.flow.local.planner

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

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.graph

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

M

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<? extends Properties>, InputStream) - Method in class cascading.tap.local.FileTap

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

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

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

openForWrite(FlowProcess<? extends 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

ParallelFork<Outgoing> - Class in cascading.flow.local.stream.duct

This "Fork" avoids a possible deadlock in Fork-and-Join scenarios by running downstream edges into parallel threads.

ParallelFork(Duct[]) - Constructor for class cascading.flow.local.stream.duct.ParallelFork

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.

PLATFORM_NAME - Static variable in class cascading.flow.local.planner.LocalPlanner

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

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

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

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

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

R

receive(Duct, int, TupleEntry) - Method in class cascading.flow.local.stream.duct.ParallelFork

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

receive(Duct, int, TupleEntry) - Method in class cascading.flow.local.stream.element.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<? extends 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<? extends Properties>, SinkCall<PrintWriter, OutputStream>) - Method in class cascading.scheme.local.TextDelimited

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

start(Duct) - Method in class cascading.flow.local.stream.element.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

SyncMergeStage - Class in cascading.flow.local.stream.element

A version of Merge that synchronizes the receives for local mode

SyncMergeStage(FlowProcess, FlowElement) - Constructor for class cascading.flow.local.stream.element.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

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.

U

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

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 U V