presto-kinesis/src/main/java/io/prestosql/plugin/kinesis/KinesisSplitManager.java/KinesisSplitManager/getSplits
class KinesisSplitManager:    @Override
    public ConnectorSplitSource getSplits(ConnectorTransactionHandle transactionHandle, ConnectorSession session, ConnectorTableHandle table, ConnectorSplitManager.SplitSchedulingStrategy splitSchedulingStrategy)
    {
        KinesisTableHandle kinesisTableHandle = (KinesisTableHandle) table;

        InternalStreamDescription description = this.getStreamDescription(kinesisTableHandle.getStreamName());

        ImmutableList.Builder<ConnectorSplit> builder = ImmutableList.builder();
        for (Shard shard : description.getShards()) {
            KinesisSplit split = new KinesisSplit(
                    kinesisTableHandle.getStreamName(),
                    kinesisTableHandle.getMessageDataFormat(),
                    shard.getShardId(),
                    shard.getSequenceNumberRange().getStartingSequenceNumber(),
                    shard.getSequenceNumberRange().getEndingSequenceNumber());
            builder.add(split);
        }

        return new FixedSplitSource(builder.build());
    }