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

Constructor Summary

Constructors

Constructor and Description
MapPopulator(com.metamx.common.parsers.Parser<K,V> parser)

Method Summary

Modifier and Type	Method and Description
long	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(com.metamx.common.parsers.Parser<K,V> parser)

Method Detail

populate

public long 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:

The number of entries parsed

Throws:

IOException