Package uk.gov.gchq.gaffer.accumulostore.performancetesting.ingest

Class BytesWritableElementGenerator

java.lang.Object

uk.gov.gchq.gaffer.accumulostore.performancetesting.ingest.BytesWritableElementGenerator

All Implemented Interfaces:

Function<Iterable<? extends org.apache.hadoop.io.BytesWritable>,Iterable<? extends uk.gov.gchq.gaffer.data.element.Element>>, uk.gov.gchq.gaffer.data.generator.ElementGenerator<org.apache.hadoop.io.BytesWritable>

public class BytesWritableElementGenerator
extends Object
implements uk.gov.gchq.gaffer.data.generator.ElementGenerator<org.apache.hadoop.io.BytesWritable>

Constructor Summary

Constructors

Constructor	Description
BytesWritableElementGenerator(uk.gov.gchq.gaffer.serialisation.ToBytesSerialiser<uk.gov.gchq.gaffer.data.element.Element> elementSerialisation)

Method Summary

Modifier and Type	Method	Description
Iterable<? extends uk.gov.gchq.gaffer.data.element.Element>	apply(Iterable<? extends org.apache.hadoop.io.BytesWritable> domainObjects)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose

Constructor Detail

BytesWritableElementGenerator

public BytesWritableElementGenerator(uk.gov.gchq.gaffer.serialisation.ToBytesSerialiser<uk.gov.gchq.gaffer.data.element.Element> elementSerialisation)

Method Detail

apply

public Iterable<? extends uk.gov.gchq.gaffer.data.element.Element> apply(Iterable<? extends org.apache.hadoop.io.BytesWritable> domainObjects)

Specified by:

apply in interface Function<Iterable<? extends org.apache.hadoop.io.BytesWritable>,Iterable<? extends uk.gov.gchq.gaffer.data.element.Element>>