io.druid.examples.web

Class RenamingKeysUpdateStream

java.lang.Object

io.druid.examples.web.RenamingKeysUpdateStream

All Implemented Interfaces:

UpdateStream

public class RenamingKeysUpdateStream
extends Object
implements UpdateStream

Constructor Summary

Constructors

Constructor and Description
RenamingKeysUpdateStream(InputSupplierUpdateStream updateStream, Map<String,String> renamedDimensions)

Method Summary

Methods

Modifier and Type	Method and Description
String	getTimeDimension()
Map<String,Object>	pollFromQueue(long waitTime, TimeUnit unit)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

RenamingKeysUpdateStream

public RenamingKeysUpdateStream(InputSupplierUpdateStream updateStream,
                        Map<String,String> renamedDimensions)

Method Detail

pollFromQueue

public Map<String,Object> pollFromQueue(long waitTime,
                               TimeUnit unit)
                                 throws InterruptedException

Specified by:

pollFromQueue in interface UpdateStream

Throws:

InterruptedException

getTimeDimension

public String getTimeDimension()

Specified by:

getTimeDimension in interface UpdateStream

start

public void start()

Specified by:

start in interface UpdateStream

stop

public void stop()

Specified by:

stop in interface UpdateStream