in local/elasticsearch-hdfs/src/main/java/org/apache/streams/example/HdfsElasticsearch.java [52:57]
public static void main(String[] args)
{
LOGGER.info(StreamsConfigurator.getConfig().toString());
HdfsElasticsearch restore = new HdfsElasticsearch();
new Thread(restore).start();
}