源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：org.apache.flink.streaming.connectors.kinesis.model.DynamoDBStreamsShardHandle

示例1
@Override
protected boolean shouldAdvanceLastDiscoveredShardId(String shardId, String lastSeenShardIdOfStream) {
	if (DynamoDBStreamsShardHandle.compareShardIds(shardId, lastSeenShardIdOfStream) <= 0) {
		// shardID update is valid only if the given shard id is greater
		// than the previous last seen shard id of the stream.
		return false;
	}

	return true;
}
示例2
@Override
protected boolean shouldAdvanceLastDiscoveredShardId(String shardId, String lastSeenShardIdOfStream) {
	if (DynamoDBStreamsShardHandle.compareShardIds(shardId, lastSeenShardIdOfStream) <= 0) {
		// shardID update is valid only if the given shard id is greater
		// than the previous last seen shard id of the stream.
		return false;
	}

	return true;
}
示例3
@Override
protected boolean shouldAdvanceLastDiscoveredShardId(String shardId, String lastSeenShardIdOfStream) {
	if (DynamoDBStreamsShardHandle.compareShardIds(shardId, lastSeenShardIdOfStream) <= 0) {
		// shardID update is valid only if the given shard id is greater
		// than the previous last seen shard id of the stream.
		return false;
	}

	return true;
}