| Package | Description |
|---|---|
| org.apache.reef.io |
APIs for I/O in REEF:
org.apache.reef.io.Codecs and org.apache.reef.io.Serializers |
| org.apache.reef.io.serialization | |
| org.apache.reef.io.storage | |
| org.apache.reef.io.storage.local | |
| org.apache.reef.io.storage.ram | |
| org.apache.reef.io.storage.util |
| Modifier and Type | Interface and Description |
|---|---|
interface |
Spool<T>
Spool files can be appended to, and can be scanned starting at the beginning.
|
| Modifier and Type | Method and Description |
|---|---|
Accumulable<ObjectType> |
Serializer.create(OutType arg)
Serialize a stream of objects.
|
| Modifier and Type | Class and Description |
|---|---|
class |
FramingOutputStream |
| Modifier and Type | Method and Description |
|---|---|
Accumulable<Tuple<K,V>> |
FramingTupleSerializer.create(OutputStream os) |
| Modifier and Type | Class and Description |
|---|---|
class |
CodecFileAccumulable<T,C extends Codec<T>> |
class |
SerializerFileSpool<T>
A SpoolFile backed by the filesystem.
|
| Modifier and Type | Class and Description |
|---|---|
class |
RamSpool<T>
A SpoolFile implementation that is backed by RAM.
|
class |
SortingRamSpool<T> |
| Modifier and Type | Method and Description |
|---|---|
Accumulable<String> |
StringSerializer.create(OutputStream arg) |
Accumulable<Integer> |
IntegerSerializer.create(OutputStream arg) |
Copyright © 2015 The Apache Software Foundation. All rights reserved.