public void flush()

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

• 10 lines of code
• 4 McCabe index (conditional complexity)

	public void flush() {
		for (String streamNAme: streamListMap.keySet() ) {
			if (flushStats.containsKey(streamNAme)) {
				if (System.currentTimeMillis() - flushStats.get(streamNAme) > Constants.S ) {
					flush(streamNAme);
					addFlushstats(streamNAme,System.currentTimeMillis());
				}
			}
		}
	}