elasticsearch: convert StreamOutput to String

Question

I'm overriding FilterClient so I can see incoming requests. I'd like some way to get a String representation of the ActionRequest that's passed in. ActionRequest let's you write to a StreamOuput, which is an Elasticsearch type that is a subclass of OutputStream. This SO post shows how to convert OutputStream to a String, but I'm forced to use StreamOuput due to the FilterClient API.

How do I get a String representation of ActionRequest or at least a readable version that will show me useful information about the request? (Calling ActionRequest.toString calls Object.toString, which is not good enough for me.)

StreamOuput extends OutputStream so can't you just use it as an OutputStream? — Amir Raminfar
– Amir Raminfar, Commented Mar 23, 2017 at 18:27
I don't understand your suggestion. The SO post I linked to suggests using ByteArrayOutputStream. But you can't use ByteArrayOutputStream where StreamOutput is expected. Perhaps you can include a bit of code in a solution so I can understand. — lf215
– lf215, Commented Mar 24, 2017 at 1:46

Val · Accepted Answer · 2017-03-24 05:24:51Z

5

+50

StreamOutput is an abstract class which has a subclass called OutputStreamStreamOutput. The latter is basically a wrapper around an OutputStream, so you'd create an instance that wraps a ByteArrayOutputStream and then use it in the ActionRequest.writeTo() call.

// in your override doExecute method, add this:
ByteArrayOutputStream baos = new ByteArrayOutputStream();
OutputStreamStreamOutput osso = new OutputStreamStreamOutput(baos);

request.writeTo(osso);
String requestAsString = baos.toString("UTF-8");

answered Mar 24, 2017 at 5:24

Val

218k14 gold badges377 silver badges384 bronze badges

Sign up to request clarification or add additional context in comments.

7 Comments

lf215 Over a year ago

This looks close to what I need, but I'm getting a bunch of �s in the output. I think it's outputting the correct request field names but the values are all gibberish. Any idea?

Val Over a year ago

Maybe the content you're getting is binary and not textual... or simply not encoded in UTF-8

lf215 Over a year ago

Is there a specific flag/configuration where the encoding of Elasticsearch requests is set?

Val Over a year ago

Can you tell which request you're intercepting?

lf215 Over a year ago

The request could be a bunch of different request types, including SearchRequest, BulkRequest, MultiGetRequest. Is this what you mean?

|

Collectives™ on Stack Overflow

elasticsearch: convert StreamOutput to String

1 Answer 1

7 Comments

Your Answer

Linked

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

7 Comments

Your Answer

Sign up or log in

Post as a guest

Linked

Related