Collection getSplitsNonPartitionedTopic()

in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarSplitManager.java [232:247]

• 15 lines of code
• 1 McCabe index (conditional complexity)

    Collection<PulsarSplit> getSplitsNonPartitionedTopic(int numSplits, TopicName topicName,
            PulsarTableHandle tableHandle, SchemaInfo schemaInfo, TupleDomain<ColumnHandle> tupleDomain,
             OffloadPolicies offloadPolicies) throws Exception {
        ManagedLedgerFactory managedLedgerFactory = PulsarConnectorCache.getConnectorCache(pulsarConnectorConfig)
                .getManagedLedgerFactory();

        return getSplitsForTopic(
                topicName.getPersistenceNamingEncoding(),
                managedLedgerFactory,
                numSplits,
                tableHandle,
                schemaInfo,
                tableHandle.getTableName(),
                tupleDomain,
                offloadPolicies);
    }