public abstract class Page extends Object
It serializes records to byte[]
(in Buffer
) for the following purposes.
(C) and (D) may not be so meaningful as of Embulk v0.7+ (or since earlier) as recent Embulk unlikely
allocates so many Page
s at the same time. Recent Embulk is streaming-driven instead of
multithreaded queue-based.
Page
is NOT for inter-process communication. For multi-process execution such as the deprecated
MapReduce Executor, the executor plugin takes responsibility about interoperable serialization.
Constructor and Description |
---|
Page() |
Modifier and Type | Method and Description |
---|---|
static Page |
allocate(int length)
Deprecated.
It is to be removed, implemented only for compatibility. Plugins should no longer call it directly.
|
abstract Buffer |
buffer() |
abstract String |
getStringReference(int index) |
abstract List<String> |
getStringReferences() |
abstract org.msgpack.value.ImmutableValue |
getValueReference(int index) |
abstract List<org.msgpack.value.ImmutableValue> |
getValueReferences() |
abstract void |
release() |
abstract Page |
setStringReferences(List<String> values) |
abstract Page |
setValueReferences(List<org.msgpack.value.ImmutableValue> values) |
static Page |
wrap(Buffer buffer)
Deprecated.
It is to be removed, implemented only for compatibility. Plugins should no longer call it directly.
|
public abstract Page setValueReferences(List<org.msgpack.value.ImmutableValue> values)
public abstract List<org.msgpack.value.ImmutableValue> getValueReferences()
public abstract String getStringReference(int index)
public abstract org.msgpack.value.ImmutableValue getValueReference(int index)
public abstract void release()
public abstract Buffer buffer()
@Deprecated public static Page allocate(int length)
Page
instance.@Deprecated public static Page wrap(Buffer buffer)