java.lang.Object
org.elasticsearch.transport.InboundAggregator
- All Implemented Interfaces:
Closeable,AutoCloseable,Releasable
-
Constructor Summary
ConstructorsConstructorDescriptionInboundAggregator(Supplier<CircuitBreaker> circuitBreaker, Function<String, RequestHandlerRegistry<TransportRequest>> registryFunction, boolean ignoreDeserializationErrors) -
Method Summary
Modifier and TypeMethodDescriptionvoidaggregate(ReleasableBytesReference content) voidclose()voidheaderReceived(Header header) booleanvoidupdateCompressionScheme(Compression.Scheme compressionScheme)
-
Constructor Details
-
InboundAggregator
public InboundAggregator(Supplier<CircuitBreaker> circuitBreaker, Function<String, RequestHandlerRegistry<TransportRequest>> registryFunction, boolean ignoreDeserializationErrors)
-
-
Method Details
-
headerReceived
-
updateCompressionScheme
-
aggregate
-
finishAggregation
- Throws:
IOException
-
isAggregating
public boolean isAggregating() -
close
public void close()- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Specified by:
closein interfaceReleasable
-