flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/KinesisStreamShard.java [54:80]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        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;
    }

    public String getStreamName() {
        return streamName;
    }

    public boolean isClosed() {
        return (shard.getSequenceNumberRange().getEndingSequenceNumber() != null);
    }

    public Shard getShard() {
        return shard;
    }

    @Override
    public String toString() {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



flink-connector-aws/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/model/StreamShardHandle.java [47:73]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        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;
    }

    public String getStreamName() {
        return streamName;
    }

    public boolean isClosed() {
        return (shard.getSequenceNumberRange().getEndingSequenceNumber() != null);
    }

    public Shard getShard() {
        return shard;
    }

    @Override
    public String toString() {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -