public FirehoseDataSinkImpl()

in firehose-sink/src/main/java/com/amazonaws/hbase/datasink/FirehoseDataSinkImpl.java [67:87]

• 17 lines of code
• 2 McCabe index (conditional complexity)

	public FirehoseDataSinkImpl(Configuration config)  {
		super(config);
		this.configUtil = this.getConfigurationUtil();
		
		this.firehose = FirehoseProducerFactory.getProducer(config);
		
		Thread flusher = new Thread(){
		
		public void run(){
		    	try {
		    		flush();
					Thread.sleep(1000L);
				} catch (InterruptedException e) {
					LOG.info("Firehose preiodic flusher died.");
					e.printStackTrace();
				}
		    }
		};

		flusher.start();
	}