Class PulsarAvroSchemaUtil

java.lang.Object

io.nosqlbench.adapter.pulsar.util.PulsarAvroSchemaUtil

public class PulsarAvroSchemaUtil
extends Object

Constructor Summary

Constructors

Constructor	Description
PulsarAvroSchemaUtil()

Method Summary

Modifier and Type	Method	Description
static org.apache.avro.generic.GenericRecord	GetGenericRecord_ApacheAvro(org.apache.avro.Schema schema, byte[] bytesData)
static org.apache.avro.generic.GenericRecord	GetGenericRecord_ApacheAvro(org.apache.avro.Schema schema, String jsonData)
static org.apache.pulsar.client.api.schema.GenericRecord	GetGenericRecord_PulsarAvro(String schemaName, String avroSchemDefStr, String jsonData)
static org.apache.pulsar.client.api.schema.GenericRecord	GetGenericRecord_PulsarAvro(org.apache.pulsar.client.impl.schema.generic.GenericAvroSchema genericAvroSchema, String avroSchemDefStr, String jsonData)
static org.apache.pulsar.client.api.schema.GenericRecord	GetGenericRecord_PulsarAvro(org.apache.pulsar.client.impl.schema.generic.GenericAvroSchema pulsarGenericAvroSchema, org.apache.avro.generic.GenericRecord apacheAvroGenericRecord)
static org.apache.pulsar.client.api.schema.GenericRecord	GetGenericRecord_PulsarAvro(org.apache.pulsar.client.impl.schema.generic.GenericAvroSchema genericAvroSchema, org.apache.avro.Schema avroSchema, String jsonData)
static org.apache.avro.Schema	GetSchema_ApacheAvro(String avroSchemDef)	/////////////////////
static org.apache.pulsar.client.impl.schema.generic.GenericAvroSchema	GetSchema_PulsarAvro(String schemaName, String avroSchemDef)	/////////////////////

Methods inherited from class java.lang.Object

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

Constructor Details

PulsarAvroSchemaUtil

public PulsarAvroSchemaUtil()

Method Details

GetSchema_ApacheAvro

public static org.apache.avro.Schema GetSchema_ApacheAvro(String avroSchemDef)

/////////////////////

GetGenericRecord_ApacheAvro

public static org.apache.avro.generic.GenericRecord GetGenericRecord_ApacheAvro(org.apache.avro.Schema schema,
 String jsonData)

GetGenericRecord_ApacheAvro

public static org.apache.avro.generic.GenericRecord GetGenericRecord_ApacheAvro(org.apache.avro.Schema schema,
 byte[] bytesData)

GetSchema_PulsarAvro

public static org.apache.pulsar.client.impl.schema.generic.GenericAvroSchema GetSchema_PulsarAvro(String schemaName,
 String avroSchemDef)

/////////////////////

GetGenericRecord_PulsarAvro

public static org.apache.pulsar.client.api.schema.GenericRecord GetGenericRecord_PulsarAvro(org.apache.pulsar.client.impl.schema.generic.GenericAvroSchema pulsarGenericAvroSchema,
 org.apache.avro.generic.GenericRecord apacheAvroGenericRecord)

GetGenericRecord_PulsarAvro

public static org.apache.pulsar.client.api.schema.GenericRecord GetGenericRecord_PulsarAvro(org.apache.pulsar.client.impl.schema.generic.GenericAvroSchema genericAvroSchema,
 String avroSchemDefStr,
 String jsonData)

GetGenericRecord_PulsarAvro

public static org.apache.pulsar.client.api.schema.GenericRecord GetGenericRecord_PulsarAvro(org.apache.pulsar.client.impl.schema.generic.GenericAvroSchema genericAvroSchema,
 org.apache.avro.Schema avroSchema,
 String jsonData)

GetGenericRecord_PulsarAvro

public static org.apache.pulsar.client.api.schema.GenericRecord GetGenericRecord_PulsarAvro(String schemaName,
 String avroSchemDefStr,
 String jsonData)