static List getPulsarColumnsFromPrimitiveSchema()

in presto-pulsar/src/main/java/org/apache/pulsar/sql/presto/PulsarMetadata.java [357:379]

19 lines of code
2 McCabe index (conditional complexity)


    static List<ColumnMetadata> getPulsarColumnsFromPrimitiveSchema(TopicName topicName,
                                                                    SchemaInfo schemaInfo,
                                                                    boolean withInternalColumns,
                                        PulsarColumnHandle.HandleKeyValueType handleKeyValueType) {
        ImmutableList.Builder<ColumnMetadata> builder = ImmutableList.builder();

        ColumnMetadata valueColumn = new PulsarColumnMetadata(
                PulsarColumnMetadata.getColumnName(handleKeyValueType, "__value__"),
                convertPulsarType(schemaInfo.getType()),
                "The value of the message with primitive type schema", null, false, false,
                new String[0],
                new Integer[0], handleKeyValueType);

        builder.add(valueColumn);

        if (withInternalColumns) {
            PulsarInternalColumn.getInternalFields()
                    .stream()
                    .forEach(pulsarInternalColumn -> builder.add(pulsarInternalColumn.getColumnMetadata(false)));
        }

        return builder.build();
    }