Class TrinoModule

src/main/java/org/apache/paimon/trino/TrinoModule.java:38–62

Module for binding instance.

/** Module for binding instance. */
public class TrinoModule implements Module {
    private Map<String, String> config;

    public TrinoModule(Map<String, String> config) {
        this.config = config;
    }

    @Override
    public void configure(Binder binder) {
        binder.bind(Options.class).toInstance(new Options(config));
        binder.bind(TrinoMetadataFactory.class).in(SINGLETON);
        binder.bind(TrinoSplitManager.class).in(SINGLETON);
        binder.bind(TrinoPageSourceProvider.class).in(SINGLETON);
        binder.bind(TrinoPageSinkProvider.class).in(SINGLETON);
        binder.bind(TrinoNodePartitioningProvider.class).in(SINGLETON);
        binder.bind(TrinoSessionProperties.class).in(SINGLETON);
        binder.bind(TrinoTableOptions.class).in(SINGLETON);
        newSetBinder(binder, ConnectorTableFunction.class)
                .addBinding()
                .toProvider(TableChangesFunctionProvider.class)
                .in(Scopes.SINGLETON);
        binder.bind(FunctionProvider.class).to(TrinoFunctionProvider.class).in(Scopes.SINGLETON);
        binder.bind(TableChangesFunctionProcessorProvider.class).in(SINGLETON);
    }
}