Package | Description |
---|---|
org.apache.reef.io |
APIs for I/O in REEF:
Codec s and
Serializer s. |
org.apache.reef.io.serialization |
Serialization utilities.
|
org.apache.reef.io.storage |
APIs for Storage Service.
|
org.apache.reef.io.storage.local |
Implementations for local filesystem-based storage service.
|
org.apache.reef.io.storage.ram |
Implementations for RAM-based storage service.
|
org.apache.reef.io.storage.util |
Utilities for storage services.
|
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 © 2016 The Apache Software Foundation. All rights reserved.