flink-instrumentation/workspace/flink-1.4.1-instrumented/flink-1.4.1/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShard.java
/**
	 * Checks if a shard id has valid format.
	 * Kinesis stream shard ids have 12-digit numbers left-padded with 0's,
	 * prefixed with "shardId-", ex. "shardId-000000000015".
	 *
	 * @param shardId the shard id to check
	 * @return whether the shard id is valid
	 */
Checks if a shard id has valid format.
Kinesis stream shard ids have 12-digit numbers left-padded with 0's,
prefixed with "shardId-", ex.

@param shardId the shard id to check
@return whether the shard id is valid
Checks if a shard id has valid format . Kinesis stream shard ids have 12 - digit numbers left - padded with 0 ' s prefixed with " shardId - " ex . @param shardId the shard id to check @return whether the shard id is valid
public static boolean isValidShardId(String shardId) {
		if (shardId == null) {
			return false;
		}
		return shardId.matches("^shardId-\\d{12}");
	}
public static boolean isValidShardId ( String shardId ) { if ( shardId == null ) { return false ; } return shardId . matches ( "^shardId-\\d{12}" ) ; }
Checks if a shard id has valid format.
Checks if a shard id has valid format .