public TrinoConnector()

in src/main/java/org/apache/paimon/trino/TrinoConnector.java [48:67]

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

    public TrinoConnector(
            ConnectorMetadata trinoMetadata,
            ConnectorSplitManager trinoSplitManager,
            ConnectorPageSourceProvider trinoPageSourceProvider,
            ConnectorPageSinkProvider trinoPageSinkProvider,
            ConnectorNodePartitioningProvider trinoNodePartitioningProvider,
            TrinoTableOptions trinoTableOptions,
            TrinoSessionProperties trinoSessionProperties) {
        this.trinoMetadata = requireNonNull(trinoMetadata, "trinoMetadata is null");
        this.trinoSplitManager = requireNonNull(trinoSplitManager, "trinoSplitManager is null");
        this.trinoPageSourceProvider =
                requireNonNull(trinoPageSourceProvider, "trinoRecordSetProvider is null");
        this.trinoPageSinkProvider =
                requireNonNull(trinoPageSinkProvider, "trinoPageSinkProvider is null");
        this.trinoNodePartitioningProvider =
                requireNonNull(
                        trinoNodePartitioningProvider, "trinoNodePartitioningProvider is null");
        this.tableProperties = trinoTableOptions.getTableProperties();
        this.sessionProperties = trinoSessionProperties.getSessionProperties();
    }