Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Support for querying Druid Asynchronously #22

Open
GG-Zapr opened this issue Apr 13, 2018 · 7 comments
Open

Support for querying Druid Asynchronously #22

GG-Zapr opened this issue Apr 13, 2018 · 7 comments

Comments

@GG-Zapr
Copy link
Member

GG-Zapr commented Apr 13, 2018

No description provided.

@patilvikram
Copy link
Contributor

Is it still open?

@nihit-zapr
Copy link
Contributor

@patilvikram Its still open but we are not working on it as of now. We have other issues piled up before we pick this issue. If you want to help us we can discuss about it.

@patilvikram
Copy link
Contributor

patilvikram commented Oct 11, 2018

Yes, I think I can pick it up as we may require this feature soon enough. Could you please provide what you guys have discussed about this one?

@moezubair
Copy link

has there been any update on this?

@moezubair
Copy link

@patilvikram @nihit-zapr

@GG-Zapr
Copy link
Member Author

GG-Zapr commented Jan 24, 2019

No plans in near future.
If we get more requests for this, we can prioritize it

@chrisociepa
Copy link

I don't think it makes sense to implement it inside the library. It can be easily achieved using pure java code with much more flexibility:

    public CompletableFuture<InputStream> sendQueryAsync(String druidQuery) {
        HttpRequest request = HttpRequest.newBuilder(URI.create(brokerUrl))
                .timeout(Duration.ofSeconds(requestTimeoutSeconds))
                .header("Authorization", "Basic " + encodedCredentials)
                .POST(HttpRequest.BodyPublishers.ofString(druidQuery))
                .build();
        return httpClient.sendAsync(request, HttpResponse.BodyHandlers.ofInputStream())
                .thenApply(this::handleDruidResponse);
    }

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

5 participants