All Classes Interface Summary Class Summary Enum Summary Exception Summary
Class |
Description |
AAvroFileTask<E> |
|
AAvroFileTask.AvroReaderVersion |
Supported versions of Avro reader implementation.
|
AAvroFileTask.Result |
|
ABufferedArchiveOutputStream |
Abstract method to managed an archive stream implementation to ensure an optimal generation of a single-entry archive file.
|
ACloudCsvScopedFetchSource<F> |
Abstract implementation of ACsvScopedFetchSource which handles creation of cloud ICsvDataProvider
paths to process for a cloud channel.
|
ACloudCsvScopedListenSource |
|
ACsvScopedFetchSource<F> |
|
ACsvScopedListenSource |
|
ACsvScopedSource<F> |
Abstract implementation of a Csv Scoped source, supports Fetching and Listening.
|
ACsvSource<I> |
|
ACsvSourceConfig<I> |
Generic ACsvSource implementation used for testing.
|
ADataConnectorsRestServiceConfig |
Base RESTful service configuration which will set up the base RESTful service endpoint at
services/rest/COMPONENT/VERSION/ with the COMPONENT being the component for data sourcing or data sinking.
|
ADataExtractionMockRestApplication |
A Mock DEE REST Service.
|
ADataExtractionMockRestApplication.AMockConfig |
|
ADataExtractionMockRestApplication.ATestEnhancedDrillthroughService |
|
ADataExtractionMockRestApplication.SpringSecurityConfig |
|
ADataExtractionMockRestApplication.TestDataExtractionRestService |
|
ADataExtractionRestServicesConfig |
Spring JavaConfig of the Data Extraction REST services required in any custom ActivePivot server project.
|
ADataExtractionService |
|
ADataExtractionServicesConfig |
Spring JavaConfig of the Data Extraction Engine service.
|
ADataLoadControllerConfig |
Configure a data load controller.
|
ADataLoadControllerRestServiceConfig |
Configures the Data Load Controllers REST service endpoint.
|
ADatastoreTransactionTask |
An abstract implementation of a task that executes a Datastore transaction with an unspecified 'content'.
|
ADeeOutput |
Simple bean representing a Data Extraction Engine output.
|
ADeeOutputColumn |
Base implementation for any Data Extraction Engine output column.
|
ADeeTask |
Base (abstract) implementation of a Data Extraction Service task.
|
ADeeTaskExtractionProcedure |
|
ADeeTaskFactory |
|
ADeeTaskResultInfo |
Bean holding Data Extraction Engine generic result information.
|
ADlcHealthEvent |
|
ADlcTest |
Generic implementation of a Testing environment for running Load-Specific tests (formally know as DLC).
|
ADlcWebApplication |
|
ADrillthroughQueryDeeTask |
|
AEnhancedDrillthroughService |
|
AEnhancedDrillthroughServicesConfig |
Spring JavaConfig of the Enhanced Drill-through service.
|
AExecutionTask |
Abstract execution task.
|
AGetAggregateQueryDeeTask |
Data Extraction Service task for Get Aggregates Query operation.
|
AJdbcPreparedStatementTask<E> |
|
AJdbcPreparedStatementTask.Result |
|
AJsonDeeOrderConversion |
Proceed to the conversion of the DEE JSON classes to the "traditional" DEE classes.
|
AJsonDeeOutput |
The base JSON DEE output implementation.
|
AJsonDeeOutputColumn |
The JSON DEE output column.
|
AJsonDrillthroughQuery |
The base JSON drill-through query implementation
|
AJsonQuery |
The base JSON query implementation
|
ALocationsQueryDeeTask |
Base (abstract) implementation of a Data Extraction Service task for Locations Query operation.
|
AMdxQueryDeeTask |
Data Extraction Service task for MDX Query operation.
|
AMdxQueryDeeTask.TupleLocation |
Helps to transform an ITuple object to a ILocation .
|
AOutputHandler |
Abstract output handler
|
AParquetFileTask<E> |
|
AParquetFileTask.Result |
|
ARemoveFactsQueryDeeTask |
|
ARequestHelper |
Sends JSON to a DEE / DEE Rest endpoint
|
ArrayAsTroveListGenericDatumReader |
A EnhancedGenericDatumReader that uses TIntArrayList , TLongArrayList , TFloatArrayList
and TDoubleArrayList Java types to materialize values when reading schema type array for
element type int, long, float and double (respectively).
|
ASearchFactsQueryDeeTask |
|
ASecurityConfig |
Class taken from 5.9.0 Sandbox project.
|
ASecurityConfig.AWebSecurityConfigurer |
Common configuration for HttpSecurity .
|
ATemplatePlaceholderHelper |
|
AvroCompactArrayUtils |
Collection of utility methods to handle 'SparseVector' in ActivePivot based on Avro 'CompactArray' records.
|
AvroFilesScopedFetchSource |
|
AvroFilesScopedFetchSource.ChannelFetchFuture |
|
AvroFilesScopedFetchSource.ChannelFetchScope |
|
AvroFilesScopedFetchSource.LogMessages |
|
AvroFilesScopedFetchTopic |
|
AvroFileTask |
Generic blank implementation of an Avro Task
|
AXmlBasedDeeOrderBuilder |
Base (abstract) implementation for a Data Extraction Engine order builder, which is based on JAXB unmarshalling of a given XML
description of DEE order.
|
AzureCsvScopedFetchSource<F> |
Fetches from an Azure CSV Blob file.
|
AzureCsvScopedListenSource |
Listens to an Azure CSV Blob file.
|
BasePublisher |
Tuple publisher which is used inside other tuple publishers.
|
BufferedCSVOutputStream |
Managed stream implementation of GZIPOutputStream for ensuring an optimal generation of a single-entry archive file.
|
BufferedGZipOutputStream |
Managed stream implementation of GZIPOutputStream for ensuring an optimal generation of a single-entry archive file.
|
BufferedSingleEntryZipOutputStream |
Managed stream implementation of ZipOutputStream for ensuring an optimal generation of a single-entry archive file.
|
CloudTestingUtils |
|
CompositeDeeOrder |
Simple bean representing a composite Data Extraction Engine order.
|
CompressionType |
Type of compression available when using the output to file.
|
CompressionTypeAdapter |
|
CsvCloudScopedFetchTopic<E> |
|
CsvCloudScopedListenTopic<E> |
|
CsvDataExtractionEngineConfig |
|
CsvDataExtractionRestService |
|
CsvDataExtractionRestServicesConfig |
|
CsvDataExtractionService |
|
CsvDataExtractionServicesConfig |
Spring JavaConfig of the Data Extraction Engine service.
|
CsvDeeTaskFactory |
|
CsvDrillthroughQueryDeeTask |
DEE task for executing a DrillthroughQuery .
|
CsvEnhancedDrillthroughService |
|
CsvEnhancedDrillthroughServicesConfig |
|
CSVFileListener<I> |
Listener for changes on one file or one directory and its inner elements.
|
CsvFilesScopedFetchTopic |
|
CsvFilesScopedListenTopic |
Default implementation of a CSV real time data-loading topic.
|
CsvFilesScopedListenTopic.FileScanParameters |
|
CsvFilesScopedListenTopic.ScopeToFileScanParametersConverter |
|
CsvGetAggregateQueryDeeTask |
Data Extraction Service task for Get Aggregates Query operation for an InMemory Data Extraction.
|
CsvJsonDeeOrderConversion |
Proceed to the conversion of the DEE JSON classes to the "traditional" DEE classes for a CSV source.
|
CsvMdxQueryDeeTask |
Data Extraction Service task for MDX Query operation.
|
CsvRemoveFactsQueryDeeTask |
|
CsvSearchFactsQueryDeeTask |
|
CsvTemplatePlaceholderHelper |
|
CubeConfig |
Configuration for the "EquityDerivativesCube"
ActivePivot instance.
|
CubeDimensionsConfig |
|
CubeMeasuresConfig |
|
CustomJsonConditionCompiler |
Custom version of the JsonConditionCompiler to simply convert the JSON content to a
ICondition object without applying any validation
|
CustomKafkaAvroDeserializerGenericRecord |
Customize the deserialize method to reuse GenericDatumReader.
|
CustomKafkaAvroDeserializerObjectTuple |
Customize the deserialize method to reuse GenericDatumReader and GenericObject.
|
DataAccessSecurityConfig |
Spring-IOC configuration of ActivePivot data access control security.
|
DataConnectorsRestVersion |
Rest endpoint version of Data-Connectors.
|
DataExtractionRemotingServicesConfig |
Spring JavaConfig to expose the DEE and Enhanced Drill-through as Spring HTTP-remoting services.
|
DataExtractionRemotingServicesConfig |
Spring JavaConfig to expose the DEE and Enhanced Drill-through as Spring HTTP-remoting services.
|
DataExtractionServiceException |
Exception thrown when a method of Data Extraction Service fails to execute.
|
DataExtractionServiceLogMessages |
Log messages for ActivePivot DEE (Data Extraction Service) services operations.
|
DataExtractionWebServicesConfig |
Spring JavaConfig to expose the DEE and Enhanced Drill-through services as CXF web-services.
|
DataExtractionWebServicesEndPoints |
List of end points for the Data Extraction web-services.
|
DataLoadController |
|
DataLoadController.TopicControllerDelegates |
|
DataLoadControllerConfig |
Configure a data load controller.
|
DataLoadControllerRequest |
|
DataLoadControllerResponse |
A simple POJO to store response related information.
|
DataLoadControllerRestService |
|
DataLoadControllerRestServiceConfig |
Configure a Rest service to allow remote control of data loading in ActivePivot.
|
DatastoreDescriptionConfig |
An IActivePivotManagerDescriptionConfig that creates the ActivePivot manager description for the Sandbox
application.
|
DataStoreNames |
Default Datastores defines two stores, Trade and Products.
|
DeeException |
Exception thrown whenever there is a failure during internal processing operations related to the Data Extraction (DEE) activity.
|
DeeFutureTask |
Cancellable asynchronous computation for tailor-made Data Extraction Engine task management.
|
DeeLogMessages |
Log messages for ActivePivot DEE (Data Extraction Service) operations.
|
DeeOrder |
Simple bean representing a Data Extraction Engine order.
|
DeeOrderPriority |
Enumeration of possible Data Extraction Engine order priorities.
|
DeeOutputAdapter |
|
DeeOutputColumnAdapter |
|
DeeOutputColumnsWrapper |
|
DeeOutputColumnsWrapperAdapter |
|
DeeOutputConstants |
List of the default values used for the DEE output configuration
|
DeeOutputExtractionProcedureWrapper |
Wrapper usable for JAXB custom marshaling.
|
DeeOutputExtractionProcedureWrapperAdapter |
|
DeeQueriesWrapper |
Wrapper of a List of IQuery instances, usable for JAXB custom marshaling.
|
DeeQueriesWrapperAdapter |
|
DeeRequestHelper |
|
DeeResultFileInfoDTO |
DTO for Data Extraction Engine result file information.
|
DeeTaskExtractionProcedureAdapter |
|
DeeTaskInfo |
Bean holding Data Extraction Engine task information.
|
DeeTaskInfoDTO |
DTO for Data Extraction Engine task information.
|
DeeTaskStatus |
Enumeration of the possible Data Extraction Engine task execution statuses.
|
DeeTaskStatusChangeEvent |
Event notifying a change of Data Extraction Engine task status.
|
DeeTaskWithTaskStatusListenersWrapper |
|
DeeThreadPoolExecutor |
Custom thread pool executor implementation for Data Extraction Engine tasks management.
|
DefaultDeeOrderBuilder |
Default implementation for a Data Extraction Engine order builder, which is based on JAXB unmarshalling of a given XML description of
DEE order.
|
DlcCacheHelper |
Helper utility class to interacting with the DLC cache for IHealthEvent .
|
DlcCacheManager |
Singleton class that ensures only one instance of DLC cache exists.
|
DlcCsvHealthEvent |
|
DlcCsvHealthEventHandler |
Default event handler used by the DLC to handle CSV source events.
|
DlcEventTypeConstants |
Class for various DlcEventType related constants
|
DlcException |
|
DlcExceptionHealthEvent |
A generic exception event
|
DlcFormatter |
|
DlcMessagingFailureHealthEvent |
A generic failure event to handle exceptions and/or failures encountered
when listening to a MessagingTopic .
|
DlcMessagingHealthEventHandler |
|
DlcMessagingSummaryHealthEvent |
A summary health event
|
DlcMessagingTaskDoneHealthEvent |
A generic messaging health event that can be fired to indicate when a task is completed
when listening to a MessagingTopic .
|
DlcNoStatusHealthEvent |
No status health event
|
DlcParquetHealthEventHandler |
|
DlcRequestHelper |
Sends load/unload operations on a given topic through a remote DLC request.
|
DlcSummaryHealthEvent |
A summary health event
|
DlcSummaryHealthEventHandler |
|
DlcUnloadHealthEvent |
An unload health event
|
EchoDeeOutputColumn |
Implementation for a Data Extraction Engine output column that returns a pre-defined constant value.
|
EnhancedDrillthroughLogMessages |
Log messages for the custom enhanced drill-through web-services operations.
|
EnhancedDrillthroughMaxRowsContext |
Context value for the enhanced drillthrough max rows configuration.
|
EnhancedDrillthroughRestService |
Defines the RESTful bridge over the Enhanced Drill-through Rest service
|
EnhancedDrillthroughRestServicesConfig |
Spring JavaConfig of the Enhanced Drill-through REST services required in any custom ActivePivot server project.
|
EnhancedDrillthroughResultFileInfoDTO |
DTO for Enhanced Drill-through result file information.
|
EnhancedDrillthroughTaskInfoDTO |
DTO for Enhanced drill-through task information.
|
EnhancedGenericData |
Enhanced implementation of Avro core GenericData specifically for usage with GenericDatumReader .
|
EnhancedGenericData.Record |
Enhanced generic record implementation.
|
EnhancedGenericDatumReader |
Extend Avro core implementation of generic datum reader with leverage of EnhancedGenericData (by
default), and optional collection/logging of detailed statistics (read objects count) about reader activity.
|
EnhancedJustInTimeConditions |
Duplication of com.qfs.pivot.cube.provider.jit.impl.JustInTimeConditions to handle java.util.Date.
|
ExtractionProcedureValueDeeOutputColumn |
Implementation for a Data Extraction Engine output column that maps to a particular value computed or retrieved by an extraction
procedure
|
FieldDeeOutputColumn |
Implementation for a Data Extraction Engine output column that maps to a particular field retrieved during a tabular query (e.g.
|
FileDeeOutput |
Simple bean representing a Data Extraction Engine output writing into files.
|
FileDeeTaskResultFileInfo |
Bean holding Data Extraction Engine result file information.
|
FileDeeTaskResultInfo |
Bean holding Data Extraction Engine file result information.
|
FilesScopedFetchTopic |
|
FilesScopedFetchTopic.FetchScopeToFileScanParametersConverter |
|
FilesScopedFetchTopic.FileScanParameters |
|
GcpCsvScopedFetchSource<F> |
Fetches from a S3 CSV file.
|
GcpCsvScopedListenSource<F> |
Listens to a Google Cloud Storage CSV bucket.
|
GenericPublisher<I> |
|
IArchiveOutputStream |
|
IAvroFileSource |
Contract for a source that can load data from Avro files in ActivePivot.
|
IAvroFileSource.IChannelFetchFuture |
Contract for a Future that represents the pending completion of an asynchronous fetch operation for a given scope
that was submitted to an Avro file source .
|
IAvroFileSource.IChannelFetchScope |
Contract for a set of parameters that defines a fetch operation to be executed by an Avro file source for a given data scope in a
given Avro channel .
|
IAvroFilesScopedFetchTopic |
Contract for a topic of a source that can fetch Avro files to load data in ActivePivot.
|
IAzureCsvConnector |
Contract that defines a connector for Azure CSV files.
|
ICloudCsvConnector<E> |
Cloud connector general implementation for loading CSV data from cloud storage.
|
ICloudsScopedFetchTopic<E> |
Contract for a topic of a source that can fetch files to load data in ActivePivot.
|
ICloudsScopedListenTopic<E> |
Contract for a topic of a source that can listen files to load data in ActivePivot.
|
ICloudsScopedTopic<E> |
Contract for a topic of a source that can process files to load data in ActivePivot.
|
ICompositeDeeOrder |
Interface for a composite Data Extraction Engine order.
|
ICsvScopedFetchSourceConfig<I> |
Configuration of the CSV source that supports scoped fetching.
|
IDataExtractionRestService |
Defines the Data Extraction service methods exposed via RESTful API.
|
IDataExtractionService |
Interface definition for a custom service allowing remote clients to trigger asynchronous batched data extraction tasks that produce the results on server
side, with dedicated URLs assigned for possible download by the remote clients later on.
|
IDataLoadController |
Contract for a component that controls data loading/unloading operations in ActivePivot.
|
IDataLoadController.IExecutionRequest |
|
IDataLoadController.IExecutionTask |
|
IDataLoadController.IScopeToRemoveWhereConditionConverter |
Contract for a supplier of remove-where condition to apply to a particular target store given
a particular business scope (for a particular data removal execution).
|
IDataLoadControllerRestService |
Contract for a Rest (JAX-RS) Web-Service that allows remote clients to trigger some data loading/unloading on this
ActivePivot server.
|
IDataLoadSourceHealthEventHandler |
DLC parent interface for Health Event Handlers.
|
IDataSource<I,E> |
Contract for a source that can fetch or listen to data for a specific scope that is specified at runtime
for each fetch or listen operation.
|
IDeeOrder |
Interface for a Data Extraction Engine order.
|
IDeeOrderBuilder |
Interface of a Data Extraction Engine order builder.
|
IDeeOutput |
Interface for a Data Extraction Engine generic output.
|
IDeeOutputColumn |
Interface for any Data Extraction Engine output column.
|
IDeeTask |
Interface for a Data Extraction Engine task.
|
IDeeTaskExtractionProcedure |
Interface for a procedure to process query results during data extraction.
|
IDeeTaskFactory |
Interface for a factory creating Data Extraction Engine tasks.
|
IDeeTaskInfo |
Interface for a bean holding Data Extraction Engine task information.
|
IDeeTaskResultInfo |
Interface for a bean holding Data Extraction Engine generic result information.
|
IDeeTaskStatusChangeEvent |
Interface for an event notifying a change of Data Extraction Engine task status.
|
IDeeTaskStatusListener |
Interface for a listener to updates of a Data Extraction Engine task status.
|
IDeeTaskWithTaskStatusListenersWrapper |
|
IDlcCsvHealthEvent |
|
IDlcHealthEvent |
|
IDlcMessagingHealthEvent |
Contract for an event that will be generated by MessagingSource like
kafka, RabbitMQ, ActiveMQ etc.
|
IDlcTopic |
Topic which can contain extra properties that can be used by all DLC topics.
|
IEnhancedDrillthroughMaxRowsContext |
Interface of context value for the enhanced drillthrough max rows configuration.
|
IEnhancedDrillthroughRestService |
Defines the Enhanced Drill-through service methods exposed via RESTful API
|
IEnhancedDrillthroughService |
Interface definition for enhanced drill-through service contract.
|
IFactsQuery |
Query that search in a schema indexer (providing contributions to the specified cube) for facts matching with a particular IFilterDescription .
|
IFetchingDataSource<I,E> |
Contract for a source that can fetch data for a specific scope that is specified at runtime for each fetch iteration.
|
IFileDeeOutput |
Interface for a Data Extraction Engine file output.
|
IFileDeeTaskResultFileInfo |
Interface for a bean holding Data Extraction Engine result file information.
|
IFileDeeTaskResultInfo |
Interface for a bean holding Data Extraction Engine file result information.
|
IFilesScopedFetchTopic |
|
IFilesScopedTopic |
Contract for a topic of a source that can fetch files and listen to directories to load data in ActivePivot.
|
IFilesScopedTopic.IFileScanParameters |
Contract for file scan parameters
|
IFilesScopedTopic.IScopeToFileScanParametersConverter |
Contract for a converter of a fetch scope into file scan parameters
|
IFileTask<I,E> |
Contract for a task that a files source may execute to load data in ActivePivot.
|
IFileTask.IResult |
Contract for a result produced by a IFileTask .
|
IGoogleCsvConnector |
Connector to fetch CSV files from a Google cloud instance.
|
IJdbcHealthEvent |
|
IJdbcScopedFetchSource |
Contract for a source that can load data from a Database into ActivePivot, based on SQL statements (defined via
source topics) and fetch business scopes, which are defined at fetch time to derive the SQL input parameters
required for injection into those statements.
|
IJdbcScopedFetchTopic |
Contract for a topic of a source that can fetch a DB to load data in ActivePivot.
|
IJdbcScopedFetchTopic.IScopeToSqlParametersConverter |
Contract for a converter of a business scope (for a particular statement task execution) into the relevant
SQL input parameters (given the JDBC statement topic that this tasks relates to).
|
IJdbcSourceHealthEventHandler |
An health event handler dedicated to
handling health events declared in the JDBC Source project.
|
IJdbcStatementTask<I,E> |
Contract for a task that a JDBC source may execute to process a given Statement SQL statement to retrieve
data from a Database and load them in ActivePivot.
|
IJdbcStatementTask.IResult |
|
IJsonDeeOrderConversion |
|
IListeningDataSource<I,E> |
Contract for a source that can consume data from a messaging source like Apache Kafka, RabbitMQ, and can stay connected and "listen" for real-time data.
|
ILocalDataExtractionService |
Interface extension for a local IDataExtractionService (web-service interface contract), which provides additional methods that are reserved
for AP server internal usage (e.g.
|
ILocalEnhancedDrillthroughService |
Interface extension for a local IEnhancedDrillthroughService (web-service interface contract), which provides additional methods that are
reserved for AP server internal usage (e.g.
|
IMemoryDeeOutput |
Interface for a Data Extraction Engine memory output.
|
IMemoryDeeTaskResultInfo |
Interface for a bean holding Data Extraction Engine memory result information.
|
IMemoryOutputHandler |
Defines the interface for the output handler keeping data in memory
|
IMessagingConsumer |
Contract for implementing consumers for remote messaging topic or queue.
|
IMessagingSourceHealthEventHandler |
A health event handler dedicated to
handling health events generated by a MessagingSource
|
IMessagingTopic |
Contract for a topic of the Messaging Source.
|
InitialDataLoadConfig |
Configure the (optional - env property driven) initial data load, which takes place at application startup.
|
InLineVectorValuesExtractionProcedure |
DEE extraction procedure allowing to do the VectorSerializerPostProcessor processing on the DEE side instead of in the cube.
It is only done for all the internal IVector objects coming from the cube.
|
InMemoryDataExtractionEngineConfig |
|
InMemoryDataExtractionRestApplication |
|
InMemoryDataExtractionRestApplication.MockConfig |
|
InMemoryDataExtractionRestService |
|
InMemoryDataExtractionRestServicesConfig |
|
InMemoryDataExtractionService |
|
InMemoryDataExtractionServicesConfig |
Spring JavaConfig of the Data Extraction Engine service.
|
InMemoryDeeOutput |
Default bean representing a Data Extraction Engine output keeping the data in memory.
|
InMemoryDeeTaskFactory |
|
InMemoryDrillthroughQueryDeeTask |
DEE task for executing a DrillthroughQuery .
|
InMemoryEnhancedDrillthroughService |
|
InMemoryEnhancedDrillthroughServicesConfig |
|
InMemoryGetAggregateQueryDeeTask |
Data Extraction Service task for Get Aggregates Query operation for an InMemory Data Extraction.
|
InMemoryJsonDeeOrderConversion |
Proceed to the conversion of the DEE JSON classes to the "traditional" DEE classes.
|
InMemoryMdxQueryDeeTask |
Data Extraction Service task for MDX Query operation.
|
InMemoryRemoveFactsQueryDeeTask |
|
InMemorySearchFactsQueryDeeTask |
|
InMemoryTemplatePlaceholderHelper |
|
InMemoryUserDetailsManagerBuilder |
An In-memory UserDetailsService builder which can be used without
AuthenticationManagerBuilder contrary to InMemoryUserDetailsManagerConfigurer .
|
IOutputHandler |
Defines the methods exposed by an output handler implementation
|
IParquetTopic<I> |
Contract for a topic of the Parquet Source.
|
IRemoveFactsQuery |
Query that remove from a schema indexer (providing contributions to the specified cube) the facts matching with a particular
IFilterDescription .
|
IS3CsvConnector |
Contract for a S3 cloud connector for CSV files.
|
ISearchFactsQuery |
Query that search in a schema indexer (providing contributions to the specified cube) for facts matching with a particular IFilterDescription .
|
ISummaryHealthEventHandler |
An health event handler dedicated to
handling health events for summary messages.
|
ITupleSource |
Contract for a source that produces Object[] tuples.
|
JdbcFailureHealthEvent |
A generic failure event to handle JDBC related exceptions and/or failures.
|
JdbcHealthEventHandler |
|
JdbcPreparedStatementTask |
|
JdbcScopedFetchSource |
|
JdbcStatementTopic |
|
JdbcStatementTopic.ScopeToSqlParametersConverter |
|
JdbcTaskDoneHealthEvent |
|
JsonDeeOrder |
The JSON DEE order.
|
JsonDeeOrderConversionManager |
Manager is responsible for creating a source specific implementation of IJsonDeeOrderConversion converter through
a provided sourceName.
|
JsonDeeTaskExtractionProcedure |
The JSON file DEE output extraction procedure.
|
JsonDlcFormatter |
|
JsonDrillthroughQuery |
The JSON Drill-through query.
|
JsonEchoDeeOutputColumn |
The JSON echo DEE output column.
|
JsonExtractionProcedureValueDeeOutputColumn |
The JSON extraction procedure value DEE output column.
|
JsonFieldDeeOutputColumn |
The JSON field DEE output column.
|
JsonFileDeeOutput |
The JSON file DEE output.
|
JsonGetAggregatesQuery |
The JSON Get Aggregates query.
|
JsonLevelDeeOutputColumn |
The JSON level DEE output column.
|
JsonLowestLevelDeeOutputColumn |
The JSON lowest level DEE output column.
|
JsonMdxDrillthroughQuery |
The JSON MDX Drill-through query.
|
JsonMdxQuery |
The JSON MDX query.
|
JsonMeasureDeeOutputColumn |
The JSON measure DEE output column.
|
JsonSearchFactsQuery |
The JSON Search Facts query.
|
JsonTemplateOrder |
The JSON template order.
|
KafkaJsonDeserializer |
Deserialize bytes from kafka to a JsonNode
and form an Object[] tuple from the JsonNode.
|
KafkaMessageConsumer |
A wrapper over KafkaConsumer to process records from a Kafka topic, and submit to a datastore.
|
LevelDeeOutputColumn |
Implementation for a Data Extraction Engine output column that maps to a particular hierarchy and level retrieved during an aggregate
query (e.g.
|
LoadDataTxControllerTask |
A IDataLoadController.IExecutionTask that loads data related to one or multiple topics and a particular
business scope, within the boundaries of a single Datastore transaction.
|
LocalContentServiceConfig |
Spring configuration of the Content Service.
|
LocalCsvScopedFetchSource<F> |
Fetches from a local CSV file.
|
LocalCsvScopedListenSource |
CSV module's local implementation of a Scoped Listen Source
|
LocaleAdapter |
Adapter for custom JAXB (un/)marshaling between a String and a Locale .
|
LoggingDeeTaskStatusListener |
Data Extraction Engine task status listener that simply generates logs.
|
LoggingUtils |
FIXME remove this once we have a shared lib with APM
Miscellaneous utilities for logging purpose.
|
LowestLevelDeeOutputColumn |
Implementation for a Data Extraction Engine output column that maps the lowest level expressed for a particular hierarchy
retrieved during an aggregate query (e.g.
|
MeasureDeeOutputColumn |
Implementation for a Data Extraction Engine output column that maps to a particular measure retrieved during an aggregate query (e.g.
|
MessagingSource |
MessagingSource to poll topics in a remote messaging system, for eg.
|
MessagingTopic |
Topic that listens for records from a messaging system, for eg.
|
MultipleResultFileOutputHandler |
Manage the writing of data rows (given by blocks) into one or multiple (if necessary) zipped CSV files.
|
MutableArrayElementGenericDatumReader |
A EnhancedGenericDatumReader that uses MutableInt , MutableLong , MutableFloat ,
MutableDouble and MutableBoolean Java types to materialize values when reading schema type
int, long, float, double and boolean (respectively) for array
elements.
|
ParquetFileListener<I> |
Listen for created and / or modified parquet files, parsing them for submitting the records to datastore.
|
ParquetFileTask |
Generic blank implementation of an Parquet Task for Topic implementation
|
ParquetSource<I> |
Parquet implementation of ITupleSource and IFetchingDataSource
|
ParquetSource.ChannelFetchFuture |
Contract for a Future that represents the pending completion of an asynchronous fetch operation for a given scope
|
ParquetSource.ChannelFetchScope |
|
ParquetTopic<I> |
Contract for a topic of the Parquet Source.
|
PivotDefinitionHelper |
Helper allowing to validate and retrieve the level and measure definitions from a cube
|
RabbitMqMessageConsumer |
Consume messages from a RabbitMQ queue.
|
ReadTupleFieldColumnCalculator |
Column calculator that extracts values for a particular column in the given (source) Object[] tuple, based
on the column index that has been configured at construction time.
|
RemoveFactsQuery |
|
RemoveFactsQueryAdapter |
|
RetrieveSearchFactQueryResultsMessage |
Message implementation for a distributed retrieval operation of the search fact query results
|
S3CsvScopedFetchSource<F> |
Fetches from a S3 CSV file.
|
S3CsvScopedListenSource |
Listens to a S3 CSV bucket.
|
SearchFactsQuery |
|
SearchFactsQueryAdapter |
|
SecurityConfig |
Spring configuration fragment for security.
|
SecurityConfig.ActivePivotSecurityConfigurer |
To expose the Pivot services
|
SecurityConfig.ContentServerSecurityConfigurer |
Only required if the content service is exposed.
|
SecurityConfig.JwtSecurityConfigurer |
Only required if Live 4 use the embedded content server.
|
SecurityConfig.VersionSecurityConfigurer |
To expose the Version REST service.
|
SimpleMemoryDeeTaskResultInfo |
Simple memory DEE task result information which return a generic Object
|
SimpleMemoryOutputHandler |
Simple memory output handler only grabbing the first object from the row.
|
SparseVectorUtils |
Collection of utility methods to handle 'SparseVector' storage in ActivePivot.
|
SparseVectorUtils.SparseVectorRepresentation |
|
StartListeningControllerTask |
|
StopListeningControllerTask |
|
StoreToTaskNameMapperManager |
Manages a single static instance of Stores to TaskNames mapping.
|
StringFormatter |
|
TestAppConfig |
Abstract Spring configuration of the ActivePivot Sandbox application.
|
TraceableExecutorThreadFactory |
Thread factory for creating new traceable task threads.
|
TraceableParquetParser |
Traceable component that parses a parquet file and loads it into the datastore.
|
TraceableParquetParserBuilder |
A tracable implementation of ParquetParserBuilder .
|
TransactionTaskUtil |
Utility class for Tx Controller Task
|
TupleMessageChannelFactory |
A factory for low-translation-overhead message channels that connect a source producing
Object[] tuples to a store in ActivePivot Datastore.
|
TupleToTupleTranslator |
A translator that produces a 'target' Object[] tuple based on a 'source' Object[] tuple.
|
TxSizeController |
Drain the AP topic's internal publishQueue, and submit records to datastore.
|
TxSizeController.LogMessageOutputStream |
|
TxSizeController.PublishTask<E> |
|
UnloadDataTxControllerTask |
A IDataLoadController.IExecutionTask that unloads data related to one or multiple topics and a particular
business scope, within the boundaries of a single Datastore transaction.
|
VectorSerializerPostProcessor |
Generate a simple serialized representation for a double aggregated IVector (the underlying measure).
|