Modifier and Type | Method and Description |
---|---|
org.roaringbitmap.RoaringBitmap |
RoaringBitmapSerialiser.deserialise(byte[] bytes) |
org.roaringbitmap.RoaringBitmap |
RoaringBitmapSerialiser.deserialise(byte[] allBytes,
int offset,
int length) |
byte[] |
RoaringBitmapSerialiser.serialise(org.roaringbitmap.RoaringBitmap object) |
Modifier and Type | Method and Description |
---|---|
static byte[] |
RoaringBitmapUtils.upConvertSerialisedForm(byte[] serialisedBitmap,
int offset,
int length) |
Modifier and Type | Method and Description |
---|---|
List<org.apache.hadoop.hbase.filter.MultiRowRangeFilter.RowRange> |
RowRangeFactory.getRowRange(ElementId elementId,
GraphFilters operation) |
Modifier and Type | Method and Description |
---|---|
Pair<org.apache.hadoop.hbase.Cell,org.apache.hadoop.hbase.Cell> |
ElementSerialisation.getCells(Element element,
org.apache.hadoop.hbase.mapreduce.CellCreator kvCreator) |
Pair<org.apache.hadoop.hbase.Cell,org.apache.hadoop.hbase.Cell> |
ElementSerialisation.getCells(Element element,
Pair<byte[],byte[]> row,
byte[] cq,
org.apache.hadoop.hbase.mapreduce.CellCreator kvCreator) |
byte[] |
ElementSerialisation.getColumnQualifier(Element element) |
byte[] |
ElementSerialisation.getColumnQualifier(String group,
Properties properties) |
byte[] |
ElementSerialisation.getColumnVisibility(Element element) |
byte[] |
ElementSerialisation.getColumnVisibility(String group,
Properties properties) |
Element |
ElementSerialisation.getElement(org.apache.hadoop.hbase.Cell cell,
boolean includeMatchedVertex) |
String |
ElementSerialisation.getGroup(byte[] columnQualifier) |
String |
ElementSerialisation.getGroup(org.apache.hadoop.hbase.Cell cell) |
Element |
ElementSerialisation.getPartialElement(String group,
byte[] rowId,
boolean includeMatchedVertex) |
Properties |
ElementSerialisation.getProperties(String group,
org.apache.hadoop.hbase.Cell cell) |
byte[] |
ElementSerialisation.getPropertiesAsBytesFromColumnQualifier(String group,
byte[] bytes,
int numProps) |
Properties |
ElementSerialisation.getPropertiesFromColumnQualifier(String group,
byte[] bytes) |
Properties |
ElementSerialisation.getPropertiesFromTimestamp(String group,
long timestamp)
Get the properties for a given group defined in the Schema as being
stored in the HBase timestamp column.
|
Properties |
ElementSerialisation.getPropertiesFromValue(String group,
byte[] value) |
Pair<org.apache.hadoop.hbase.client.Put,org.apache.hadoop.hbase.client.Put> |
ElementSerialisation.getPuts(Element element) |
Pair<org.apache.hadoop.hbase.client.Put,org.apache.hadoop.hbase.client.Put> |
ElementSerialisation.getPuts(Element element,
Pair<byte[],byte[]> row,
byte[] cq) |
byte[] |
ElementSerialisation.getRowKey(Entity entity) |
Pair<byte[],byte[]> |
ElementSerialisation.getRowKeys(Edge edge) |
Pair<byte[],byte[]> |
ElementSerialisation.getRowKeys(Element element) |
EdgeDirection |
ElementSerialisation.getSourceAndDestination(byte[] rowKey,
byte[][] sourceDestValues) |
long |
ElementSerialisation.getTimestamp(Element element) |
long |
ElementSerialisation.getTimestamp(Properties properties) |
byte[] |
ElementSerialisation.getValue(Element element) |
byte[] |
ElementSerialisation.getValue(String group,
Properties properties) |
boolean |
ElementSerialisation.isEntity(org.apache.hadoop.hbase.Cell cell) |
byte[] |
ElementSerialisation.serialiseVertex(Object vertex) |
Modifier and Type | Method and Description |
---|---|
static <T> T |
JSONSerialiser.deserialise(byte[] bytes,
Class<T> clazz) |
static <T> T |
JSONSerialiser.deserialise(byte[] bytes,
com.fasterxml.jackson.core.type.TypeReference<T> type) |
static <T> T |
JSONSerialiser.deserialise(InputStream stream,
Class<T> clazz) |
static <T> T |
JSONSerialiser.deserialise(InputStream stream,
com.fasterxml.jackson.core.type.TypeReference<T> type) |
static <T> T |
JSONSerialiser.deserialise(String json,
Class<T> clazz) |
static com.fasterxml.jackson.databind.JsonNode |
JSONSerialiser.getJsonNodeFromString(String content) |
static byte[] |
JSONSerialiser.serialise(Object object,
boolean prettyPrint,
String... fieldsToExclude)
Serialises an object.
|
static void |
JSONSerialiser.serialise(Object object,
com.fasterxml.jackson.core.JsonGenerator jsonGenerator,
boolean prettyPrint,
String... fieldsToExclude)
Serialises an object using the provided json generator.
|
static byte[] |
JSONSerialiser.serialise(Object object,
String... fieldsToExclude)
Serialises an object.
|
Modifier and Type | Method and Description |
---|---|
void |
ElementWriter.write(Edge edge) |
void |
ElementWriter.write(Entity entity) |
void |
ElementWriter.writeElement(Element element) |
Modifier and Type | Method and Description |
---|---|
org.apache.spark.sql.Row |
AggregateGafferRowsFunction.call(org.apache.spark.sql.Row v1,
org.apache.spark.sql.Row v2) |
Constructor and Description |
---|
AggregateDataForGroup(org.apache.hadoop.fs.FileSystem fs,
SchemaUtils schemaUtils,
String group,
List<String> inputFiles,
String outputDir,
org.apache.spark.sql.SparkSession sparkSession) |
Modifier and Type | Method and Description |
---|---|
org.apache.parquet.filter2.predicate.FilterPredicate |
JavaPredicateToParquetPredicate.getAndFilter(List<Predicate> predicateList,
String[] selection,
String group,
SchemaUtils schemaUtils) |
org.apache.parquet.filter2.predicate.FilterPredicate |
JavaPredicateToParquetPredicate.getOrFilter(List<Predicate> predicateList,
String[] selection,
String group,
SchemaUtils schemaUtils) |
org.apache.parquet.filter2.predicate.FilterPredicate |
JavaPredicateToParquetPredicate.getParquetPredicate() |
org.apache.parquet.filter2.predicate.FilterPredicate |
JavaPredicateToParquetPredicate.getPrimitiveFilter(Predicate filterFunction,
String selection,
String group,
SchemaUtils schemaUtils) |
Modifier and Type | Method and Description |
---|---|
INPUT |
ParquetSerialiser.deserialise(Object[] objects)
This method provides the user a way of specifying how to recreate the Plain Old Java Object (POJO)
from the Parquet primitive types.
|
Object[] |
ParquetSerialiser.serialise(INPUT object)
This method provides the user a way of specifying how to convert a Plain Old Java Object (POJO)
into the Parquet primitive types.
|
Modifier and Type | Method and Description |
---|---|
Long |
LongParquetSerialiser.deserialise(Object[] objects) |
Integer |
IntegerParquetSerialiser.deserialise(Object[] objects) |
Short |
ShortParquetSerialiser.deserialise(Object[] objects) |
TypeValue |
TypeValueParquetSerialiser.deserialise(Object[] objects) |
TypeSubTypeValue |
TypeSubTypeValueParquetSerialiser.deserialise(Object[] objects) |
Date |
DateParquetSerialiser.deserialise(Object[] objects) |
String |
StringParquetSerialiser.deserialise(Object[] objects) |
Boolean |
BooleanParquetSerialiser.deserialise(Object[] objects) |
com.clearspring.analytics.stream.cardinality.HyperLogLogPlus |
InLineHyperLogLogPlusParquetSerialiser.deserialise(Object[] objects) |
com.clearspring.analytics.stream.cardinality.HyperLogLogPlus |
NestedHyperLogLogPlusParquetSerialiser.deserialise(Object[] objects) |
TreeSet<String> |
TreeSetStringParquetSerialiser.deserialise(Object[] objects) |
Byte |
ByteParquetSerialiser.deserialise(Object[] objects) |
ArrayList<String> |
ArrayListStringParquetSerialiser.deserialise(Object[] objects) |
Float |
FloatParquetSerialiser.deserialise(Object[] objects) |
FreqMap |
FreqMapParquetSerialiser.deserialise(Object[] objects) |
HashSet<String> |
HashSetStringParquetSerialiser.deserialise(Object[] objects) |
Double |
DoubleParquetSerialiser.deserialise(Object[] objects) |
Long |
LongParquetSerialiser.deserialiseEmpty() |
Integer |
IntegerParquetSerialiser.deserialiseEmpty() |
Short |
ShortParquetSerialiser.deserialiseEmpty() |
TypeValue |
TypeValueParquetSerialiser.deserialiseEmpty() |
TypeSubTypeValue |
TypeSubTypeValueParquetSerialiser.deserialiseEmpty() |
Date |
DateParquetSerialiser.deserialiseEmpty() |
String |
StringParquetSerialiser.deserialiseEmpty() |
Boolean |
BooleanParquetSerialiser.deserialiseEmpty() |
com.clearspring.analytics.stream.cardinality.HyperLogLogPlus |
InLineHyperLogLogPlusParquetSerialiser.deserialiseEmpty() |
com.clearspring.analytics.stream.cardinality.HyperLogLogPlus |
NestedHyperLogLogPlusParquetSerialiser.deserialiseEmpty() |
TreeSet<String> |
TreeSetStringParquetSerialiser.deserialiseEmpty() |
Byte |
ByteParquetSerialiser.deserialiseEmpty() |
ArrayList<String> |
ArrayListStringParquetSerialiser.deserialiseEmpty() |
Float |
FloatParquetSerialiser.deserialiseEmpty() |
FreqMap |
FreqMapParquetSerialiser.deserialiseEmpty() |
HashSet<String> |
HashSetStringParquetSerialiser.deserialiseEmpty() |
Double |
DoubleParquetSerialiser.deserialiseEmpty() |
Object[] |
ArrayListStringParquetSerialiser.serialise(ArrayList<String> object) |
Object[] |
BooleanParquetSerialiser.serialise(Boolean object) |
Object[] |
ByteParquetSerialiser.serialise(Byte object) |
Object[] |
DateParquetSerialiser.serialise(Date object) |
Object[] |
DoubleParquetSerialiser.serialise(Double object) |
Object[] |
FloatParquetSerialiser.serialise(Float object) |
Object[] |
FreqMapParquetSerialiser.serialise(FreqMap object) |
Object[] |
HashSetStringParquetSerialiser.serialise(HashSet<String> object) |
Object[] |
InLineHyperLogLogPlusParquetSerialiser.serialise(com.clearspring.analytics.stream.cardinality.HyperLogLogPlus object) |
Object[] |
NestedHyperLogLogPlusParquetSerialiser.serialise(com.clearspring.analytics.stream.cardinality.HyperLogLogPlus object) |
Object[] |
IntegerParquetSerialiser.serialise(Integer object) |
Object[] |
LongParquetSerialiser.serialise(Long object) |
Object[] |
ShortParquetSerialiser.serialise(Short object) |
Object[] |
StringParquetSerialiser.serialise(String object) |
Object[] |
TreeSetStringParquetSerialiser.serialise(TreeSet<String> object) |
Object[] |
TypeSubTypeValueParquetSerialiser.serialise(TypeSubTypeValue object) |
Object[] |
TypeValueParquetSerialiser.serialise(TypeValue object) |
Modifier and Type | Method and Description |
---|---|
void |
GafferGroupObjectConverter.addGafferObjectToSparkRow(String column,
Object gafferObject,
ArrayList<Object> recordBuilder,
org.apache.spark.sql.types.StructType sparkSchema)
Converts the provided
gafferObject into objects as specified by the sparkSchema . |
Element |
GafferGroupObjectConverter.buildElementFromParquetObjects(Map<String,Object[]> parquetColumnToObject,
boolean isEntity)
Builds up a Gaffer element using a map of parquetColumn to Object[] containing the relevant objects stored in that column
|
Object[] |
GafferGroupObjectConverter.corePropertiesToParquetObjects(Element element) |
Object[] |
GafferGroupObjectConverter.corePropertiesToParquetObjectsForReversedEdge(Edge edge) |
ParquetEdgeSeed |
GafferGroupObjectConverter.edgeIdToParquetObjects(EdgeId edgeId) |
Object[] |
GafferGroupObjectConverter.gafferObjectsToParquetObjects(List<Pair<String,Object>> gafferColumnsAndObjects) |
Object[] |
GafferGroupObjectConverter.gafferObjectToParquetObjects(String gafferColumn,
Object gafferObject)
Converts a Gaffer object from a single Gaffer column to the representative Parquet objects, using the relevant serialiser.
|
Serialiser |
SchemaUtils.getSerialiser(String serialiserClassName) |
Object |
GafferGroupObjectConverter.parquetObjectsToGafferObject(String gafferColumn,
Object[] parquetObjects)
Generates the Gaffer object from the Parquet objects using the relevant serialiser's de-serialise method.
|
Object |
GafferGroupObjectConverter.sparkRowToGafferObject(String gafferColumn,
org.apache.spark.sql.Row row)
Extracts an object corresponding to column
gafferColumn from the provided GenericRowWithSchema . |
Modifier and Type | Method and Description |
---|---|
O |
ResponseDeserialiser.deserialise(String jsonString) |
default byte[] |
ResponseDeserialiser.encodeString(String jsonString) |
Modifier and Type | Method and Description |
---|---|
Set<Class<? extends Operation>> |
OperationsResponseDeserialiser.deserialise(String jsonString) |
O |
DefaultResponseDeserialiser.deserialise(String jsonString) |
Modifier and Type | Method and Description |
---|---|
IntegerFreqMap |
IntegerFreqMapSerialiser.deserialise(byte[] bytes)
Deprecated.
|
Object |
AvroSerialiser.deserialise(byte[] bytes) |
TypeSubTypeValue |
TypeSubTypeValueSerialiser.deserialise(byte[] bytes) |
CustomMap |
CustomMapSerialiser.deserialise(byte[] bytes) |
TypeValue |
TypeValueSerialiser.deserialise(byte[] bytes) |
FreqMap |
FreqMapSerialiser.deserialise(byte[] bytes) |
Long |
LongSerialiser.deserialise(byte[] bytes)
Deprecated.
|
Float |
FloatSerialiser.deserialise(byte[] bytes)
Deprecated.
|
T |
ToBytesViaStringDeserialiser.deserialise(byte[] bytes)
Deprecated.
|
T |
ToBytesSerialiser.deserialise(byte[] bytes)
Deserialise an array of bytes into the original object.
|
Object |
AvroSerialiser.deserialise(byte[] allBytes,
int offset,
int length) |
T |
ToBytesViaStringDeserialiser.deserialise(byte[] allBytes,
int offset,
int length) |
default T |
ToBytesSerialiser.deserialise(byte[] allBytes,
int offset,
int length) |
INPUT |
Serialiser.deserialise(OUTPUT output)
Deserialise an OUTPUT into the original object.
|
IntegerFreqMap |
IntegerFreqMapSerialiser.deserialiseEmpty()
Deprecated.
|
CustomMap |
CustomMapSerialiser.deserialiseEmpty() |
TypeValue |
TypeValueSerialiser.deserialiseEmpty() |
Long |
LongSerialiser.deserialiseEmpty()
Deprecated.
|
INPUT |
Serialiser.deserialiseEmpty()
Handle an empty OUTPUT and reconstruct an appropriate representation in Object form.
|
Integer |
IntegerSerialiser.deserialiseEmpty()
Deprecated.
|
T |
ToBytesSerialiser.deserialiseEmpty()
Handle an empty byte array and reconstruct an appropriate representation in T form.
|
Double |
DoubleSerialiser.deserialiseString(String value)
Deprecated.
|
Date |
DateSerialiser.deserialiseString(String value)
Deprecated.
|
Integer |
IntegerSerialiser.deserialiseString(String value)
Deprecated.
|
byte[] |
CustomMapSerialiser.serialise(CustomMap customMap) |
byte[] |
FloatSerialiser.serialise(Float value)
Deprecated.
|
byte[] |
FreqMapSerialiser.serialise(FreqMap map) |
OUTPUT |
Serialiser.serialise(INPUT object)
Serialise some object and returns the OUTPUT of the serialised form.
|
byte[] |
IntegerFreqMapSerialiser.serialise(IntegerFreqMap map)
Deprecated.
|
byte[] |
LongSerialiser.serialise(Long value)
Deprecated.
|
byte[] |
AvroSerialiser.serialise(Object object) |
byte[] |
ToBytesViaStringDeserialiser.serialise(T object) |
byte[] |
ToBytesSerialiser.serialise(T object)
Serialise some object and returns the raw bytes of the serialised form.
|
byte[] |
TypeSubTypeValueSerialiser.serialise(TypeSubTypeValue typeSubTypeValue) |
byte[] |
TypeValueSerialiser.serialise(TypeValue typeValue) |
Modifier and Type | Method and Description |
---|---|
Boolean |
BooleanSerialiser.deserialise(byte[] bytes) |
Object |
JavaSerialiser.deserialise(byte[] bytes) |
Object |
MultiSerialiser.deserialise(byte[] bytes) |
Map<? extends Object,? extends Object> |
MapSerialiser.deserialise(byte[] bytes) |
Set<? extends Object> |
SetSerialiser.deserialise(byte[] bytes) |
byte[] |
BytesSerialiser.deserialise(byte[] bytes) |
Object |
NullSerialiser.deserialise(byte[] bytes) |
<T> T |
BooleanSerialiser.deserialise(byte[] bytes,
Class<T> clazz) |
Boolean |
BooleanSerialiser.deserialise(byte[] allBytes,
int offset,
int length) |
Object |
JavaSerialiser.deserialise(byte[] allBytes,
int offset,
int length) |
Object |
MultiSerialiser.deserialiseEmpty() |
Map<? extends Object,? extends Object> |
MapSerialiser.deserialiseEmpty() |
Set<? extends Object> |
SetSerialiser.deserialiseEmpty() |
TreeSet<String> |
TreeSetStringSerialiser.deserialiseString(String value) |
byte[] |
BooleanSerialiser.serialise(Boolean value) |
byte[] |
BytesSerialiser.serialise(byte[] value) |
byte[] |
MapSerialiser.serialise(Map object) |
byte[] |
JavaSerialiser.serialise(Object object) |
byte[] |
MultiSerialiser.serialise(Object object) |
byte[] |
NullSerialiser.serialise(Object value) |
byte[] |
SetSerialiser.serialise(Set<? extends Object> object) |
Modifier and Type | Method and Description |
---|---|
Long |
OrderedLongSerialiser.deserialise(byte[] bytes) |
Double |
OrderedDoubleSerialiser.deserialise(byte[] bytes) |
Date |
OrderedDateSerialiser.deserialise(byte[] bytes) |
Integer |
OrderedIntegerSerialiser.deserialise(byte[] bytes) |
Float |
OrderedFloatSerialiser.deserialise(byte[] bytes) |
Modifier and Type | Method and Description |
---|---|
Long |
CompactRawLongSerialiser.deserialise(byte[] bytes) |
Integer |
CompactRawIntegerSerialiser.deserialise(byte[] bytes) |
Integer |
RawIntegerSerialiser.deserialise(byte[] bytes)
Deprecated.
|
Double |
RawDoubleSerialiser.deserialise(byte[] bytes)
Deprecated.
|
Float |
RawFloatSerialiser.deserialise(byte[] bytes)
Deprecated.
|
Long |
RawLongSerialiser.deserialise(byte[] bytes)
Deprecated.
|
Date |
RawDateSerialiser.deserialise(byte[] bytes)
Deprecated.
|
Long |
CompactRawLongSerialiser.deserialise(byte[] allBytes,
int offset,
int length) |
Integer |
CompactRawIntegerSerialiser.deserialise(byte[] allBytes,
int offset,
int length) |
Integer |
RawIntegerSerialiser.deserialise(byte[] allBytes,
int offset,
int length)
Deprecated.
|
Double |
RawDoubleSerialiser.deserialise(byte[] allBytes,
int offset,
int length)
Deprecated.
|
Float |
RawFloatSerialiser.deserialise(byte[] allBytes,
int offset,
int length)
Deprecated.
|
Long |
RawLongSerialiser.deserialise(byte[] allBytes,
int offset,
int length)
Deprecated.
|
Date |
RawDateSerialiser.deserialise(byte[] allBytes,
int offset,
int length)
Deprecated.
|
static long |
CompactRawSerialisationUtils.read(InputStream input)
Reads a long from the provided
InputStream . |
static long |
CompactRawSerialisationUtils.readLong(byte[] bytes) |
static long |
CompactRawSerialisationUtils.readLong(byte[] allBytes,
int offset) |
byte[] |
RawDateSerialiser.serialise(Date date)
Deprecated.
|
byte[] |
RawDoubleSerialiser.serialise(Double d)
Deprecated.
|
byte[] |
RawFloatSerialiser.serialise(Float f)
Deprecated.
|
byte[] |
CompactRawIntegerSerialiser.serialise(Integer i) |
byte[] |
RawIntegerSerialiser.serialise(Integer value)
Deprecated.
|
byte[] |
CompactRawLongSerialiser.serialise(Long l) |
byte[] |
RawLongSerialiser.serialise(Long value)
Deprecated.
|
static void |
CompactRawSerialisationUtils.write(long l,
OutputStream output)
Writes a long to the provided
OutputStream . |
Modifier and Type | Method and Description |
---|---|
String |
StringToStringSerialiser.deserialise(String s)
Deserialise an String into the original object.
|
String |
StringToStringSerialiser.serialise(String object)
Serialise some object and returns the String of the serialised form.
|
Modifier and Type | Method and Description |
---|---|
LengthValueBytesSerialiserUtil.LengthValueBuilder |
LengthValueBytesSerialiserUtil.LengthValueBuilder.appendLengthValueFromBytesToByteStream(byte[] serialisedObject) |
static ByteArrayOutputStream |
LengthValueBytesSerialiserUtil.appendLengthValueFromBytesToByteStream(ByteArrayOutputStream byteOut,
byte[] serialisedObject) |
static ByteArrayOutputStream |
LengthValueBytesSerialiserUtil.appendLengthValueFromObjectToByteStream(ByteArrayOutputStream byteOut,
ToBytesSerialiser serialiser,
Object object) |
LengthValueBytesSerialiserUtil.LengthValueBuilder |
LengthValueBytesSerialiserUtil.LengthValueBuilder.appendLengthValueFromObjectToByteStream(ToBytesSerialiser serialiser,
Object object) |
static byte[] |
LengthValueBytesSerialiserUtil.deserialise(byte[] allBytes) |
static byte[] |
LengthValueBytesSerialiserUtil.deserialise(byte[] allBytes,
int delimiter) |
static byte[] |
LengthValueBytesSerialiserUtil.deserialise(byte[] allBytes,
int[] delimiterWrapper) |
static byte[] |
LengthValueBytesSerialiserUtil.deserialise(byte[] allBytes,
int lengthSize,
int valueSize,
int delimiter) |
static <T> T |
LengthValueBytesSerialiserUtil.deserialise(ToBytesSerialiser<T> serialiser,
byte[] allBytes) |
static <T> T |
LengthValueBytesSerialiserUtil.deserialise(ToBytesSerialiser<T> serialiser,
byte[] allBytes,
int delimiter) |
static <T> T |
LengthValueBytesSerialiserUtil.deserialise(ToBytesSerialiser<T> serialiser,
byte[] allBytes,
int[] delimiterWrapper) |
static <T> LengthValueBytesSerialiserUtil.ObjectCarriage<T> |
LengthValueBytesSerialiserUtil.deserialiseNextObject(ToBytesSerialiser<T> serialiser,
int currentCarriage,
byte[] bytes) |
static int |
LengthValueBytesSerialiserUtil.getLengthSize(byte[] allBytes,
int delimiter) |
static int |
LengthValueBytesSerialiserUtil.getNextDelimiter(byte[] allBytes,
int delimiter) |
static <T> byte[] |
LengthValueBytesSerialiserUtil.getValueBytes(ToBytesSerialiser<T> serialiser,
T value) |
static int |
LengthValueBytesSerialiserUtil.getValueSize(byte[] allBytes,
int delimiter) |
static int |
LengthValueBytesSerialiserUtil.getValueSize(byte[] allBytes,
int lengthSize,
int delimiter) |
static byte[] |
LengthValueBytesSerialiserUtil.serialise(byte[] valueBytes) |
static void |
LengthValueBytesSerialiserUtil.serialise(byte[] valueBytes,
ByteArrayOutputStream out) |
static <T> byte[] |
LengthValueBytesSerialiserUtil.serialise(ToBytesSerialiser<T> serialiser,
T value) |
static <T> void |
LengthValueBytesSerialiserUtil.serialise(ToBytesSerialiser<T> serialiser,
T value,
ByteArrayOutputStream out) |
Modifier and Type | Method and Description |
---|---|
com.clearspring.analytics.stream.cardinality.HyperLogLogPlus |
HyperLogLogPlusSerialiser.deserialise(byte[] bytes) |
com.clearspring.analytics.stream.cardinality.HyperLogLogPlus |
HyperLogLogPlusSerialiser.deserialiseEmpty() |
byte[] |
HyperLogLogPlusSerialiser.serialise(com.clearspring.analytics.stream.cardinality.HyperLogLogPlus value) |
Modifier and Type | Method and Description |
---|---|
com.yahoo.sketches.hll.HllSketch |
HllSketchSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.hll.Union |
HllUnionSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.hll.HllSketch |
HllSketchSerialiser.deserialiseEmpty() |
com.yahoo.sketches.hll.Union |
HllUnionSerialiser.deserialiseEmpty() |
byte[] |
HllSketchSerialiser.serialise(com.yahoo.sketches.hll.HllSketch sketch) |
byte[] |
HllUnionSerialiser.serialise(com.yahoo.sketches.hll.Union sketch) |
Modifier and Type | Method and Description |
---|---|
com.yahoo.sketches.frequencies.ItemsSketch<String> |
StringsSketchSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.frequencies.LongsSketch |
LongsSketchSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.frequencies.ItemsSketch<String> |
StringsSketchSerialiser.deserialiseEmpty() |
com.yahoo.sketches.frequencies.LongsSketch |
LongsSketchSerialiser.deserialiseEmpty() |
byte[] |
StringsSketchSerialiser.serialise(com.yahoo.sketches.frequencies.ItemsSketch<String> sketch) |
byte[] |
LongsSketchSerialiser.serialise(com.yahoo.sketches.frequencies.LongsSketch sketch) |
Modifier and Type | Method and Description |
---|---|
com.yahoo.sketches.quantiles.ItemsUnion<String> |
StringsUnionSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.quantiles.DoublesUnion |
DoublesUnionSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.quantiles.ItemsSketch<String> |
StringsSketchSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.kll.KllFloatsSketch |
KllFloatsSketchSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.quantiles.DoublesSketch |
DoublesSketchSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.quantiles.ItemsUnion<String> |
StringsUnionSerialiser.deserialiseEmpty() |
com.yahoo.sketches.quantiles.DoublesUnion |
DoublesUnionSerialiser.deserialiseEmpty() |
com.yahoo.sketches.quantiles.ItemsSketch<String> |
StringsSketchSerialiser.deserialiseEmpty() |
com.yahoo.sketches.kll.KllFloatsSketch |
KllFloatsSketchSerialiser.deserialiseEmpty() |
com.yahoo.sketches.quantiles.DoublesSketch |
DoublesSketchSerialiser.deserialiseEmpty() |
byte[] |
DoublesSketchSerialiser.serialise(com.yahoo.sketches.quantiles.DoublesSketch sketch) |
byte[] |
DoublesUnionSerialiser.serialise(com.yahoo.sketches.quantiles.DoublesUnion union) |
byte[] |
StringsSketchSerialiser.serialise(com.yahoo.sketches.quantiles.ItemsSketch<String> sketch) |
byte[] |
StringsUnionSerialiser.serialise(com.yahoo.sketches.quantiles.ItemsUnion<String> union) |
byte[] |
KllFloatsSketchSerialiser.serialise(com.yahoo.sketches.kll.KllFloatsSketch sketch) |
Modifier and Type | Method and Description |
---|---|
com.yahoo.sketches.sampling.ReservoirItemsUnion<String> |
ReservoirStringsUnionSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.sampling.ReservoirLongsUnion |
ReservoirLongsUnionSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.sampling.ReservoirItemsUnion<Number> |
ReservoirNumbersUnionSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.sampling.ReservoirLongsSketch |
ReservoirLongsSketchSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.sampling.ReservoirItemsSketch<T> |
ReservoirItemsSketchSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.sampling.ReservoirItemsUnion<String> |
ReservoirStringsUnionSerialiser.deserialiseEmpty() |
com.yahoo.sketches.sampling.ReservoirLongsUnion |
ReservoirLongsUnionSerialiser.deserialiseEmpty() |
com.yahoo.sketches.sampling.ReservoirItemsUnion<Number> |
ReservoirNumbersUnionSerialiser.deserialiseEmpty() |
com.yahoo.sketches.sampling.ReservoirLongsSketch |
ReservoirLongsSketchSerialiser.deserialiseEmpty() |
com.yahoo.sketches.sampling.ReservoirItemsSketch<T> |
ReservoirItemsSketchSerialiser.deserialiseEmpty() |
byte[] |
ReservoirItemsSketchSerialiser.serialise(com.yahoo.sketches.sampling.ReservoirItemsSketch<T> sketch) |
byte[] |
ReservoirNumbersUnionSerialiser.serialise(com.yahoo.sketches.sampling.ReservoirItemsUnion<Number> union) |
byte[] |
ReservoirStringsUnionSerialiser.serialise(com.yahoo.sketches.sampling.ReservoirItemsUnion<String> union) |
byte[] |
ReservoirLongsSketchSerialiser.serialise(com.yahoo.sketches.sampling.ReservoirLongsSketch sketch) |
byte[] |
ReservoirLongsUnionSerialiser.serialise(com.yahoo.sketches.sampling.ReservoirLongsUnion union) |
Modifier and Type | Method and Description |
---|---|
com.yahoo.sketches.theta.Sketch |
SketchSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.theta.Union |
UnionSerialiser.deserialise(byte[] bytes) |
com.yahoo.sketches.theta.Sketch |
SketchSerialiser.deserialiseEmpty() |
com.yahoo.sketches.theta.Union |
UnionSerialiser.deserialiseEmpty() |
byte[] |
SketchSerialiser.serialise(com.yahoo.sketches.theta.Sketch sketch) |
byte[] |
UnionSerialiser.serialise(com.yahoo.sketches.theta.Union union) |
Modifier and Type | Method and Description |
---|---|
Entity |
EntitySerialiser.deserialise(byte[] bytes) |
ElementId |
ElementIdSerialiser.deserialise(byte[] bytes) |
GroupedProperties |
GroupedPropertiesSerialiser.deserialise(byte[] bytes) |
Edge |
EdgeSerialiser.deserialise(byte[] bytes) |
EntityId |
EntityIdSerialiser.deserialise(byte[] bytes) |
Element |
ElementSerialiser.deserialise(byte[] bytes) |
EdgeId |
EdgeIdSerialiser.deserialise(byte[] bytes) |
Entity |
EntitySerialiser.deserialiseEmpty() |
ElementId |
ElementIdSerialiser.deserialiseEmpty() |
GroupedProperties |
GroupedPropertiesSerialiser.deserialiseEmpty() |
Edge |
EdgeSerialiser.deserialiseEmpty() |
EntityId |
EntityIdSerialiser.deserialiseEmpty() |
Element |
ElementSerialiser.deserialiseEmpty() |
EdgeId |
EdgeIdSerialiser.deserialiseEmpty() |
String |
GroupedPropertiesSerialiser.getGroup(byte[] bytes) |
String |
ElementSerialiser.getGroup(byte[] bytes) |
byte[] |
EdgeSerialiser.serialise(Edge edge) |
byte[] |
ElementIdSerialiser.serialise(EdgeId edgeId) |
byte[] |
EdgeIdSerialiser.serialise(EdgeId edgeId) |
byte[] |
ElementSerialiser.serialise(Element element) |
byte[] |
ElementIdSerialiser.serialise(ElementId elementId) |
byte[] |
EntitySerialiser.serialise(Entity entity) |
byte[] |
ElementIdSerialiser.serialise(EntityId entityId) |
byte[] |
EntityIdSerialiser.serialise(EntityId entityId) |
byte[] |
GroupedPropertiesSerialiser.serialise(GroupedProperties properties) |
byte[] |
ElementIdSerialiser.serialiseVertex(Object vertex) |
byte[] |
EntityIdSerialiser.serialiseVertex(Object vertex) |
Modifier and Type | Method and Description |
---|---|
LongTimeSeries |
DeltaLongTimeSeriesSerialiser.deserialise(byte[] bytes) |
BoundedTimestampSet |
BoundedTimestampSetSerialiser.deserialise(byte[] bytes) |
RBMBackedTimestampSet |
RBMBackedTimestampSetSerialiser.deserialise(byte[] bytes) |
LongTimeSeries |
DeltaLongTimeSeriesSerialiser.deserialise(byte[] allBytes,
int offset,
int length) |
BoundedTimestampSet |
BoundedTimestampSetSerialiser.deserialise(byte[] allBytes,
int offset,
int length) |
RBMBackedTimestampSet |
RBMBackedTimestampSetSerialiser.deserialise(byte[] allBytes,
int offset,
int length) |
LongTimeSeries |
DeltaLongTimeSeriesSerialiser.deserialiseEmpty() |
BoundedTimestampSet |
BoundedTimestampSetSerialiser.deserialiseEmpty() |
RBMBackedTimestampSet |
RBMBackedTimestampSetSerialiser.deserialiseEmpty() |
byte[] |
BoundedTimestampSetSerialiser.serialise(BoundedTimestampSet boundedTimestampSet) |
byte[] |
DeltaLongTimeSeriesSerialiser.serialise(LongTimeSeries timeSeries) |
byte[] |
RBMBackedTimestampSetSerialiser.serialise(RBMBackedTimestampSet rbmBackedTimestampSet) |
Copyright © 2022. All rights reserved.