public static class AvroKeyValueSinkWriter.AvroKeyValue<K,V> extends Object
taken from AvroKeyValue avro-mapr lib
Modifier and Type | Field and Description |
---|---|
static String |
KEY_FIELD
The name of the generic record field containing the key.
|
static String |
KEY_VALUE_PAIR_RECORD_NAME
The name of the key value pair generic record.
|
static String |
KEY_VALUE_PAIR_RECORD_NAMESPACE
The namespace of the key value pair generic record.
|
org.apache.avro.generic.GenericRecord |
mKeyValueRecord
The key/value generic record wrapped by this class.
|
static String |
VALUE_FIELD
The name of the generic record field containing the value.
|
Constructor and Description |
---|
AvroKeyValue(org.apache.avro.generic.GenericRecord keyValueRecord)
Wraps a GenericRecord that is a key value pair.
|
Modifier and Type | Method and Description |
---|---|
org.apache.avro.generic.GenericRecord |
get() |
K |
getKey() |
static org.apache.avro.Schema |
getSchema(org.apache.avro.Schema keySchema,
org.apache.avro.Schema valueSchema)
Creates a KeyValuePair generic record schema.
|
V |
getValue() |
void |
setKey(K key) |
void |
setValue(V value) |
public static final String KEY_VALUE_PAIR_RECORD_NAME
public static final String KEY_VALUE_PAIR_RECORD_NAMESPACE
public static final String KEY_FIELD
public static final String VALUE_FIELD
public final org.apache.avro.generic.GenericRecord mKeyValueRecord
public AvroKeyValue(org.apache.avro.generic.GenericRecord keyValueRecord)
public org.apache.avro.generic.GenericRecord get()
public void setKey(K key)
public void setValue(V value)
public K getKey()
public V getValue()
public static org.apache.avro.Schema getSchema(org.apache.avro.Schema keySchema, org.apache.avro.Schema valueSchema)
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.