Index (galagosearch-tupleflow 1.0-SNAPSHOT API)

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV NEXT

FRAMES NO FRAMES

A B C D E F G H I J L M N O P R S T U V W X

A

acceptsParameters() - Method in interface org.galagosearch.tupleflow.execution.StepSpecification
add(Step) - Method in class org.galagosearch.tupleflow.execution.Chain
add(String, Job) - Method in class org.galagosearch.tupleflow.execution.Job: Sometimes its convenient to specify a group of stages as its own job, with connections that flow between stages specified in the job.
add(Stage) - Method in class org.galagosearch.tupleflow.execution.Job: Adds a stage to the current job.
add(StageConnectionPoint) - Method in class org.galagosearch.tupleflow.execution.Stage
add(Step) - Method in class org.galagosearch.tupleflow.execution.Stage
add(String, List<Parameters.Value>) - Method in class org.galagosearch.tupleflow.Parameters
add(String, String) - Method in class org.galagosearch.tupleflow.Parameters
add(Object) - Method in class org.galagosearch.tupleflow.Parameters.CharSequenceBuffer
add(String) - Method in class org.galagosearch.tupleflow.Parameters.Value: Add a new child value object.
add(String, List<Parameters.Value>) - Method in class org.galagosearch.tupleflow.Parameters.Value
add(String, CharSequence) - Method in class org.galagosearch.tupleflow.Parameters.Value: Add a new XML value.
addError(String) - Method in interface org.galagosearch.tupleflow.execution.ErrorHandler
addError(FileLocation, String) - Method in class org.galagosearch.tupleflow.execution.ErrorStore
addError(String) - Method in class org.galagosearch.tupleflow.execution.ErrorStore.LocatedHandler
addError(String, SAXParseException) - Method in class org.galagosearch.tupleflow.execution.JobConstructor
addError(String) - Method in class org.galagosearch.tupleflow.execution.JobConstructor
addErrors(ErrorHandler) - Method in interface org.galagosearch.tupleflow.execution.StepSpecification
addHandler(StackHandler, String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.StackHandler
addHandler(StackHandler) - Method in class org.galagosearch.tupleflow.execution.StackHandler
addMergeStage(Job, String, String) - Method in class org.galagosearch.tupleflow.execution.JobExecutor: Add a merge stage to this job that merges the output of stageName called pointName.
addMergeStages(Job) - Method in class org.galagosearch.tupleflow.execution.JobExecutor: Find stages that need to open a lot of files for reading when running, and add some intermediate merge stages to reduce problems with open files.
addWarning(String) - Method in interface org.galagosearch.tupleflow.execution.ErrorHandler
addWarning(FileLocation, String) - Method in class org.galagosearch.tupleflow.execution.ErrorStore
addWarning(String) - Method in class org.galagosearch.tupleflow.execution.ErrorStore.LocatedHandler
addWarning(String) - Method in class org.galagosearch.tupleflow.execution.JobConstructor
ArrayInput - Class in org.galagosearch.tupleflow
ArrayInput(DataInput) - Constructor for class org.galagosearch.tupleflow.ArrayInput
ArrayOutput - Class in org.galagosearch.tupleflow
ArrayOutput(DataOutput) - Constructor for class org.galagosearch.tupleflow.ArrayOutput

B

batchCount - Variable in class org.galagosearch.tupleflow.OrderedReader
BufferedFileDataStream - Class in org.galagosearch.tupleflow
BufferedFileDataStream(RandomAccessFile, long) - Constructor for class org.galagosearch.tupleflow.BufferedFileDataStream: Creates a new instance of BufferedFileDataStream
BufferedFileDataStream(RandomAccessFile, long, long) - Constructor for class org.galagosearch.tupleflow.BufferedFileDataStream

C

calculateMessageDigest(File, MessageDigest) - Static method in class org.galagosearch.tupleflow.Utility
caps(String) - Static method in class org.galagosearch.tupleflow.Utility
Chain - Class in org.galagosearch.tupleflow.execution
Chain() - Constructor for class org.galagosearch.tupleflow.execution.Chain
characters(char[], int, int) - Method in class org.galagosearch.tupleflow.execution.JobConstructor
characters(char[], int, int) - Method in class org.galagosearch.tupleflow.execution.StackHandler
characters(char[], int, int) - Method in class org.galagosearch.tupleflow.Parameters.Parser
charAt(int) - Method in class org.galagosearch.tupleflow.Parameters.CharSequenceBuffer
className - Variable in class org.galagosearch.tupleflow.execution.DataPipe
clear() - Method in class org.galagosearch.tupleflow.execution.JobExecutor
clone() - Method in class org.galagosearch.tupleflow.execution.Connection
clone() - Method in class org.galagosearch.tupleflow.execution.ConnectionEndPoint
clone() - Method in class org.galagosearch.tupleflow.execution.Stage
clone(T) - Method in class org.galagosearch.tupleflow.OrderedReader
clone() - Method in class org.galagosearch.tupleflow.Parameters
close() - Method in class org.galagosearch.tupleflow.FileOrderedReader
close() - Method in class org.galagosearch.tupleflow.FileOrderedWriter
close() - Method in class org.galagosearch.tupleflow.FileSource
close(Step) - Static method in class org.galagosearch.tupleflow.Linkage
close() - Method in class org.galagosearch.tupleflow.Multi
close() - Method in class org.galagosearch.tupleflow.NullProcessor
close() - Method in class org.galagosearch.tupleflow.OrderedCombiner
close() - Method in interface org.galagosearch.tupleflow.Processor
close() - Method in class org.galagosearch.tupleflow.Sorter
close() - Method in class org.galagosearch.tupleflow.Splitter
close() - Method in class org.galagosearch.tupleflow.StandardStep
close() - Method in class org.galagosearch.tupleflow.Unique
close() - Method in class org.galagosearch.tupleflow.XMLMinimum
columnNumber - Variable in class org.galagosearch.tupleflow.execution.FileLocation
combineFromFiles(List<String>, Order<S>) - Static method in class org.galagosearch.tupleflow.OrderedCombiner
combineFromFiles(List<String>, Order<S>, Processor<S>, boolean, int) - Static method in class org.galagosearch.tupleflow.OrderedCombiner
combineFromFiles(List<String>) - Static method in class org.galagosearch.tupleflow.OrderedCombiner
combineFromFiles(List<String>, Order<S>, Processor<S>) - Static method in class org.galagosearch.tupleflow.OrderedCombiner
combineFromFiles(List<String>, Order<S>) - Static method in class org.galagosearch.tupleflow.SequentialCombiner
compare(int, int) - Static method in class org.galagosearch.tupleflow.Utility
compare(long, long) - Static method in class org.galagosearch.tupleflow.Utility
compare(double, double) - Static method in class org.galagosearch.tupleflow.Utility
compare(float, float) - Static method in class org.galagosearch.tupleflow.Utility
compare(String, String) - Static method in class org.galagosearch.tupleflow.Utility
compare(byte[], byte[]) - Static method in class org.galagosearch.tupleflow.Utility
compareTo(ErrorStore.Statement) - Method in class org.galagosearch.tupleflow.execution.ErrorStore.Statement
compareTo(FileLocation) - Method in class org.galagosearch.tupleflow.execution.FileLocation
compareTo(Job.StagePoint) - Method in class org.galagosearch.tupleflow.execution.Job.StagePoint
compareTo(MasterWebHandler.CounterName) - Method in class org.galagosearch.tupleflow.execution.MasterWebHandler.CounterName
compatibleOrders(String[], String[]) - Static method in class org.galagosearch.tupleflow.execution.Verification: Tests to see if two object orders are compatible.
connect(String, String, ConnectionAssignmentType) - Method in class org.galagosearch.tupleflow.execution.Job: Connects outputs from stage sourceName to inputs from stage destinationName.
connect(Job.StagePoint, Job.StagePoint, ConnectionAssignmentType) - Method in class org.galagosearch.tupleflow.execution.Job
connect(Job.StagePoint, Job.StagePoint, ConnectionAssignmentType, String[], int) - Method in class org.galagosearch.tupleflow.execution.Job
connectable(ConnectionPointType, ConnectionPointType) - Static method in enum org.galagosearch.tupleflow.execution.ConnectionPointType
Connection - Class in org.galagosearch.tupleflow.execution: Represents a data connection between two stages in a TupleFlow job.
Connection(FileLocation, String, String, String[], String[], int) - Constructor for class org.galagosearch.tupleflow.execution.Connection
Connection(FileLocation, String, String[], String[], int) - Constructor for class org.galagosearch.tupleflow.execution.Connection
connection - Variable in class org.galagosearch.tupleflow.execution.JobConstructor.ConnectionHandler
ConnectionAssignmentType - Enum in org.galagosearch.tupleflow.execution: This specifies how input data should be assigned to outputs in a TupleFlow connection.
ConnectionEndPoint - Class in org.galagosearch.tupleflow.execution
ConnectionEndPoint(FileLocation, String, String, ConnectionAssignmentType, ConnectionPointType) - Constructor for class org.galagosearch.tupleflow.execution.ConnectionEndPoint
ConnectionEndPoint(FileLocation, String, String, ConnectionPointType) - Constructor for class org.galagosearch.tupleflow.execution.ConnectionEndPoint
ConnectionPointType - Enum in org.galagosearch.tupleflow.execution: Represents the end point type of a TupleFlow connection: either input or output.
connections - Variable in class org.galagosearch.tupleflow.execution.Job
connections - Variable in class org.galagosearch.tupleflow.execution.JobConstructor.ConnectionsHandler
connections - Variable in class org.galagosearch.tupleflow.execution.Stage
containsInput(String) - Method in class org.galagosearch.tupleflow.execution.Stage
containsInput(String) - Method in class org.galagosearch.tupleflow.execution.StageGroupDescription
containsKey(String) - Method in class org.galagosearch.tupleflow.Parameters
containsKey(String) - Method in class org.galagosearch.tupleflow.Parameters.Value
containsOutput(String) - Method in class org.galagosearch.tupleflow.execution.Stage
containsOutput(String) - Method in class org.galagosearch.tupleflow.execution.StageGroupDescription
copy(String, Parameters) - Method in class org.galagosearch.tupleflow.Parameters
copy(Parameters) - Method in class org.galagosearch.tupleflow.Parameters
copyFileToStream(File, OutputStream) - Static method in class org.galagosearch.tupleflow.Utility: Copies the data from file into the stream.
copyStreamToFile(InputStream, File) - Static method in class org.galagosearch.tupleflow.Utility: Copies the data from the InputStream to a file, then closes both when finished.
Counter - Interface in org.galagosearch.tupleflow: A counter sends statistics from individual TupleFlow workers back to the JobExecutor.
createOrder(DataPipe) - Static method in class org.galagosearch.tupleflow.execution.StageInstanceFactory
createOrder(String, String[]) - Static method in class org.galagosearch.tupleflow.execution.StageInstanceFactory
createTemporary() - Static method in class org.galagosearch.tupleflow.Utility
createTemporary(long) - Static method in class org.galagosearch.tupleflow.Utility

D

DataPipe - Class in org.galagosearch.tupleflow.execution
DataPipe(String, String, String, String[], String[], int, int) - Constructor for class org.galagosearch.tupleflow.execution.DataPipe
DataStream - Interface in org.galagosearch.tupleflow
decode(ArrayInput, String) - Static method in class org.galagosearch.tupleflow.Delta
decodeAscending(ArrayInput, String) - Static method in class org.galagosearch.tupleflow.Delta
decodeAscending(ArrayInput, long) - Static method in class org.galagosearch.tupleflow.Delta
decodeAscending(ArrayInput, int) - Static method in class org.galagosearch.tupleflow.Delta
decodeDescending(ArrayInput, String) - Static method in class org.galagosearch.tupleflow.Delta
decodeDescending(ArrayInput, long) - Static method in class org.galagosearch.tupleflow.Delta
decodeDescending(ArrayInput, int) - Static method in class org.galagosearch.tupleflow.Delta
deleteDirectory(File) - Static method in class org.galagosearch.tupleflow.Utility
Delta - Class in org.galagosearch.tupleflow: This class holds helper static methods that help with delta encoding for compression.
Delta() - Constructor for class org.galagosearch.tupleflow.Delta

E

encode(ArrayOutput, String, String) - Static method in class org.galagosearch.tupleflow.Delta
encodeAscending(ArrayOutput, String, String) - Static method in class org.galagosearch.tupleflow.Delta
encodeAscending(ArrayOutput, long, long) - Static method in class org.galagosearch.tupleflow.Delta
encodeDescending(ArrayOutput, String, String) - Static method in class org.galagosearch.tupleflow.Delta
encodeDescending(ArrayOutput, long, long) - Static method in class org.galagosearch.tupleflow.Delta
endChild(StackHandler, String, String, String) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.ConnectionsHandler
endChild(StackHandler, String, String, String) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.JobHandler
endChild(StackHandler, String, String, String) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.MultiHandler
endChild(StackHandler, String, String, String) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StageHandler
endChild(StackHandler, String, String, String) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StagesHandler
endChild(StackHandler, String, String, String) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StepsHandler
endChild(StackHandler, String, String, String) - Method in class org.galagosearch.tupleflow.execution.StackHandler
endElement(String, String, String) - Method in class org.galagosearch.tupleflow.execution.JobConstructor
endElement(String, String, String) - Method in class org.galagosearch.tupleflow.execution.StackHandler
endElement(String, String, String) - Method in class org.galagosearch.tupleflow.Parameters.Parser
endHandler(String, String, String) - Method in class org.galagosearch.tupleflow.execution.StackHandler
equals(Job.StagePoint) - Method in class org.galagosearch.tupleflow.execution.Job.StagePoint
equals(Object) - Method in class org.galagosearch.tupleflow.execution.Job.StagePoint
ErrorExecutionStatus - Class in org.galagosearch.tupleflow.execution: A dummy execution status object that wraps an error.
ErrorExecutionStatus(String, Exception) - Constructor for class org.galagosearch.tupleflow.execution.ErrorExecutionStatus
ErrorHandler - Interface in org.galagosearch.tupleflow.execution
ErrorStore - Class in org.galagosearch.tupleflow.execution
ErrorStore() - Constructor for class org.galagosearch.tupleflow.execution.ErrorStore
ErrorStore.LocatedHandler - Class in org.galagosearch.tupleflow.execution
ErrorStore.LocatedHandler(FileLocation) - Constructor for class org.galagosearch.tupleflow.execution.ErrorStore.LocatedHandler
ErrorStore.Statement - Class in org.galagosearch.tupleflow.execution
ErrorStore.Statement(FileLocation, String) - Constructor for class org.galagosearch.tupleflow.execution.ErrorStore.Statement
escape(String) - Static method in class org.galagosearch.tupleflow.Utility
execute(StageGroupDescription, String) - Method in class org.galagosearch.tupleflow.execution.LocalStageExecutor
execute(StageInstanceDescription) - Method in class org.galagosearch.tupleflow.execution.LocalStageExecutor
execute(String) - Method in class org.galagosearch.tupleflow.execution.LocalStageExecutor
execute(StageGroupDescription, String) - Method in class org.galagosearch.tupleflow.execution.RemoteStageExecutor
execute(StageGroupDescription, String) - Method in interface org.galagosearch.tupleflow.execution.StageExecutor
execute(StageGroupDescription, String) - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor
ExNihiloSource<T> - Interface in org.galagosearch.tupleflow
exports - Variable in class org.galagosearch.tupleflow.execution.Job
externalName - Variable in class org.galagosearch.tupleflow.execution.StageConnectionPoint

F

FakeParameters - Class in org.galagosearch.tupleflow
FakeParameters(Parameters) - Constructor for class org.galagosearch.tupleflow.FakeParameters
fileCount() - Method in class org.galagosearch.tupleflow.execution.StageGroupDescription.DataPipeRegion
FileLocation - Class in org.galagosearch.tupleflow.execution
FileLocation(String, int, int) - Constructor for class org.galagosearch.tupleflow.execution.FileLocation
FileLocation(String, Locator) - Constructor for class org.galagosearch.tupleflow.execution.FileLocation
fileName - Variable in class org.galagosearch.tupleflow.execution.FileLocation
FileOrderedReader<T> - Class in org.galagosearch.tupleflow
FileOrderedReader(String, int, boolean) - Constructor for class org.galagosearch.tupleflow.FileOrderedReader
FileOrderedReader(String) - Constructor for class org.galagosearch.tupleflow.FileOrderedReader
FileOrderedReader(String, Order<T>, int, boolean) - Constructor for class org.galagosearch.tupleflow.FileOrderedReader: Creates a new instance of FileOrderedReader
FileOrderedReader(String, Order<T>, int) - Constructor for class org.galagosearch.tupleflow.FileOrderedReader
FileOrderedReader(String, Order<T>) - Constructor for class org.galagosearch.tupleflow.FileOrderedReader
FileOrderedWriter<T> - Class in org.galagosearch.tupleflow
FileOrderedWriter(String, Order<T>, boolean) - Constructor for class org.galagosearch.tupleflow.FileOrderedWriter
FileOrderedWriter(String, Order<T>) - Constructor for class org.galagosearch.tupleflow.FileOrderedWriter
FileOrderedWriter(File, Order<T>) - Constructor for class org.galagosearch.tupleflow.FileOrderedWriter
FileSource - Class in org.galagosearch.tupleflow
FileSource(TupleFlowParameters) - Constructor for class org.galagosearch.tupleflow.FileSource: Creates a new instance of FileSource
findDanglingEndpoints(Job) - Method in class org.galagosearch.tupleflow.execution.JobExecutor: In the parameter file, each stage has a connections section that describes a set of connection endpoints for the stage (inputs and outputs).
flush() - Method in class org.galagosearch.tupleflow.execution.NetworkedCounter
flush() - Method in class org.galagosearch.tupleflow.Sorter
flushIfNecessary() - Method in class org.galagosearch.tupleflow.Sorter

G

get(String) - Method in class org.galagosearch.tupleflow.Parameters: Gets the value for this key.
get(String, String) - Method in class org.galagosearch.tupleflow.Parameters: Gets the value for this key.
get(String, boolean) - Method in class org.galagosearch.tupleflow.Parameters: Gets the value for this key, but returning a default value if the key doesn't exist in the object.
get(String, long) - Method in class org.galagosearch.tupleflow.Parameters
get(String, double) - Method in class org.galagosearch.tupleflow.Parameters
get(String, String) - Method in class org.galagosearch.tupleflow.Parameters.Value
get(String) - Method in class org.galagosearch.tupleflow.Parameters.Value
getAbsolutePosition() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
getAsDefault(String, String) - Method in class org.galagosearch.tupleflow.Parameters: Gets the value for key.
getAsDefault(String, boolean) - Method in class org.galagosearch.tupleflow.Parameters
getAsDefault(String, long) - Method in class org.galagosearch.tupleflow.Parameters
getAsDefault(String, double) - Method in class org.galagosearch.tupleflow.Parameters
getAssignment() - Method in class org.galagosearch.tupleflow.execution.ConnectionEndPoint
getBlockedInstances() - Method in class org.galagosearch.tupleflow.execution.ErrorExecutionStatus
getBlockedInstances() - Method in class org.galagosearch.tupleflow.execution.LocalStageExecutor.SequentialExecutionContext
getBlockedInstances() - Method in class org.galagosearch.tupleflow.execution.SSHStageExecutor.SSHStageExecutionContext
getBlockedInstances() - Method in interface org.galagosearch.tupleflow.execution.StageExecutionStatus
getBlockedInstances() - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor.ThreadedStageContext
getClassName() - Method in class org.galagosearch.tupleflow.execution.DataPipe
getClassName() - Method in class org.galagosearch.tupleflow.execution.StageConnectionPoint
getClassName() - Method in class org.galagosearch.tupleflow.execution.Step
getCompletedInstances() - Method in class org.galagosearch.tupleflow.execution.ErrorExecutionStatus
getCompletedInstances() - Method in class org.galagosearch.tupleflow.execution.LocalStageExecutor.SequentialExecutionContext
getCompletedInstances() - Method in class org.galagosearch.tupleflow.execution.SSHStageExecutor.SSHStageExecutionContext
getCompletedInstances() - Method in interface org.galagosearch.tupleflow.execution.StageExecutionStatus
getCompletedInstances() - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor.ThreadedStageContext
getConnection() - Method in class org.galagosearch.tupleflow.execution.JobConstructor.ConnectionHandler
getConnection(String) - Method in class org.galagosearch.tupleflow.execution.Stage
getConnectionPoints() - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StageConnectionsHandler
getConnections() - Method in class org.galagosearch.tupleflow.execution.JobConstructor.ConnectionsHandler
getConnections() - Method in class org.galagosearch.tupleflow.execution.Stage
getCounter(String) - Method in class org.galagosearch.tupleflow.execution.StageInstanceFactory.StepParameters
getCounter(String) - Method in class org.galagosearch.tupleflow.FakeParameters
getCounter(String) - Method in interface org.galagosearch.tupleflow.TupleFlowParameters
getCounterName() - Method in class org.galagosearch.tupleflow.execution.MasterWebHandler.CounterName
getDataInput() - Method in class org.galagosearch.tupleflow.ArrayInput
getDataOutput() - Method in class org.galagosearch.tupleflow.ArrayOutput
getDocumentation() - Method in interface org.galagosearch.tupleflow.execution.StepSpecification
getErrorHandler(FileLocation) - Method in class org.galagosearch.tupleflow.execution.ErrorStore
getErrors() - Method in class org.galagosearch.tupleflow.execution.ErrorStore
getErrorStore() - Method in class org.galagosearch.tupleflow.execution.JobConstructor
getException() - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor.InstanceRunnable
getExceptions() - Method in class org.galagosearch.tupleflow.execution.ErrorExecutionStatus
getExceptions() - Method in class org.galagosearch.tupleflow.execution.LocalStageExecutor.SequentialExecutionContext
getExceptions() - Method in class org.galagosearch.tupleflow.execution.SSHStageExecutor.SSHStageExecutionContext
getExceptions() - Method in interface org.galagosearch.tupleflow.execution.StageExecutionStatus
getExceptions() - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor.ThreadedStageContext
getExternalName() - Method in class org.galagosearch.tupleflow.execution.StageConnectionPoint
getFileName(int, int) - Method in class org.galagosearch.tupleflow.execution.DataPipe
getFileNames() - Method in class org.galagosearch.tupleflow.execution.StageInstanceDescription.PipeInput
getFileNames() - Method in class org.galagosearch.tupleflow.execution.StageInstanceDescription.PipeOutput
getFreeMemory() - Method in class org.galagosearch.tupleflow.execution.JobExecutor.JobExecutionStatus: Returns the total amount of free memory in this JVM.
getFreePort() - Static method in class org.galagosearch.tupleflow.Utility: Finds a free port to listen on.
getFreeSpace(String) - Static method in class org.galagosearch.tupleflow.Utility
getHash() - Method in class org.galagosearch.tupleflow.execution.DataPipe
getId() - Method in class org.galagosearch.tupleflow.execution.InputStep
getId() - Method in class org.galagosearch.tupleflow.execution.OutputStep
getIndex() - Method in class org.galagosearch.tupleflow.execution.StageInstanceDescription
getInput(String) - Method in interface org.galagosearch.tupleflow.execution.StepSpecification
getInputClass() - Method in interface org.galagosearch.tupleflow.execution.StepSpecification
getInputClass() - Method in class org.galagosearch.tupleflow.FileOrderedWriter
getInputClass(TupleFlowParameters) - Static method in class org.galagosearch.tupleflow.NullProcessor
getInputClass(TupleFlowParameters) - Static method in class org.galagosearch.tupleflow.Sorter
getInputClass(TupleFlowParameters) - Static method in class org.galagosearch.tupleflow.StreamCombiner
getInputCount() - Method in class org.galagosearch.tupleflow.execution.DataPipe
getInputFileNames(int) - Method in class org.galagosearch.tupleflow.execution.DataPipe
getInputOrder(String) - Method in interface org.galagosearch.tupleflow.execution.StepSpecification
getInputOrder() - Method in interface org.galagosearch.tupleflow.execution.StepSpecification
getInputOrder(TupleFlowParameters) - Static method in class org.galagosearch.tupleflow.NullProcessor
getInputOrder(TupleFlowParameters) - Static method in class org.galagosearch.tupleflow.StreamCombiner
getInstanceCount() - Method in class org.galagosearch.tupleflow.execution.StageGroupDescription
getInstances() - Method in class org.galagosearch.tupleflow.execution.StageGroupDescription
getInternalName() - Method in class org.galagosearch.tupleflow.execution.StageConnectionPoint
getJob() - Method in class org.galagosearch.tupleflow.execution.JobConstructor
getJob() - Method in class org.galagosearch.tupleflow.execution.JobConstructor.JobHandler
getLastPageLoad() - Method in class org.galagosearch.tupleflow.execution.MasterWebHandler
getLocation() - Method in class org.galagosearch.tupleflow.execution.Locatable
getLocation() - Method in class org.galagosearch.tupleflow.execution.Step
getMasterURL() - Method in class org.galagosearch.tupleflow.execution.StageGroupDescription
getMasterURL() - Method in class org.galagosearch.tupleflow.execution.StageInstanceDescription
getMaxMemory() - Method in class org.galagosearch.tupleflow.execution.JobExecutor.JobExecutionStatus: Returns the maximum amount of memory that can be used by this Java virtual machine.
getName() - Method in class org.galagosearch.tupleflow.execution.Connection
getName() - Method in class org.galagosearch.tupleflow.execution.ErrorExecutionStatus
getName() - Method in class org.galagosearch.tupleflow.execution.LocalStageExecutor.SequentialExecutionContext
getName() - Method in class org.galagosearch.tupleflow.execution.SSHStageExecutor.SSHStageExecutionContext
getName() - Method in interface org.galagosearch.tupleflow.execution.StageExecutionStatus
getName() - Method in class org.galagosearch.tupleflow.execution.StageGroupDescription
getName() - Method in class org.galagosearch.tupleflow.execution.StageInstanceDescription
getName() - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor.ThreadedStageContext
getOrder() - Method in class org.galagosearch.tupleflow.execution.DataPipe
getOrder() - Method in class org.galagosearch.tupleflow.execution.StageConnectionPoint
getOrder() - Method in class org.galagosearch.tupleflow.FileOrderedReader
getOrder(String...) - Method in interface org.galagosearch.tupleflow.Type
getOrderedClass() - Method in interface org.galagosearch.tupleflow.Order
getOrderedReader() - Method in class org.galagosearch.tupleflow.FileOrderedReader
getOrderSpec() - Method in interface org.galagosearch.tupleflow.Order: Returns a string representation of the fields ordered by this class.
getOutput(String) - Method in interface org.galagosearch.tupleflow.execution.StepSpecification
getOutputClass() - Method in interface org.galagosearch.tupleflow.execution.StepSpecification
getOutputClass() - Method in class org.galagosearch.tupleflow.FileOrderedReader
getOutputClass(TupleFlowParameters) - Static method in class org.galagosearch.tupleflow.NullSource
getOutputClass() - Method in class org.galagosearch.tupleflow.OrderedCombiner
getOutputClass(TupleFlowParameters) - Method in class org.galagosearch.tupleflow.Select
getOutputClass() - Method in class org.galagosearch.tupleflow.SequentialCombiner
getOutputClass(TupleFlowParameters) - Static method in class org.galagosearch.tupleflow.Sorter
getOutputClass(TupleFlowParameters) - Static method in class org.galagosearch.tupleflow.StreamCombiner
getOutputCount() - Method in class org.galagosearch.tupleflow.execution.DataPipe
getOutputFileNames(int) - Method in class org.galagosearch.tupleflow.execution.DataPipe
getOutputOrder(String) - Method in interface org.galagosearch.tupleflow.execution.StepSpecification
getOutputOrder() - Method in interface org.galagosearch.tupleflow.execution.StepSpecification
getOutputOrder(TupleFlowParameters) - Static method in class org.galagosearch.tupleflow.Sorter
getOutputOrder(TupleFlowParameters) - Static method in class org.galagosearch.tupleflow.StreamCombiner
getParameters() - Method in class org.galagosearch.tupleflow.execution.Step
getParseHandler() - Method in class org.galagosearch.tupleflow.Parameters
getPath() - Method in class org.galagosearch.tupleflow.execution.StageInstanceDescription
getPipe() - Method in class org.galagosearch.tupleflow.execution.StageInstanceDescription.PipeInput
getPipe() - Method in class org.galagosearch.tupleflow.execution.StageInstanceDescription.PipeOutput
getPipeName() - Method in class org.galagosearch.tupleflow.execution.DataPipe
getPoint() - Method in class org.galagosearch.tupleflow.execution.Job.StagePoint
getPointName() - Method in class org.galagosearch.tupleflow.execution.ConnectionEndPoint
getPosition() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
getPosition() - Method in interface org.galagosearch.tupleflow.DataStream
getPosition() - Method in class org.galagosearch.tupleflow.MemoryDataStream
getQueuedInstances() - Method in class org.galagosearch.tupleflow.execution.ErrorExecutionStatus
getQueuedInstances() - Method in class org.galagosearch.tupleflow.execution.LocalStageExecutor.SequentialExecutionContext
getQueuedInstances() - Method in class org.galagosearch.tupleflow.execution.SSHStageExecutor.SSHStageExecutionContext
getQueuedInstances() - Method in interface org.galagosearch.tupleflow.execution.StageExecutionStatus
getQueuedInstances() - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor.ThreadedStageContext
getReaders() - Method in class org.galagosearch.tupleflow.execution.StageInstanceDescription
getRunningInstances() - Method in class org.galagosearch.tupleflow.execution.ErrorExecutionStatus
getRunningInstances() - Method in class org.galagosearch.tupleflow.execution.LocalStageExecutor.SequentialExecutionContext
getRunningInstances() - Method in class org.galagosearch.tupleflow.execution.SSHStageExecutor.SSHStageExecutionContext
getRunningInstances() - Method in interface org.galagosearch.tupleflow.execution.StageExecutionStatus
getRunningInstances() - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor.ThreadedStageContext
getSorter(Order) - Static method in class org.galagosearch.tupleflow.Utility: Builds a simple Sorter step that can be added to a TupleFlow stage.
getStage() - Method in class org.galagosearch.tupleflow.execution.Chain
getStage() - Method in class org.galagosearch.tupleflow.execution.StageGroupDescription
getStage() - Method in class org.galagosearch.tupleflow.execution.StageInstanceDescription
getStageName() - Method in class org.galagosearch.tupleflow.execution.ConnectionEndPoint
getStageName() - Method in class org.galagosearch.tupleflow.execution.MasterWebHandler.CounterName
getStageStatus() - Method in class org.galagosearch.tupleflow.execution.JobExecutor.JobExecutionStatus
getStartDate() - Method in class org.galagosearch.tupleflow.execution.JobExecutor.JobExecutionStatus: Returns the start date for this job.
getStep() - Method in class org.galagosearch.tupleflow.execution.JobConstructor.MultiHandler
getStep() - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StepHandler
getSteps() - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StepsHandler
getSteps() - Method in class org.galagosearch.tupleflow.execution.Stage
getType() - Method in class org.galagosearch.tupleflow.execution.ConnectionEndPoint
getType() - Method in class org.galagosearch.tupleflow.execution.StageConnectionPoint
getTypeReader(StageInstanceDescription.PipeOutput) - Static method in class org.galagosearch.tupleflow.execution.StageInstanceFactory
getTypeReader(String) - Method in class org.galagosearch.tupleflow.execution.StageInstanceFactory.StepParameters
getTypeReader(String) - Method in class org.galagosearch.tupleflow.FakeParameters
getTypeReader(String) - Method in interface org.galagosearch.tupleflow.TupleFlowParameters
getTypeReaderSource(StageInstanceDescription.PipeOutput) - Method in class org.galagosearch.tupleflow.execution.StageInstanceFactory
getTypeWriter(StageInstanceDescription.PipeInput) - Static method in class org.galagosearch.tupleflow.execution.StageInstanceFactory
getTypeWriter(String) - Method in class org.galagosearch.tupleflow.execution.StageInstanceFactory.StepParameters
getTypeWriter(String) - Method in class org.galagosearch.tupleflow.FakeParameters
getTypeWriter(String) - Method in interface org.galagosearch.tupleflow.TupleFlowParameters
getUnixFreeSpace(String) - Static method in class org.galagosearch.tupleflow.Utility
getWarnings() - Method in class org.galagosearch.tupleflow.execution.ErrorStore
getWriters() - Method in class org.galagosearch.tupleflow.execution.StageInstanceDescription
getXML() - Method in class org.galagosearch.tupleflow.execution.StageInstanceFactory.StepParameters
getXML() - Method in class org.galagosearch.tupleflow.FakeParameters
getXML() - Method in interface org.galagosearch.tupleflow.TupleFlowParameters
greaterThan() - Method in interface org.galagosearch.tupleflow.Order: lessThan().compare(a,b) = greaterThan().compare(b,a);
groups - Variable in class org.galagosearch.tupleflow.execution.MultiStep

H

handle(String, HttpServletRequest, HttpServletResponse, int) - Method in class org.galagosearch.tupleflow.execution.MasterWebHandler
handleNotification(Notification, Object) - Method in class org.galagosearch.tupleflow.Sorter
handleSetCounter(HttpServletRequest, HttpServletResponse) - Method in class org.galagosearch.tupleflow.execution.MasterWebHandler
handleStatus(HttpServletRequest, HttpServletResponse) - Method in class org.galagosearch.tupleflow.execution.MasterWebHandler
hash - Variable in class org.galagosearch.tupleflow.execution.DataPipe
hash(T) - Method in interface org.galagosearch.tupleflow.Order: This is a hash function over an object that only uses ordered fields.
hash(byte) - Static method in class org.galagosearch.tupleflow.Utility
hash(int) - Static method in class org.galagosearch.tupleflow.Utility
hash(long) - Static method in class org.galagosearch.tupleflow.Utility
hash(double) - Static method in class org.galagosearch.tupleflow.Utility
hash(float) - Static method in class org.galagosearch.tupleflow.Utility
hash(String) - Static method in class org.galagosearch.tupleflow.Utility
hash(byte[]) - Static method in class org.galagosearch.tupleflow.Utility
hashCode() - Method in class org.galagosearch.tupleflow.execution.Job.StagePoint
hasStatements() - Method in class org.galagosearch.tupleflow.execution.ErrorStore

I

IncompatibleProcessorException - Exception in org.galagosearch.tupleflow
IncompatibleProcessorException(String) - Constructor for exception org.galagosearch.tupleflow.IncompatibleProcessorException
IncompatibleProcessorException(String, Throwable) - Constructor for exception org.galagosearch.tupleflow.IncompatibleProcessorException
increment() - Method in interface org.galagosearch.tupleflow.Counter
increment() - Method in class org.galagosearch.tupleflow.execution.NetworkedCounter
incrementBy(int) - Method in interface org.galagosearch.tupleflow.Counter
incrementBy(int) - Method in class org.galagosearch.tupleflow.execution.NetworkedCounter
input - Variable in class org.galagosearch.tupleflow.OrderedReader
InputClass - Annotation Type in org.galagosearch.tupleflow
inputs - Variable in class org.galagosearch.tupleflow.execution.Connection
inputs - Variable in class org.galagosearch.tupleflow.execution.StageGroupDescription
InputStep - Class in org.galagosearch.tupleflow.execution: Represents an input step in a TupleFlow stage.
InputStep(String) - Constructor for class org.galagosearch.tupleflow.execution.InputStep
InputStep(FileLocation, String) - Constructor for class org.galagosearch.tupleflow.execution.InputStep
inputStream(String) - Static method in class org.galagosearch.tupleflow.StreamCreator
instanceCount - Variable in class org.galagosearch.tupleflow.execution.StageGroupDescription
instantiate(StageInstanceDescription) - Method in class org.galagosearch.tupleflow.execution.StageInstanceFactory
instantiate(StageInstanceDescription, ArrayList<Step>) - Method in class org.galagosearch.tupleflow.execution.StageInstanceFactory
instantiateInput(StageInstanceDescription, InputStep) - Method in class org.galagosearch.tupleflow.execution.StageInstanceFactory
instantiateOutput(StageInstanceDescription, OutputStep) - Method in class org.galagosearch.tupleflow.execution.StageInstanceFactory
instantiateStep(StageInstanceDescription, Step) - Method in class org.galagosearch.tupleflow.execution.StageInstanceFactory
internalName - Variable in class org.galagosearch.tupleflow.execution.StageConnectionPoint
isClassAvailable(String) - Static method in class org.galagosearch.tupleflow.execution.Verification
isComplete() - Method in class org.galagosearch.tupleflow.execution.JobExecutor.JobExecutionStatus
isDone() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
isDone() - Method in interface org.galagosearch.tupleflow.DataStream
isDone() - Method in class org.galagosearch.tupleflow.execution.ErrorExecutionStatus
isDone() - Method in class org.galagosearch.tupleflow.execution.LocalStageExecutor.SequentialExecutionContext
isDone() - Method in class org.galagosearch.tupleflow.execution.SSHStageExecutor.SSHStageExecutionContext
isDone() - Method in interface org.galagosearch.tupleflow.execution.StageExecutionStatus
isDone() - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor.InstanceRunnable
isDone() - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor.ThreadedStageContext
isDone() - Method in class org.galagosearch.tupleflow.MemoryDataStream
isEmpty() - Method in class org.galagosearch.tupleflow.Parameters
isEmpty() - Method in class org.galagosearch.tupleflow.Parameters.Value: Returns true if there is no data in this value object.
isInteger(String) - Static method in class org.galagosearch.tupleflow.Utility
isNullTask() - Method in class org.galagosearch.tupleflow.execution.SSHStageExecutor.StageTask
isOrderAvailable(String, String[]) - Static method in class org.galagosearch.tupleflow.execution.Verification
isQueued() - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor.InstanceRunnable
isRunning() - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor.InstanceRunnable
isStatic() - Method in class org.galagosearch.tupleflow.Parameters.CharSequenceBuffer
isStepClassAvailable() - Method in class org.galagosearch.tupleflow.execution.Step

J

Job - Class in org.galagosearch.tupleflow.execution: A Job object specifies a TupleFlow execution: the objects used, their parameters, and how they communicate.
Job() - Constructor for class org.galagosearch.tupleflow.execution.Job
Job.StagePoint - Class in org.galagosearch.tupleflow.execution
Job.StagePoint(String, String) - Constructor for class org.galagosearch.tupleflow.execution.Job.StagePoint
Job.StagePoint(String, String, StageConnectionPoint) - Constructor for class org.galagosearch.tupleflow.execution.Job.StagePoint
JobConnectionEndPoint - Class in org.galagosearch.tupleflow.execution
JobConnectionEndPoint() - Constructor for class org.galagosearch.tupleflow.execution.JobConnectionEndPoint
JobConstructor - Class in org.galagosearch.tupleflow.execution
JobConstructor(String, ErrorStore) - Constructor for class org.galagosearch.tupleflow.execution.JobConstructor: Creates a new instance of JobConstructor
JobConstructor(ErrorStore) - Constructor for class org.galagosearch.tupleflow.execution.JobConstructor
JobConstructor.ConnectionHandler - Class in org.galagosearch.tupleflow.execution
JobConstructor.ConnectionHandler() - Constructor for class org.galagosearch.tupleflow.execution.JobConstructor.ConnectionHandler
JobConstructor.ConnectionsHandler - Class in org.galagosearch.tupleflow.execution
JobConstructor.ConnectionsHandler() - Constructor for class org.galagosearch.tupleflow.execution.JobConstructor.ConnectionsHandler
JobConstructor.JobHandler - Class in org.galagosearch.tupleflow.execution
JobConstructor.JobHandler() - Constructor for class org.galagosearch.tupleflow.execution.JobConstructor.JobHandler
JobConstructor.MultiHandler - Class in org.galagosearch.tupleflow.execution
JobConstructor.MultiHandler() - Constructor for class org.galagosearch.tupleflow.execution.JobConstructor.MultiHandler
JobConstructor.StageConnectionsHandler - Class in org.galagosearch.tupleflow.execution
JobConstructor.StageConnectionsHandler() - Constructor for class org.galagosearch.tupleflow.execution.JobConstructor.StageConnectionsHandler
JobConstructor.StageHandler - Class in org.galagosearch.tupleflow.execution
JobConstructor.StageHandler() - Constructor for class org.galagosearch.tupleflow.execution.JobConstructor.StageHandler
JobConstructor.StagesHandler - Class in org.galagosearch.tupleflow.execution
JobConstructor.StagesHandler() - Constructor for class org.galagosearch.tupleflow.execution.JobConstructor.StagesHandler
JobConstructor.StepHandler - Class in org.galagosearch.tupleflow.execution
JobConstructor.StepHandler() - Constructor for class org.galagosearch.tupleflow.execution.JobConstructor.StepHandler
JobConstructor.StepsHandler - Class in org.galagosearch.tupleflow.execution
JobConstructor.StepsHandler() - Constructor for class org.galagosearch.tupleflow.execution.JobConstructor.StepsHandler
JobExecutor - Class in org.galagosearch.tupleflow.execution: This class is responsible for executing TupleFlow jobs.
JobExecutor(Job, String, ErrorStore) - Constructor for class org.galagosearch.tupleflow.execution.JobExecutor
JobExecutor.JobExecutionStatus - Class in org.galagosearch.tupleflow.execution
JobExecutor.JobExecutionStatus(HashMap<String, StageGroupDescription>, String, StageExecutor, String) - Constructor for class org.galagosearch.tupleflow.execution.JobExecutor.JobExecutionStatus
join(String[], String) - Static method in class org.galagosearch.tupleflow.Utility: Returns a string containing all the elements of args, space delimited.
join(String[]) - Static method in class org.galagosearch.tupleflow.Utility

L

last - Variable in class org.galagosearch.tupleflow.OrderedReader
length() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
length() - Method in interface org.galagosearch.tupleflow.DataStream
length() - Method in class org.galagosearch.tupleflow.MemoryDataStream
length() - Method in class org.galagosearch.tupleflow.Parameters.CharSequenceBuffer
lessThan() - Method in interface org.galagosearch.tupleflow.Order: Returns a comparator that applies this order to objects of type T.
lineNumber - Variable in class org.galagosearch.tupleflow.execution.FileLocation
link(Step, Step, String) - Static method in class org.galagosearch.tupleflow.Linkage
link(Step, Step) - Static method in class org.galagosearch.tupleflow.Linkage
Linkage - Class in org.galagosearch.tupleflow
Linkage() - Constructor for class org.galagosearch.tupleflow.Linkage
list(String) - Method in class org.galagosearch.tupleflow.Parameters
list(String) - Method in class org.galagosearch.tupleflow.Parameters.Value
LocalRemoteStageExecutor - Class in org.galagosearch.tupleflow.execution: This executor has no practical use at all.
LocalRemoteStageExecutor() - Constructor for class org.galagosearch.tupleflow.execution.LocalRemoteStageExecutor
LocalStageExecutor - Class in org.galagosearch.tupleflow.execution
LocalStageExecutor() - Constructor for class org.galagosearch.tupleflow.execution.LocalStageExecutor
LocalStageExecutor.SequentialExecutionContext - Class in org.galagosearch.tupleflow.execution
Locatable - Class in org.galagosearch.tupleflow.execution: This is a mixin class that allows a Job stage/step class to be associated with a file location.
Locatable(FileLocation) - Constructor for class org.galagosearch.tupleflow.execution.Locatable
location() - Method in class org.galagosearch.tupleflow.execution.JobConstructor
location - Variable in class org.galagosearch.tupleflow.execution.Locatable
location - Variable in class org.galagosearch.tupleflow.execution.Step

M

main(String[]) - Static method in class org.galagosearch.tupleflow.execution.JobExecutor
main(String[]) - Static method in class org.galagosearch.tupleflow.execution.LocalStageExecutor
makeBytes(String) - Static method in class org.galagosearch.tupleflow.Utility
makeDirectories() - Method in class org.galagosearch.tupleflow.execution.DataPipe
makeString(byte[]) - Static method in class org.galagosearch.tupleflow.Utility
map() - Method in class org.galagosearch.tupleflow.Parameters.Value
markDone() - Method in class org.galagosearch.tupleflow.execution.LocalStageExecutor.SequentialExecutionContext
MasterWebHandler - Class in org.galagosearch.tupleflow.execution: This handler creates a web interface for checking on the status of a running TupleFlow job.
MasterWebHandler(JobExecutor.JobExecutionStatus) - Constructor for class org.galagosearch.tupleflow.execution.MasterWebHandler
MasterWebHandler.CounterName - Class in org.galagosearch.tupleflow.execution
MasterWebHandler.CounterName(String, String) - Constructor for class org.galagosearch.tupleflow.execution.MasterWebHandler.CounterName
MemoryDataStream - Class in org.galagosearch.tupleflow
MemoryDataStream(byte[], int, int) - Constructor for class org.galagosearch.tupleflow.MemoryDataStream
more - Variable in class org.galagosearch.tupleflow.OrderedCombiner.SortPair
Multi<T> - Class in org.galagosearch.tupleflow
Multi(Processor[]) - Constructor for class org.galagosearch.tupleflow.Multi: Creates a new instance of Multi
Multi(List<Processor>) - Constructor for class org.galagosearch.tupleflow.Multi
MultiStep - Class in org.galagosearch.tupleflow.execution: Represents a multi block in a TupleFlow stage.
MultiStep() - Constructor for class org.galagosearch.tupleflow.execution.MultiStep

N

name - Variable in class org.galagosearch.tupleflow.execution.Stage
needsFlush() - Method in class org.galagosearch.tupleflow.Sorter
needsInit - Variable in class org.galagosearch.tupleflow.OrderedReader
needsMergeStages() - Method in class org.galagosearch.tupleflow.execution.JobExecutor: Checks to see if any stage has too many inputs.
NetworkedCounter - Class in org.galagosearch.tupleflow.execution
NetworkedCounterManager - Class in org.galagosearch.tupleflow.execution
NetworkedCounterManager() - Constructor for class org.galagosearch.tupleflow.execution.NetworkedCounterManager
newCounter(String, String, String, String) - Method in class org.galagosearch.tupleflow.execution.NetworkedCounterManager
newInstance(String, String...) - Static method in class org.galagosearch.tupleflow.execution.StageExecutorFactory
NullProcessor<T> - Class in org.galagosearch.tupleflow
NullProcessor() - Constructor for class org.galagosearch.tupleflow.NullProcessor
NullProcessor(TupleFlowParameters) - Constructor for class org.galagosearch.tupleflow.NullProcessor
NullProcessor(Class<T>) - Constructor for class org.galagosearch.tupleflow.NullProcessor
NullSource<T> - Class in org.galagosearch.tupleflow
NullSource(TupleFlowParameters) - Constructor for class org.galagosearch.tupleflow.NullSource
NullSource(Class<T>) - Constructor for class org.galagosearch.tupleflow.NullSource

O

object - Variable in class org.galagosearch.tupleflow.OrderedCombiner.SortPair
optimize(Job) - Static method in class org.galagosearch.tupleflow.execution.JobExecutor: This method tries to combine stages together to reduce overhead.
order - Variable in class org.galagosearch.tupleflow.execution.DataPipe
Order<T> - Interface in org.galagosearch.tupleflow: An Order is a class that represents an ordering of a Galago Type.
orderedCombiner(Collection<TypeReader<T>>, boolean) - Method in interface org.galagosearch.tupleflow.Order: Produces an OrderedCombiner object.
OrderedCombiner<T> - Class in org.galagosearch.tupleflow
OrderedCombiner(TypeReader<T>[], FileOrderedReader<T>[], Order<T>, Processor<T>, boolean) - Constructor for class org.galagosearch.tupleflow.OrderedCombiner
OrderedCombiner(TypeReader<T>[], Order<T>, Processor<T>) - Constructor for class org.galagosearch.tupleflow.OrderedCombiner
OrderedCombiner(TypeReader<T>[], Order<T>) - Constructor for class org.galagosearch.tupleflow.OrderedCombiner
OrderedCombiner.SortPair<T> - Class in org.galagosearch.tupleflow
OrderedCombiner.SortPair(T, TypeReader<T>) - Constructor for class org.galagosearch.tupleflow.OrderedCombiner.SortPair
orderedReader(ArrayInput) - Method in interface org.galagosearch.tupleflow.Order: Produces an OrderedReader object.
orderedReader(ArrayInput, int) - Method in interface org.galagosearch.tupleflow.Order: Produces an OrderedReader object.
OrderedReader<T> - Class in org.galagosearch.tupleflow
OrderedReader(ArrayInput, Processor<T>) - Constructor for class org.galagosearch.tupleflow.OrderedReader
OrderedReader(ArrayInput) - Constructor for class org.galagosearch.tupleflow.OrderedReader
orderedWriter(ArrayOutput) - Method in interface org.galagosearch.tupleflow.Order: Produces an OrderedWriter object that can write objects of class T in this order.
OrderedWriter<T> - Class in org.galagosearch.tupleflow
OrderedWriter() - Constructor for class org.galagosearch.tupleflow.OrderedWriter
org.galagosearch.tupleflow - package org.galagosearch.tupleflow
org.galagosearch.tupleflow.execution - package org.galagosearch.tupleflow.execution
OutputClass - Annotation Type in org.galagosearch.tupleflow
outputs - Variable in class org.galagosearch.tupleflow.execution.Connection
outputs - Variable in class org.galagosearch.tupleflow.execution.StageGroupDescription
OutputStep - Class in org.galagosearch.tupleflow.execution: Represents an output step in a TupleFlow stage.
OutputStep(String) - Constructor for class org.galagosearch.tupleflow.execution.OutputStep
OutputStep(FileLocation, String) - Constructor for class org.galagosearch.tupleflow.execution.OutputStep
outputStream(String) - Static method in class org.galagosearch.tupleflow.StreamCreator

P

Parameters - Class in org.galagosearch.tupleflow: A Parameters object is a hierarchical collection of strings.
Parameters() - Constructor for class org.galagosearch.tupleflow.Parameters
Parameters(byte[]) - Constructor for class org.galagosearch.tupleflow.Parameters: Creates a Parameters object using XML data.
Parameters(File) - Constructor for class org.galagosearch.tupleflow.Parameters: Creates a Parameters object using the contents of an XML file.
Parameters(Parameters.Value) - Constructor for class org.galagosearch.tupleflow.Parameters
Parameters(Map<String, String>) - Constructor for class org.galagosearch.tupleflow.Parameters: Creates a Parameters object based on a key/value map.
Parameters(String[]) - Constructor for class org.galagosearch.tupleflow.Parameters: Fills in a Parameters object based on command line flags.
Parameters.CharSequenceBuffer - Class in org.galagosearch.tupleflow: This class gathers up a stack of CharSequence objects and makes them look like a single CharSequence.
Parameters.CharSequenceBuffer() - Constructor for class org.galagosearch.tupleflow.Parameters.CharSequenceBuffer
Parameters.Parser - Class in org.galagosearch.tupleflow
Parameters.Parser() - Constructor for class org.galagosearch.tupleflow.Parameters.Parser
Parameters.Value - Class in org.galagosearch.tupleflow
Parameters.Value() - Constructor for class org.galagosearch.tupleflow.Parameters.Value: Construct a new Value object with nothing in it.
Parameters.Variable - Class in org.galagosearch.tupleflow
Parameters.Variable(String) - Constructor for class org.galagosearch.tupleflow.Parameters.Variable
parse(String) - Method in class org.galagosearch.tupleflow.Parameters
parse(byte[]) - Method in class org.galagosearch.tupleflow.Parameters
parseFile(String, ErrorStore) - Static method in class org.galagosearch.tupleflow.execution.JobExecutor: Parses the XML text in the file specified by the filename parameter into a Job.
parseText(String, ErrorStore) - Static method in class org.galagosearch.tupleflow.execution.JobExecutor: Parses the XML text in the text parameter into a Job.
pipeName - Variable in class org.galagosearch.tupleflow.execution.DataPipe
plural(String) - Static method in class org.galagosearch.tupleflow.Utility
prepare() - Method in class org.galagosearch.tupleflow.execution.JobExecutor
process(T) - Method in class org.galagosearch.tupleflow.FileOrderedWriter
process(T) - Method in class org.galagosearch.tupleflow.Multi
process(T) - Method in class org.galagosearch.tupleflow.NullProcessor
process(T) - Method in class org.galagosearch.tupleflow.OrderedWriter
process(T) - Method in interface org.galagosearch.tupleflow.Processor
process(T) - Method in class org.galagosearch.tupleflow.Sorter
process(T) - Method in class org.galagosearch.tupleflow.Splitter
process(T) - Method in class org.galagosearch.tupleflow.StandardStep
process(T) - Method in class org.galagosearch.tupleflow.Unique
process(XMLFragment) - Method in class org.galagosearch.tupleflow.XMLMinimum
processor - Variable in class org.galagosearch.tupleflow.FileSource
processor - Variable in class org.galagosearch.tupleflow.NullSource
processor - Variable in class org.galagosearch.tupleflow.OrderedCombiner
processor - Variable in class org.galagosearch.tupleflow.OrderedReader
Processor<T> - Interface in org.galagosearch.tupleflow
processor - Variable in class org.galagosearch.tupleflow.Select
processor - Variable in class org.galagosearch.tupleflow.SequentialCombiner
processor - Variable in class org.galagosearch.tupleflow.StandardStep
processor - Variable in class org.galagosearch.tupleflow.StreamCombiner
properties - Variable in class org.galagosearch.tupleflow.execution.Job

R

read() - Method in class org.galagosearch.tupleflow.FileOrderedReader
read() - Method in class org.galagosearch.tupleflow.OrderedCombiner
read() - Method in class org.galagosearch.tupleflow.OrderedReader
read() - Method in class org.galagosearch.tupleflow.SequentialCombiner
read() - Method in interface org.galagosearch.tupleflow.TypeReader
readBoolean() - Method in class org.galagosearch.tupleflow.ArrayInput
readBoolean() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
readBoolean() - Method in class org.galagosearch.tupleflow.MemoryDataStream
readBoolean() - Method in class org.galagosearch.tupleflow.VByteInput
readByte() - Method in class org.galagosearch.tupleflow.ArrayInput
readByte() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
readByte() - Method in class org.galagosearch.tupleflow.MemoryDataStream
readByte() - Method in class org.galagosearch.tupleflow.VByteInput
readBytes() - Method in class org.galagosearch.tupleflow.ArrayInput
readChar() - Method in class org.galagosearch.tupleflow.ArrayInput
readChar() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
readChar() - Method in class org.galagosearch.tupleflow.MemoryDataStream
readChar() - Method in class org.galagosearch.tupleflow.VByteInput
readChars() - Method in class org.galagosearch.tupleflow.ArrayInput
readDouble() - Method in class org.galagosearch.tupleflow.ArrayInput
readDouble() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
readDouble() - Method in class org.galagosearch.tupleflow.MemoryDataStream
readDouble() - Method in class org.galagosearch.tupleflow.VByteInput
readDoubles() - Method in class org.galagosearch.tupleflow.ArrayInput
readerExists(String, String, String[]) - Method in class org.galagosearch.tupleflow.execution.StageInstanceDescription
readerExists(String, String, String[]) - Method in class org.galagosearch.tupleflow.execution.StageInstanceFactory.StepParameters
readerExists(String, String, String[]) - Method in class org.galagosearch.tupleflow.FakeParameters
readerExists(String, String, String[]) - Method in interface org.galagosearch.tupleflow.TupleFlowParameters
ReaderSource<T> - Interface in org.galagosearch.tupleflow
readFileToStringSet(File) - Static method in class org.galagosearch.tupleflow.Utility
readFloat() - Method in class org.galagosearch.tupleflow.ArrayInput
readFloat() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
readFloat() - Method in class org.galagosearch.tupleflow.MemoryDataStream
readFloat() - Method in class org.galagosearch.tupleflow.VByteInput
readFloats() - Method in class org.galagosearch.tupleflow.ArrayInput
readFully(byte[], int, int) - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
readFully(byte[]) - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
readFully(byte[]) - Method in class org.galagosearch.tupleflow.MemoryDataStream
readFully(byte[], int, int) - Method in class org.galagosearch.tupleflow.MemoryDataStream
readFully(byte[], int, int) - Method in class org.galagosearch.tupleflow.VByteInput
readFully(byte[]) - Method in class org.galagosearch.tupleflow.VByteInput
readInt() - Method in class org.galagosearch.tupleflow.ArrayInput
readInt() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
readInt() - Method in class org.galagosearch.tupleflow.MemoryDataStream
readInt() - Method in class org.galagosearch.tupleflow.VByteInput
readInts() - Method in class org.galagosearch.tupleflow.ArrayInput
readLine() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
readLine() - Method in class org.galagosearch.tupleflow.MemoryDataStream
readLine() - Method in class org.galagosearch.tupleflow.VByteInput
readLong() - Method in class org.galagosearch.tupleflow.ArrayInput
readLong() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
readLong() - Method in class org.galagosearch.tupleflow.MemoryDataStream
readLong() - Method in class org.galagosearch.tupleflow.VByteInput
readLongs() - Method in class org.galagosearch.tupleflow.ArrayInput
readShort() - Method in class org.galagosearch.tupleflow.ArrayInput
readShort() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
readShort() - Method in class org.galagosearch.tupleflow.MemoryDataStream
readShort() - Method in class org.galagosearch.tupleflow.VByteInput
readShorts() - Method in class org.galagosearch.tupleflow.ArrayInput
readString() - Method in class org.galagosearch.tupleflow.ArrayInput
readString() - Method in class org.galagosearch.tupleflow.VByteInput
readStrings() - Method in class org.galagosearch.tupleflow.ArrayInput
readTuple() - Method in class org.galagosearch.tupleflow.OrderedReader
readUnsignedByte() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
readUnsignedByte() - Method in class org.galagosearch.tupleflow.MemoryDataStream
readUnsignedByte() - Method in class org.galagosearch.tupleflow.VByteInput
readUnsignedShort() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
readUnsignedShort() - Method in class org.galagosearch.tupleflow.MemoryDataStream
readUnsignedShort() - Method in class org.galagosearch.tupleflow.VByteInput
readUTF() - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
readUTF() - Method in class org.galagosearch.tupleflow.MemoryDataStream
readUTF() - Method in class org.galagosearch.tupleflow.VByteInput
realInputStream(String) - Static method in class org.galagosearch.tupleflow.StreamCreator
realOutputStream(String) - Static method in class org.galagosearch.tupleflow.StreamCreator
reduce(List<T>) - Method in interface org.galagosearch.tupleflow.Reducer
Reducer<T> - Interface in org.galagosearch.tupleflow
RemoteStageExecutor - Class in org.galagosearch.tupleflow.execution
RemoteStageExecutor() - Constructor for class org.galagosearch.tupleflow.execution.RemoteStageExecutor
removeMemoryWarnings() - Method in class org.galagosearch.tupleflow.Sorter
renameConnections(Job, Stage, Stage) - Static method in class org.galagosearch.tupleflow.execution.JobExecutor
requestMemoryWarnings() - Method in class org.galagosearch.tupleflow.Sorter
requireClass(String, ErrorHandler) - Static method in class org.galagosearch.tupleflow.execution.Verification
requireOrder(String, String[], ErrorHandler) - Static method in class org.galagosearch.tupleflow.execution.Verification
requireParameters(String[], Parameters, ErrorHandler) - Static method in class org.galagosearch.tupleflow.execution.Verification
requireWriteableDirectory(String, ErrorHandler) - Static method in class org.galagosearch.tupleflow.execution.Verification
requireWriteableDirectoryParent(String, ErrorHandler) - Static method in class org.galagosearch.tupleflow.execution.Verification: If pathname exists, returns true.
requireWriteableFile(String, ErrorHandler) - Static method in class org.galagosearch.tupleflow.execution.Verification
resetInt() - Static method in class org.galagosearch.tupleflow.Delta
resetLong() - Static method in class org.galagosearch.tupleflow.Delta
resetString() - Static method in class org.galagosearch.tupleflow.Delta
root - Variable in class org.galagosearch.tupleflow.execution.DataPipe
run() - Method in class org.galagosearch.tupleflow.execution.JobExecutor.JobExecutionStatus
run(StageExecutor) - Method in class org.galagosearch.tupleflow.execution.JobExecutor
run() - Method in class org.galagosearch.tupleflow.execution.LocalStageExecutor.SequentialExecutionContext
run() - Method in class org.galagosearch.tupleflow.execution.NetworkedCounterManager
run() - Method in class org.galagosearch.tupleflow.execution.SSHStageExecutor.SSHStageExecutionContext
run() - Method in class org.galagosearch.tupleflow.execution.SSHStageExecutor.StageTask
run() - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor.InstanceRunnable
run() - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor.ThreadedStageContext
run() - Method in interface org.galagosearch.tupleflow.ExNihiloSource
run() - Method in class org.galagosearch.tupleflow.FileOrderedReader
run() - Method in class org.galagosearch.tupleflow.FileSource
run() - Method in class org.galagosearch.tupleflow.NullSource
run() - Method in class org.galagosearch.tupleflow.OrderedCombiner
run() - Method in class org.galagosearch.tupleflow.OrderedReader
run() - Method in class org.galagosearch.tupleflow.Select
run() - Method in class org.galagosearch.tupleflow.SequentialCombiner
run() - Method in class org.galagosearch.tupleflow.StreamCombiner
run() - Method in interface org.galagosearch.tupleflow.TypeReader
runLocally(Job, ErrorStore) - Static method in class org.galagosearch.tupleflow.execution.JobExecutor
runWithServer(StageExecutor, Server) - Method in class org.galagosearch.tupleflow.execution.JobExecutor

S

seek(long) - Method in class org.galagosearch.tupleflow.BufferedFileDataStream: Seeks forward into the stream to a particular byte offset (reverse seeks are not allowed).
seek(long) - Method in interface org.galagosearch.tupleflow.DataStream: Seeks forward into the stream to a particular byte offset (reverse seeks are not allowed).
seek(long) - Method in class org.galagosearch.tupleflow.MemoryDataStream
seekAbsolute(long) - Method in class org.galagosearch.tupleflow.BufferedFileDataStream: Seeks forward into the stream to a particular byte offset (reverse seeks are not allowed).
Select<T> - Class in org.galagosearch.tupleflow: Takes two inputs, keys and values.
Select(TupleFlowParameters) - Constructor for class org.galagosearch.tupleflow.Select
SequentialCombiner<T> - Class in org.galagosearch.tupleflow
SequentialCombiner(List<String>, Order<T>) - Constructor for class org.galagosearch.tupleflow.SequentialCombiner: Creates a new instance of SequentialCombiner
set(String, List<Parameters.Value>) - Method in class org.galagosearch.tupleflow.Parameters
set(String, String) - Method in class org.galagosearch.tupleflow.Parameters
set(CharSequence) - Method in class org.galagosearch.tupleflow.Parameters.Value
set(String, List<Parameters.Value>) - Method in class org.galagosearch.tupleflow.Parameters.Value
setDocumentLocator(Locator) - Method in class org.galagosearch.tupleflow.execution.JobConstructor
setInputCount(int) - Method in class org.galagosearch.tupleflow.execution.DataPipe
setLastPageLoad(long) - Method in class org.galagosearch.tupleflow.execution.MasterWebHandler
setLocation(FileLocation) - Method in class org.galagosearch.tupleflow.execution.Locatable
setMasterURL(String) - Method in class org.galagosearch.tupleflow.execution.StageGroupDescription
setOutputCount(int) - Method in class org.galagosearch.tupleflow.execution.DataPipe
setParameters(Parameters) - Method in interface org.galagosearch.tupleflow.execution.StepSpecification
setPoint(StageConnectionPoint) - Method in class org.galagosearch.tupleflow.execution.Job.StagePoint
setPointName(String) - Method in class org.galagosearch.tupleflow.execution.ConnectionEndPoint
setProcessor(Step) - Method in class org.galagosearch.tupleflow.FileOrderedReader
setProcessor(Step) - Method in class org.galagosearch.tupleflow.FileSource
setProcessor(Step) - Method in class org.galagosearch.tupleflow.NullSource
setProcessor(Step) - Method in class org.galagosearch.tupleflow.OrderedCombiner
setProcessor(Processor<T>) - Method in class org.galagosearch.tupleflow.OrderedReader
setProcessor(Step) - Method in class org.galagosearch.tupleflow.Select
setProcessor(Step) - Method in class org.galagosearch.tupleflow.SequentialCombiner
setProcessor(Step) - Method in interface org.galagosearch.tupleflow.Source
setProcessor(Step) - Method in class org.galagosearch.tupleflow.StandardStep
setProcessor(Step) - Method in class org.galagosearch.tupleflow.StreamCombiner
setStageName(String) - Method in class org.galagosearch.tupleflow.execution.ConnectionEndPoint
shutdown() - Method in class org.galagosearch.tupleflow.execution.LocalRemoteStageExecutor
shutdown() - Method in class org.galagosearch.tupleflow.execution.LocalStageExecutor
shutdown() - Method in class org.galagosearch.tupleflow.execution.RemoteStageExecutor
shutdown() - Method in class org.galagosearch.tupleflow.execution.SSHStageExecutor
shutdown() - Method in interface org.galagosearch.tupleflow.execution.StageExecutor
shutdown() - Method in class org.galagosearch.tupleflow.execution.ThreadedStageExecutor
skipBytes(int) - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
skipBytes(int) - Method in class org.galagosearch.tupleflow.MemoryDataStream
skipBytes(int) - Method in class org.galagosearch.tupleflow.VByteInput
Sorter<T> - Class in org.galagosearch.tupleflow: This class sorts an incoming stream of objects in some specified order.
Sorter(Order<T>) - Constructor for class org.galagosearch.tupleflow.Sorter
Sorter(Order<T>, Reducer<T>) - Constructor for class org.galagosearch.tupleflow.Sorter
Sorter(int, Order<T>) - Constructor for class org.galagosearch.tupleflow.Sorter
Sorter(int, Order<T>, Reducer<T>) - Constructor for class org.galagosearch.tupleflow.Sorter
Sorter(int, Order<T>, Reducer<T>, Processor<T>) - Constructor for class org.galagosearch.tupleflow.Sorter
Sorter(TupleFlowParameters) - Constructor for class org.galagosearch.tupleflow.Sorter
Source<T> - Interface in org.galagosearch.tupleflow: An object that can generate objects of type T
Splitter<T> - Class in org.galagosearch.tupleflow
Splitter(Processor<T>[], Order<T>) - Constructor for class org.galagosearch.tupleflow.Splitter
splitToFiles(String[], Order<S>, Order<S>) - Static method in class org.galagosearch.tupleflow.Splitter
splitToFiles(String[], Order<S>, Order<S>, Class) - Static method in class org.galagosearch.tupleflow.Splitter
splitToFiles(String, int, Type<S>, Order<S>, int) - Static method in class org.galagosearch.tupleflow.Splitter
SSHStageExecutor - Class in org.galagosearch.tupleflow.execution: This will eventually allow you to run TupleFlow workers on other machines using SSH.
SSHStageExecutor(String, List<String>) - Constructor for class org.galagosearch.tupleflow.execution.SSHStageExecutor
SSHStageExecutor.SSHStageExecutionContext - Class in org.galagosearch.tupleflow.execution
SSHStageExecutor.SSHStageExecutionContext(String, List<String>) - Constructor for class org.galagosearch.tupleflow.execution.SSHStageExecutor.SSHStageExecutionContext
SSHStageExecutor.StageTask - Class in org.galagosearch.tupleflow.execution
SSHStageExecutor.StageTask(String, String, CountDownLatch) - Constructor for class org.galagosearch.tupleflow.execution.SSHStageExecutor.StageTask
StackHandler - Class in org.galagosearch.tupleflow.execution
StackHandler() - Constructor for class org.galagosearch.tupleflow.execution.StackHandler
Stage - Class in org.galagosearch.tupleflow.execution: This is a stage description for a TupleFlow job.
Stage() - Constructor for class org.galagosearch.tupleflow.execution.Stage
Stage(String) - Constructor for class org.galagosearch.tupleflow.execution.Stage
Stage(FileLocation) - Constructor for class org.galagosearch.tupleflow.execution.Stage
StageConnectionPoint - Class in org.galagosearch.tupleflow.execution: Represents an endpoint for a connection within a TupleFlow stage.
StageConnectionPoint(ConnectionPointType, String, Order) - Constructor for class org.galagosearch.tupleflow.execution.StageConnectionPoint
StageConnectionPoint(ConnectionPointType, String, Order, FileLocation) - Constructor for class org.galagosearch.tupleflow.execution.StageConnectionPoint
StageConnectionPoint(ConnectionPointType, String, String, String[], FileLocation) - Constructor for class org.galagosearch.tupleflow.execution.StageConnectionPoint
StageConnectionPoint(ConnectionPointType, String, String, String, String[], FileLocation) - Constructor for class org.galagosearch.tupleflow.execution.StageConnectionPoint
StageExecutionStatus - Interface in org.galagosearch.tupleflow.execution
StageExecutor - Interface in org.galagosearch.tupleflow.execution: This interface marks classes that can be used to execute TupleFlow job stages.
StageExecutorFactory - Class in org.galagosearch.tupleflow.execution
StageExecutorFactory() - Constructor for class org.galagosearch.tupleflow.execution.StageExecutorFactory
StageGroupDescription - Class in org.galagosearch.tupleflow.execution
StageGroupDescription(Stage) - Constructor for class org.galagosearch.tupleflow.execution.StageGroupDescription
StageGroupDescription(Stage, int, String) - Constructor for class org.galagosearch.tupleflow.execution.StageGroupDescription: Creates a new instance of StageGroupDescription
StageGroupDescription.DataPipeRegion - Class in org.galagosearch.tupleflow.execution
StageGroupDescription.DataPipeRegion(DataPipe, int, int, ConnectionPointType) - Constructor for class org.galagosearch.tupleflow.execution.StageGroupDescription.DataPipeRegion
StageInstanceDescription - Class in org.galagosearch.tupleflow.execution
StageInstanceDescription(Stage, int, Map<String, StageInstanceDescription.PipeInput>, Map<String, StageInstanceDescription.PipeOutput>, String) - Constructor for class org.galagosearch.tupleflow.execution.StageInstanceDescription
StageInstanceDescription.PipeInput - Class in org.galagosearch.tupleflow.execution
StageInstanceDescription.PipeInput(DataPipe, int) - Constructor for class org.galagosearch.tupleflow.execution.StageInstanceDescription.PipeInput
StageInstanceDescription.PipeOutput - Class in org.galagosearch.tupleflow.execution
StageInstanceDescription.PipeOutput(DataPipe, int) - Constructor for class org.galagosearch.tupleflow.execution.StageInstanceDescription.PipeOutput
StageInstanceDescription.PipeOutput(DataPipe, int, int) - Constructor for class org.galagosearch.tupleflow.execution.StageInstanceDescription.PipeOutput
StageInstanceFactory - Class in org.galagosearch.tupleflow.execution
StageInstanceFactory(NetworkedCounterManager) - Constructor for class org.galagosearch.tupleflow.execution.StageInstanceFactory
StageInstanceFactory.StepParameters - Class in org.galagosearch.tupleflow.execution
StageInstanceFactory.StepParameters(Step, StageInstanceDescription) - Constructor for class org.galagosearch.tupleflow.execution.StageInstanceFactory.StepParameters
stages - Variable in class org.galagosearch.tupleflow.execution.Job
StandardStep<T,U> - Class in org.galagosearch.tupleflow: This is the base class for most TupleFlow steps.
StandardStep() - Constructor for class org.galagosearch.tupleflow.StandardStep
start() - Method in class org.galagosearch.tupleflow.execution.NetworkedCounterManager
startElement(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.JobConstructor
startElement(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.StackHandler
startElement(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.Parameters.Parser
startHandler(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.ConnectionHandler
startHandler(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StageHandler
startHandler(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StepHandler
startHandler(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.StackHandler
Step - Class in org.galagosearch.tupleflow.execution
Step() - Constructor for class org.galagosearch.tupleflow.execution.Step
Step(Class) - Constructor for class org.galagosearch.tupleflow.execution.Step
Step(String) - Constructor for class org.galagosearch.tupleflow.execution.Step
Step(Class, Parameters) - Constructor for class org.galagosearch.tupleflow.execution.Step
Step(String, Parameters) - Constructor for class org.galagosearch.tupleflow.execution.Step
Step(FileLocation, String, Parameters) - Constructor for class org.galagosearch.tupleflow.execution.Step
Step - Interface in org.galagosearch.tupleflow: This interface is empty.
steps - Variable in class org.galagosearch.tupleflow.execution.Stage
StepSpecification - Interface in org.galagosearch.tupleflow.execution: There are a few different things this interface needs to support.
stop() - Method in class org.galagosearch.tupleflow.execution.NetworkedCounterManager
StreamCombiner<T> - Class in org.galagosearch.tupleflow: Combines many streams of data together, sequentially.
StreamCombiner(TupleFlowParameters) - Constructor for class org.galagosearch.tupleflow.StreamCombiner
StreamCreator - Class in org.galagosearch.tupleflow
StreamCreator() - Constructor for class org.galagosearch.tupleflow.StreamCreator
stringList(String) - Method in class org.galagosearch.tupleflow.Parameters
stringList(String) - Method in class org.galagosearch.tupleflow.Parameters.Value
strip(String, String) - Static method in class org.galagosearch.tupleflow.Utility
subarray(String[], int) - Static method in class org.galagosearch.tupleflow.Utility: For an array master, returns an array containing the last master.length-index elements.
submit(String, ArrayList<String>, String) - Method in class org.galagosearch.tupleflow.execution.LocalRemoteStageExecutor
submit(String, ArrayList<String>, String) - Method in class org.galagosearch.tupleflow.execution.RemoteStageExecutor
submit(String, ArrayList<String>, String) - Method in class org.galagosearch.tupleflow.execution.SSHStageExecutor
subSequence(int, int) - Method in class org.galagosearch.tupleflow.Parameters.CharSequenceBuffer
subStream(long, long) - Method in class org.galagosearch.tupleflow.BufferedFileDataStream
subStream(long, long) - Method in interface org.galagosearch.tupleflow.DataStream
subStream(long, long) - Method in class org.galagosearch.tupleflow.MemoryDataStream

T

ThreadedStageExecutor - Class in org.galagosearch.tupleflow.execution
ThreadedStageExecutor() - Constructor for class org.galagosearch.tupleflow.execution.ThreadedStageExecutor
ThreadedStageExecutor.InstanceRunnable - Class in org.galagosearch.tupleflow.execution
ThreadedStageExecutor.InstanceRunnable(StageInstanceDescription, NetworkedCounterManager, CountDownLatch) - Constructor for class org.galagosearch.tupleflow.execution.ThreadedStageExecutor.InstanceRunnable
ThreadedStageExecutor.ThreadedStageContext - Class in org.galagosearch.tupleflow.execution
toDotString() - Method in class org.galagosearch.tupleflow.execution.Job: Returns this job as a graph in the DOT language.
toString() - Method in class org.galagosearch.tupleflow.execution.ConnectionEndPoint
toString() - Method in class org.galagosearch.tupleflow.execution.DataPipe
toString(String) - Method in class org.galagosearch.tupleflow.execution.ErrorStore.Statement
toString() - Method in class org.galagosearch.tupleflow.execution.ErrorStore.Statement
toString() - Method in class org.galagosearch.tupleflow.execution.ErrorStore
toString() - Method in class org.galagosearch.tupleflow.execution.FileLocation
toString() - Method in class org.galagosearch.tupleflow.execution.Job.StagePoint
toString() - Method in class org.galagosearch.tupleflow.execution.Job
toString() - Method in class org.galagosearch.tupleflow.execution.StageGroupDescription
toString() - Method in class org.galagosearch.tupleflow.execution.Step
toString() - Method in class org.galagosearch.tupleflow.Parameters.CharSequenceBuffer
toString(HashMap<String, String>) - Method in class org.galagosearch.tupleflow.Parameters.CharSequenceBuffer
toString() - Method in class org.galagosearch.tupleflow.Parameters
toString() - Method in class org.galagosearch.tupleflow.Parameters.Value
toString(HashMap<String, String>) - Method in class org.galagosearch.tupleflow.Parameters.Variable
toString() - Method in class org.galagosearch.tupleflow.Sorter
TupleFlowParameters - Interface in org.galagosearch.tupleflow
type - Variable in class org.galagosearch.tupleflow.execution.StageConnectionPoint
Type<T> - Interface in org.galagosearch.tupleflow
TypeReader<T> - Interface in org.galagosearch.tupleflow

U

unhandledCharacters(char[], int, int) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StepHandler
unhandledCharacters(char[], int, int) - Method in class org.galagosearch.tupleflow.execution.StackHandler
unhandledEndElement(String, String, String) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StepHandler
unhandledEndElement(String, String, String) - Method in class org.galagosearch.tupleflow.execution.StackHandler
unhandledStartElement(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.ConnectionHandler
unhandledStartElement(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.ConnectionsHandler
unhandledStartElement(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.JobHandler
unhandledStartElement(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.MultiHandler
unhandledStartElement(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StageConnectionsHandler
unhandledStartElement(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StageHandler
unhandledStartElement(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StagesHandler
unhandledStartElement(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StepHandler
unhandledStartElement(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.JobConstructor.StepsHandler
unhandledStartElement(String, String, String, Attributes) - Method in class org.galagosearch.tupleflow.execution.StackHandler
Unique<T> - Class in org.galagosearch.tupleflow
Unique(Comparator<T>, Processor<T>) - Constructor for class org.galagosearch.tupleflow.Unique: Creates a new instance of Unique
Utility - Class in org.galagosearch.tupleflow: Lots of static methods here that have broad use.
Utility() - Constructor for class org.galagosearch.tupleflow.Utility

V

value() - Method in class org.galagosearch.tupleflow.Parameters
valueOf(String) - Static method in enum org.galagosearch.tupleflow.execution.ConnectionAssignmentType: Returns the enum constant of this type with the specified name.
valueOf(String) - Static method in enum org.galagosearch.tupleflow.execution.ConnectionPointType: Returns the enum constant of this type with the specified name.
values() - Static method in enum org.galagosearch.tupleflow.execution.ConnectionAssignmentType: Returns an array containing the constants of this enum type, in the order they're declared.
values() - Static method in enum org.galagosearch.tupleflow.execution.ConnectionPointType: Returns an array containing the constants of this enum type, in the order they're declared.
VByteInput - Class in org.galagosearch.tupleflow
VByteInput(DataInput) - Constructor for class org.galagosearch.tupleflow.VByteInput
VByteOutput - Class in org.galagosearch.tupleflow
VByteOutput(DataOutput) - Constructor for class org.galagosearch.tupleflow.VByteOutput: Creates a new instance of VByteOutput
Verification - Class in org.galagosearch.tupleflow.execution
Verification() - Constructor for class org.galagosearch.tupleflow.execution.Verification
Verified - Annotation Type in org.galagosearch.tupleflow.execution: This annotation is applied to Step classes that don't need any extra verification before they're executed.
verify(Verification.TypeState, Stage, ArrayList<Step>, ErrorStore) - Static method in class org.galagosearch.tupleflow.execution.Verification
verify(Stage, ErrorStore) - Static method in class org.galagosearch.tupleflow.execution.Verification
verify(Job, ErrorStore) - Static method in class org.galagosearch.tupleflow.execution.Verification
verify(TupleFlowParameters, ErrorHandler) - Static method in class org.galagosearch.tupleflow.FileSource
verify(TupleFlowParameters, ErrorHandler) - Static method in class org.galagosearch.tupleflow.NullProcessor
verify(TupleFlowParameters, ErrorHandler) - Static method in class org.galagosearch.tupleflow.NullSource
verify(TupleFlowParameters, ErrorHandler) - Static method in class org.galagosearch.tupleflow.Select
verify(TupleFlowParameters, ErrorHandler) - Static method in class org.galagosearch.tupleflow.Sorter
verify(TupleFlowParameters, ErrorHandler) - Static method in class org.galagosearch.tupleflow.StreamCombiner
verifyTypeReader(String, Class, TupleFlowParameters, ErrorHandler) - Static method in class org.galagosearch.tupleflow.execution.Verification
verifyTypeReader(String, Class, String[], TupleFlowParameters, ErrorHandler) - Static method in class org.galagosearch.tupleflow.execution.Verification
verifyTypeWriter(String, Class, String[], TupleFlowParameters, ErrorHandler) - Static method in class org.galagosearch.tupleflow.execution.Verification

W

waitForFinalPage() - Method in class org.galagosearch.tupleflow.execution.MasterWebHandler: Waits a bit longer for someone to load a final status page.
wrap(String) - Static method in class org.galagosearch.tupleflow.Utility
write(Parameters.Value, Document, Element) - Method in class org.galagosearch.tupleflow.Parameters
write(StreamResult) - Method in class org.galagosearch.tupleflow.Parameters
write(String) - Method in class org.galagosearch.tupleflow.Parameters
write(byte[], int, int) - Method in class org.galagosearch.tupleflow.VByteOutput
write(byte[]) - Method in class org.galagosearch.tupleflow.VByteOutput
write(int) - Method in class org.galagosearch.tupleflow.VByteOutput
writeBoolean(boolean) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeBoolean(boolean) - Method in class org.galagosearch.tupleflow.VByteOutput
writeByte(byte) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeByte(int) - Method in class org.galagosearch.tupleflow.VByteOutput
writeBytes(byte[]) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeBytes(String) - Method in class org.galagosearch.tupleflow.VByteOutput
writeChar(char) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeChar(int) - Method in class org.galagosearch.tupleflow.VByteOutput
writeChars(char[]) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeChars(String) - Method in class org.galagosearch.tupleflow.VByteOutput
writeDouble(double) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeDouble(double) - Method in class org.galagosearch.tupleflow.VByteOutput
writeDoubles(double[]) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeFloat(float) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeFloat(float) - Method in class org.galagosearch.tupleflow.VByteOutput
writeFloats(float[]) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeInt(int) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeInt(int) - Method in class org.galagosearch.tupleflow.VByteOutput
writeInts(int[]) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeLong(long) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeLong(long) - Method in class org.galagosearch.tupleflow.VByteOutput
writeLongs(long[]) - Method in class org.galagosearch.tupleflow.ArrayOutput
writerExists(String, String, String[]) - Method in class org.galagosearch.tupleflow.execution.StageInstanceDescription
writerExists(String, String, String[]) - Method in class org.galagosearch.tupleflow.execution.StageInstanceFactory.StepParameters
writerExists(String, String, String[]) - Method in class org.galagosearch.tupleflow.FakeParameters
writerExists(String, String, String[]) - Method in interface org.galagosearch.tupleflow.TupleFlowParameters
writeShort(short) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeShort(int) - Method in class org.galagosearch.tupleflow.VByteOutput
writeShorts(short[]) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeString(String) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeString(String) - Method in class org.galagosearch.tupleflow.VByteOutput
writeStrings(String[]) - Method in class org.galagosearch.tupleflow.ArrayOutput
writeUTF(String) - Method in class org.galagosearch.tupleflow.VByteOutput

X

XMLMinimum - Class in org.galagosearch.tupleflow
XMLMinimum() - Constructor for class org.galagosearch.tupleflow.XMLMinimum

A B C D E F G H I J L M N O P R S T U V W X

Overview

Package

Class

Use

Tree

Deprecated

Index

Help

PREV NEXT

FRAMES NO FRAMES