Share

Search Java Classes and Packages

Search Java Frameworks and Libraries

255581 classes and counting ...
Search Tips Index Status



# Classes and Interfaces in #Apache Crunch - 221 results found.
NameDescriptionTypePackageFrameworkJavaDoc
AbstractCompositeExtractorBase class for Extractor instances that delegates the parsing of fields to other Extractor instances, primarily used for constructing composite records that implementClassorg.apache.crunch.contrib.textApache Crunchjavadoc
AbstractSimpleExtractorBase class for the common case Extractor instances that construct a single object from a block of text stored in a String, with support for error handlingClassorg.apache.crunch.contrib.textApache Crunchjavadoc
AggregateMethods for performing various types of aggregations over PCollection instances.Classorg.apache.crunch.libApache Crunchjavadoc
AggregatorAggregate a sequence of values into a possibly smaller sequence of the same type.Interfaceorg.apache.crunchApache Crunchjavadoc
AggregatorsA collection of pre-defined Aggregators.Classorg.apache.crunch.fnApache Crunchjavadoc
AtStatic factory methods for creating common SourceTarget types, which may be treated as both a Source The At methods is analogous to the From and To factory methods, but is used forClassorg.apache.crunch.ioApache Crunchjavadoc
AverageBytesByIPSee Also:Serialized FormConstructor SummaryAverageBytesByIP()Classorg.apache.crunch.examplesApache Crunchjavadoc
AvroDerivedValueDeepCopierA DeepCopier specific to Avro derived types.Classorg.apache.crunch.types.avroApache Crunchjavadoc
AvroInputFormatAn InputFormat for Avro data files.Classorg.apache.crunch.types.avroApache Crunchjavadoc
AvroModeAvroMode is an immutable object used for configuring the reading and writing of Avro types.Classorg.apache.crunch.types.avroApache Crunchjavadoc
AvroOutputFormatAn OutputFormat for Avro data files.Classorg.apache.crunch.types.avroApache Crunchjavadoc
AvroPathPerKeyOutputFormatA FileOutputFormat that takes in a Utf8 and an Avro record and writes the Avro records to a sub-directory of the output path whose name is equal to the string-form of the Utf8.Classorg.apache.crunch.types.avroApache Crunchjavadoc
AvrosDefines static methods that are analogous to the methods defined in AvroTypeFamily for convenient static importing.Classorg.apache.crunch.types.avroApache Crunchjavadoc
Check Code Snippets / Samples for org.apache.crunch.types.avro.Avros
AvroSerDeClassorg.apache.crunch.impl.spark.serdeApache Crunchjavadoc
AvroTextOutputFormatNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.types.avroApache Crunchjavadoc
AvroTypeThe implementation of the PType interface for Avro-based serialization.Classorg.apache.crunch.types.avroApache Crunchjavadoc
AvroTypeFamilyClassorg.apache.crunch.types.avroApache Crunchjavadoc
AvroUtf8InputFormatAn InputFormat for text files.Classorg.apache.crunch.types.avroApache Crunchjavadoc
BaseDoCollectionNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.dist.collectApache Crunchjavadoc
BaseDoTableNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.dist.collectApache Crunchjavadoc
BaseGroupedTableNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.dist.collectApache Crunchjavadoc
BaseInputCollectionNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.dist.collectApache Crunchjavadoc
BaseInputTableNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.dist.collectApache Crunchjavadoc
BaseUnionCollectionNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.dist.collectApache Crunchjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

BaseUnionTableNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.dist.collectApache Crunchjavadoc
BloomFilterFactoryFactory Class for creating BloomFilters.Classorg.apache.crunch.contrib.bloomfilterApache Crunchjavadoc
BloomFilterFnThe class is responsible for generating keys that are used in a BloomFilterSee Also:Serialized FormClassorg.apache.crunch.contrib.bloomfilterApache Crunchjavadoc
BloomFilterJoinStrategyJoin strategy that uses a Bloom filter that is trained on the keys of the left-side table to filter the key/value pairs of the right-sideClassorg.apache.crunch.lib.joinApache Crunchjavadoc
ByteArrayClassorg.apache.crunch.impl.sparkApache Crunchjavadoc
CachingOptionsOptions for controlling how a PCollection is cached for subsequent processing.Classorg.apache.crunchApache Crunchjavadoc
CartesianUtilities for Cartesian products of two PTable or PCollectionConstructor SummaryCartesian()Classorg.apache.crunch.libApache Crunchjavadoc
ChannelsUtilities for splitting Pair instances emitted by DoFn into separate PCollection instances.Classorg.apache.crunch.libApache Crunchjavadoc
CogroupConstructor SummaryCogroup() PTableClassorg.apache.crunch.libApache Crunchjavadoc
CollectionDeepCopierPerforms deep copies (based on underlying PType deep copying) of Collections.Classorg.apache.crunch.typesApache Crunchjavadoc
CombineFnA special DoFn implementation that converts an Iterable of values into a single value.Classorg.apache.crunchApache Crunchjavadoc
CombineMapsideFunctionClassorg.apache.crunch.impl.spark.fnApache Crunchjavadoc
CompositeMapFnClassorg.apache.crunch.fnApache Crunchjavadoc
CompositePathIterablecreate(org.Classorg.apache.crunch.ioApache Crunchjavadoc
CompressHelper functions for compressing output data.Classorg.apache.crunch.ioApache Crunchjavadoc
ConverterConverts the input key/value from a MapReduce task into the input to a DoFn, or takes the output of a DoFn and write it to theInterfaceorg.apache.crunch.typesApache Crunchjavadoc
CounterAccumulatorParamSee Also:Serialized FormConstructor SummaryCounterAccumulatorParam()Classorg.apache.crunch.impl.sparkApache Crunchjavadoc
CrunchInputsHelper functions for configuring multiple InputFormat instances within a single Crunch MapReduce job.Classorg.apache.crunch.ioApache Crunchjavadoc
CrunchIterableClassorg.apache.crunch.impl.spark.fnApache Crunchjavadoc
CrunchOutputsAn analogue of CrunchInputs for handling multiple OutputFormat instances writing to multiple files within a single MapReduce job.Classorg.apache.crunch.ioApache Crunchjavadoc
CrunchPairTuple2See Also:Serialized FormConstructor SummaryCrunchPairTuple2()Classorg.apache.crunch.impl.spark.fnApache Crunchjavadoc
CrunchRuntimeExceptionA RuntimeException implementation that includes some additional options for the Crunch execution engine to track reporting status.Classorg.apache.crunchApache Crunchjavadoc
CrunchTestSupportA temporary workaround for Scala tests to use when working with Rule annotations until it gets fixed in JUnit 4.Classorg.apache.crunch.testApache Crunchjavadoc
CrunchToolAn extension of the Tool interface that creates a Pipeline instance and provides methods for working with the Pipeline from inside ofClassorg.apache.crunch.utilApache Crunchjavadoc
DataBaseSourceSource from reading from a database via a JDBC connection.Classorg.apache.crunch.contrib.io.jdbcApache Crunchjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

DebugLoggingAllows direct manipulation of the Hadoop log4j settings to aid in unit testing.Classorg.apache.crunch.testApache Crunchjavadoc
DeepCopierPerforms deep copies of values.Interfaceorg.apache.crunch.typesApache Crunchjavadoc
DefaultJoinStrategyDefault join strategy that simply sends all data through the map, shuffle, and reduce phase.Classorg.apache.crunch.lib.joinApache Crunchjavadoc
DelegatingReadableData and passing its contents through a DoFn.Classorg.apache.crunch.utilApache Crunchjavadoc
DistCacheProvides functions for working with Hadoop's distributed cache.Classorg.apache.crunch.utilApache Crunchjavadoc
DistinctFunctions for computing the distinct elements of a PCollection.Classorg.apache.crunch.libApache Crunchjavadoc
DistributedPipelineClassorg.apache.crunch.impl.distApache Crunchjavadoc
DoCollectionNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.spark.collectApache Crunchjavadoc
DoFnBase class for all data processing functions in Crunch.Classorg.apache.crunchApache Crunchjavadoc
Check Code Snippets / Samples for org.apache.crunch.DoFn
DoFnIteratorAn Iterator that combines a delegate Iterator and a DoFn, generating data by passing the contents of the iterator through the function.Classorg.apache.crunch.utilApache Crunchjavadoc
DoTableNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.spark.collectApache Crunchjavadoc
EmitterInterface for writing outputs from a DoFn.Interfaceorg.apache.crunchApache Crunchjavadoc
Check Code Snippets / Samples for org.apache.crunch.Emitter
EmptyPCollectionNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.dist.collectApache Crunchjavadoc
EmptyPCollectionNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.spark.collectApache Crunchjavadoc
EmptyPTableNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.dist.collectApache Crunchjavadoc
EmptyPTableNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.spark.collectApache Crunchjavadoc
ExtractKeyFnWrapper function for converting a MapFn into a key-value pair that is used to convert from a PCollection to a PTable.Classorg.apache.crunch.fnApache Crunchjavadoc
ExtractorAn interface for extracting a specific data type from a text string that is being processed by a Scanner object.Interfaceorg.apache.crunch.contrib.textApache Crunchjavadoc
ExtractorsFactory methods for constructing common Extractor types.Classorg.apache.crunch.contrib.textApache Crunchjavadoc
ExtractorStatsClassorg.apache.crunch.contrib.textApache Crunchjavadoc
FileNamingSchemeEncapsulates rules for naming output files.Interfaceorg.apache.crunch.ioApache Crunchjavadoc
FileReaderFactoryInterfaceorg.apache.crunch.ioApache Crunchjavadoc
FilterFnA DoFn for the common case of filtering the members of a PCollection based on a boolean condition.Classorg.apache.crunchApache Crunchjavadoc
Check Code Snippets / Samples for org.apache.crunch.FilterFn
FilterFnsA collection of pre-defined FilterFn implementations.Classorg.apache.crunch.fnApache Crunchjavadoc
FlatMapIndexFnClassorg.apache.crunch.impl.spark.fnApache Crunchjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

FlatMapPairDoFnClassorg.apache.crunch.impl.spark.fnApache Crunchjavadoc
FormatBundleA combination of an InputFormat or OutputFormat and any extra configuration information that format class needs to run.Classorg.apache.crunch.ioApache Crunchjavadoc
FromStatic factory methods for creating common Source types.Classorg.apache.crunch.ioApache Crunchjavadoc
Check Code Snippets / Samples for org.apache.crunch.io.From
FullOuterJoinFnUsed to perform the last step of an full outer join.Classorg.apache.crunch.lib.joinApache Crunchjavadoc
GroupingOptionsOptions that can be passed to a groupByKey operation in order to exercise finer control over how the partitioning, grouping, and sorting ofClassorg.apache.crunchApache Crunchjavadoc
GuavaUtilsConstructor SummaryGuavaUtils() com.Classorg.apache.crunch.impl.sparkApache Crunchjavadoc
IdentifiableNameClassorg.apache.crunch.contrib.io.jdbcApache Crunchjavadoc
IdentityFnClassorg.apache.crunch.fnApache Crunchjavadoc
InnerJoinFnUsed to perform the last step of an inner join.Classorg.apache.crunch.lib.joinApache Crunchjavadoc
InputCollectionNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.spark.collectApache Crunchjavadoc
InputConverterFunctionClassorg.apache.crunch.impl.spark.fnApache Crunchjavadoc
InputTableNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.spark.collectApache Crunchjavadoc
IntByteArraySee Also:Serialized FormFields inherited from class org.Classorg.apache.crunch.impl.sparkApache Crunchjavadoc
JoinUtilities for joining multiple PTable instances based on a commonConstructor SummaryJoin()Classorg.apache.crunch.libApache Crunchjavadoc
JoinFnRepresents a DoFn for performing joins.Classorg.apache.crunch.lib.joinApache Crunchjavadoc
JoinStrategyDefines a strategy for joining two PTables together on a common key.Interfaceorg.apache.crunch.lib.joinApache Crunchjavadoc
JoinTypeenum JoinTypeextends EnumSpecifies the specific behavior of how a join should be performed in terms of requiring matching keys Classorg.apache.crunch.lib.joinApache Crunchjavadoc
JoinUtilsUtilities that are useful in joining multiple data sets via a MapReduce.Classorg.apache.crunch.lib.joinApache Crunchjavadoc
LeftOuterJoinFnUsed to perform the last step of an left outer join.Classorg.apache.crunch.lib.joinApache Crunchjavadoc
MapDeepCopierClassorg.apache.crunch.typesApache Crunchjavadoc
MapFnA DoFn for the common case of emitting exactly one value for eachSee Also:Serialized FormClassorg.apache.crunchApache Crunchjavadoc
Check Code Snippets / Samples for org.apache.crunch.MapFn
MapFunctionClassorg.apache.crunch.impl.spark.fnApache Crunchjavadoc
MapOutputFunctionClassorg.apache.crunch.impl.spark.fnApache Crunchjavadoc
MapredStatic functions for working with legacy Mappers and Reducers that live under the org.Classorg.apache.crunch.libApache Crunchjavadoc
MapreduceStatic functions for working with legacy Mappers and Reducers that live under the org.Classorg.apache.crunch.libApache Crunchjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

MapReduceTargetNested Class SummaryNested classes/interfaces inherited from interface org.Interfaceorg.apache.crunch.ioApache Crunchjavadoc
MapsideJoinStrategyUtility for doing map side joins on a common key between two PTables.Classorg.apache.crunch.lib.joinApache Crunchjavadoc
MemPipelineClassorg.apache.crunch.impl.memApache Crunchjavadoc
MRCollectionInterfaceorg.apache.crunch.impl.dist.collectApache Crunchjavadoc
MRJobA Hadoop MapReduce job managed by Crunch.Interfaceorg.apache.crunch.impl.mrApache Crunchjavadoc
MRPipelinePipeline implementation that is executed within Hadoop MapReduce.Classorg.apache.crunch.impl.mrApache Crunchjavadoc
Check Code Snippets / Samples for org.apache.crunch.impl.mr.MRPipeline
MRPipelineExecutionNested Class SummaryNested classes/interfaces inherited from interface org.Interfaceorg.apache.crunch.impl.mrApache Crunchjavadoc
NoOpDeepCopierA DeepCopier that does nothing, and just returns the input value without copying anything.Classorg.apache.crunch.typesApache Crunchjavadoc
OneToManyJoinOptimized join for situations where exactly one value is being joined with any other number of values based on a common key.Classorg.apache.crunch.lib.joinApache Crunchjavadoc
OrcsUtilities to create PTypes for ORC serialization / deserializationConstructor SummaryOrcs()Classorg.apache.crunch.types.orcApache Crunchjavadoc
OrcUtilsClassorg.apache.crunch.types.orcApache Crunchjavadoc
OutputConverterFunctionClassorg.apache.crunch.impl.spark.fnApache Crunchjavadoc
OutputHandlerInterfaceorg.apache.crunch.ioApache Crunchjavadoc
PairA convenience class for two-element Tuples.Classorg.apache.crunchApache Crunchjavadoc
PairFlatMapDoFnClassorg.apache.crunch.impl.spark.fnApache Crunchjavadoc
PairMapFnClassorg.apache.crunch.fnApache Crunchjavadoc
PairMapFunctionClassorg.apache.crunch.impl.spark.fnApache Crunchjavadoc
PairMapIterableFunctionClassorg.apache.crunch.impl.spark.fnApache Crunchjavadoc
ParallelDoOptionsContainer class that includes optional information about a parallelDo operation applied to a PCollection.Classorg.apache.crunchApache Crunchjavadoc
ParseClassorg.apache.crunch.contrib.textApache Crunchjavadoc
PartitionedMapOutputFunctionClassorg.apache.crunch.impl.spark.fnApache Crunchjavadoc
PartitionUtilsHelper functions and settings for determining the number of reducers to use in a pipeline job created by the Crunch planner.Classorg.apache.crunch.utilApache Crunchjavadoc
PathTargetA target whose output goes to a given path on a file system.Interfaceorg.apache.crunch.ioApache Crunchjavadoc
PCollectionA representation of an immutable, distributed collection of elements that is the fundamental target of computations in Crunch.Interfaceorg.apache.crunchApache Crunchjavadoc
Check Code Snippets / Samples for org.apache.crunch.PCollection
PCollectionFactoryInterfaceorg.apache.crunch.impl.dist.collectApache Crunchjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

PCollectionImplClassorg.apache.crunch.impl.dist.collectApache Crunchjavadoc
PGroupedTableThe Crunch representation of a grouped PTable, which corresponds to the output of the shuffle phase of a MapReduce job.Interfaceorg.apache.crunchApache Crunchjavadoc
PGroupedTableImplNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.spark.collectApache Crunchjavadoc
PGroupedTableTypeThe PType instance for PGroupedTable instances.Classorg.apache.crunch.typesApache Crunchjavadoc
PipelineManages the state of a pipeline execution.Interfaceorg.apache.crunchApache Crunchjavadoc
Check Code Snippets / Samples for org.apache.crunch.Pipeline
PipelineCallableA specialization of Callable that executes some sequential logic on the client machine as part of an overall Crunch pipeline in order to generate zero or more outputs, some ofClassorg.apache.crunchApache Crunchjavadoc
PipelineExecutionA handle to allow clients to control a Crunch pipeline as it runs.Interfaceorg.apache.crunchApache Crunchjavadoc
PipelineResultContainer for the results of a call to run or done on the Pipeline interface that includes details and statistics about the componentClassorg.apache.crunchApache Crunchjavadoc
Check Code Snippets / Samples for org.apache.crunch.PipelineResult
PObjectA PObject represents a singleton object value that results from a distributed computation.Interfaceorg.apache.crunchApache Crunchjavadoc
ProtosUtility functions for working with protocol buffers in Crunch.Classorg.apache.crunch.typesApache Crunchjavadoc
PTableA sub-interface of PCollection that represents an immutable, distributed multi-map of keys and values.Interfaceorg.apache.crunchApache Crunchjavadoc
PTableBaseNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.dist.collectApache Crunchjavadoc
PTablesMethods for performing common operations on PTables.Classorg.apache.crunch.libApache Crunchjavadoc
PTableTypeAn extension of PType specifically for PTable objects.Interfaceorg.apache.crunch.typesApache Crunchjavadoc
PTypeA PType defines a mapping between a data type that is used in a Crunch pipeline and a serialization and storage format that is used to read/write data from/to HDFS.Interfaceorg.apache.crunch.typesApache Crunchjavadoc
PTypeFamilyAn abstract factory for creating PType instances that have the same serialization/storage backing format.Interfaceorg.apache.crunch.typesApache Crunchjavadoc
PTypesUtility functions for creating common types of derived PTypes, e.Classorg.apache.crunch.typesApache Crunchjavadoc
PTypeUtilsUtilities for converting between PTypes from different PTypeFamily implementations.Classorg.apache.crunch.typesApache Crunchjavadoc
ReadableDataRepresents the contents of a data source that can be read on the cluster from within one of the tasks running as part of a Crunch pipeline.Interfaceorg.apache.crunchApache Crunchjavadoc
ReadableSourceAn extension of the Source interface that indicates that a Source instance may be read as a series of records by the clientInterfaceorg.apache.crunch.ioApache Crunchjavadoc
ReadableSourceTargetAn interface that indicates that a SourceTarget instance can be read into the local client.Interfaceorg.apache.crunch.ioApache Crunchjavadoc
ReaderWriterFactoryInterface for accessing DatumReader, DatumWriter, and Data classes.Interfaceorg.apache.crunch.types.avroApache Crunchjavadoc
ReduceGroupingFunctionClassorg.apache.crunch.impl.spark.fnApache Crunchjavadoc
ReduceInputFunctionClassorg.apache.crunch.impl.spark.fnApache Crunchjavadoc
ReflectDataFactoryA Factory class for constructing Avro reflection-related objects.Classorg.apache.crunch.types.avroApache Crunchjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

ReverseAvroComparatorClassorg.apache.crunch.lib.sortApache Crunchjavadoc
ReverseWritableComparatorClassorg.apache.crunch.lib.sortApache Crunchjavadoc
RightOuterJoinFnUsed to perform the last step of an right outer join.Classorg.apache.crunch.lib.joinApache Crunchjavadoc
SampleMethods for performing random sampling in a distributed fashion, either by accepting each record in a PCollection with an independent probability in order to sample someClassorg.apache.crunch.libApache Crunchjavadoc
SDoubleFlatMapFunctionA Crunch-compatible abstract base class for Spark's DoubleFlatMapFunction.Classorg.apache.crunch.fnApache Crunchjavadoc
SDoubleFunctionA Crunch-compatible abstract base class for Spark's DoubleFunction.Classorg.apache.crunch.fnApache Crunchjavadoc
SecondarySortUtilities for performing a secondary sort on a PTable> collection.Classorg.apache.crunch.libApache Crunchjavadoc
SecondarySortExampleSee Also:Serialized FormConstructor SummarySecondarySortExample()Classorg.apache.crunch.examplesApache Crunchjavadoc
SequentialFileNamingSchemeDefault FileNamingScheme that uses an incrementing sequence number in order to generate unique file names.Classorg.apache.crunch.ioApache Crunchjavadoc
SerDeInterfaceorg.apache.crunch.impl.spark.serdeApache Crunchjavadoc
SerializableSupplierAn extension of Guava's Supplier interface that indicates that an instance will also implement Serializable, which makes this object suitable for useInterfaceorg.apache.crunch.utilApache Crunchjavadoc
SetUtilities for performing set operations (difference, intersection, etc) on PCollection instances.Classorg.apache.crunch.libApache Crunchjavadoc
SFlatMapFunctionA Crunch-compatible abstract base class for Spark's FlatMapFunction.Classorg.apache.crunch.fnApache Crunchjavadoc
SFlatMapFunction2A Crunch-compatible abstract base class for Spark's FlatMapFunction2.Classorg.apache.crunch.fnApache Crunchjavadoc
SFunctionA Crunch-compatible abstract base class for Spark's Function.Classorg.apache.crunch.fnApache Crunchjavadoc
SFunction2A Crunch-compatible abstract base class for Spark's Function2.Classorg.apache.crunch.fnApache Crunchjavadoc
SFunctionsUtility methods for wrapping existing Spark Java API Functions for Crunch compatibility.Classorg.apache.crunch.fnApache Crunchjavadoc
ShardUtilities for controlling how the data in a PCollection is balanced across reducersConstructor SummaryShard()Classorg.apache.crunch.libApache Crunchjavadoc
ShardedJoinStrategyJoinStrategy that splits the key space up into shards.Classorg.apache.crunch.lib.joinApache Crunchjavadoc
SingleUseIterableWrapper around a Reducer's input Iterable.Classorg.apache.crunch.implApache Crunchjavadoc
SortUtilities for sorting PCollection instances.Classorg.apache.crunch.libApache Crunchjavadoc
SortExampleSimple Crunch tool for running sorting examples from the command line.Classorg.apache.crunch.examplesApache Crunchjavadoc
SortFnsA set of DoFns that are used by Crunch's Sort library.Classorg.apache.crunch.lib.sortApache Crunchjavadoc
SourceInterfaceorg.apache.crunchApache Crunchjavadoc
SourceTargetInterfaceorg.apache.crunchApache Crunchjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

SourceTargetHelperFunctions for configuring the inputs/outputs of MapReduce jobs.Classorg.apache.crunch.ioApache Crunchjavadoc
SPairFlatMapFunctionA Crunch-compatible abstract base class for Spark's PairFlatMapFunction.Classorg.apache.crunch.fnApache Crunchjavadoc
SPairFunctionA Crunch-compatible abstract base class for Spark's PairFunction.Classorg.apache.crunch.fnApache Crunchjavadoc
SparkCollectFactoryConstructor SummarySparkCollectFactory() BaseDoCollectionClassorg.apache.crunch.impl.spark.collectApache Crunchjavadoc
SparkCollectionInterfaceorg.apache.crunch.impl.sparkApache Crunchjavadoc
SparkComparatorClassorg.apache.crunch.impl.sparkApache Crunchjavadoc
SparkCounterClassorg.apache.hadoop.mapredApache Crunchjavadoc
SparkPartitionerClassorg.apache.crunch.impl.sparkApache Crunchjavadoc
SparkPipelineConstructor SummarySparkPipeline(org.Classorg.apache.crunch.impl.sparkApache Crunchjavadoc
SparkRuntimeNested Class SummaryNested classes/interfaces inherited from interface org.Classorg.apache.crunch.impl.sparkApache Crunchjavadoc
SparkRuntimeContextClassorg.apache.crunch.impl.sparkApache Crunchjavadoc
SwapFnSwap the elements of a Pair type.Classorg.apache.crunch.fnApache Crunchjavadoc
TableSourceThe interface Source implementations that return a PTable.Interfaceorg.apache.crunchApache Crunchjavadoc
TableSourceTargetInterfaceorg.apache.crunchApache Crunchjavadoc
TargetA Target represents the output destination of a Crunch PCollection in the context of a Crunch job.Interfaceorg.apache.crunchApache Crunchjavadoc
TemporaryPathCreates a temporary directory for a test case and destroys it afterwards.Classorg.apache.crunch.testApache Crunchjavadoc
TestCountersA utility class used during unit testing to update and read counters.Classorg.apache.crunch.testApache Crunchjavadoc
ToStatic factory methods for creating common Target types.Classorg.apache.crunch.ioApache Crunchjavadoc
Check Code Snippets / Samples for org.apache.crunch.io.To
ToByteArrayFunctionSee Also:Serialized FormConstructor SummaryToByteArrayFunction()Classorg.apache.crunch.impl.spark.collectApache Crunchjavadoc
TokenizerManages a Scanner instance and provides support for returning only a subset of the fields returned by the underlying Scanner.Classorg.apache.crunch.contrib.textApache Crunchjavadoc
TokenizerFactoryFactory class that constructs Tokenizer instances for input strings that use a fixed set of delimiters, skip patterns, locales, and sets of indices to keep or drop.Classorg.apache.crunch.contrib.textApache Crunchjavadoc
TotalBytesByIPSee Also:Serialized FormConstructor SummaryTotalBytesByIP()Classorg.apache.crunch.examplesApache Crunchjavadoc
TotalOrderPartitionerClassorg.apache.crunch.lib.sortApache Crunchjavadoc
TotalWordCountSee Also:Serialized FormConstructor SummaryTotalWordCount()Classorg.apache.crunch.examplesApache Crunchjavadoc
TupleA fixed-size collection of Objects, used in Crunch for representing joins between PCollections.Interfaceorg.apache.crunchApache Crunchjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner

Tuple3A convenience class for three-element Tuples.Classorg.apache.crunchApache Crunchjavadoc
Tuple4A convenience class for four-element Tuples.Classorg.apache.crunchApache Crunchjavadoc
TupleDeepCopierPerforms deep copies (based on underlying PType deep copying) of Tuple-based objects.Classorg.apache.crunch.typesApache Crunchjavadoc
TupleFactoryClassorg.apache.crunch.typesApache Crunchjavadoc
TupleNA Tuple instance for an arbitrary number of values.Classorg.apache.crunchApache Crunchjavadoc
TupleObjectInspectorClassorg.apache.crunch.types.orcApache Crunchjavadoc
TuplesUtilities for working with subclasses of the Tuple interface.Classorg.apache.crunch.utilApache Crunchjavadoc
TupleWritableA serialization format for Tuple.Classorg.apache.crunch.types.writableApache Crunchjavadoc
TupleWritableComparatorClassorg.apache.crunch.lib.sortApache Crunchjavadoc
UnionAllows us to represent the combination of multiple data sources that may contain different types of data as a single type with an index to indicate which of the original sources the current record was from.Classorg.apache.crunchApache Crunchjavadoc
UnionCollectionNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.spark.collectApache Crunchjavadoc
UnionDeepCopierSee Also:Serialized FormConstructor SummaryUnionDeepCopier(PType.Classorg.apache.crunch.typesApache Crunchjavadoc
UnionReadableDataClassorg.apache.crunch.utilApache Crunchjavadoc
UnionTableNested Class SummaryNested classes/interfaces inherited from class org.Classorg.apache.crunch.impl.spark.collectApache Crunchjavadoc
UnionWritableClassorg.apache.crunch.types.writableApache Crunchjavadoc
WordAggregationHBaseYou need to have a HBase instance running.Classorg.apache.crunch.examplesApache Crunchjavadoc
WordCountSee Also:Serialized FormConstructor SummaryWordCount()Classorg.apache.crunch.examplesApache Crunchjavadoc
WritableDeepCopierPerforms deep copies of Writable values.Classorg.apache.crunch.types.writableApache Crunchjavadoc
WritablesDefines static methods that are analogous to the methods defined in WritableTypeFamily for convenient static importing.Classorg.apache.crunch.types.writableApache Crunchjavadoc
WritableSerDeSee Also:Serialized FormConstructor SummaryWritableSerDe(ClassClassorg.apache.crunch.impl.spark.serdeApache Crunchjavadoc
WritableTypeClassorg.apache.crunch.types.writableApache Crunchjavadoc
WritableTypeFamilyThe Writable-based implementation of the PTypeFamily interface.Classorg.apache.crunch.types.writableApache Crunchjavadoc

Subscribe to Java News and Posts. Get latest updates and posts on Java from Buggybread.com
Enter your email address:
Delivered by FeedBurner



comments powered by Disqus