com.adgear.anoa.test

Class AnoaTestSample

java.lang.Object

com.adgear.anoa.test.AnoaTestSample

public class AnoaTestSample
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
Class<LogEventAvro>	avroClass
Schema	avroSchema
int	n
long	nl
static ObjectMapper	OBJECT_MAPPER
Class<AdExchangeProtobuf.LogEvent>	protobufClass
Supplier<AdExchangeProtobuf.LogEvent.Builder>	protobufSupplier
Class<LogEventThrift>	thriftClass
Supplier<LogEventThrift>	thriftSupplier

Constructor Summary

Constructors

Constructor and Description
AnoaTestSample()

Method Summary

Modifier and Type	Method and Description
InputStream	allAsInputStream(CheckedConsumer<OutputStream> lambda)
void	assertAvroGenerics(Stream<GenericRecord> stream)
void	assertAvroSpecifics(Stream<LogEventAvro> stream)
void	assertJsonNodes(Stream<JsonNode> stream)
void	assertJsonObjects(Stream<ObjectNode> stream)
void	assertProtobufObjects(Stream<AdExchangeProtobuf.LogEvent> stream)
void	assertThriftObjects(Stream<LogEventThrift> stream)
InputStream	avroBatch()
InputStream	avroBatchInputStream(int readFailureIndex)
Stream<byte[]>	avroBinary()
InputStream	avroBinaryInputStream(int readFailureIndex)
Stream<GenericRecord>	avroGeneric()
Stream<String>	avroJson()
InputStream	avroJsonInputStream(int readFailureIndex)
Stream<LogEventAvro>	avroSpecific()
Stream<String>	json()
InputStream	jsonInputStream(int readFailureIndex)
Stream<JsonNode>	jsonNodes()
JsonParser	jsonNullsObjectParser()
Stream<ObjectNode>	jsonObjects()
JsonParser	jsonParser(int readFailureIndex)
InputStream	protoBinaryInputStream(int readFailureIndex)
Stream<AdExchangeProtobuf.LogEvent>	protobuf()
Stream<byte[]>	protobufBinary()
Stream<String>	protobufJson()
Stream<LogEventThrift>	thrift()
Stream<byte[]>	thriftBinary()
InputStream	thriftBinaryInputStream(int readFailureIndex)
Stream<byte[]>	thriftCompact()
InputStream	thriftCompactInputStream(int readFailureIndex)
Stream<String>	thriftJson()
InputStream	thriftJsonInputStream(int readFailureIndex)

Methods inherited from class java.lang.Object

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

Field Detail

n

public final int n

See Also:

Constant Field Values

nl

public final long nl

See Also:

Constant Field Values

avroSchema

public final Schema avroSchema

avroClass

public final Class<LogEventAvro> avroClass

thriftClass

public final Class<LogEventThrift> thriftClass

thriftSupplier

public final Supplier<LogEventThrift> thriftSupplier

protobufClass

public final Class<AdExchangeProtobuf.LogEvent> protobufClass

protobufSupplier

public final Supplier<AdExchangeProtobuf.LogEvent.Builder> protobufSupplier

OBJECT_MAPPER

public static final ObjectMapper OBJECT_MAPPER

Constructor Detail

AnoaTestSample

public AnoaTestSample()

Method Detail

json

public Stream<String> json()

avroSpecific

public Stream<LogEventAvro> avroSpecific()

avroGeneric

public Stream<GenericRecord> avroGeneric()

avroBinary

public Stream<byte[]> avroBinary()

avroJson

public Stream<String> avroJson()

avroBatch

public InputStream avroBatch()

thrift

public Stream<LogEventThrift> thrift()

thriftBinary

public Stream<byte[]> thriftBinary()

thriftCompact

public Stream<byte[]> thriftCompact()

thriftJson

public Stream<String> thriftJson()

protobuf

public Stream<AdExchangeProtobuf.LogEvent> protobuf()

protobufBinary

public Stream<byte[]> protobufBinary()

protobufJson

public Stream<String> protobufJson()

jsonNullsObjectParser

public JsonParser jsonNullsObjectParser()

jsonNodes

public Stream<JsonNode> jsonNodes()

jsonObjects

public Stream<ObjectNode> jsonObjects()

allAsInputStream

public InputStream allAsInputStream(CheckedConsumer<OutputStream> lambda)

assertJsonNodes

public void assertJsonNodes(Stream<JsonNode> stream)

assertJsonObjects

public void assertJsonObjects(Stream<ObjectNode> stream)

jsonInputStream

public InputStream jsonInputStream(int readFailureIndex)

jsonParser

public JsonParser jsonParser(int readFailureIndex)

assertAvroGenerics

public void assertAvroGenerics(Stream<GenericRecord> stream)

assertAvroSpecifics

public void assertAvroSpecifics(Stream<LogEventAvro> stream)

avroBinaryInputStream

public InputStream avroBinaryInputStream(int readFailureIndex)

avroJsonInputStream

public InputStream avroJsonInputStream(int readFailureIndex)

avroBatchInputStream

public InputStream avroBatchInputStream(int readFailureIndex)

assertThriftObjects

public void assertThriftObjects(Stream<LogEventThrift> stream)

thriftBinaryInputStream

public InputStream thriftBinaryInputStream(int readFailureIndex)

thriftCompactInputStream

public InputStream thriftCompactInputStream(int readFailureIndex)

thriftJsonInputStream

public InputStream thriftJsonInputStream(int readFailureIndex)

protoBinaryInputStream

public InputStream protoBinaryInputStream(int readFailureIndex)

assertProtobufObjects

public void assertProtobufObjects(Stream<AdExchangeProtobuf.LogEvent> stream)