flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShard.java [53:65]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public KinesisStreamShard(String streamName, Shard shard) {
        this.streamName = checkNotNull(streamName);
        this.shard = checkNotNull(shard);

        // since our description of Kinesis Streams shards can be fully defined with the stream name
        // and shard id,
        // our hash doesn't need to use hash code of Amazon's description of Shards, which uses
        // other info for calculation
        int hash = 17;
        hash = 37 * hash + streamName.hashCode();
        hash = 37 * hash + shard.getShardId().hashCode();
        this.cachedHash = hash;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/StreamShardHandle.java [46:58]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public StreamShardHandle(String streamName, Shard shard) {
        this.streamName = checkNotNull(streamName);
        this.shard = checkNotNull(shard);

        // since our description of Kinesis Streams shards can be fully defined with the stream name
        // and shard id,
        // our hash doesn't need to use hash code of Amazon's description of Shards, which uses
        // other info for calculation
        int hash = 17;
        hash = 37 * hash + streamName.hashCode();
        hash = 37 * hash + shard.getShardId().hashCode();
        this.cachedHash = hash;
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -