Toggle navigation
Home
java.lang.String to org.apache.flink.streaming.connectors.kinesis.model.SequenceNumber
No. of Instances - 20
No. of Commits - 1
No. of Projects - {'flink'}
Hierarchy/Composition: SIBLING
Primitive Info: -
NameSpace: Jdk -> Internal
Mapping:
Add or Remove Method invocation
kinesisProxy.getShardIterator(assignedShard,ShardIteratorType.AFTER_SEQUENCE_NUMBER.toString(),lastSequenceNum)
to
kinesisProxy.getShardIterator(assignedShard,ShardIteratorType.AFTER_SEQUENCE_NUMBER.toString(),lastSequenceNum.getSequenceNumber())
lastSequenceNum.equals(SentinelSequenceNumber.SENTINEL_SHARD_ENDING_SEQUENCE_NUM.toString())
to
lastSequenceNum.equals(SentinelSequenceNumber.SENTINEL_SHARD_ENDING_SEQUENCE_NUM.get())
lastSequenceNum.equals(SentinelSequenceNumber.SENTINEL_EARLIEST_SEQUENCE_NUM.toString())
to
lastSequenceNum.equals(SentinelSequenceNumber.SENTINEL_EARLIEST_SEQUENCE_NUM.get())
lastSequenceNum.equals(SentinelSequenceNumber.SENTINEL_LATEST_SEQUENCE_NUM.toString())
to
lastSequenceNum.equals(SentinelSequenceNumber.SENTINEL_LATEST_SEQUENCE_NUM.get())
record.getSequenceNumber()
to
SentinelSequenceNumber.SENTINEL_SHARD_ENDING_SEQUENCE_NUM.get()
SentinelSequenceNumber.SENTINEL_SEQUENCE_NUMBER_NOT_SET.toString()
to
SentinelSequenceNumber.SENTINEL_SEQUENCE_NUMBER_NOT_SET.get()
Rename Variable
listOfSeqNumIfAssignedShards
to
listOfSeqNumOfAssignedShards
listOfSeqNumIfAssignedShards
to
listOfSeqNumOfAssignedShards