Package org.apache.reef.io.data.loading.impl

Implementations of Data Loading Service.

See: Description

Class Summary

Class	Description
AbstractEvaluatorToPartitionStrategy	This is an abstract class useful for EvaluatorToPartitionStrategy implementations.
AvroEvaluatorRequestSerializer	Serialize and deserialize EvaluatorRequest objects using Avro.
DistributedDataSetPartition	POJO that represents a distributed data set partition.
DistributedDataSetPartition.Builder	DistributedDataSetPartitions are build using this Builder.
DistributedDataSetPartitionSerializer	Serialize and deserialize DistributedDataSetPartition objects.
DistributedDataSetPartitionSerializer.DistributedDataSetPartitions	Allows to specify a set of distributed data set partitions.
InMemoryInputFormatDataSet<K extends org.apache.hadoop.io.WritableComparable<K>,V extends org.apache.hadoop.io.Writable>
InputFormatDataSet<K extends org.apache.hadoop.io.WritableComparable<K>,V extends org.apache.hadoop.io.Writable>	An implementation of DataSet that reads records using a RecordReader encoded inside an InputSplit.
InputFormatExternalConstructor	A Tang External Constructor to inject the required.
InputFormatLoadingService<K,V>	An implementation of DataLoadingService that uses the Hadoop InputFormat to find partitions of data and request resources.
InputSplitExternalConstructor	A Tang external constructor to inject an InputSplit.
InputSplitExternalConstructor.SerializedInputSplit
JobConfExternalConstructor
JobConfExternalConstructor.InputFormatClass
JobConfExternalConstructor.InputPath
MultiDataCenterEvaluatorToPartitionStrategy	This is an online version which satisfies requests based on the locations the users ask the data to be loaded, for multiple data center network topologies.
NumberedSplit<E>	A tuple of an object of type E and an integer index.
SingleDataCenterEvaluatorToPartitionStrategy	This is an online version which satisfies requests in a greedy way, for single data center network topologies.
WritableSerializer	A serializer class that serializes Writables into String using the below Codec that encodes and decodes Writables By default this stores the class name in the serialized form so that the specific type can be instantiated on de-serialization.

Package org.apache.reef.io.data.loading.impl Description

Implementations of Data Loading Service.