Package org.apache.juneau.marshall.parquet

Class ParquetSerializerSession

java.lang.Object

org.apache.juneau.marshall.ContextSession

org.apache.juneau.marshall.MarshallingSession

org.apache.juneau.marshall.MarshallingTraverseSession

org.apache.juneau.marshall.serializer.SerializerSession

org.apache.juneau.marshall.serializer.OutputStreamSerializerSession

org.apache.juneau.marshall.parquet.ParquetSerializerSession

All Implemented Interfaces:

BeanSession, ConverterSession, ArrayRecordWritable, RecordWritable

public class ParquetSerializerSession
extends OutputStreamSerializerSession
implements RecordWritable, ArrayRecordWritable

Session for ParquetSerializer.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ParquetSerializerSession.Builder	Builder for serializer sessions.
static class	ParquetSerializerSession.ValueHolder	Simple bean for wrapping non-bean values (Map is not convertible to BeanMap).

Nested classes/interfaces inherited from class org.apache.juneau.marshall.serializer.OutputStreamSerializerSession

OutputStreamSerializerSession.DefaultBuilder

Field Summary

Fields inherited from class org.apache.juneau.marshall.MarshallingTraverseSession

indent

Fields inherited from class org.apache.juneau.marshall.MarshallingSession

NAME_PROPERTY_NAME

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ParquetSerializerSession(ParquetSerializerSession.Builder builder)

Method Summary

Modifier and Type	Method	Description
static ParquetSerializerSession.Builder	create(ParquetSerializer ctx)	Creates a new session builder.
protected void	doWrite(SerializerPipe pipe, Object o)	Serializes a POJO to the specified pipe.
boolean	hasNativeBytes()	Returns whether this binary serializer has a native byte-array wire type.
boolean	isArrayRecordStreaming()	The Parquet array-record writer is buffered/RecordAdapter-backed, not O(1) streaming.
boolean	isRecordStreaming()	The Parquet record writer is buffered/RecordAdapter-backed, not O(1) streaming.
RecordWriter	writeArrayRecords(Object output)	Buffered array-element RecordWriter for Parquet, bound to this live session.
RecordWriter	writeRecords(Object output)	Opens a whole-value push generator targeting Parquet output, bound to this live session.

Methods inherited from class org.apache.juneau.marshall.serializer.OutputStreamSerializerSession

create, createPipe, getBinaryFormat, isWriterSerializer, write, writeToString

Methods inherited from class org.apache.juneau.marshall.serializer.SerializerSession

addVarBean, canIgnoreValue, canIgnoreValue, create, createBeanTypeNameProperty, createDefaultVarResolverSession, forEachEntry, forEachEntry, forEachStreamableEntry, generalize, getBeanTypeName, getCalendarFormat, getDateFormat, getDurationFormat, getExpectedRootType, getJavaMethod, getListener, getListener, getLocaleFormat, getPeriodFormat, getResponseHeaders, getSchema, getTemporalFormat, getTimeZoneFormat, getUriContext, getUriRelativity, getUriResolution, getUriResolver, getVarResolver, handleThrown, isAddBeanTypes, isAddRootType, isKeepNullProperties, isNonDefault, isSortCollections, isSortMaps, isTrimEmptyCollections, isTrimEmptyMaps, isTrimStrings, onBeanGetterException, onError, properties, push2, relativizeUri, resolve, resolveUri, sort, sort, sort, swap, toList, toListFromStreamable, toString, trim, unwrapSupplier, write, writeCalendar, writeDate, writeDuration, writePeriod, writeTemporal

Methods inherited from class org.apache.juneau.marshall.MarshallingTraverseSession

getInitialDepth, getLastLocation, getMaxDepth, getOptionalType, getOptionalValue, getStack, isDetectRecursions, isIgnoreRecursions, isOptional, isRoot, pop, push, setCurrentClass, setCurrentProperty, willExceedDepth, willRecurse

Methods inherited from class org.apache.juneau.marshall.MarshallingSession

addWarning, convertToMemberType, convertToMemberType, convertToMemberType, convertToType, convertToType, convertToType, convertToType, create, get, getActiveView, getAnnotationProvider, getArgsClassMeta, getBeanClassVisibility, getBeanConstructorVisibility, getBeanDictionary, getBeanFieldVisibility, getBeanMeta, getBeanMethodVisibility, getBeanRegistry, getBeanTypePropertyName, getBeanTypePropertyName, getClassLoader, getClassMeta, getClassMeta, getClassMetaForObject, getClassMetaForObject, getLocale, getMarshallingContext, getMediaType, getNotBeanClasses, getNotBeanPackagesNames, getPropertyNamer, getSwaps, getTimeZone, getTimeZoneId, isBean, isBean, isBeanMapPutReturnsOldValue, isBeansRequireDefaultConstructor, isBeansRequireSerializable, isBeansRequireSettersForGetters, isBeansRequireSomeProperties, isFindFluentSetters, isIgnoreInvocationExceptionsOnGetters, isIgnoreInvocationExceptionsOnSetters, isIgnoreMissingSetters, isIgnoreUnknownBeanProperties, isIgnoreUnknownNullBeanProperties, isPropertyInActiveView, isRecordComponentOrder, isUnsortedProperties, isUseInterfaceProxies, isUseJavaBeanIntrospector, isValidateSchema, newBean, newBean, newBeanMap, newBeanMap, newGenericList, newGenericMap, newGenericMap, object, parseToList, parseToMap, string, toArray, toBeanMap, toBeanMap, toBeanMap

Methods inherited from class org.apache.juneau.marshall.ContextSession

checkForWarnings, getContext, getSessionProperties, getWarnings, isDebug, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.juneau.marshall.stream.ArrayRecordWritable

writeArrayRecords

Methods inherited from interface org.apache.juneau.commons.conversion.ConverterSession

get

Constructor Details

ParquetSerializerSession

protected ParquetSerializerSession(ParquetSerializerSession.Builder builder)

Method Details

create

public static ParquetSerializerSession.Builder create(ParquetSerializer ctx)

Creates a new session builder.

Parameters:

ctx - The serializer context.
Cannot be null.

Returns:

A new builder.

writeRecords

public RecordWriter writeRecords(Object output)
                          throws IOException

Opens a whole-value push generator targeting Parquet output, bound to this live session. write(Object) delegates to SerializerSession.write(Object, Object).

Specified by:

writeRecords in interface RecordWritable

Parameters:

output - The output.

Returns:

A new RecordWriter.

Throws:

IOException - If a problem occurred opening the underlying output.

writeArrayRecords

public RecordWriter writeArrayRecords(Object output)
                               throws IOException

Buffered array-element RecordWriter for Parquet, bound to this live session. Buffers each write(...) and emits the whole list on close().

Specified by:

writeArrayRecords in interface ArrayRecordWritable

Parameters:

output - The output.

Returns:

A new RecordWriter.

Throws:

IOException - If a problem occurred opening the underlying output.

isRecordStreaming

public boolean isRecordStreaming()

The Parquet record writer is buffered/RecordAdapter-backed, not O(1) streaming.

Specified by:

isRecordStreaming in interface RecordWritable

Returns:

Always false.

isArrayRecordStreaming

public boolean isArrayRecordStreaming()

The Parquet array-record writer is buffered/RecordAdapter-backed, not O(1) streaming.

Specified by:

isArrayRecordStreaming in interface ArrayRecordWritable

Returns:

Always false.

hasNativeBytes

public boolean hasNativeBytes()

Description copied from class: OutputStreamSerializerSession

Returns whether this binary serializer has a native byte-array wire type.

When true, byte[] payloads bypass the configured BinaryFormat dispatch in BinarySwap and the variant binary swap installed by MarshalledPropertyPostProcessor, and are written as raw bytes through the serializer's native binary opcode (e.g. MsgPack bin family, CBOR byte-string major type 2, BSON binary subtype 0x05). When false, the configured BinaryFormat fires for non-NOT_SET formats and produces a text wire form (HEX / BASE64 / etc.) that the serializer emits as a string in its native string column / literal type — used by serializers whose wire format has no native byte-array primitive (Parquet column writer, binary RDF formats).

Defaults to true. Subclasses without a native byte-array wire type (e.g. ParquetSerializerSession and the binary RDF sessions) override and return false.

Overrides:

hasNativeBytes in class OutputStreamSerializerSession

Returns:

true if this serializer has a native byte-array wire type.

doWrite

protected void doWrite(SerializerPipe pipe,
 Object o)
                throws IOException,
SerializeException

Description copied from class: SerializerSession

Serializes a POJO to the specified pipe.

This method should NOT close the context object.

The default implementation of this method simply calls Serializer.doWrite(SerializerSession,SerializerPipe,Object).

Overrides:

doWrite in class SerializerSession

Parameters:

pipe - Where to send the output from the serializer.

o - The object to serialize.

Throws:

IOException - Thrown by underlying stream.

SerializeException - Problem occurred trying to serialize object.