Package org.apache.juneau.marshall.stream

Class RecordAdapter

java.lang.Object

org.apache.juneau.marshall.stream.RecordAdapter

public final class RecordAdapter
extends Object

Static factories that produce buffered RecordReader / RecordWriter instances for formats whose token-stream surface is whole-value-only (no native TokenReader / TokenWriter).

The cursors are created from the live session (ParserSession / SerializerSession), so they honor the same per-invocation configuration (swaps, bean filters, locale/timezone, schema) as parse(...)/serialize(...).

Reduces per-format override boilerplate to a one-liner on the session class:

@Override public RecordReader readRecords(Object input) throws IOException { return RecordAdapter.reader(this, input); } @Override public RecordWriter writeRecords(Object output) throws IOException { return RecordAdapter.writer(this, output); }

All four cursors report isStreaming() == false (they buffer) and obey one resource-ownership rule: close() closes the input/output it was handed when it is Closeable. Multi-rooted formats that need different semantics (jsonl, csv, sse) implement their own cursor.

Method Summary

Modifier and Type	Method	Description
static RecordReader	arrayReader(ParserSession session, Object input)	Creates an array-element RecordReader backed by a buffered list parse.
static RecordWriter	arrayWriter(SerializerSession session, Object output)	Creates an array-element RecordWriter that buffers each write(...) call and emits the whole list on RecordWriter.close().
static RecordReader	reader(ParserSession session, Object input)	Creates a single-shot RecordReader that delegates read(...) calls to the session's read(...) entry point.
static RecordWriter	writer(SerializerSession session, Object output)	Creates a single-shot RecordWriter that delegates write(Object) calls to the session's write(...) entry point.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

reader

public static RecordReader reader(ParserSession session,
 Object input)

Creates a single-shot RecordReader that delegates read(...) calls to the session's read(...) entry point.

Parameters:

session - The format's live parser session. Must not be null.

input - The input to bind on the first read(...) call.

Returns:

A new RecordReader.

arrayReader

public static RecordReader arrayReader(ParserSession session,
 Object input)
                                throws IOException

Creates an array-element RecordReader backed by a buffered list parse.

Equivalent to calling session.read(input, List.class, Object.class) once and iterating the result. This is correct but NOT streaming — the whole array is materialized. Format-specific implementations may override ArrayRecordReadable.readArrayRecords(Object) directly for actual streaming.

Parameters:

session - The format's live parser session. Must not be null.

input - The input to bind on the first read.

Returns:

A new RecordReader that yields one record per array element.

Throws:

IOException - If a problem occurred reading the input.

arrayWriter

public static RecordWriter arrayWriter(SerializerSession session,
 Object output)

Creates an array-element RecordWriter that buffers each write(...) call and emits the whole list on RecordWriter.close().

This is correct but NOT streaming — the writes are accumulated in memory. Format-specific implementations may override ArrayRecordWritable.writeArrayRecords(Object) directly for actual streaming.

Parameters:

session - The format's live serializer session. Must not be null.

output - The output to write to.

Returns:

A new RecordWriter that accepts N elements and emits an N-element array.

writer

public static RecordWriter writer(SerializerSession session,
 Object output)

Creates a single-shot RecordWriter that delegates write(Object) calls to the session's write(...) entry point.

Parameters:

session - The format's live serializer session. Must not be null.

output - The output to write to.

Returns:

A new RecordWriter.