K
- The java type for the key.V
- The java type for the value.public class AvroKeyValue<K,V> extends Object
Modifier and Type | Class and Description |
---|---|
static class |
AvroKeyValue.Iterator<K,V>
A wrapper for iterators over GenericRecords that are known to be KeyValue records.
|
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.
|
static String |
VALUE_FIELD
The name of the generic record field containing the value.
|
Constructor and Description |
---|
AvroKeyValue(GenericRecord keyValueRecord)
Wraps a GenericRecord that is a key value pair.
|
Modifier and Type | Method and Description |
---|---|
GenericRecord |
get()
Gets the wrapped key/value GenericRecord.
|
K |
getKey()
Read the key.
|
static Schema |
getSchema(Schema keySchema,
Schema valueSchema)
Creates a KeyValuePair generic record schema.
|
V |
getValue()
Read the value.
|
void |
setKey(K key)
Sets the key.
|
void |
setValue(V value)
Sets the 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 AvroKeyValue(GenericRecord keyValueRecord)
public GenericRecord get()
public K getKey()
public V getValue()
public void setKey(K key)
key
- The key.public void setValue(V value)
value
- The value.Copyright © 2009-2014 The Apache Software Foundation. All Rights Reserved.