Modifier and Type	Class and Description
private static class	BinaryData.Decoders
private static class	BinaryData.HashData

Modifier and Type	Field and Description
private static final ThreadLocal<BinaryData.Decoders>	DECODERS
private static final ThreadLocal<BinaryData.HashData>	HASH_DATA

Access	Constructor and Description
private	BinaryData()

Method Summary

Modifier and Type	Method and Description
public static int	compare(byte[] b1, int s1, byte[] b2, int s2, Schema schema) Compare binary encoded data.
public static int	compare(byte[] b1, int s1, int l1, byte[] b2, int s2, int l2, Schema schema) Compare binary encoded data.
private static int	compare(BinaryData.Decoders d, Schema schema) If equal, return the number of bytes consumed.
public static int	compareBytes(byte[] b1, int s1, int l1, byte[] b2, int s2, int l2) Lexicographically compare bytes.
public static int	Returns: The number of bytes written to the buffer, 1. encodeBoolean(boolean b, byte[] buf, int pos) Encode a boolean to the byte array at the given position.
public static int	Returns: Returns the number of bytes written to the buffer, 8. encodeDouble(double d, byte[] buf, int pos) Encode a double to the byte array at the given position.
public static int	Returns: Returns the number of bytes written to the buffer, 4. encodeFloat(float f, byte[] buf, int pos) Encode a float to the byte array at the given position.
public static int	Returns: The number of bytes written to the buffer, between 1 and 5. encodeInt(int n, byte[] buf, int pos) Encode an integer to the byte array at the given position.
public static int	Returns: The number of bytes written to the buffer, between 1 and 10. encodeLong(long n, byte[] buf, int pos) Encode a long to the byte array at the given position.
private static int	hashBytes(int init, BinaryData.HashData data, int len, boolean rev)
public static int	hashCode(byte[] bytes, int start, int length, Schema schema) Hash binary encoded data.
private static int	hashCode(BinaryData.HashData data, Schema schema)
public static int	skipLong(final byte[] bytes, int start) Skip a binary-encoded long, returning the position after it.

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

Field Detail

DECODERS	back to summary
private static final ThreadLocal<BinaryData.Decoders> DECODERS

HASH_DATA	back to summary
private static final ThreadLocal<BinaryData.HashData> HASH_DATA

Constructor Detail

BinaryData	back to summary
private BinaryData()

Method Detail

compare	back to summary
public static int compare(byte[] b1, int s1, byte[] b2, int s2, Schema schema) Compare binary encoded data. If equal, return zero. If greater-than, return 1, if less than return -1. Order is consistent with that of `org.apache.avro.generic.GenericData#compare(Object, Object, Schema)`.

compare	back to summary
public static int compare(byte[] b1, int s1, int l1, byte[] b2, int s2, int l2, Schema schema) Compare binary encoded data. If equal, return zero. If greater-than, return 1, if less than return -1. Order is consistent with that of `org.apache.avro.generic.GenericData#compare(Object, Object, Schema)`.

compare	back to summary
private static int compare(BinaryData.Decoders d, Schema schema) throws IOException If equal, return the number of bytes consumed. If greater than, return GT, if less than, return LT.

compareBytes	back to summary
public static int compareBytes(byte[] b1, int s1, int l1, byte[] b2, int s2, int l2) Lexicographically compare bytes. If equal, return zero. If greater-than, return a positive value, if less than return a negative value.

encodeBoolean	back to summary
public static int encodeBoolean(boolean b, byte[] buf, int pos) Encode a boolean to the byte array at the given position. Will throw IndexOutOfBounds if the position is not valid. Returns:int The number of bytes written to the buffer, 1.

encodeBoolean

back to summary

public static int encodeBoolean(boolean b, byte[] buf, int pos)

Encode a boolean to the byte array at the given position. Will throw IndexOutOfBounds if the position is not valid.

Returns:int: The number of bytes written to the buffer, 1.

encodeDouble	back to summary
public static int encodeDouble(double d, byte[] buf, int pos) Encode a double to the byte array at the given position. Will throw IndexOutOfBounds if it overflows. Users should ensure that there are at least 8 bytes left in the buffer before calling this method. Returns:int Returns the number of bytes written to the buffer, 8.

encodeDouble

back to summary

public static int encodeDouble(double d, byte[] buf, int pos)

Encode a double to the byte array at the given position. Will throw IndexOutOfBounds if it overflows. Users should ensure that there are at least 8 bytes left in the buffer before calling this method.

Returns:int: Returns the number of bytes written to the buffer, 8.

encodeFloat	back to summary
public static int encodeFloat(float f, byte[] buf, int pos) Encode a float to the byte array at the given position. Will throw IndexOutOfBounds if it overflows. Users should ensure that there are at least 4 bytes left in the buffer before calling this method. Returns:int Returns the number of bytes written to the buffer, 4.

encodeFloat

back to summary

public static int encodeFloat(float f, byte[] buf, int pos)

Encode a float to the byte array at the given position. Will throw IndexOutOfBounds if it overflows. Users should ensure that there are at least 4 bytes left in the buffer before calling this method.

Returns:int: Returns the number of bytes written to the buffer, 4.

encodeInt	back to summary
public static int encodeInt(int n, byte[] buf, int pos) Encode an integer to the byte array at the given position. Will throw IndexOutOfBounds if it overflows. Users should ensure that there are at least 5 bytes left in the buffer before calling this method. Returns:int The number of bytes written to the buffer, between 1 and 5.

encodeInt

back to summary

public static int encodeInt(int n, byte[] buf, int pos)

Encode an integer to the byte array at the given position. Will throw IndexOutOfBounds if it overflows. Users should ensure that there are at least 5 bytes left in the buffer before calling this method.

Returns:int: The number of bytes written to the buffer, between 1 and 5.

encodeLong	back to summary
public static int encodeLong(long n, byte[] buf, int pos) Encode a long to the byte array at the given position. Will throw IndexOutOfBounds if it overflows. Users should ensure that there are at least 10 bytes left in the buffer before calling this method. Returns:int The number of bytes written to the buffer, between 1 and 10.

encodeLong

back to summary

public static int encodeLong(long n, byte[] buf, int pos)

Encode a long to the byte array at the given position. Will throw IndexOutOfBounds if it overflows. Users should ensure that there are at least 10 bytes left in the buffer before calling this method.

Returns:int: The number of bytes written to the buffer, between 1 and 10.

hashBytes	back to summary
private static int hashBytes(int init, BinaryData.HashData data, int len, boolean rev) throws IOException

hashCode	back to summary
public static int hashCode(byte[] bytes, int start, int length, Schema schema) Hash binary encoded data. Consistent with `org.apache.avro.generic.GenericData#hashCode(Object, Schema)`.

hashCode	back to summary
private static int hashCode(BinaryData.HashData data, Schema schema) throws IOException

skipLong	back to summary
public static int skipLong(final byte[] bytes, int start) Skip a binary-encoded long, returning the position after it.

org.apache.avro.io back to summary

private Class BinaryData.Decoders

Class Inheritance

extends Object

java.lang.Object
org.apache.avro.io.BinaryData.Decoders

Field Summary

Modifier and Type	Field and Description
private final BinaryDecoder	d1
private final BinaryDecoder	d2

Constructor Summary

Access	Constructor and Description
public	Decoders()

Method Summary

Modifier and Type	Method and Description
public void	clear()
public void	set(byte[] data1, int off1, int len1, byte[] data2, int off2, int len2)

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

Field Detail

d1	back to summary
private final BinaryDecoder d1

d2	back to summary
private final BinaryDecoder d2

Constructor Detail

Decoders	back to summary
public Decoders()

Method Detail

clear	back to summary
public void clear()

set	back to summary
public void set(byte[] data1, int off1, int len1, byte[] data2, int off2, int len2)

org.apache.avro.io back to summary

private Class BinaryData.HashData

Class Inheritance

extends Object

java.lang.Object
org.apache.avro.io.BinaryData.HashData

Field Summary

Modifier and Type	Field and Description
private final BinaryDecoder	decoder

Constructor Summary

Access	Constructor and Description
public	HashData()

Method Summary

Modifier and Type	Method and Description
public void	set(byte[] bytes, int start, int len)

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

Field Detail

decoder	back to summary
private final BinaryDecoder decoder

Constructor Detail

HashData	back to summary
public HashData()

Method Detail

set	back to summary
public void set(byte[] bytes, int start, int len)

public Class BinaryData

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class BinaryData.Decoders

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class BinaryData.HashData

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail