All Classes Interface Summary Class Summary Enum Summary
| Class |
Description |
| AbstractBaseAdminCommand |
Super class for all the commands.
|
| AbstractBaseCommand |
|
| AddSchemaCommand |
|
| AddTableCommand |
Class to implement CreateResource command.
|
| AddTenantCommand |
|
| Aggregation |
|
| AggregationFunc |
|
| AggregationFuncFactory |
|
| AirlineDataStream |
This is used in Hybrid Quickstart.
|
| AnonymizeDataCommand |
|
| ArrayBasedGlobalDictionaries |
|
| AuthQuickstart |
|
| AutoAddInvertedIndexTool |
|
| AvgFunction |
|
| AvroSchemaToPinotSchema |
Class for command to convert avro schema to pinot schema.
|
| BackfillSegmentUtils |
Contains APIs which are used for backfilling the pinot segments with dateTimeFieldSpec
|
| BatchQuickstartWithMinion |
|
| BootstrapTableCommand |
The command to bootstrap a Pinot table from a directory with table schema/config/ingestionJobSpec/raw data files.
|
| BootstrapTableTool |
|
| ChangeNumReplicasCommand |
|
| ChangeTableState |
|
| ClusterStarter |
|
| ClusterStateVerifier |
|
| Command |
Interface class for pinot-admin commands.
|
| CountFunction |
|
| CreateSegmentCommand |
Class to implement CreateSegment command.
|
| DeleteClusterCommand |
|
| DictionaryToRawIndexConverter |
Class to convert segment with dictionary encoded column to raw index (without dictionary).
|
| DistinctCountFunction |
|
| EqualsPredicateFilter |
|
| GenerateDataCommand |
Class to implement GenerateData command.
|
| GenericQuickstart |
Sets up a demo Pinot cluster with 1 zookeeper, 1 controller, 1 broker and 1 server
Sets up a demo Kafka cluster for real-time ingestion
It takes a directory as input
rawData
- 1.csv
table_config.json
schema.json
ingestion_job_spec.json
|
| GitHubAPICaller |
Helper class to make http calls to GitHub API
|
| GitHubEventsQuickstart |
Sets up a demo Pinot cluster with 1 zookeeper, 1 controller, 1 broker and 1 server
Sets up a demo Kafka cluster, and creates a topic pullRequestMergedEvents
Creates a realtime table pullRequestMergedEvents
Starts the PullRequestMergedEventsStream to publish pullRequestMergedEvents into the topic |
| GitHubEventsQuickStartCommand |
Command to run GitHubEventsQuickStart
|
| GlobalDictionaries |
|
| GroupByOperator |
|
| HybridQuickstart |
|
| ImportDataCommand |
Class to implement ImportData command.
|
| InPredicateFilter |
|
| JarUtils |
|
| JoinQuickStart |
|
| JsonIndexQuickStart |
|
| JsonToPinotSchema |
Class for command to infer pinot schema from Json data.
|
| KafkaStarterUtils |
|
| LaunchDataIngestionJobCommand |
Class to implement LaunchDataIngestionJob command.
|
| MapBasedGlobalDictionaries |
|
| MaxFunction |
|
| MeetupRsvpJsonStream |
|
| MeetupRsvpStream |
|
| MinFunction |
|
| MinMaxRangeFunction |
|
| MoveReplicaGroup |
Command to migrate a subset of replica group from current servers to the provided destination servers.
|
| NotInPredicateFilter |
|
| NotPredicateFilter |
|
| OfflineComplexTypeHandlingQuickStart |
|
| OfflineSegmentIntervalCheckerCommand |
Pinot admin command to list all offline segments with invalid intervals, group by table name
|
| OperateClusterConfigCommand |
|
| PartialUpsertQuickStart |
|
| PerfBenchmarkDriver |
|
| PerfBenchmarkDriverConf |
|
| PerfBenchmarkRunner |
|
| PinotAdministrator |
Class to implement Pinot Administrator, that provides the following commands:
System property: `pinot.admin.system.exit`(default to false) is used to decide if System.exit(...) will be called
with exit code.
|
| PinotBroker |
Simple shim so that jps -l shows PinotBroker instead of PinotAdministrator
|
| PinotConfigUtils |
|
| PinotController |
Simple shim so that jps -l shows PinotController instead of PinotAdministrator
|
| PinotDataAndQueryAnonymizer |
The goal of this tool is to generate test dataset (as Avro files) with
characteristics similar to a given source dataset.
|
| PinotDataAndQueryAnonymizer.FilterColumnExtractor |
*
Filter Column Extractor *
*
|
| PinotDataAndQueryAnonymizer.QueryGenerator |
*
QueryGenerator *
*
|
| PinotFSBenchmarkDriver |
|
| PinotFSBenchmarkRunner |
|
| PinotIdealstateChanger |
|
| PinotInstanceStatus |
|
| PinotMinion |
Simple shim so that jps -l shows PinotMinion instead of PinotAdministrator
|
| PinotNumReplicaChanger |
|
| PinotSegmentConvertCommand |
The PinotSegmentConvertCommand class provides tools to convert Pinot segments into another format.
|
| PinotSegmentConverter |
|
| PinotSegmentToAvroConverter |
The PinotSegmentToAvroConverter class is the tool to convert Pinot segment to AVRO format.
|
| PinotSegmentToCsvConverter |
The PinotSegmentToCsvConverter class is the tool to convert Pinot segment to CSV format.
|
| PinotSegmentToJsonConverter |
The PinotSegmentToJsonConverter class is the tool to convert Pinot segment to JSON format.
|
| PinotServer |
Simple shim so that jps -l shows PinotServer instead of PinotAdministrator
|
| PinotServiceManager |
PinotServiceManager is a user entry point to start Pinot instances in one process.
|
| PinotServiceManagerAdminApiApplication |
|
| PinotServiceManagerHealthCheck |
|
| PinotServiceManagerInstanceResource |
|
| PinotServiceManagerStarter |
Simple shim so that jps -l shows StartServiceManager instead of PinotAdministrator
|
| PinotServiceManagerStatusCallback |
|
| PinotTableRebalancer |
Helper class for pinot-admin tool's RebalanceTable command.
|
| PinotToolLauncher |
|
| PinotZKChanger |
This class provides utilities that change zookeeper state in a cluster
|
| PostQueryCommand |
|
| PredicateFilter |
|
| Projection |
|
| PullRequestMergedEvent |
Represents the pull request merged event
|
| PullRequestMergedEventsStream |
Creates a Kafka producer, for given kafka broker list
Continuously fetches github events data.
|
| QueryComparison |
|
| QueryComparison.ComparisonStatus |
|
| QueryComparisonConfig |
|
| QueryResponse |
|
| QueryRunner |
|
| QueryRunner.QuerySummary |
|
| Quickstart |
|
| Quickstart.Color |
|
| QuickStartBase |
|
| QuickStartCommand |
|
| QuickstartRunner |
|
| QuickstartTableRequest |
|
| RangePredicateFilter |
|
| RealtimeComplexTypeHandlingQuickStart |
|
| RealtimeJsonIndexQuickStart |
|
| RealtimeProvisioningHelperCommand |
Given a set of input params, output a table of num hosts to num hours and the memory required per host
|
| RealtimeQuickStart |
|
| RealtimeQuickStartWithMinion |
This quickstart shows how RealtimeToOfflineSegmentsTask and MergeRollupTask minion
tasks continuously optimize segments as data gets ingested into Realtime table.
|
| RebalanceTableCommand |
A sub-command for pinot-admin tool to rebalance a specific table
|
| ResultTable |
|
| ScanBasedQueryProcessor |
|
| SchemaValidator |
|
| SegmentDumpTool |
|
| SegmentInfoProvider |
Given a segments directory, pick all segments and read the dictionaries for all single-value dimension columns.
|
| SegmentProcessorFrameworkCommand |
|
| SegmentProcessorFrameworkSpec |
Container for all spec related to Segment Processor Framework required for running via pinot-admin
|
| Selection |
|
| ShowClusterInfoCommand |
|
| SpeedTest |
Compares perf between Heap, Direct and Memory Mapped
|
| StartBrokerCommand |
Class to implement StartBroker command.
|
| StartControllerCommand |
Class to implement StartController command.
|
| StartKafkaCommand |
Class for command to start Kafka.
|
| StartMinionCommand |
Class to implement StartMinion command.
|
| StarTreeIndexViewer |
|
| StarTreeIndexViewer.StarTreeViewRestResource |
|
| StarTreeQueryGenerator |
Given a list of dimension and metric columns, and possible values for dimension columns:
Generate queries of the form: SELECT SUM(m1), SUM(m2)...
|
| StartServerCommand |
Class to implement StartServer command.
|
| StartServiceManagerCommand |
Starts services in the following order, and returns false on any startup failure:
|
| StartZookeeperCommand |
Class for command to start ZooKeeper.
|
| StatsGenerator |
|
| StopProcessCommand |
Class for command to stop a process.
|
| StreamAvroIntoKafkaCommand |
Class for command to stream Avro data into Kafka.
|
| StreamGitHubEventsCommand |
Command to stream GitHub events into a kafka topic
|
| SumFunction |
|
| TableConfigValidator |
|
| UpdateSegmentState |
|
| UploadSegmentCommand |
Class for command to upload data into Pinot.
|
| UpsertJsonQuickStart |
|
| UpsertQuickStart |
|
| Utils |
|
| ValidateConfigCommand |
Class for command to validate configs.
|
| ValidateTableRetention |
|
| VerifyClusterStateCommand |
|
| VerifySegmentState |
|
| ZookeeperLauncher |
|