public class PivotFacet extends AnalyticsFacet implements StreamingFacet
collectionManager, expressionCalculator, name, reductionData| Constructor and Description |
|---|
PivotFacet(String name,
PivotNode<?> topPivot) |
| Modifier and Type | Method and Description |
|---|---|
void |
addFacetValueCollectionTargets()
Determine which facet values match the current document.
|
NamedList<Object> |
createOldResponse()
Create the old olap-style response of the facet to be returned in the overall analytics response.
|
Iterable<Map<String,Object>> |
createResponse()
Create the response of the facet to be returned in the overall analytics response.
|
void |
exportShardData(DataOutput output)
Export the shard data through a bit-stream, to be imported by the
AnalyticsFacet.importShardData(java.io.DataInput) method
in the originating shard. |
void |
importShardData(DataInput input)
Import the shard data from a bit-stream, exported by the
AnalyticsFacet.exportShardData(java.io.DataOutput) method
in the each of the collection's shards. |
void |
setExpressionCalculator(ExpressionCalculator expressionCalculator)
Set the
ExpressionCalculator that calculates the collection of the expressions
requested for this facet. |
void |
setReductionCollectionManager(ReductionCollectionManager collectionManager)
Set the
ReductionCollectionManager that manages the collection of the expressions
calculated with this facet. |
exportFacetValue, getName, importFacetValuepublic void setReductionCollectionManager(ReductionCollectionManager collectionManager)
AnalyticsFacetReductionCollectionManager that manages the collection of the expressions
calculated with this facet.setReductionCollectionManager in class AnalyticsFacetcollectionManager - The manager for relevant expressionspublic void setExpressionCalculator(ExpressionCalculator expressionCalculator)
AnalyticsFacetExpressionCalculator that calculates the collection of the expressions
requested for this facet.setExpressionCalculator in class AnalyticsFacetexpressionCalculator - The calculator for relevant expressionspublic void addFacetValueCollectionTargets()
StreamingFacetReductionCollectionManager.ReductionDataCollections of the relevant facet values
to the targets of the streaming ReductionCollectionManager so that they are updated with the current document's data.addFacetValueCollectionTargets in interface StreamingFacetpublic void importShardData(DataInput input) throws IOException
AnalyticsFacetAnalyticsFacet.exportShardData(java.io.DataOutput) method
in the each of the collection's shards.importShardData in class AnalyticsFacetinput - The bit-stream to import the data fromIOException - if an exception occurs while reading from the DataInputpublic void exportShardData(DataOutput output) throws IOException
AnalyticsFacetAnalyticsFacet.importShardData(java.io.DataInput) method
in the originating shard.exportShardData in class AnalyticsFacetoutput - The bit-stream to output the data throughIOException - if an exception occurs while writing to the DataOutputpublic NamedList<Object> createOldResponse()
AnalyticsFacetcreateOldResponse in class AnalyticsFacetpublic Iterable<Map<String,Object>> createResponse()
AnalyticsFacetcreateResponse in class AnalyticsFacetCopyright © 2000-2020 Apache Software Foundation. All Rights Reserved.