public List filter()

in kafka-sink/src/main/java/com/amazonaws/hbase/datasink/KafkaDataSinkImpl.java [36:50]

• 12 lines of code
• 3 McCabe index (conditional complexity)

	public List<Entry> filter(final List<Entry> oldEntries) {
		
		List<Entry> entries = new ArrayList<>();
		for (Entry e : oldEntries) {
			TableName tableName = e.getKey().getTableName();

			if ( this.getConfigurationUtil().getTopicFromTableName(tableName.getNameAsString()) != null ) {
				entries.add(e);
			} else {
				LOG.debug("Not mapped to stream: " + tableName.toString());
			}
		}

		return entries;
	}