Modifier and Type	Class and Description
private static class	EncoderFactory.DefaultEncoderFactory

Modifier and Type	Field and Description
protected int	binaryBlockSize
protected int	binaryBufferSize
private static final int	DEFAULT_BLOCK_BUFFER_SIZE
private static final int	DEFAULT_BUFFER_SIZE
private static final EncoderFactory	DEFAULT_FACTORY
private static final int	MAX_BLOCK_BUFFER_SIZE
private static final int	MIN_BLOCK_BUFFER_SIZE

Access	Constructor and Description
public	EncoderFactory()

Method Summary

Modifier and Type	Method and Description
public BinaryEncoder	Returns: A BinaryEncoder that uses out as its data output. If reuse is null, this will be a new instance. If reuse is not null, then the returned instance may be a new instance or reuse reconfigured to use out. binaryEncoder(OutputStream The OutputStream to write to. Cannot be null. out, BinaryEncoder The BinaryEncoder to attempt to reuse given the factory configuration. A BinaryEncoder implementation may not be compatible with reuse, causing a new instance to be returned. If null, a new instance is returned. reuse) Creates or reinitializes a `BinaryEncoder` with the OutputStream provided as the destination for written data.
public BinaryEncoder	Returns: A BinaryEncoder that uses out as its data output. If reuse is null, this will be a new instance. If reuse is not null, then the returned instance may be a new instance or reuse reconfigured to use out. blockingBinaryEncoder(OutputStream The OutputStream to initialize to. Cannot be null. out, BinaryEncoder The BinaryEncoder to attempt to reuse given the factory configuration. A BinaryEncoder implementation may not be compatible with reuse, causing a new instance to be returned. If null, a new instance is returned. reuse) Creates or reinitializes a `BinaryEncoder` with the OutputStream provided as the destination for written data.
public EncoderFactory	Returns: This factory, to enable method chaining: EncoderFactory factory = new EncoderFactory().configureBlockSize(8000); configureBlockSize(int The preferred block size for array blocking. Arrays larger than this size will be segmented into blocks according to the Avro spec. Valid values are in the range [64, 102410241024] Values outside this range are set to the nearest value in the range. The encoder will require at least this amount of memory. size) Configures this factory to construct blocking BinaryEncoders with the specified block buffer size.
public EncoderFactory	Returns: This factory, to enable method chaining: EncoderFactory factory = new EncoderFactory().configureBufferSize(4096); configureBufferSize(int The buffer size to configure new instances with. Valid values are in the range [32, 1610241024]. Values outside this range are set to the nearest value in the range. Values less than 256 will limit performance but will consume less memory if the BinaryEncoder is short-lived, values greater than 8*1024 are not likely to improve performance but may be useful for the downstream OutputStream. size) Configures this factory to use the specified buffer size when creating Encoder instances that buffer their output.
public BinaryEncoder	Returns: A BinaryEncoder that uses out as its data output. If reuse is null, this will be a new instance. If reuse is not null, then the returned instance may be a new instance or reuse reconfigured to use out. directBinaryEncoder(OutputStream The OutputStream to initialize to. Cannot be null. out, BinaryEncoder The BinaryEncoder to attempt to reuse given the factory configuration. A BinaryEncoder implementation may not be compatible with reuse, causing a new instance to be returned. If null, a new instance is returned. reuse) Creates or reinitializes a `BinaryEncoder` with the OutputStream provided as the destination for written data.
public static EncoderFactory	get() Returns an immutable static DecoderFactory with default configuration.
public int	Returns: The preferred block size, in bytes. getBlockSize() Returns this factory's configured default block buffer size.
public int	Returns: The preferred buffer size, in bytes. getBufferSize() Returns this factory's configured default buffer size.
public JsonEncoder	Returns: A JsonEncoder configured with out and schema jsonEncoder(Schema The Schema for data written to this JsonEncoder. Cannot be null. schema, OutputStream The OutputStream to write to. Cannot be null. out) Creates a `JsonEncoder` using the OutputStream provided for writing data conforming to the Schema provided.
public JsonEncoder	Returns: A JsonEncoder configured with out, schema and pretty jsonEncoder(Schema The Schema for data written to this JsonEncoder. Cannot be null. schema, OutputStream The OutputStream to write to. Cannot be null. out, boolean Pretty print encoding. pretty) Creates a `JsonEncoder` using the OutputStream provided for writing data conforming to the Schema provided with optional pretty printing.
pack-priv JsonEncoder	Returns: A JsonEncoder configured with gen and schema jsonEncoder(Schema The Schema for data written to this JsonEncoder. Cannot be null. schema, JsonGenerator The JsonGenerator to write with. Cannot be null. gen) Creates a `JsonEncoder` using the `JsonGenerator` provided for output of data conforming to the Schema provided.
public ValidatingEncoder	Returns: A ValidatingEncoder configured to wrap encoder and validate against schema validatingEncoder(Schema The Schema to validate operations against. Cannot be null. schema, Encoder The Encoder to wrap. Cannot be be null. encoder) Creates a `ValidatingEncoder` that wraps the Encoder provided.

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

binaryBlockSize	back to summary
protected int binaryBlockSize

binaryBufferSize	back to summary
protected int binaryBufferSize

DEFAULT_BLOCK_BUFFER_SIZE	back to summary
private static final int DEFAULT_BLOCK_BUFFER_SIZE

DEFAULT_BUFFER_SIZE	back to summary
private static final int DEFAULT_BUFFER_SIZE

DEFAULT_FACTORY	back to summary
private static final EncoderFactory DEFAULT_FACTORY

MAX_BLOCK_BUFFER_SIZE	back to summary
private static final int MAX_BLOCK_BUFFER_SIZE

MIN_BLOCK_BUFFER_SIZE	back to summary
private static final int MIN_BLOCK_BUFFER_SIZE

Constructor Detail

EncoderFactory	back to summary
public EncoderFactory()

Method Detail

binaryEncoder back to summary

binaryEncoder	back to summary
public BinaryEncoder binaryEncoder(OutputStream out, BinaryEncoder reuse) Creates or reinitializes a `BinaryEncoder` with the OutputStream provided as the destination for written data. If reuse is provided, an attempt will be made to reconfigure reuse rather than construct a new instance, but this is not guaranteed, a new instance may be returned. The `BinaryEncoder` implementation returned may buffer its output. Data may not appear on the underlying OutputStream until `Encoder#flush()` is called. The buffer size is configured with `configureBufferSize(int)`. If buffering is not desired, and lower performance is acceptable, use `directBinaryEncoder(OutputStream, BinaryEncoder)` `BinaryEncoder` instances returned by this method are not thread-safe Parameters out:OutputStream The OutputStream to write to. Cannot be null. reuse:BinaryEncoder The BinaryEncoder to attempt to reuse given the factory configuration. A BinaryEncoder implementation may not be compatible with reuse, causing a new instance to be returned. If null, a new instance is returned. Returns:BinaryEncoder A BinaryEncoder that uses out as its data output. If reuse is null, this will be a new instance. If reuse is not null, then the returned instance may be a new instance or reuse reconfigured to use out. See Also `BufferedBinaryEncoder`, `Encoder`

public BinaryEncoder binaryEncoder(OutputStream out, BinaryEncoder reuse)

Creates or reinitializes a BinaryEncoder with the OutputStream provided as the destination for written data. If reuse is provided, an attempt will be made to reconfigure reuse rather than construct a new instance, but this is not guaranteed, a new instance may be returned.

The BinaryEncoder implementation returned may buffer its output. Data may not appear on the underlying OutputStream until Encoder#flush() is called. The buffer size is configured with configureBufferSize(int).

If buffering is not desired, and lower performance is acceptable, use directBinaryEncoder(OutputStream, BinaryEncoder)

BinaryEncoder instances returned by this method are not thread-safe

Parameters

out:OutputStream: The OutputStream to write to. Cannot be null.
reuse:BinaryEncoder: The BinaryEncoder to attempt to reuse given the factory configuration. A BinaryEncoder implementation may not be compatible with reuse, causing a new instance to be returned. If null, a new instance is returned.

Returns:BinaryEncoder

A BinaryEncoder that uses out as its data output. If reuse is null, this will be a new instance. If reuse is not null, then the returned instance may be a new instance or reuse reconfigured to use out.

See Also

BufferedBinaryEncoder, Encoder

blockingBinaryEncoder back to summary

blockingBinaryEncoder	back to summary
public BinaryEncoder blockingBinaryEncoder(OutputStream out, BinaryEncoder reuse) Creates or reinitializes a `BinaryEncoder` with the OutputStream provided as the destination for written data. If reuse is provided, an attempt will be made to reconfigure reuse rather than construct a new instance, but this is not guaranteed, a new instance may be returned. The `BinaryEncoder` implementation returned buffers its output, calling `Encoder#flush()` is required for output to appear on the underlying OutputStream. The returned BinaryEncoder implements the Avro binary encoding using blocks delimited with byte sizes for Arrays and Maps. This allows for some decoders to skip over large Arrays or Maps without decoding the contents, but adds some overhead. The default block size is configured with `configureBlockSize(int)` `BinaryEncoder` instances returned by this method are not thread-safe. Parameters out:OutputStream The OutputStream to initialize to. Cannot be null. reuse:BinaryEncoder The BinaryEncoder to attempt to reuse given the factory configuration. A BinaryEncoder implementation may not be compatible with reuse, causing a new instance to be returned. If null, a new instance is returned. Returns:BinaryEncoder A BinaryEncoder that uses out as its data output. If reuse is null, this will be a new instance. If reuse is not null, then the returned instance may be a new instance or reuse reconfigured to use out. See Also `BlockingBinaryEncoder`, `Encoder`

public BinaryEncoder blockingBinaryEncoder(OutputStream out, BinaryEncoder reuse)

The BinaryEncoder implementation returned buffers its output, calling Encoder#flush() is required for output to appear on the underlying OutputStream.

The returned BinaryEncoder implements the Avro binary encoding using blocks delimited with byte sizes for Arrays and Maps. This allows for some decoders to skip over large Arrays or Maps without decoding the contents, but adds some overhead. The default block size is configured with configureBlockSize(int)

BinaryEncoder instances returned by this method are not thread-safe.

Parameters

out:OutputStream: The OutputStream to initialize to. Cannot be null.
reuse:BinaryEncoder: The BinaryEncoder to attempt to reuse given the factory configuration. A BinaryEncoder implementation may not be compatible with reuse, causing a new instance to be returned. If null, a new instance is returned.

Returns:BinaryEncoder

See Also

BlockingBinaryEncoder, Encoder

configureBlockSize back to summary

configureBlockSize	back to summary
public EncoderFactory configureBlockSize(int size) Configures this factory to construct blocking BinaryEncoders with the specified block buffer size. The default buffer size is 64 * 1024 bytes. Parameters size:int The preferred block size for array blocking. Arrays larger than this size will be segmented into blocks according to the Avro spec. Valid values are in the range [64, 102410241024] Values outside this range are set to the nearest value in the range. The encoder will require at least this amount of memory. Returns:EncoderFactory This factory, to enable method chaining: EncoderFactory factory = new EncoderFactory().configureBlockSize(8000); See Also `blockingBinaryEncoder(OutputStream, BinaryEncoder)`

public EncoderFactory configureBlockSize(int size)

Configures this factory to construct blocking BinaryEncoders with the specified block buffer size. The default buffer size is 64 * 1024 bytes.

Parameters

size:int: The preferred block size for array blocking. Arrays larger than this size will be segmented into blocks according to the Avro spec. Valid values are in the range [64, 1024*1024*1024] Values outside this range are set to the nearest value in the range. The encoder will require at least this amount of memory.

Returns:EncoderFactory

This factory, to enable method chaining:

        EncoderFactory factory = new EncoderFactory().configureBlockSize(8000);

configureBufferSize back to summary

configureBufferSize	back to summary
public EncoderFactory configureBufferSize(int size) Configures this factory to use the specified buffer size when creating Encoder instances that buffer their output. The default buffer size is 2048 bytes. Parameters size:int The buffer size to configure new instances with. Valid values are in the range [32, 1610241024]. Values outside this range are set to the nearest value in the range. Values less than 256 will limit performance but will consume less memory if the BinaryEncoder is short-lived, values greater than 8*1024 are not likely to improve performance but may be useful for the downstream OutputStream. Returns:EncoderFactory This factory, to enable method chaining: EncoderFactory factory = new EncoderFactory().configureBufferSize(4096); See Also `binaryEncoder(OutputStream, BinaryEncoder)`

public EncoderFactory configureBufferSize(int size)

Configures this factory to use the specified buffer size when creating Encoder instances that buffer their output. The default buffer size is 2048 bytes.

Parameters

size:int: The buffer size to configure new instances with. Valid values are in the range [32, 16*1024*1024]. Values outside this range are set to the nearest value in the range. Values less than 256 will limit performance but will consume less memory if the BinaryEncoder is short-lived, values greater than 8*1024 are not likely to improve performance but may be useful for the downstream OutputStream.

Returns:EncoderFactory

This factory, to enable method chaining:

        EncoderFactory factory = new EncoderFactory().configureBufferSize(4096);

directBinaryEncoder back to summary

directBinaryEncoder	back to summary
public BinaryEncoder directBinaryEncoder(OutputStream out, BinaryEncoder reuse) Creates or reinitializes a `BinaryEncoder` with the OutputStream provided as the destination for written data. If reuse is provided, an attempt will be made to reconfigure reuse rather than construct a new instance, but this is not guaranteed, a new instance may be returned. The `BinaryEncoder` implementation returned does not buffer its output, calling `Encoder#flush()` will simply cause the wrapped OutputStream to be flushed. Performance of unbuffered writes can be significantly slower than buffered writes. `binaryEncoder(OutputStream, BinaryEncoder)` returns BinaryEncoder instances that are tuned for performance but may buffer output. The unbuffered, 'direct' encoder may be desired when buffering semantics are problematic, or if the lifetime of the encoder is so short that the buffer would not be useful. `BinaryEncoder` instances returned by this method are not thread-safe. Parameters out:OutputStream The OutputStream to initialize to. Cannot be null. reuse:BinaryEncoder The BinaryEncoder to attempt to reuse given the factory configuration. A BinaryEncoder implementation may not be compatible with reuse, causing a new instance to be returned. If null, a new instance is returned. Returns:BinaryEncoder A BinaryEncoder that uses out as its data output. If reuse is null, this will be a new instance. If reuse is not null, then the returned instance may be a new instance or reuse reconfigured to use out. See Also `DirectBinaryEncoder`, `Encoder`

public BinaryEncoder directBinaryEncoder(OutputStream out, BinaryEncoder reuse)

The BinaryEncoder implementation returned does not buffer its output, calling Encoder#flush() will simply cause the wrapped OutputStream to be flushed.

Performance of unbuffered writes can be significantly slower than buffered writes. binaryEncoder(OutputStream, BinaryEncoder) returns BinaryEncoder instances that are tuned for performance but may buffer output. The unbuffered, 'direct' encoder may be desired when buffering semantics are problematic, or if the lifetime of the encoder is so short that the buffer would not be useful.

BinaryEncoder instances returned by this method are not thread-safe.

Parameters

out:OutputStream: The OutputStream to initialize to. Cannot be null.
reuse:BinaryEncoder: The BinaryEncoder to attempt to reuse given the factory configuration. A BinaryEncoder implementation may not be compatible with reuse, causing a new instance to be returned. If null, a new instance is returned.

Returns:BinaryEncoder

See Also

DirectBinaryEncoder, Encoder

get	back to summary
public static EncoderFactory get() Returns an immutable static DecoderFactory with default configuration. All configuration methods throw AvroRuntimeExceptions if called.

getBlockSize back to summary

getBlockSize	back to summary
public int getBlockSize() Returns this factory's configured default block buffer size. `BinaryEncoder` instances created with #blockingBinaryEncoder(OutputStream, BinaryEncoder) will have block buffers of this size. Returns:int The preferred block size, in bytes. See Also `configureBlockSize(int)`, `blockingBinaryEncoder(OutputStream, BinaryEncoder)`

public int getBlockSize()

Returns this factory's configured default block buffer size. BinaryEncoder instances created with #blockingBinaryEncoder(OutputStream, BinaryEncoder) will have block buffers of this size.

Returns:int: The preferred block size, in bytes.
See Also: configureBlockSize(int), blockingBinaryEncoder(OutputStream, BinaryEncoder)

getBufferSize back to summary

getBufferSize	back to summary
public int getBufferSize() Returns this factory's configured default buffer size. Used when creating Encoder instances that buffer writes. Returns:int The preferred buffer size, in bytes. See Also `configureBufferSize(int)`, `binaryEncoder(OutputStream, BinaryEncoder)`

public int getBufferSize()

Returns this factory's configured default buffer size. Used when creating Encoder instances that buffer writes.

Returns:int: The preferred buffer size, in bytes.
See Also: configureBufferSize(int), binaryEncoder(OutputStream, BinaryEncoder)

jsonEncoder back to summary

jsonEncoder	back to summary
public JsonEncoder jsonEncoder(Schema schema, OutputStream out) throws IOException Creates a `JsonEncoder` using the OutputStream provided for writing data conforming to the Schema provided. `JsonEncoder` buffers its output. Data may not appear on the underlying OutputStream until `Encoder#flush()` is called. `JsonEncoder` is not thread-safe. Parameters schema:Schema The Schema for data written to this JsonEncoder. Cannot be null. out:OutputStream The OutputStream to write to. Cannot be null. Returns:JsonEncoder A JsonEncoder configured with out and schema

public JsonEncoder jsonEncoder(Schema schema, OutputStream out) throws IOException

Creates a JsonEncoder using the OutputStream provided for writing data conforming to the Schema provided.

JsonEncoder buffers its output. Data may not appear on the underlying OutputStream until Encoder#flush() is called.

JsonEncoder is not thread-safe.

Parameters

schema:Schema: The Schema for data written to this JsonEncoder. Cannot be null.
out:OutputStream: The OutputStream to write to. Cannot be null.

Returns:JsonEncoder

A JsonEncoder configured with out and schema

jsonEncoder back to summary

jsonEncoder	back to summary
public JsonEncoder jsonEncoder(Schema schema, OutputStream out, boolean pretty) throws IOException Creates a `JsonEncoder` using the OutputStream provided for writing data conforming to the Schema provided with optional pretty printing. `JsonEncoder` buffers its output. Data may not appear on the underlying OutputStream until `Encoder#flush()` is called. `JsonEncoder` is not thread-safe. Parameters schema:Schema The Schema for data written to this JsonEncoder. Cannot be null. out:OutputStream The OutputStream to write to. Cannot be null. pretty:boolean Pretty print encoding. Returns:JsonEncoder A JsonEncoder configured with out, schema and pretty

public JsonEncoder jsonEncoder(Schema schema, OutputStream out, boolean pretty) throws IOException

Creates a JsonEncoder using the OutputStream provided for writing data conforming to the Schema provided with optional pretty printing.

JsonEncoder buffers its output. Data may not appear on the underlying OutputStream until Encoder#flush() is called.

JsonEncoder is not thread-safe.

Parameters

schema:Schema: The Schema for data written to this JsonEncoder. Cannot be null.
out:OutputStream: The OutputStream to write to. Cannot be null.
pretty:boolean: Pretty print encoding.

Returns:JsonEncoder

A JsonEncoder configured with out, schema and pretty

jsonEncoder back to summary

jsonEncoder	back to summary
pack-priv JsonEncoder jsonEncoder(Schema schema, JsonGenerator gen) throws IOException Creates a `JsonEncoder` using the `JsonGenerator` provided for output of data conforming to the Schema provided. `JsonEncoder` buffers its output. Data may not appear on the underlying output until `Encoder#flush()` is called. `JsonEncoder` is not thread-safe. Parameters schema:Schema The Schema for data written to this JsonEncoder. Cannot be null. gen:JsonGenerator The JsonGenerator to write with. Cannot be null. Returns:JsonEncoder A JsonEncoder configured with gen and schema

pack-priv JsonEncoder jsonEncoder(Schema schema, JsonGenerator gen) throws IOException

Creates a JsonEncoder using the JsonGenerator provided for output of data conforming to the Schema provided.

JsonEncoder buffers its output. Data may not appear on the underlying output until Encoder#flush() is called.

JsonEncoder is not thread-safe.

Parameters

schema:Schema: The Schema for data written to this JsonEncoder. Cannot be null.
gen:JsonGenerator: The JsonGenerator to write with. Cannot be null.

Returns:JsonEncoder

A JsonEncoder configured with gen and schema

validatingEncoder back to summary

validatingEncoder	back to summary
public ValidatingEncoder validatingEncoder(Schema schema, Encoder encoder) throws IOException Creates a `ValidatingEncoder` that wraps the Encoder provided. This ValidatingEncoder will ensure that operations against it conform to the schema provided. Many `Encoder`s buffer their output. Data may not appear on the underlying output until `Encoder#flush()` is called. `ValidatingEncoder` is not thread-safe. Parameters schema:Schema The Schema to validate operations against. Cannot be null. encoder:Encoder The Encoder to wrap. Cannot be be null. Returns:ValidatingEncoder A ValidatingEncoder configured to wrap encoder and validate against schema

public ValidatingEncoder validatingEncoder(Schema schema, Encoder encoder) throws IOException

Creates a ValidatingEncoder that wraps the Encoder provided. This ValidatingEncoder will ensure that operations against it conform to the schema provided.

Many Encoders buffer their output. Data may not appear on the underlying output until Encoder#flush() is called.

ValidatingEncoder is not thread-safe.

Parameters

schema:Schema: The Schema to validate operations against. Cannot be null.
encoder:Encoder: The Encoder to wrap. Cannot be be null.

Returns:ValidatingEncoder

A ValidatingEncoder configured to wrap encoder and validate against schema

org.apache.avro.io back to summary

private Class EncoderFactory.DefaultEncoderFactory

Class Inheritance

extends EncoderFactory

java.lang.Object
org.apache.avro.io.EncoderFactory
org.apache.avro.io.EncoderFactory.DefaultEncoderFactory

Field Summary

Inherited from org.apache.avro.io.EncoderFactory:: binaryBlockSize binaryBufferSize

Constructor Summary

Access	Constructor and Description
private	DefaultEncoderFactory()

Method Summary

Modifier and Type	Method and Description
public EncoderFactory	configureBlockSize(int The preferred block size for array blocking. Arrays larger than this size will be segmented into blocks according to the Avro spec. Valid values are in the range [64, 102410241024] Values outside this range are set to the nearest value in the range. The encoder will require at least this amount of memory. size) Overrides org.apache.avro.io.EncoderFactory.configureBlockSize. Configures this factory to construct blocking BinaryEncoders with the specified block buffer size.
public EncoderFactory	configureBufferSize(int The buffer size to configure new instances with. Valid values are in the range [32, 1610241024]. Values outside this range are set to the nearest value in the range. Values less than 256 will limit performance but will consume less memory if the BinaryEncoder is short-lived, values greater than 8*1024 are not likely to improve performance but may be useful for the downstream OutputStream. size) Overrides org.apache.avro.io.EncoderFactory.configureBufferSize. Configures this factory to use the specified buffer size when creating Encoder instances that buffer their output.

Modifier and Type

Method and Description

public EncoderFactory

configureBlockSize(int

The preferred block size for array blocking. Arrays larger than this size will be segmented into blocks according to the Avro spec. Valid values are in the range [64, 1024*1024*1024] Values outside this range are set to the nearest value in the range. The encoder will require at least this amount of memory.

size)

Overrides org.apache.avro.io.EncoderFactory.configureBlockSize.

Configures this factory to construct blocking BinaryEncoders with the specified block buffer size.

public EncoderFactory

configureBufferSize(int

The buffer size to configure new instances with. Valid values are in the range [32, 16*1024*1024]. Values outside this range are set to the nearest value in the range. Values less than 256 will limit performance but will consume less memory if the BinaryEncoder is short-lived, values greater than 8*1024 are not likely to improve performance but may be useful for the downstream OutputStream.

size)

Overrides org.apache.avro.io.EncoderFactory.configureBufferSize.

Configures this factory to use the specified buffer size when creating Encoder instances that buffer their output.

Inherited from org.apache.avro.io.EncoderFactory:: binaryEncoder blockingBinaryEncoder directBinaryEncoder get getBlockSize getBufferSize jsonEncoder jsonEncoder jsonEncoder validatingEncoder

Constructor Detail

DefaultEncoderFactory	back to summary
private DefaultEncoderFactory()

Method Detail

configureBlockSize	back to summary
public EncoderFactory configureBlockSize(int size) Overrides org.apache.avro.io.EncoderFactory.configureBlockSize. Doc from org.apache.avro.io.EncoderFactory.configureBlockSize. Configures this factory to construct blocking BinaryEncoders with the specified block buffer size. The default buffer size is 64 * 1024 bytes. Parameters size:int The preferred block size for array blocking. Arrays larger than this size will be segmented into blocks according to the Avro spec. Valid values are in the range [64, 102410241024] Values outside this range are set to the nearest value in the range. The encoder will require at least this amount of memory. Returns:EncoderFactory This factory, to enable method chaining: EncoderFactory factory = new EncoderFactory().configureBlockSize(8000); Annotations @Override

configureBlockSize

back to summary

public EncoderFactory configureBlockSize(int size)

Overrides org.apache.avro.io.EncoderFactory.configureBlockSize.

Doc from org.apache.avro.io.EncoderFactory.configureBlockSize.

Configures this factory to construct blocking BinaryEncoders with the specified block buffer size. The default buffer size is 64 * 1024 bytes.

Parameters

size:int: The preferred block size for array blocking. Arrays larger than this size will be segmented into blocks according to the Avro spec. Valid values are in the range [64, 1024*1024*1024] Values outside this range are set to the nearest value in the range. The encoder will require at least this amount of memory.

Returns:EncoderFactory

This factory, to enable method chaining:

        EncoderFactory factory = new EncoderFactory().configureBlockSize(8000);

Annotations

@Override

configureBufferSize	back to summary
public EncoderFactory configureBufferSize(int size) Overrides org.apache.avro.io.EncoderFactory.configureBufferSize. Doc from org.apache.avro.io.EncoderFactory.configureBufferSize. Configures this factory to use the specified buffer size when creating Encoder instances that buffer their output. The default buffer size is 2048 bytes. Parameters size:int The buffer size to configure new instances with. Valid values are in the range [32, 1610241024]. Values outside this range are set to the nearest value in the range. Values less than 256 will limit performance but will consume less memory if the BinaryEncoder is short-lived, values greater than 8*1024 are not likely to improve performance but may be useful for the downstream OutputStream. Returns:EncoderFactory This factory, to enable method chaining: EncoderFactory factory = new EncoderFactory().configureBufferSize(4096); Annotations @Override

configureBufferSize

back to summary

public EncoderFactory configureBufferSize(int size)

Overrides org.apache.avro.io.EncoderFactory.configureBufferSize.

Doc from org.apache.avro.io.EncoderFactory.configureBufferSize.

Configures this factory to use the specified buffer size when creating Encoder instances that buffer their output. The default buffer size is 2048 bytes.

Parameters

size:int: The buffer size to configure new instances with. Valid values are in the range [32, 16*1024*1024]. Values outside this range are set to the nearest value in the range. Values less than 256 will limit performance but will consume less memory if the BinaryEncoder is short-lived, values greater than 8*1024 are not likely to improve performance but may be useful for the downstream OutputStream.

Returns:EncoderFactory

This factory, to enable method chaining:

        EncoderFactory factory = new EncoderFactory().configureBufferSize(4096);

Annotations

@Override

public Class EncoderFactory

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class EncoderFactory.DefaultEncoderFactory

Field Summary

Constructor Summary

Method Summary

Constructor Detail

Method Detail