public static boolean checkIfStreamExist()

in src/main/java/com/amazonaws/kda/flink/starterkit/SessionUtil.java [37:55]

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

	public static boolean checkIfStreamExist(String region, String streamName) {

		boolean streamExist = false;
		AmazonKinesis kinesis = AmazonKinesisClientBuilder.standard().withRegion(region).build();
		ListShardsRequest listShardsRequest = new ListShardsRequest();
		listShardsRequest.setStreamName(streamName);
		// get shards
		try {
			ListShardsResult listShardResult = kinesis.listShards(listShardsRequest);
			List<Shard> shardList = listShardResult.getShards();
			if (shardList.size() > 0)
				streamExist = true;
		} catch (Exception e) {
			e.printStackTrace();
			log.error("Exception recieved while listing shards for stream: " + streamName);
		}
		kinesis.shutdown();
		return streamExist;
	}