Fix pulsar sql issues when run select count(*) for the table with primary schema

[codelipenghui]

(If this PR fixes a github issue, please add Fixes #<xyz>.)

Motivation

Fix pulsar sql issues when run select count(*) for the table with primary schema

error log:

2021-06-06T14:36:41.669+0800 ERROR SplitRunner-3-106 io.prestosql.execution.executor.TaskExecutor Error processing Split 20210606_063634_00002_6j8bm.1.0-1 PulsarSplit{splitId=1, connectorId='pulsar', originSchemaName='Bytes', schemaName='public/default', tableName='my-topic', splitSize=39324, schema='', schemaType=BYTES, startPositionEntryId=39325, endPositionEntryId=78649, startPositionLedgerId=10, endPositionLedgerId=10, schemaInfoProperties={}} (start = 2.24098441109938E8, wall = 320 ms, cpu = 0 ms, wait = 1 ms, calls = 1)
java.lang.RuntimeException: Primitive type must has only one ColumnHandle.
 at org.apache.pulsar.sql.presto.decoder.primitive.PulsarPrimitiveRowDecoderFactory.createRowDecoder(PulsarPrimitiveRowDecoderFactory.java:67)
 at org.apache.pulsar.sql.presto.PulsarDispatchingRowDecoderFactory.createRowDecoder(PulsarDispatchingRowDecoderFactory.java:59)
 at org.apache.pulsar.sql.presto.PulsarRecordCursor.advanceNextPosition(PulsarRecordCursor.java:545)
 at io.prestosql.spi.connector.RecordPageSource.getNextPage(RecordPageSource.java:90)
 at io.prestosql.operator.TableScanOperator.getOutput(TableScanOperator.java:302)
 at io.prestosql.operator.Driver.processInternal(Driver.java:379)
 at io.prestosql.operator.Driver.lambda$processFor$8(Driver.java:283)
 at io.prestosql.operator.Driver.tryWithLock(Driver.java:675)
 at io.prestosql.operator.Driver.processFor(Driver.java:276)
 at io.prestosql.execution.SqlTaskExecution$DriverSplitRunner.processFor(SqlTaskExecution.java:1075)
 at io.prestosql.execution.executor.PrioritizedSplitRunner.process(PrioritizedSplitRunner.java:163)
 at io.prestosql.execution.executor.TaskExecutor$TaskRunner.run(TaskExecutor.java:484)
 at io.prestosql.$gen.Presto_332__testversion____20210606_063438_2.run(Unknown Source)
 at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
 at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
 at java.base/java.lang.Thread.run(Thread.java:834)

Modifications

Remove check for the column size when on the primary schema since when run select count(*) on the presto, we will get empty column handlers

Verifying this change

New integration test added.

Does this pull request potentially affect one of the following parts:

If yes was chosen, please highlight the changes

• Dependencies (does it add or upgrade a dependency): (no)
• The public API: (no)
• The schema: (no)
• The default values of configurations: (no)
• The wire protocol: (no)
• The rest endpoints: (no)
• The admin cli options: (no)
• Anything that affects deployment: (no)

Documentation

• Does this pull request introduce a new feature? (no)

[gaoran10]

LGTM

[hangc0276]

LGTM