class LocalSourceConfigExecutor implements FunctionConfigExecutor< LocalSourceConfig, Source > {

    @Override
    public Optional< Source > apply( LocalSourceConfig localSourceConfig ) {
        Path path = Paths.get( URI.create( localSourceConfig.getRootPath() ) );
        return Optional.of( new LocalSource( path ) );
    }

    public  LocalSourceConfigExecutor( );

}