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(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()
Gets the wrapped key/value GenericRecord.
|
K |
getKey()
Read the key.
|
static org.apache.avro.Schema |
getSchema(org.apache.avro.Schema keySchema,
org.apache.avro.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(org.apache.avro.generic.GenericRecord keyValueRecord)
public org.apache.avro.generic.GenericRecord get()
public K getKey()
public V getValue()
public void setKey(K key)
key
- The key.public void setValue(V value)
value
- The value.public static org.apache.avro.Schema getSchema(org.apache.avro.Schema keySchema, org.apache.avro.Schema valueSchema)
Copyright © 2009–2023 The Apache Software Foundation. All rights reserved.