| Package | Description | 
|---|---|
| org.apache.avro.hadoop.io | |
| org.apache.avro.mapreduce | |
| org.apache.trevni.avro.mapreduce | 
| Modifier and Type | Method and Description | 
|---|---|
| int | AvroKeyComparator. compare(AvroKey<T> x,
       AvroKey<T> y) | 
| int | AvroKeyComparator. compare(AvroKey<T> x,
       AvroKey<T> y) | 
| Modifier and Type | Method and Description | 
|---|---|
| AvroKey<K> | AvroKeyValueRecordReader. getCurrentKey() | 
| AvroKey<T> | AvroKeyRecordReader. getCurrentKey() | 
| Modifier and Type | Method and Description | 
|---|---|
| protected RecordWriter<AvroKey<T>,NullWritable> | AvroKeyOutputFormat.RecordWriterFactory. create(Schema writerSchema,
      GenericData dataModel,
      CodecFactory compressionCodec,
      OutputStream outputStream,
      int syncInterval)Creates a new record writer instance. | 
| RecordReader<AvroKey<K>,AvroValue<V>> | CombineAvroKeyValueFileInputFormat. createRecordReader(InputSplit inputSplit,
                  TaskAttemptContext taskAttemptContext) | 
| RecordReader<AvroKey<K>,AvroValue<V>> | AvroKeyValueInputFormat. createRecordReader(InputSplit split,
                  TaskAttemptContext context) | 
| RecordReader<AvroKey<T>,NullWritable> | AvroKeyInputFormat. createRecordReader(InputSplit split,
                  TaskAttemptContext context) | 
| RecordWriter<AvroKey<T>,NullWritable> | AvroKeyOutputFormat. getRecordWriter(TaskAttemptContext context) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | AvroKeyRecordWriter. write(AvroKey<T> record,
     NullWritable ignore) | 
| Modifier and Type | Method and Description | 
|---|---|
| AvroKey<K> | AvroTrevniKeyValueRecordReader. getCurrentKey() | 
| AvroKey<T> | AvroTrevniKeyRecordReader. getCurrentKey() | 
| Modifier and Type | Method and Description | 
|---|---|
| RecordReader<AvroKey<K>,AvroValue<V>> | AvroTrevniKeyValueInputFormat. createRecordReader(InputSplit split,
                  TaskAttemptContext context) | 
| RecordReader<AvroKey<T>,NullWritable> | AvroTrevniKeyInputFormat. createRecordReader(InputSplit split,
                  TaskAttemptContext context) | 
| RecordWriter<AvroKey<K>,AvroValue<V>> | AvroTrevniKeyValueOutputFormat. getRecordWriter(TaskAttemptContext context) | 
| RecordWriter<AvroKey<T>,NullWritable> | AvroTrevniKeyOutputFormat. getRecordWriter(TaskAttemptContext context) | 
| Modifier and Type | Method and Description | 
|---|---|
| void | AvroTrevniKeyValueRecordWriter. write(AvroKey<K> key,
     AvroValue<V> value) | 
| void | AvroTrevniKeyRecordWriter. write(AvroKey<T> key,
     NullWritable value) | 
Copyright © 2009–2020 The Apache Software Foundation. All rights reserved.