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

A

accept(Class<?>) - Method in class cascading.tuple.hadoop.BigDecimalSerialization

accept(Class<?>) - Method in class cascading.tuple.hadoop.BytesSerialization

accept(Class) - Method in class cascading.tuple.hadoop.TupleSerialization

Method accept implements Serialization.accept(Class).

accepts(Class<T>) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer

accepts(Class<T>) - Method in interface cascading.flow.hadoop.util.ObjectSerializer

addComparators(Configuration, String, Map<String, Fields>, BaseFlowStep, Group) - Static method in class cascading.flow.hadoop.util.HadoopUtil

addComparators(Configuration, String, Map<String, Fields>, Fields) - Static method in class cascading.flow.hadoop.util.HadoopUtil

addFields(Configuration, String, Map<Integer, Fields>) - Static method in class cascading.flow.hadoop.util.HadoopUtil

addHadoopSerialization(String) - Method in class cascading.tuple.hadoop.TupleSerializationProps

Method addHadoopSerialization adds a Hadoop serialization className to be used as properties.

addHadoopSerializations(List<String>) - Method in class cascading.tuple.hadoop.TupleSerializationProps

Method addHadoopSerializations adds the Hadoop serialization classNames to be used as properties.

addInputFormat(JobConf, JobConf...) - Static method in class cascading.tap.hadoop.io.MultiInputFormat

Used to set the current JobConf with all sub jobs configurations.

addInputPath(Configuration, Path) - Static method in class cascading.flow.hadoop.util.HadoopUtil

addInputPaths(Configuration, Iterable<Path>) - Static method in class cascading.flow.hadoop.util.HadoopUtil

addLocalCacheFiles(Configuration, URI) - Method in class cascading.tap.hadoop.BaseDistCacheTap

addPropertiesTo(Properties) - Method in class cascading.tap.hadoop.HfsProps

addPropertiesTo(Properties) - Method in class cascading.tuple.hadoop.TupleSerializationProps

addSerialization(Map<Object, Object>, String) - Static method in class cascading.tuple.hadoop.TupleSerializationProps

Adds the given className as a Hadoop IO serialization class.

addSerializationToken(Map<Object, Object>, int, String) - Static method in class cascading.tuple.hadoop.TupleSerializationProps

Adds the given token and className pair as a serialization token property.

addSerializationToken(int, String) - Method in class cascading.tuple.hadoop.TupleSerializationProps

Method addSerializationToken adds the given integer token and classNames as a serialization properties.

addSerializationTokens(Map<Integer, String>) - Method in class cascading.tuple.hadoop.TupleSerializationProps

Method addSerializationTokens adds the given integer tokens and classNames Map as a serialization properties.

append(Path, int, Progressable) - Method in class cascading.tap.hadoop.io.StreamedFileSystem

applySourceConfInitIdentifiers(FlowProcess<? extends Configuration>, Configuration, String...) - Method in class cascading.tap.hadoop.Hfs

areTypesIgnored() - Method in class cascading.tuple.hadoop.TupleSerialization

areTypesRequired() - Method in class cascading.tuple.hadoop.TupleSerialization

asJobConfInstance(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

B

BaseDistCacheTap - Class in cascading.tap.hadoop

BaseDistCacheTap(Tap<Configuration, RecordReader, OutputCollector>) - Constructor for class cascading.tap.hadoop.BaseDistCacheTap

BigDecimalSerialization - Class in cascading.tuple.hadoop

Class BigDecimalSerialization is an implementation of Hadoop's Serialization interface for use by BigDecimal instances.

BigDecimalSerialization() - Constructor for class cascading.tuple.hadoop.BigDecimalSerialization

BigDecimalSerialization.BigDecimalDeserializer - Class in cascading.tuple.hadoop

BigDecimalSerialization.BigDecimalDeserializer() - Constructor for class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalDeserializer

BigDecimalSerialization.BigDecimalSerializer - Class in cascading.tuple.hadoop

BigDecimalSerialization.BigDecimalSerializer() - Constructor for class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalSerializer

BufferedInputStream - Class in cascading.tuple.hadoop.io

BufferedInputStream() - Constructor for class cascading.tuple.hadoop.io.BufferedInputStream

BytesComparator - Class in cascading.tuple.hadoop.util

Class BytesComparator is used to compare arrays of bytes.

BytesComparator() - Constructor for class cascading.tuple.hadoop.util.BytesComparator

BytesSerialization - Class in cascading.tuple.hadoop

Class BytesSerialization is an implementation of Hadoop's Serialization interface for use by byte arrays (byte[]).

BytesSerialization() - Constructor for class cascading.tuple.hadoop.BytesSerialization

BytesSerialization.RawBytesDeserializer - Class in cascading.tuple.hadoop

BytesSerialization.RawBytesDeserializer() - Constructor for class cascading.tuple.hadoop.BytesSerialization.RawBytesDeserializer

BytesSerialization.RawBytesSerializer - Class in cascading.tuple.hadoop

BytesSerialization.RawBytesSerializer() - Constructor for class cascading.tuple.hadoop.BytesSerialization.RawBytesSerializer

C

callCopyConstructor(Class, Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

cascading.flow.hadoop - package cascading.flow.hadoop

cascading.flow.hadoop.util - package cascading.flow.hadoop.util

cascading.scheme.hadoop - package cascading.scheme.hadoop

cascading.tap.hadoop - package cascading.tap.hadoop

cascading.tap.hadoop.io - package cascading.tap.hadoop.io

cascading.tap.hadoop.util - package cascading.tap.hadoop.util

cascading.tuple.hadoop - package cascading.tuple.hadoop

cascading.tuple.hadoop.collect - package cascading.tuple.hadoop.collect

cascading.tuple.hadoop.io - package cascading.tuple.hadoop.io

cascading.tuple.hadoop.util - package cascading.tuple.hadoop.util

CASCADING_FLOW_EXECUTING - Static variable in class cascading.flow.hadoop.util.HadoopUtil

CASCADING_SOURCE_PATH - Static variable in class cascading.tap.hadoop.io.MultiInputSplit

cleanupJob(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil

May only be called once.

cleanupTapMetaData(Configuration, Tap) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil

Called from flow step to remove temp dirs

clear() - Method in class cascading.tuple.hadoop.io.BufferedInputStream

close() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper

close() - Method in class cascading.tap.hadoop.io.FSDigestInputStream

close() - Method in class cascading.tap.hadoop.io.MultiRecordReaderIterator

close() - Method in class cascading.tap.hadoop.io.RecordReaderIterator

close() - Method in class cascading.tap.hadoop.io.TapOutputCollector

close() - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector

close() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader

close() - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalDeserializer

close() - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalSerializer

close() - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesDeserializer

close() - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesSerializer

close() - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader

close() - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementWriter

collect(Object, Object) - Method in class cascading.tap.hadoop.io.TapOutputCollector

Method collect writes the given values to the Tap this instance encapsulates.

collect(Object, Object) - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector

COMBINE_INPUT_FILES - Static variable in class cascading.tap.hadoop.HfsProps

Field COMBINE_INPUT_FILES

COMBINE_INPUT_FILES_SAFE_MODE - Static variable in class cascading.tap.hadoop.HfsProps

Field COMBINE_INPUT_FILES_SAFEMODE

COMBINE_INPUT_FILES_SIZE_MAX - Static variable in class cascading.tap.hadoop.HfsProps

Field COMBINE_INPUT_FILES_SIZE_MAX

combinedInputMaxSize - Variable in class cascading.tap.hadoop.HfsProps

combinedInputSafeMode - Variable in class cascading.tap.hadoop.HfsProps

CombineFileRecordReaderWrapper<K,V> - Class in cascading.tap.hadoop.io

A wrapper class for a record reader that handles a single file split.

CombineFileRecordReaderWrapper(CombineFileSplit, Configuration, Reporter, Integer) - Constructor for class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper

CombineInputPartitionTupleEntryIterator - Class in cascading.tap.hadoop.io

CombineInputPartitionTupleEntryIterator(FlowProcess<? extends Configuration>, Fields, Partition, String, TupleEntrySchemeIterator) - Constructor for class cascading.tap.hadoop.io.CombineInputPartitionTupleEntryIterator

commitResource(Configuration) - Method in class cascading.tap.hadoop.PartitionTap

commitTask(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil

copies all files from the taskoutputpath to the outputpath

compare(byte[], byte[]) - Method in class cascading.tuple.hadoop.util.BytesComparator

compare(BufferedInputStream, BufferedInputStream) - Method in class cascading.tuple.hadoop.util.BytesComparator

configure(JobConf) - Method in class cascading.tap.hadoop.io.MultiInputSplit

copyConfiguration(C) - Static method in class cascading.flow.hadoop.util.HadoopUtil

copyConfiguration(Map<Object, Object>, C) - Static method in class cascading.flow.hadoop.util.HadoopUtil

copyJobConf(C) - Static method in class cascading.flow.hadoop.util.HadoopUtil

copyJobConf(JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil

create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class cascading.tap.hadoop.io.StreamedFileSystem

create(FlowProcess<? extends Configuration>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleCollectionFactory

create(FlowProcess<? extends Configuration>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleMapFactory

createJobConf(Map<Object, Object>, JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil

createKey() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper

createKey() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader

createPlatformInfo(Class, String, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil

createProperties(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

createResource(Configuration) - Method in class cascading.tap.hadoop.Hfs

createTuple() - Method in class cascading.tuple.hadoop.io.IndexTupleDeserializer

createTuple() - Method in class cascading.tuple.hadoop.io.KeyIndexTupleDeserializer

createTuple() - Method in class cascading.tuple.hadoop.io.KeyTupleDeserializer

createTuple() - Method in class cascading.tuple.hadoop.io.TupleDeserializer

createTuple() - Method in class cascading.tuple.hadoop.io.TuplePairDeserializer

createTuple() - Method in class cascading.tuple.hadoop.io.ValueIndexTupleDeserializer

createTuple() - Method in class cascading.tuple.hadoop.io.ValueTupleDeserializer

createTupleCollection(Tuple) - Method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleMap

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

createTupleEntrySchemeIterator(FlowProcess<? extends Configuration>, Tap, String, RecordReader) - Method in class cascading.tap.hadoop.PartitionTap

createTupleInputStream(File) - Method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleList

createTupleOutputStream(File) - Method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleList

createValue() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper

createValue() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader

D

decodeBytes(String) - Static method in class cascading.flow.hadoop.util.HadoopUtil

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

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

DEFAULT_SOURCE_FIELDS - Static variable in class cascading.scheme.hadoop.TextLine

Field DEFAULT_SOURCE_FIELDS

defaultCodecs - Static variable in class cascading.tuple.hadoop.collect.HadoopSpillableTupleList

delete(Path) - Method in class cascading.tap.hadoop.io.StreamedFileSystem

Deprecated.

delete(Path, boolean) - Method in class cascading.tap.hadoop.io.StreamedFileSystem

deleteChildResource(FlowProcess<? extends Configuration>, String) - Method in class cascading.tap.hadoop.Hfs

deleteChildResource(Configuration, String) - Method in class cascading.tap.hadoop.Hfs

deleteResource(Configuration) - Method in class cascading.tap.hadoop.Hfs

delimitedParser - Variable in class cascading.scheme.hadoop.TextDelimited

Field delimitedParser

deserialize(byte[], Class<T>, boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer

deserialize(byte[], Class<T>, boolean) - Method in interface cascading.flow.hadoop.util.ObjectSerializer

deserialize(BigDecimal) - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalDeserializer

deserialize(byte[]) - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesDeserializer

deserialize(IndexTuple) - Method in class cascading.tuple.hadoop.io.IndexTupleDeserializer

deserialize(Tuple) - Method in class cascading.tuple.hadoop.io.TupleDeserializer

deserialize(TuplePair) - Method in class cascading.tuple.hadoop.io.TuplePairDeserializer

deserializeBase64(String, Configuration, Class<T>) - Static method in class cascading.flow.hadoop.util.HadoopUtil

This method deserializes the Base64 encoded String into an Object instance.

deserializeBase64(String, Configuration, Class<T>, boolean) - Static method in class cascading.flow.hadoop.util.HadoopUtil

deserializeList(byte[], boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer

deserializeMap(byte[], boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer

Dfs - Class in cascading.tap.hadoop

Class Dfs is a Tap class that provides access to the Hadoop Distributed File System.

Dfs(Scheme, URI) - Constructor for class cascading.tap.hadoop.Dfs

Constructor Dfs creates a new Dfs instance.

Dfs(Scheme, URI, SinkMode) - Constructor for class cascading.tap.hadoop.Dfs

Constructor Dfs creates a new Dfs instance.

Dfs(Scheme, String) - Constructor for class cascading.tap.hadoop.Dfs

Constructor Dfs creates a new Dfs instance.

Dfs(Scheme, String, SinkMode) - Constructor for class cascading.tap.hadoop.Dfs

Constructor Dfs creates a new Dfs instance.

E

encodeBytes(byte[]) - Static method in class cascading.flow.hadoop.util.HadoopUtil

equals(Object) - Method in class cascading.scheme.hadoop.WritableSequenceFile

equals(Object) - Method in class cascading.tap.hadoop.GlobHfs

exists(Path) - Method in class cascading.tap.hadoop.io.HttpFileSystem

F

findMainClass(Class) - Static method in class cascading.flow.hadoop.util.HadoopUtil

flush() - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector

FSDigestInputStream - Class in cascading.tap.hadoop.io

Class FSDigestInputStream is an FSInputStream implementation that can verify a MessageDigest and will count the number of bytes read for use in progress status.

FSDigestInputStream(InputStream, String) - Constructor for class cascading.tap.hadoop.io.FSDigestInputStream

Constructor FSDigestInputStream creates a new FSDigestInputStream instance.

FSDigestInputStream(InputStream, MessageDigest, String) - Constructor for class cascading.tap.hadoop.io.FSDigestInputStream

Constructor FSDigestInputStream creates a new FSDigestInputStream instance.

G

getBlockSize(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs

Method getBlockSize returns the blocksize specified by the underlying file system for this resource.

getBlockSize(Configuration) - Method in class cascading.tap.hadoop.Hfs

Method getBlockSize returns the blocksize specified by the underlying file system for this resource.

getBuffer() - Method in class cascading.tuple.hadoop.io.BufferedInputStream

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

getChildIdentifiers(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs

getChildIdentifiers(Configuration) - Method in class cascading.tap.hadoop.Hfs

getChildIdentifiers(FlowProcess<? extends Configuration>, int, boolean) - Method in class cascading.tap.hadoop.Hfs

getChildIdentifiers(Configuration, int, boolean) - Method in class cascading.tap.hadoop.Hfs

getClass(String) - Method in class cascading.tuple.hadoop.TupleSerialization

getClassNameFor(int, DataInputStream) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader

getCodec(FlowProcess<? extends Configuration>, String) - Static method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleList

getCombinedInputMaxSize() - Method in class cascading.tap.hadoop.HfsProps

getCombinedInputSafeMode(Configuration) - Static method in class cascading.tap.hadoop.Hfs

getCommonPaths(Map<String, Path>, Map<String, Path>) - Static method in class cascading.flow.hadoop.util.HadoopUtil

getComparator(Class<byte[]>) - Method in class cascading.tuple.hadoop.BytesSerialization

getComparator(Class) - Method in class cascading.tuple.hadoop.TupleSerialization

getComparatorFor(int, DataInputStream) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader

getConf() - Method in class cascading.tuple.hadoop.TupleSerialization

getConfig(Configuration, Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

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

getCurrentTapSourcePath(JobConf) - Static method in class cascading.tap.hadoop.io.MultiInputSplit

Method getCurrentTapSourcePath finds and returns the current source Tap filename path, if any.

getDefaultComparator(Comparator, Configuration) - Static method in class cascading.tuple.hadoop.TupleSerialization

getDefaultComparator(Configuration) - Static method in class cascading.tuple.hadoop.TupleSerialization

getDefaultComparator() - Method in class cascading.tuple.hadoop.TupleSerialization

getDefaultFileSystem(Configuration) - Method in class cascading.tap.hadoop.Dfs

getDefaultFileSystem(Configuration) - Method in class cascading.tap.hadoop.Hfs

getDefaultFileSystemURIScheme(Configuration) - Method in class cascading.tap.hadoop.Hfs

Method getDefaultFileSystemURIScheme returns the URI scheme for the default Hadoop FileSystem.

getDefaultFS(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

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

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

getDeserializer(Class<BigDecimal>) - Method in class cascading.tuple.hadoop.BigDecimalSerialization

getDeserializer(Class<byte[]>) - Method in class cascading.tuple.hadoop.BytesSerialization

getDeserializer(Class) - Method in class cascading.tuple.hadoop.TupleSerialization

Method getDeserializer implements Serialization.getDeserializer(Class).

getElementReader() - Method in class cascading.tuple.hadoop.TupleSerialization

Method getElementReader returns the elementReader of this TupleSerialization object.

getElementWriter() - Method in class cascading.tuple.hadoop.TupleSerialization

Method getElementWriter returns the elementWriter of this TupleSerialization object.

getFields(Configuration, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil

getFields(Configuration, String) - Static method in class cascading.tuple.hadoop.TupleSerialization

getFileStatus(Configuration) - Method in class cascading.tap.hadoop.Hfs

getFileStatus(Path) - Method in class cascading.tap.hadoop.io.HttpFileSystem

getFileSystem(Configuration) - Method in class cascading.tap.hadoop.Hfs

getFileSystem(Configuration) - Method in class cascading.tap.hadoop.Lfs

getFirstOrdinal() - Method in class cascading.tuple.hadoop.TupleSerialization

getFullIdentifier(Configuration) - Method in class cascading.tap.hadoop.Hfs

getHadoopSerializations() - Method in class cascading.tuple.hadoop.TupleSerializationProps

getHDFSShutdownHook() - Static method in class cascading.flow.hadoop.util.HadoopUtil

getIdentifier() - Method in class cascading.tap.hadoop.GlobHfs

getIdentifier() - Method in class cascading.tap.hadoop.Hfs

getIgnoreTypes() - Method in class cascading.tuple.hadoop.TupleSerializationProps

getJobConfs(Configuration, List<Map<String, String>>) - Static method in class cascading.flow.hadoop.util.HadoopUtil

getKeyFields() - Method in class cascading.tuple.hadoop.TupleSerialization

getKeyFieldsMap() - Method in class cascading.tuple.hadoop.TupleSerialization

getKeyTypeMap() - Method in class cascading.tuple.hadoop.TupleSerialization

getKeyTypes() - Method in class cascading.tuple.hadoop.TupleSerialization

getLength() - Method in class cascading.tap.hadoop.io.MultiInputSplit

getLength() - Method in class cascading.tuple.hadoop.io.BufferedInputStream

getLocalCacheFiles(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.BaseDistCacheTap

getLocalFS(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

getLocalModeScheme(Configuration, String) - Static method in class cascading.tap.hadoop.Hfs

getLocalModeScheme() - Method in class cascading.tap.hadoop.HfsProps

getLocations() - Method in class cascading.tap.hadoop.io.MultiInputSplit

getMaskedValueFields() - Method in class cascading.tuple.hadoop.TupleSerialization

getMaskedValueTypeMap() - Method in class cascading.tuple.hadoop.TupleSerialization

getMD5SumFor(Configuration, Path) - Static method in class cascading.tap.hadoop.io.StreamedFileSystem

getMD5SumFor(Configuration, String) - Static method in class cascading.tap.hadoop.io.StreamedFileSystem

getModifiedTime(Configuration) - Method in class cascading.tap.hadoop.Hfs

getNextElement() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream

getNumElements() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream

getOrdinals() - Method in class cascading.tuple.hadoop.TupleSerialization

getOutputCollector() - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector

getOutputPath(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

getPath() - Method in class cascading.tap.hadoop.Hfs

getPlatformInfo() - Static method in class cascading.flow.hadoop.util.HadoopUtil

getPlatformInfo(Class, String, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil

getPos() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper

getPos() - Method in class cascading.tap.hadoop.io.FSDigestInputStream

getPos() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader

getPosition() - Method in class cascading.tuple.hadoop.io.BufferedInputStream

getPreventBitWiseComparisons() - Method in class cascading.tuple.hadoop.TupleSerializationProps

getProgress() - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper

getProgress() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader

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

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

getReadersFor(TupleInputStream.ElementReader, Class[]) - Static method in class cascading.tuple.hadoop.io.HadoopTupleInputStream

getRecordReader(InputSplit, JobConf, Reporter) - Method in class cascading.tap.hadoop.io.MultiInputFormat

Method getRecordReader delegates to the appropriate InputFormat.

getRecordReader() - Method in class cascading.tap.hadoop.util.MeasuredRecordReader

getReplication(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs

Method getReplication returns the replication specified by the underlying file system for this resource.

getReplication(Configuration) - Method in class cascading.tap.hadoop.Hfs

Method getReplication returns the replication specified by the underlying file system for this resource.

getReporter() - Method in interface cascading.flow.hadoop.MapRed

getRequireTypes() - Method in class cascading.tuple.hadoop.TupleSerializationProps

getSchemeClass() - Method in class cascading.tap.hadoop.util.TempHfs

getSerializationTokens(Map<Object, Object>) - Static method in class cascading.tuple.hadoop.TupleSerializationProps

Returns the serialization tokens property.

getSerializationTokens() - Method in class cascading.tuple.hadoop.TupleSerializationProps

getSerializer(Class<BigDecimal>) - Method in class cascading.tuple.hadoop.BigDecimalSerialization

getSerializer(Class<byte[]>) - Method in class cascading.tuple.hadoop.BytesSerialization

getSerializer(Class) - Method in class cascading.tuple.hadoop.TupleSerialization

Method getSerializer implements Serialization.getSerializer(Class).

getSinkCompression() - Method in class cascading.scheme.hadoop.TextLine

Method getSinkCompression returns the sinkCompression of this TextLine object.

getSize(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs

getSize(Configuration) - Method in class cascading.tap.hadoop.Hfs

getSortFields() - Method in class cascading.tuple.hadoop.TupleSerialization

getSortFieldsMap() - Method in class cascading.tuple.hadoop.TupleSerialization

getSortTypes() - Method in class cascading.tuple.hadoop.TupleSerialization

getSpillStrategy() - Method in class cascading.tuple.hadoop.collect.HadoopSpillableTupleMap

Method getSpillStrategy returns a SpillStrategy instance that is passed to the underlying Spillable tuple collection.

getSplits(JobConf, int) - Method in class cascading.tap.hadoop.io.MultiInputFormat

Method getSplits delegates to the appropriate InputFormat.

getTaps() - Method in class cascading.tap.hadoop.GlobHfs

getTemporaryDirectory() - Method in class cascading.tap.hadoop.HfsProps

getTempPath(Configuration) - Static method in class cascading.tap.hadoop.Hfs

getTupleSerialization() - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader

getTupleSerialization() - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementWriter

getTypesFor(int) - Method in class cascading.tuple.hadoop.io.IndexTupleDeserializer

getTypesFor(int) - Method in class cascading.tuple.hadoop.io.IndexTupleSerializer

getTypesFor(int) - Method in class cascading.tuple.hadoop.io.KeyIndexTupleDeserializer

getTypesFor(int) - Method in class cascading.tuple.hadoop.io.ValueIndexTupleDeserializer

getTypesFor(Fields) - Method in class cascading.tuple.hadoop.TupleSerialization

getUri() - Method in class cascading.tap.hadoop.io.HttpFileSystem

getURIScheme(Configuration) - Method in class cascading.tap.hadoop.Hfs

getUseCombinedInput(Configuration) - Static method in class cascading.tap.hadoop.Hfs

getValueFields() - Method in class cascading.tuple.hadoop.TupleSerialization

getValueFieldsMap() - Method in class cascading.tuple.hadoop.TupleSerialization

getValueTypeMap() - Method in class cascading.tuple.hadoop.TupleSerialization

getValueTypes() - Method in class cascading.tuple.hadoop.TupleSerialization

getWorkingDirectory() - Method in class cascading.tap.hadoop.io.StreamedFileSystem

getWrappedInputSplit() - Method in class cascading.tap.hadoop.io.MultiInputSplit

getWritersFor(TupleOutputStream.ElementWriter, Class[]) - Static method in class cascading.tuple.hadoop.io.HadoopTupleOutputStream

GlobHfs - Class in cascading.tap.hadoop

Class GlobHfs is a type of MultiSourceTap that accepts Hadoop style 'file globing' expressions so multiple files that match the given pattern may be used as the input sources for a given Flow.

GlobHfs(Scheme<Configuration, RecordReader, ?, ?, ?>, String) - Constructor for class cascading.tap.hadoop.GlobHfs

Constructor GlobHfs creates a new GlobHfs instance.

GlobHfs(Scheme<Configuration, RecordReader, ?, ?, ?>, String, PathFilter) - Constructor for class cascading.tap.hadoop.GlobHfs

Constructor GlobHfs creates a new GlobHfs instance.

globStatus(Path, PathFilter) - Method in class cascading.tap.hadoop.io.HttpFileSystem

H

Hadoop18TapUtil - Class in cascading.tap.hadoop.util

Hadoop18TapUtil() - Constructor for class cascading.tap.hadoop.util.Hadoop18TapUtil

HADOOP_IO_SERIALIZATIONS - Static variable in class cascading.tuple.hadoop.TupleSerializationProps

HadoopSpillableTupleList - Class in cascading.tuple.hadoop.collect

SpillableTupleList is a simple Iterable object that can store an unlimited number of Tuple instances by spilling excess to a temporary disk file.

HadoopSpillableTupleList(int, CompressionCodec, Configuration) - Constructor for class cascading.tuple.hadoop.collect.HadoopSpillableTupleList

Constructor SpillableTupleList creates a new SpillableTupleList instance using the given threshold value, and the first available compression codec, if any.

HadoopSpillableTupleList(int, TupleSerialization, CompressionCodec) - Constructor for class cascading.tuple.hadoop.collect.HadoopSpillableTupleList

HadoopSpillableTupleMap - Class in cascading.tuple.hadoop.collect

HadoopSpillableTupleMap is responsible for spilling values to disk if the map threshold is reached.

HadoopSpillableTupleMap(int, float, int, int, FlowProcess<? extends Configuration>) - Constructor for class cascading.tuple.hadoop.collect.HadoopSpillableTupleMap

HadoopTupleCollectionFactory - Class in cascading.tuple.hadoop.collect

HadoopTupleCollectionFactory() - Constructor for class cascading.tuple.hadoop.collect.HadoopTupleCollectionFactory

HadoopTupleEntrySchemeCollector - Class in cascading.tap.hadoop.io

Class HadoopTupleEntrySchemeCollector is a kind of TupleEntryCollector that writes tuples to the resource managed by a particular Tap instance.

HadoopTupleEntrySchemeCollector(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeCollector

HadoopTupleEntrySchemeCollector(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, OutputCollector) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeCollector

HadoopTupleEntrySchemeIterator - Class in cascading.tap.hadoop.io

HadoopTupleEntrySchemeIterator(FlowProcess<? extends Configuration>, Tap, RecordReader) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeIterator

HadoopTupleEntrySchemeIterator(FlowProcess<? extends Configuration>, Scheme, CloseableIterator<RecordReader>) - Constructor for class cascading.tap.hadoop.io.HadoopTupleEntrySchemeIterator

HadoopTupleInputStream - Class in cascading.tuple.hadoop.io

HadoopTupleInputStream(InputStream, TupleInputStream.ElementReader) - Constructor for class cascading.tuple.hadoop.io.HadoopTupleInputStream

HadoopTupleMapFactory - Class in cascading.tuple.hadoop.collect

HadoopTupleMapFactory() - Constructor for class cascading.tuple.hadoop.collect.HadoopTupleMapFactory

HadoopTupleOutputStream - Class in cascading.tuple.hadoop.io

HadoopTupleOutputStream(OutputStream, TupleOutputStream.ElementWriter) - Constructor for class cascading.tuple.hadoop.io.HadoopTupleOutputStream

HadoopUtil - Class in cascading.flow.hadoop.util

HadoopUtil() - Constructor for class cascading.flow.hadoop.util.HadoopUtil

hashCode() - Method in class cascading.scheme.hadoop.WritableSequenceFile

hashCode() - Method in class cascading.tap.hadoop.GlobHfs

hashCode(byte[]) - Method in class cascading.tuple.hadoop.util.BytesComparator

hasNext() - Method in class cascading.tap.hadoop.io.CombineInputPartitionTupleEntryIterator

hasNext() - Method in class cascading.tap.hadoop.io.MultiRecordReaderIterator

Method hasNext returns true if there more Tuple instances available.

Hfs - Class in cascading.tap.hadoop

Class Hfs is the base class for all Hadoop file system access.

Hfs() - Constructor for class cascading.tap.hadoop.Hfs

Hfs(Scheme<Configuration, RecordReader, OutputCollector, ?, ?>) - Constructor for class cascading.tap.hadoop.Hfs

Hfs(Scheme<Configuration, RecordReader, OutputCollector, ?, ?>, String) - Constructor for class cascading.tap.hadoop.Hfs

Constructor Hfs creates a new Hfs instance.

Hfs(Scheme<Configuration, RecordReader, OutputCollector, ?, ?>, String, SinkMode) - Constructor for class cascading.tap.hadoop.Hfs

Constructor Hfs creates a new Hfs instance.

HfsProps - Class in cascading.tap.hadoop

Class HfsProps is a fluent helper for setting various Hadoop FS level properties that some Flow may or may not be required to have set.

HfsProps() - Constructor for class cascading.tap.hadoop.HfsProps

hfsProps() - Static method in class cascading.tap.hadoop.HfsProps

Creates a new HfsProps instance.

HTTP_SCHEME - Static variable in class cascading.tap.hadoop.io.HttpFileSystem

Field HTTP_SCHEME

HttpFileSystem - Class in cascading.tap.hadoop.io

Class HttpFileSystem provides a basic read-only FileSystem for accessing remote HTTP and HTTPS data.

HttpFileSystem() - Constructor for class cascading.tap.hadoop.io.HttpFileSystem

HTTPS_SCHEME - Static variable in class cascading.tap.hadoop.io.HttpFileSystem

Field HTTPS_SCHEME

I

IGNORE_TYPES - Static variable in class cascading.tuple.hadoop.TupleSerializationProps

IndexTupleDeserializer<T extends IndexTuple> - Class in cascading.tuple.hadoop.io

IndexTupleDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.IndexTupleDeserializer

IndexTupleSerializer<T extends IndexTuple> - Class in cascading.tuple.hadoop.io

IndexTupleSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.IndexTupleSerializer

INDIVIDUAL_INPUT_FORMAT - Static variable in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper

property that indicates how individual input format is to be interpreted

initialize(URI, Configuration) - Method in class cascading.tap.hadoop.io.HttpFileSystem

initialize() - Method in class cascading.tap.hadoop.io.TapOutputCollector

initialize(FlowProcess<? extends Configuration>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleCollectionFactory

initialize(FlowProcess<? extends Configuration>) - Method in class cascading.tuple.hadoop.collect.HadoopTupleMapFactory

initLog4j(JobConf) - Static method in class cascading.flow.hadoop.util.HadoopUtil

initLog4j(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

instantiateSerializer(Configuration, Class<T>) - Static method in class cascading.flow.hadoop.util.HadoopUtil

isDirectory(FlowProcess<? extends Configuration>) - Method in class cascading.tap.hadoop.Hfs

isDirectory(Configuration) - Method in class cascading.tap.hadoop.Hfs

isInflow(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

isLocal(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

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

isTemporary() - Method in class cascading.tap.hadoop.util.TempHfs

isUseCombinedInput() - Method in class cascading.tap.hadoop.HfsProps

isUseCombinedInputSafeMode() - Method in class cascading.tap.hadoop.HfsProps

isYARN(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

J

JavaObjectSerializer - Class in cascading.flow.hadoop.util

Class JavaObjectSerializer is the default implementation of ObjectSerializer.

JavaObjectSerializer() - Constructor for class cascading.flow.hadoop.util.JavaObjectSerializer

K

KeyIndexTupleDeserializer - Class in cascading.tuple.hadoop.io

KeyIndexTupleDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.KeyIndexTupleDeserializer

KeyIndexTupleSerializer - Class in cascading.tuple.hadoop.io

KeyIndexTupleSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.KeyIndexTupleSerializer

KeyTupleDeserializer - Class in cascading.tuple.hadoop.io

KeyTupleDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.KeyTupleDeserializer

KeyTupleSerializer - Class in cascading.tuple.hadoop.io

KeyTupleSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.KeyTupleSerializer

keyType - Variable in class cascading.scheme.hadoop.WritableSequenceFile

L

Lfs - Class in cascading.tap.hadoop

Class Lfs is a Tap class that provides access to the Local File System via Hadoop.

Lfs(Scheme, String) - Constructor for class cascading.tap.hadoop.Lfs

Constructor Lfs creates a new Lfs instance.

Lfs(Scheme, String, SinkMode) - Constructor for class cascading.tap.hadoop.Lfs

Constructor Lfs creates a new Lfs instance.

listStatus(Path) - Method in class cascading.tap.hadoop.io.StreamedFileSystem

LOCAL_MODE_SCHEME - Static variable in class cascading.tap.hadoop.HfsProps

Fields LOCAL_MODE_SCHEME *

localModeScheme - Variable in class cascading.tap.hadoop.HfsProps

M

makeEncodedString(Object[]) - Method in class cascading.scheme.hadoop.TextLine

makeTemporaryPathDirString(String) - Method in class cascading.tap.hadoop.Hfs

makeTempPath(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil

makeURIScheme(Configuration) - Method in class cascading.tap.hadoop.Hfs

MapRed - Interface in cascading.flow.hadoop

A helper interface to allow a mapred.* package implementation instances to be exposed for internal use.

MeasuredOutputCollector - Class in cascading.tap.hadoop.util

MeasuredOutputCollector(FlowProcess, Enum) - Constructor for class cascading.tap.hadoop.util.MeasuredOutputCollector

MeasuredOutputCollector(FlowProcess, Enum, OutputCollector) - Constructor for class cascading.tap.hadoop.util.MeasuredOutputCollector

MeasuredRecordReader - Class in cascading.tap.hadoop.util

MeasuredRecordReader(FlowProcess, Enum) - Constructor for class cascading.tap.hadoop.util.MeasuredRecordReader

mergeConf(J, Map<String, String>, boolean) - Static method in class cascading.flow.hadoop.util.HadoopUtil

mkdirs(Path, FsPermission) - Method in class cascading.tap.hadoop.io.StreamedFileSystem

MultiInputFormat - Class in cascading.tap.hadoop.io

Class MultiInputFormat accepts multiple InputFormat class declarations allowing a single MR job to read data from incompatible file types.

MultiInputFormat() - Constructor for class cascading.tap.hadoop.io.MultiInputFormat

MultiInputSplit - Class in cascading.tap.hadoop.io

Class MultiInputSplit is used by MultiInputFormat

MultiInputSplit(InputSplit, Map<String, String>) - Constructor for class cascading.tap.hadoop.io.MultiInputSplit

MultiInputSplit() - Constructor for class cascading.tap.hadoop.io.MultiInputSplit

This constructor is used internally by Hadoop.

MultiRecordReaderIterator - Class in cascading.tap.hadoop.io

Class TapIterator is an implementation of CloseableIterator.

MultiRecordReaderIterator(FlowProcess<? extends Configuration>, Tap) - Constructor for class cascading.tap.hadoop.io.MultiRecordReaderIterator

Constructor TapIterator creates a new TapIterator instance.

N

needsTaskCommit(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil

next(K, V) - Method in class cascading.tap.hadoop.io.CombineFileRecordReaderWrapper

next() - Method in class cascading.tap.hadoop.io.CombineInputPartitionTupleEntryIterator

next() - Method in class cascading.tap.hadoop.io.MultiRecordReaderIterator

Method next returns the next Tuple.

next(Object, Object) - Method in class cascading.tap.hadoop.util.MeasuredRecordReader

O

OBJECT_SERIALIZER_PROPERTY - Static variable in interface cascading.flow.hadoop.util.ObjectSerializer

ObjectSerializer - Interface in cascading.flow.hadoop.util

Class ObjectSerializer is an experimental interface for allowing custom java.lang.Object subclass serialization other than via the java.io.Serializable interface.

open(Path, int) - Method in class cascading.tap.hadoop.io.HttpFileSystem

open(InputStream) - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalDeserializer

open(OutputStream) - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalSerializer

open(InputStream) - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesDeserializer

open(OutputStream) - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesSerializer

openForRead(FlowProcess<? extends Configuration>, RecordReader) - Method in class cascading.tap.hadoop.BaseDistCacheTap

openForRead(FlowProcess<? extends Configuration>, RecordReader) - Method in class cascading.tap.hadoop.Hfs

openForRead(FlowProcess<? extends Configuration>, RecordReader) - Method in class cascading.tap.hadoop.PartitionTap

openForWrite(FlowProcess<? extends Configuration>, OutputCollector) - Method in class cascading.tap.hadoop.Hfs

outgoingScopeFor(Set<Scope>) - Method in class cascading.tap.hadoop.util.TempHfs

P

pack(Object, Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

PART_TASK_PATTERN - Static variable in class cascading.tap.hadoop.io.TapOutputCollector

PART_TASK_SEQ_PATTERN - Static variable in class cascading.tap.hadoop.io.TapOutputCollector

PartitionTap - Class in cascading.tap.hadoop

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(Hfs, Partition) - Constructor for class cascading.tap.hadoop.PartitionTap

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

PartitionTap(Hfs, Partition, int) - Constructor for class cascading.tap.hadoop.PartitionTap

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

PartitionTap(Hfs, Partition, SinkMode) - Constructor for class cascading.tap.hadoop.PartitionTap

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

PartitionTap(Hfs, Partition, SinkMode, boolean) - Constructor for class cascading.tap.hadoop.PartitionTap

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

PartitionTap(Hfs, Partition, SinkMode, boolean, int) - Constructor for class cascading.tap.hadoop.PartitionTap

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

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

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

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

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

preventBitWiseComparison(boolean) - Method in class cascading.tuple.hadoop.TupleSerializationProps

Method preventBitWiseComparison will enable/disable bitwise comparisons of grouping keys during ordered partitioning (GroupBy and CoGroup).

R

read() - Method in class cascading.tap.hadoop.io.FSDigestInputStream

read(byte[], int, int) - Method in class cascading.tap.hadoop.io.FSDigestInputStream

read(int, DataInputStream) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader

read(Class, DataInputStream) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader

readFields(DataInput) - Method in class cascading.tap.hadoop.io.MultiInputSplit

readIndexTuple(IndexTuple) - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream

readNullVInt() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream

readNullVLong() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream

readString() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream

readToken() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream

readType(int) - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream

readType(Class) - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream

readVInt() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream

readVLong() - Method in class cascading.tuple.hadoop.io.HadoopTupleInputStream

RecordReaderIterator - Class in cascading.tap.hadoop.io

RecordReaderIterator is a utility class for handing off a single RecordReader instance via the Iterator.

RecordReaderIterator(RecordReader) - Constructor for class cascading.tap.hadoop.io.RecordReaderIterator

remove() - Method in class cascading.tap.hadoop.io.CombineInputPartitionTupleEntryIterator

remove() - Method in class cascading.tap.hadoop.io.MultiRecordReaderIterator

removePropertiesFrom(Configuration, String...) - Static method in class cascading.flow.hadoop.util.HadoopUtil

removeStateFromDistCache(Configuration, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil

rename(Path, Path) - Method in class cascading.tap.hadoop.io.StreamedFileSystem

REQUIRE_TYPES - Static variable in class cascading.tuple.hadoop.TupleSerializationProps

reset(byte[], int, int) - Method in class cascading.tuple.hadoop.io.BufferedInputStream

resetFileStatuses() - Method in class cascading.tap.hadoop.Hfs

Method resetFileStatuses removes the status cache, if any.

resolvePaths(Configuration, Collection<String>, String, String, Map<String, Path>, Map<String, Path>) - Static method in class cascading.flow.hadoop.util.HadoopUtil

resourceExists(Configuration) - Method in class cascading.tap.hadoop.Hfs

retrieveSourceFields(FlowProcess<? extends Configuration>, Tap) - Method in class cascading.scheme.hadoop.TextDelimited

S

seek(long) - Method in class cascading.tap.hadoop.io.FSDigestInputStream

seekToNewSource(long) - Method in class cascading.tap.hadoop.io.FSDigestInputStream

SequenceFile - Class in cascading.scheme.hadoop

A SequenceFile is a type of Scheme, which is a flat file consisting of binary key/value pairs.

SequenceFile() - Constructor for class cascading.scheme.hadoop.SequenceFile

Protected for use by TempDfs and other subclasses.

SequenceFile(Fields) - Constructor for class cascading.scheme.hadoop.SequenceFile

Creates a new SequenceFile instance that stores the given field names.

SERIALIZATION_COMPARISON_BITWISE_PREVENT - Static variable in class cascading.tuple.hadoop.TupleSerializationProps

SERIALIZATION_TOKENS - Static variable in class cascading.tuple.hadoop.TupleSerializationProps

SerializationToken - Annotation Type in cascading.tuple.hadoop

Annotation SerializationToken enables TupleInputStream and TupleOutputStream to substitute Integer values for a class name when writing out nested objects inside a Tuple.

serialize(T, boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer

serialize(T, boolean) - Method in interface cascading.flow.hadoop.util.ObjectSerializer

serialize(BigDecimal) - Method in class cascading.tuple.hadoop.BigDecimalSerialization.BigDecimalSerializer

serialize(byte[]) - Method in class cascading.tuple.hadoop.BytesSerialization.RawBytesSerializer

serialize(T) - Method in class cascading.tuple.hadoop.io.IndexTupleSerializer

serialize(TuplePair) - Method in class cascading.tuple.hadoop.io.TuplePairSerializer

serialize(Tuple) - Method in class cascading.tuple.hadoop.io.TupleSerializer

serializeBase64(T, Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

serializeBase64(T, Configuration, boolean) - Static method in class cascading.flow.hadoop.util.HadoopUtil

serializeList(List<T>, boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer

serializeMap(Map<String, T>, boolean) - Method in class cascading.flow.hadoop.util.JavaObjectSerializer

setCharsetName(String) - Method in class cascading.scheme.hadoop.TextLine

setCombinedInputMaxSize(Map<Object, Object>, Long) - Static method in class cascading.tap.hadoop.HfsProps

Method setCombinedInputMaxSize sets the maximum input split size to be used.

setCombinedInputMaxSize(long) - Method in class cascading.tap.hadoop.HfsProps

Method setCombinedInputMaxSize sets the maximum input split size to be used.

setConf(Configuration) - Method in class cascading.tuple.hadoop.TupleSerialization

setHadoopSerializations(List<String>) - Method in class cascading.tuple.hadoop.TupleSerializationProps

Method setHadoopSerializations sets the Hadoop serialization classNames to be used as properties.

setIgnoreTypes(Boolean) - Method in class cascading.tuple.hadoop.TupleSerializationProps

Method setIgnoreTypes forces the TupleSerialization class to ignore any and all declared types causing the serialization to write each type or SerializationToken per Tuple element.

setIsInflow(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

setLocal(Configuration) - Static method in class cascading.flow.hadoop.util.HadoopUtil

setLocalModeScheme(Map<Object, Object>, String) - Static method in class cascading.tap.hadoop.HfsProps

Method setLocalModeScheme provides a means to change the scheme value used to detect when a MapReduce job should be run in Hadoop local mode.

setLocalModeScheme(String) - Method in class cascading.tap.hadoop.HfsProps

Method setLocalModeScheme provides a means to change the scheme value used to detect when a MapReduce job should be run in Hadoop local mode.

setMD5SumFor(Configuration, Path, String) - Static method in class cascading.tap.hadoop.io.StreamedFileSystem

setMD5SumFor(Configuration, String, String) - Static method in class cascading.tap.hadoop.io.StreamedFileSystem

setNewApi(Configuration, String) - Static method in class cascading.flow.hadoop.util.HadoopUtil

setOutputCollector(OutputCollector) - Method in class cascading.tap.hadoop.util.MeasuredOutputCollector

setOutputPath(Configuration, Path) - Static method in class cascading.flow.hadoop.util.HadoopUtil

setRecordReader(RecordReader) - Method in class cascading.tap.hadoop.util.MeasuredRecordReader

setRequireTypes(Boolean) - Method in class cascading.tuple.hadoop.TupleSerializationProps

Method setRequireTypes forces TupleSerialization to fail if field types are not declared.

setSerializations(Configuration) - Static method in class cascading.tuple.hadoop.TupleSerialization

Adds this class as a Hadoop Serialization class.

setSerializationTokens(Map<Integer, String>) - Method in class cascading.tuple.hadoop.TupleSerializationProps

Method setSerializationTokens sets the given integer tokens and classNames Map as a serialization properties.

setSinkCompression(TextLine.Compress) - Method in class cascading.scheme.hadoop.TextLine

Method setSinkCompression sets the sinkCompression of this TextLine object.

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

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

setStringPath(String) - Method in class cascading.tap.hadoop.Dfs

setStringPath(String) - Method in class cascading.tap.hadoop.Hfs

setStringPath(String) - Method in class cascading.tap.hadoop.Lfs

setTemporaryDirectory(Map<Object, Object>, String) - Static method in class cascading.tap.hadoop.HfsProps

Method setTemporaryDirectory sets the temporary directory on the given properties object.

setTemporaryDirectory(String) - Method in class cascading.tap.hadoop.HfsProps

Method setTemporaryDirectory sets the temporary directory for use on the underlying filesystem.

setupJob(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil

should only be called if not in a Flow

setupTask(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil

setUriScheme(URI) - Method in class cascading.tap.hadoop.Hfs

setUseCombinedInput(Map<Object, Object>, Boolean) - Static method in class cascading.tap.hadoop.HfsProps

Method setUseCombinedInput provides a means to indicate whether to leverage CombineFileInputFormat for the input format.

setUseCombinedInput(boolean) - Method in class cascading.tap.hadoop.HfsProps

Method setUseCombinedInput provides a means to indicate whether to leverage CombineFileInputFormat for the input format.

setUseCombinedInputSafeMode(Map<Object, Object>, Boolean) - Static method in class cascading.tap.hadoop.HfsProps

Method setUseCombinedInputSafeMode toggles safe mode when using CombineFileInputFormat.

setUseCombinedInputSafeMode(boolean) - Method in class cascading.tap.hadoop.HfsProps

Method setUseCombinedInputSafeMode toggles safe mode when using CombineFileInputFormat.

setWorkingDirectory(Path) - Method in class cascading.tap.hadoop.io.StreamedFileSystem

sink(FlowProcess<? extends Configuration>, SinkCall<Void, OutputCollector>) - Method in class cascading.scheme.hadoop.SequenceFile

sink(FlowProcess<? extends Configuration>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextDelimited

sink(FlowProcess<? extends Configuration>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextLine

sink(FlowProcess<? extends Configuration>, SinkCall<Void, OutputCollector>) - Method in class cascading.scheme.hadoop.WritableSequenceFile

sinkConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.SequenceFile

sinkConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.TextLine

sinkConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.WritableSequenceFile

sinkConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.Hfs

sinkPrepare(FlowProcess<? extends Configuration>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextDelimited

sinkPrepare(FlowProcess<? extends Configuration>, SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextLine

source(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.SequenceFile

source(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextDelimited

source(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine

source(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.WritableSequenceFile

sourceCleanup(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.SequenceFile

sourceCleanup(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine

sourceConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.SequenceFile

sourceConfInit(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, Configuration) - Method in class cascading.scheme.hadoop.TextLine

sourceConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.BaseDistCacheTap

sourceConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.GlobHfs

sourceConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.Hfs

sourceConfInit(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.PartitionTap

sourceConfInitAddInputPath(Configuration, Path) - Method in class cascading.tap.hadoop.Hfs

Deprecated.

sourceConfInitAddInputPaths(Configuration, Iterable<Path>) - Method in class cascading.tap.hadoop.Hfs

sourceConfInitComplete(FlowProcess<? extends Configuration>, Configuration) - Method in class cascading.tap.hadoop.Hfs

sourceHandleInput(SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine

sourcePrepare(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.SequenceFile

sourcePrepare(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextDelimited

sourcePrepare(FlowProcess<? extends Configuration>, SourceCall<Object[], RecordReader>) - Method in class cascading.scheme.hadoop.TextLine

StreamedFileSystem - Class in cascading.tap.hadoop.io

Class StreamedFileSystem is a base class for FileSystem implementations that manage remote resources.

StreamedFileSystem() - Constructor for class cascading.tap.hadoop.io.StreamedFileSystem

stringPath - Variable in class cascading.tap.hadoop.Hfs

Field stringPath

syncPaths(Configuration, Map<Path, Path>, boolean) - Static method in class cascading.flow.hadoop.util.HadoopUtil

Copies paths from one local path to a remote path.

T

TapOutputCollector - Class in cascading.tap.hadoop.io

TapOutputCollector(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>) - Constructor for class cascading.tap.hadoop.io.TapOutputCollector

TapOutputCollector(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, String) - Constructor for class cascading.tap.hadoop.io.TapOutputCollector

TapOutputCollector(FlowProcess<? extends Configuration>, Tap<Configuration, RecordReader, OutputCollector>, String, long) - Constructor for class cascading.tap.hadoop.io.TapOutputCollector

TempHfs - Class in cascading.tap.hadoop.util

Class TempHfs creates a temporary Tap instance for use internally.

TempHfs(Configuration, String, boolean) - Constructor for class cascading.tap.hadoop.util.TempHfs

Constructor TempHfs creates a new TempHfs instance.

TempHfs(Configuration, String, Class<? extends Scheme>) - Constructor for class cascading.tap.hadoop.util.TempHfs

Constructor TempDfs creates a new TempDfs instance.

TempHfs(Configuration, String, Class<? extends Scheme>, boolean) - Constructor for class cascading.tap.hadoop.util.TempHfs

TEMPORARY_DIRECTORY - Static variable in class cascading.tap.hadoop.HfsProps

Field TEMPORARY_DIRECTORY

TEMPORARY_PATH - Static variable in class cascading.tap.hadoop.util.Hadoop18TapUtil

The Hadoop temporary path used to prevent collisions

temporaryDirectory - Variable in class cascading.tap.hadoop.HfsProps

TextDelimited - Class in cascading.scheme.hadoop

Class TextDelimited is a sub-class of TextLine.

TextDelimited() - Constructor for class cascading.scheme.hadoop.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.hadoop.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.hadoop.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.hadoop.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.hadoop.TextDelimited

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

TextDelimited(TextLine.Compress, boolean, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited

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

TextDelimited(TextLine.Compress, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited

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

TextDelimited(TextLine.Compress, boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited

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

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

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

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, TextLine.Compress, String) - Constructor for class cascading.scheme.hadoop.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, TextLine.Compress, boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, TextLine.Compress, boolean, boolean, String) - Constructor for class cascading.scheme.hadoop.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, TextLine.Compress, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, TextLine.Compress, boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, TextLine.Compress, boolean, String, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, String) - Constructor for class cascading.scheme.hadoop.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

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

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, TextLine.Compress, boolean, boolean, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextDelimited(Fields, TextLine.Compress, boolean, boolean, String, DelimitedParser) - Constructor for class cascading.scheme.hadoop.TextDelimited

Constructor TextDelimited creates a new TextDelimited instance.

TextLine - Class in cascading.scheme.hadoop

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

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

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

TextLine(int) - Constructor for class cascading.scheme.hadoop.TextLine

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

TextLine(TextLine.Compress) - Constructor for class cascading.scheme.hadoop.TextLine

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

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

Creates a new TextLine instance.

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

Creates a new TextLine instance.

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

Creates a new TextLine instance.

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

Constructor TextLine creates a new TextLine instance.

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

Constructor TextLine creates a new TextLine instance.

TextLine(Fields, Fields, TextLine.Compress, int) - Constructor for class cascading.scheme.hadoop.TextLine

Constructor TextLine creates a new TextLine instance.

TextLine(Fields, Fields, TextLine.Compress, int, String) - Constructor for class cascading.scheme.hadoop.TextLine

Constructor TextLine creates a new TextLine instance.

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

Creates a new TextLine instance.

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

Creates a new TextLine instance.

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

Creates a new TextLine instance.

TextLine.Compress - Enum in cascading.scheme.hadoop

toString() - Method in class cascading.tap.hadoop.GlobHfs

toString() - Method in class cascading.tap.hadoop.util.TempHfs

TupleDeserializer - Class in cascading.tuple.hadoop.io

TupleDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.TupleDeserializer

TuplePairDeserializer - Class in cascading.tuple.hadoop.io

TuplePairDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.TuplePairDeserializer

TuplePairSerializer - Class in cascading.tuple.hadoop.io

TuplePairSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.TuplePairSerializer

TupleSerialization - Class in cascading.tuple.hadoop

Class TupleSerialization is an implementation of Hadoop's Serialization interface.

TupleSerialization() - Constructor for class cascading.tuple.hadoop.TupleSerialization

Constructor TupleSerialization creates a new TupleSerialization instance.

TupleSerialization(FlowProcess<? extends Configuration>) - Constructor for class cascading.tuple.hadoop.TupleSerialization

TupleSerialization(Configuration) - Constructor for class cascading.tuple.hadoop.TupleSerialization

Constructor TupleSerialization creates a new TupleSerialization instance.

TupleSerialization.SerializationElementReader - Class in cascading.tuple.hadoop

TupleSerialization.SerializationElementReader(TupleSerialization) - Constructor for class cascading.tuple.hadoop.TupleSerialization.SerializationElementReader

Constructor SerializationElementReader creates a new SerializationElementReader instance.

TupleSerialization.SerializationElementWriter - Class in cascading.tuple.hadoop

TupleSerialization.SerializationElementWriter(TupleSerialization) - Constructor for class cascading.tuple.hadoop.TupleSerialization.SerializationElementWriter

TupleSerializationProps - Class in cascading.tuple.hadoop

Class TupleSerializationProps is a fluent interface for building properties to be passed to a FlowConnector before creating new Flow instances.

TupleSerializationProps() - Constructor for class cascading.tuple.hadoop.TupleSerializationProps

tupleSerializationProps() - Static method in class cascading.tuple.hadoop.TupleSerializationProps

Creates a new TupleSerializationProps instance.

TupleSerializer - Class in cascading.tuple.hadoop.io

TupleSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.TupleSerializer

typeMap - Variable in class cascading.tuple.hadoop.io.IndexTupleDeserializer

typeMap - Variable in class cascading.tuple.hadoop.io.IndexTupleSerializer

U

useCombinedInput - Variable in class cascading.tap.hadoop.HfsProps

V

validateInput(JobConf) - Method in class cascading.tap.hadoop.io.MultiInputFormat

ValueIndexTupleDeserializer - Class in cascading.tuple.hadoop.io

ValueIndexTupleDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.ValueIndexTupleDeserializer

ValueIndexTupleSerializer - Class in cascading.tuple.hadoop.io

ValueIndexTupleSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.ValueIndexTupleSerializer

valueOf(String) - Static method in enum cascading.scheme.hadoop.TextLine.Compress

Returns the enum constant of this type with the specified name.

values() - Static method in enum cascading.scheme.hadoop.TextLine.Compress

Returns an array containing the constants of this enum type, in the order they are declared.

ValueTupleDeserializer - Class in cascading.tuple.hadoop.io

ValueTupleDeserializer(TupleSerialization.SerializationElementReader) - Constructor for class cascading.tuple.hadoop.io.ValueTupleDeserializer

ValueTupleSerializer - Class in cascading.tuple.hadoop.io

ValueTupleSerializer(TupleSerialization.SerializationElementWriter) - Constructor for class cascading.tuple.hadoop.io.ValueTupleSerializer

valueType - Variable in class cascading.scheme.hadoop.WritableSequenceFile

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

verifyNoDuplicates(Configuration) - Static method in class cascading.tap.hadoop.Hfs

W

wrapInput(RecordReader) - Method in class cascading.tap.hadoop.io.HadoopTupleEntrySchemeIterator

wrapOutput(OutputCollector) - Method in class cascading.tap.hadoop.io.HadoopTupleEntrySchemeCollector

WRITABLE_TOKEN - Static variable in class cascading.tuple.hadoop.io.HadoopTupleOutputStream

Field WRITABLE_TOKEN

WritableSequenceFile - Class in cascading.scheme.hadoop

Class WritableSequenceFile is a sub-class of SequenceFile that reads and writes values of the given writableType Class, instead of Tuple instances used by default in SequenceFile.

WritableSequenceFile(Fields, Class<? extends Writable>) - Constructor for class cascading.scheme.hadoop.WritableSequenceFile

Constructor WritableSequenceFile creates a new WritableSequenceFile instance.

WritableSequenceFile(Fields, Class<? extends Writable>, Class<? extends Writable>) - Constructor for class cascading.scheme.hadoop.WritableSequenceFile

Constructor WritableSequenceFile creates a new WritableSequenceFile instance.

write(DataOutput) - Method in class cascading.tap.hadoop.io.MultiInputSplit

write(DataOutputStream, Object) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementWriter

write(DataOutputStream, Class<?>, Object) - Method in class cascading.tuple.hadoop.TupleSerialization.SerializationElementWriter

writeHeader(SinkCall<Object[], OutputCollector>) - Method in class cascading.scheme.hadoop.TextDelimited

writeIndexTuple(IndexTuple) - Method in class cascading.tuple.hadoop.io.HadoopTupleOutputStream

writeIntInternal(int) - Method in class cascading.tuple.hadoop.io.HadoopTupleOutputStream

writeSuccessMarker(Configuration) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil

writeSuccessMarker(Configuration, Path) - Static method in class cascading.tap.hadoop.util.Hadoop18TapUtil

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