io.druid.data.input

Class MapPopulator<K,V>

java.lang.Object

io.druid.data.input.MapPopulator<K,V>

public class MapPopulator<K,V>
extends Object

Simple class that takes a `ByteSource` and uses a `Parser` to populate a `Map` The `ByteSource` must be UTF-8 encoded

If this is handy for other use cases pleaes move this class into a common module

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MapPopulator.PopulateResult

Constructor Summary

Constructors

Constructor and Description
MapPopulator(Parser<K,V> parser)

Method Summary

Modifier and Type	Method and Description
MapPopulator.PopulateResult	populate(com.google.common.io.ByteSource source, Map<K,V> map) Read through the `source` line by line and populate `map` with the data returned from the `parser`

Methods inherited from class java.lang.Object

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

Constructor Detail

MapPopulator

public MapPopulator(Parser<K,V> parser)

Method Detail

populate

public MapPopulator.PopulateResult populate(com.google.common.io.ByteSource source,
                                            Map<K,V> map)
                                     throws IOException

Read through the `source` line by line and populate `map` with the data returned from the `parser`

Parameters:

source - The ByteSource to read lines from

map - The map to populate

Returns:

number of lines read and entries parsed

Throws:

IOException