A B C D E F G H I J K L M N O P Q R S T U V W Z _

A

AbstractBaseAdminCommand - Class in org.apache.pinot.tools.admin.command

Super class for all the commands.

AbstractBaseAdminCommand(boolean) - Constructor for class org.apache.pinot.tools.admin.command.AbstractBaseAdminCommand

AbstractBaseAdminCommand() - Constructor for class org.apache.pinot.tools.admin.command.AbstractBaseAdminCommand

AbstractBaseCommand - Class in org.apache.pinot.tools

AbstractBaseCommand(boolean) - Constructor for class org.apache.pinot.tools.AbstractBaseCommand

AbstractBaseCommand() - Constructor for class org.apache.pinot.tools.AbstractBaseCommand

add(int, Object) - Method in class org.apache.pinot.tools.scan.query.ResultTable

addBootstrapService(ServiceRole, Map<String, Object>) - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

addDerivedValuesToGlobalDictionaries() - Method in class org.apache.pinot.tools.anonymizer.ArrayBasedGlobalDictionaries

This is the third and final step where we complete the global dictionaries by generating values: For numeric columns, we generate in order since we start with a base value.

addDerivedValuesToGlobalDictionaries() - Method in interface org.apache.pinot.tools.anonymizer.GlobalDictionaries

addDerivedValuesToGlobalDictionaries() - Method in class org.apache.pinot.tools.anonymizer.MapBasedGlobalDictionaries

This is the third and final step where we complete the global dictionaries by generating values: For numeric columns, we generate in order since we start with a base value.

addOrigValueToGlobalDictionary(Object, String, ColumnMetadata, int) - Method in class org.apache.pinot.tools.anonymizer.ArrayBasedGlobalDictionaries

First step towards building global dictionary by inserting the original values from segments into global dictionary

addOrigValueToGlobalDictionary(Object, String, ColumnMetadata, int) - Method in interface org.apache.pinot.tools.anonymizer.GlobalDictionaries

addOrigValueToGlobalDictionary(Object, String, ColumnMetadata, int) - Method in class org.apache.pinot.tools.anonymizer.MapBasedGlobalDictionaries

First step towards building global dictionary by inserting the original values from segments into global dictionary

AddSchemaCommand - Class in org.apache.pinot.tools.admin.command

AddSchemaCommand() - Constructor for class org.apache.pinot.tools.admin.command.AddSchemaCommand

addSegment(String, SegmentMetadata) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriver

Add segment while segment data is already in server data directory.

addTable() - Method in class org.apache.pinot.tools.admin.command.QuickstartRunner

AddTableCommand - Class in org.apache.pinot.tools.admin.command

Class to implement CreateResource command.

AddTableCommand() - Constructor for class org.apache.pinot.tools.admin.command.AddTableCommand

AddTenantCommand - Class in org.apache.pinot.tools.admin.command

AddTenantCommand() - Constructor for class org.apache.pinot.tools.admin.command.AddTenantCommand

aggregate(ResultTable) - Method in class org.apache.pinot.tools.scan.query.Aggregation

Aggregation - Class in org.apache.pinot.tools.scan.query

Aggregation(List<AggregationInfo>, List<String>, long) - Constructor for class org.apache.pinot.tools.scan.query.Aggregation

Aggregation(ImmutableSegment, SegmentMetadataImpl, List<Integer>, List<AggregationInfo>, List<String>, long) - Constructor for class org.apache.pinot.tools.scan.query.Aggregation

AggregationFunc - Class in org.apache.pinot.tools.scan.query

AggregationFuncFactory - Class in org.apache.pinot.tools.scan.query

AggregationFuncFactory() - Constructor for class org.apache.pinot.tools.scan.query.AggregationFuncFactory

AirlineDataStream - Class in org.apache.pinot.tools.streams

This is used in Hybrid Quickstart.

AirlineDataStream(Schema, TableConfig, File) - Constructor for class org.apache.pinot.tools.streams.AirlineDataStream

AnonymizeDataCommand - Class in org.apache.pinot.tools.admin.command

AnonymizeDataCommand() - Constructor for class org.apache.pinot.tools.admin.command.AnonymizeDataCommand

append(ResultTable) - Method in class org.apache.pinot.tools.scan.query.ResultTable

append(ResultTable.Row) - Method in class org.apache.pinot.tools.scan.query.ResultTable

apply(int) - Method in class org.apache.pinot.tools.scan.query.EqualsPredicateFilter

apply(int[], int) - Method in class org.apache.pinot.tools.scan.query.EqualsPredicateFilter

apply(int) - Method in class org.apache.pinot.tools.scan.query.InPredicateFilter

apply(int[], int) - Method in class org.apache.pinot.tools.scan.query.InPredicateFilter

apply(int) - Method in class org.apache.pinot.tools.scan.query.NotInPredicateFilter

apply(int[], int) - Method in class org.apache.pinot.tools.scan.query.NotInPredicateFilter

apply(int) - Method in class org.apache.pinot.tools.scan.query.NotPredicateFilter

apply(int[], int) - Method in class org.apache.pinot.tools.scan.query.NotPredicateFilter

apply(int) - Method in interface org.apache.pinot.tools.scan.query.PredicateFilter

apply(int[], int) - Method in interface org.apache.pinot.tools.scan.query.PredicateFilter

apply(int) - Method in class org.apache.pinot.tools.scan.query.RangePredicateFilter

apply(int[], int) - Method in class org.apache.pinot.tools.scan.query.RangePredicateFilter

ArrayBasedGlobalDictionaries - Class in org.apache.pinot.tools.anonymizer

AutoAddInvertedIndexTool - Class in org.apache.pinot.tools

AutoAddInvertedIndexTool() - Constructor for class org.apache.pinot.tools.AutoAddInvertedIndexTool

AvgFunction - Class in org.apache.pinot.tools.scan.query

AvroSchemaToPinotSchema - Class in org.apache.pinot.tools.admin.command

Class for command to convert avro schema to pinot schema.

AvroSchemaToPinotSchema() - Constructor for class org.apache.pinot.tools.admin.command.AvroSchemaToPinotSchema

AvroWriter - Class in org.apache.pinot.tools.data.generator

AvroWriter(File, int, Map<String, Generator>, Schema) - Constructor for class org.apache.pinot.tools.data.generator.AvroWriter

B

BackfillSegmentUtils - Class in org.apache.pinot.tools.backfill

Contains APIs which are used for backfilling the pinot segments with dateTimeFieldSpec

BackfillSegmentUtils(String, String) - Constructor for class org.apache.pinot.tools.backfill.BackfillSegmentUtils

BROKER_ID - Static variable in class org.apache.pinot.tools.utils.KafkaStarterUtils

buildGlobalDictionaries() - Method in class org.apache.pinot.tools.anonymizer.PinotDataAndQueryAnonymizer

* Global Dictionary Builder * *

C

callAPI(String) - Method in class org.apache.pinot.tools.streams.githubevents.GitHubAPICaller

Calls the given url

callEventsAPI(String) - Method in class org.apache.pinot.tools.streams.githubevents.GitHubAPICaller

Calls the events API

cartesianProduct(List<List<Object>>) - Static method in class org.apache.pinot.tools.scan.query.Utils

changeNumReplicas(String) - Method in class org.apache.pinot.tools.PinotNumReplicaChanger

ChangeNumReplicasCommand - Class in org.apache.pinot.tools.admin.command

ChangeNumReplicasCommand() - Constructor for class org.apache.pinot.tools.admin.command.ChangeNumReplicasCommand

ChangeTableState - Class in org.apache.pinot.tools.admin.command

ChangeTableState() - Constructor for class org.apache.pinot.tools.admin.command.ChangeTableState

cleanup() - Method in class org.apache.pinot.tools.AbstractBaseCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.AddSchemaCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.AddTableCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.ChangeTableState

cleanup() - Method in class org.apache.pinot.tools.admin.command.DeleteClusterCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.GenerateDataCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.GitHubEventsQuickStartCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.MoveReplicaGroup

cleanup() - Method in class org.apache.pinot.tools.admin.command.OfflineSegmentIntervalCheckerCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.OperateClusterConfigCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.PostQueryCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.QuickStartCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.SegmentProcessorFrameworkCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.StartBrokerCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.StartControllerCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.StartMinionCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.StartServerCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.StartZookeeperCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.StopProcessCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.StreamGitHubEventsCommand

cleanup() - Method in class org.apache.pinot.tools.admin.command.UploadSegmentCommand

clone() - Method in class org.apache.pinot.tools.scan.query.ScanBasedQueryProcessor

close() - Method in class org.apache.pinot.tools.data.generator.AvroWriter

close() - Method in class org.apache.pinot.tools.scan.query.ScanBasedQueryProcessor

clusterName - Variable in class org.apache.pinot.tools.PinotZKChanger

ClusterStarter - Class in org.apache.pinot.tools.query.comparison

ClusterStateVerifier - Class in org.apache.pinot.tools

ClusterStateVerifier(String, String) - Constructor for class org.apache.pinot.tools.ClusterStateVerifier

Command - Interface in org.apache.pinot.tools

Interface class for pinot-admin commands.

compare(JsonNode, JsonNode) - Static method in class org.apache.pinot.tools.query.comparison.QueryComparison

compare(JsonNode, JsonNode, boolean) - Static method in class org.apache.pinot.tools.query.comparison.QueryComparison

Some clients (eg Star Tree) may have different num docs scanned, but produce the same result.

compareAggregation(JsonNode, JsonNode) - Static method in class org.apache.pinot.tools.query.comparison.QueryComparison

compareWithEmpty(JsonNode, JsonNode) - Static method in class org.apache.pinot.tools.query.comparison.QueryComparison

configureHostName(Properties, String) - Static method in class org.apache.pinot.tools.utils.KafkaStarterUtils

configureOffsetsTopicReplicationFactor(Properties, short) - Static method in class org.apache.pinot.tools.utils.KafkaStarterUtils

configureTable(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriver

configureTable(String, List<String>, List<String>) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriver

configureTopicDeletion(Properties, boolean) - Static method in class org.apache.pinot.tools.utils.KafkaStarterUtils

convert() - Method in class org.apache.pinot.tools.segment.converter.DictionaryToRawIndexConverter

Method to perform the conversion for a set of segments in the DictionaryToRawIndexConverter._dataDir

convert() - Method in interface org.apache.pinot.tools.segment.converter.PinotSegmentConverter

Convert Pinot Segment into another format.

convert() - Method in class org.apache.pinot.tools.segment.converter.PinotSegmentToAvroConverter

convert() - Method in class org.apache.pinot.tools.segment.converter.PinotSegmentToCsvConverter

convert() - Method in class org.apache.pinot.tools.segment.converter.PinotSegmentToJsonConverter

convertSegment(File, String[], File, boolean) - Method in class org.apache.pinot.tools.segment.converter.DictionaryToRawIndexConverter

This method converts the specified columns of the given segment from dictionary encoded forward index to raw index without dictionary.

copyResourcesToDirectory(String, String, String) - Static method in class org.apache.pinot.tools.utils.JarUtils

Copies a directory from a jar file to an external directory.

CountFunction - Class in org.apache.pinot.tools.scan.query

createBrokerTenantWith(int, String) - Method in class org.apache.pinot.tools.admin.command.QuickstartRunner

CreateSegmentCommand - Class in org.apache.pinot.tools.admin.command

Class to implement CreateSegment command.

CreateSegmentCommand() - Constructor for class org.apache.pinot.tools.admin.command.CreateSegmentCommand

createServerTenantWith(int, int, String) - Method in class org.apache.pinot.tools.admin.command.QuickstartRunner

D

DataGenerator - Class in org.apache.pinot.tools.data.generator

Sep 12, 2014

DataGenerator() - Constructor for class org.apache.pinot.tools.data.generator.DataGenerator

DataGeneratorSpec - Class in org.apache.pinot.tools.data.generator

Sep 12, 2014

DataGeneratorSpec() - Constructor for class org.apache.pinot.tools.data.generator.DataGeneratorSpec

DataGeneratorSpec(List<String>, Map<String, Integer>, Map<String, IntRange>, Map<String, Map<String, Object>>, Map<String, FieldSpec.DataType>, Map<String, FieldSpec.FieldType>, Map<String, TimeUnit>, FileFormat, String, boolean) - Constructor for class org.apache.pinot.tools.data.generator.DataGeneratorSpec

DEFAULT_BROKER_ID - Static variable in class org.apache.pinot.tools.utils.KafkaStarterUtils

DEFAULT_CLUSTER_NAME - Static variable in class org.apache.pinot.tools.AbstractBaseCommand

DEFAULT_KAFKA_BROKER - Static variable in class org.apache.pinot.tools.utils.KafkaStarterUtils

DEFAULT_KAFKA_PORT - Static variable in class org.apache.pinot.tools.utils.KafkaStarterUtils

DEFAULT_SEGMENT_NAME - Static variable in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

DEFAULT_ZK_ADDRESS - Static variable in class org.apache.pinot.tools.AbstractBaseCommand

DEFAULT_ZK_STR - Static variable in class org.apache.pinot.tools.utils.KafkaStarterUtils

DEFAULT_ZK_TEST_PORT - Static variable in class org.apache.pinot.tools.utils.KafkaStarterUtils

DeleteClusterCommand - Class in org.apache.pinot.tools.admin.command

DeleteClusterCommand() - Constructor for class org.apache.pinot.tools.admin.command.DeleteClusterCommand

description() - Method in class org.apache.pinot.tools.admin.command.AddSchemaCommand

description() - Method in class org.apache.pinot.tools.admin.command.AddTableCommand

description() - Method in class org.apache.pinot.tools.admin.command.AddTenantCommand

description() - Method in class org.apache.pinot.tools.admin.command.AnonymizeDataCommand

description() - Method in class org.apache.pinot.tools.admin.command.AvroSchemaToPinotSchema

description() - Method in class org.apache.pinot.tools.admin.command.ChangeNumReplicasCommand

description() - Method in class org.apache.pinot.tools.admin.command.ChangeTableState

description() - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

description() - Method in class org.apache.pinot.tools.admin.command.DeleteClusterCommand

description() - Method in class org.apache.pinot.tools.admin.command.GenerateDataCommand

description() - Method in class org.apache.pinot.tools.admin.command.GitHubEventsQuickStartCommand

description() - Method in class org.apache.pinot.tools.admin.command.LaunchDataIngestionJobCommand

description() - Method in class org.apache.pinot.tools.admin.command.MoveReplicaGroup

description() - Method in class org.apache.pinot.tools.admin.command.OfflineSegmentIntervalCheckerCommand

description() - Method in class org.apache.pinot.tools.admin.command.OperateClusterConfigCommand

description() - Method in class org.apache.pinot.tools.admin.command.PostQueryCommand

description() - Method in class org.apache.pinot.tools.admin.command.QuickStartCommand

description() - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

description() - Method in class org.apache.pinot.tools.admin.command.RebalanceTableCommand

description() - Method in class org.apache.pinot.tools.admin.command.SegmentProcessorFrameworkCommand

description() - Method in class org.apache.pinot.tools.admin.command.ShowClusterInfoCommand

description() - Method in class org.apache.pinot.tools.admin.command.StartBrokerCommand

description() - Method in class org.apache.pinot.tools.admin.command.StartControllerCommand

description() - Method in class org.apache.pinot.tools.admin.command.StartKafkaCommand

description() - Method in class org.apache.pinot.tools.admin.command.StartMinionCommand

description() - Method in class org.apache.pinot.tools.admin.command.StartServerCommand

description() - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

description() - Method in class org.apache.pinot.tools.admin.command.StartZookeeperCommand

description() - Method in class org.apache.pinot.tools.admin.command.StopProcessCommand

description() - Method in class org.apache.pinot.tools.admin.command.StreamAvroIntoKafkaCommand

description() - Method in class org.apache.pinot.tools.admin.command.StreamGitHubEventsCommand

description() - Method in class org.apache.pinot.tools.admin.command.UploadSegmentCommand

description() - Method in class org.apache.pinot.tools.admin.command.ValidateConfigCommand

description() - Method in class org.apache.pinot.tools.admin.command.VerifyClusterStateCommand

description() - Method in class org.apache.pinot.tools.admin.command.VerifySegmentState

description() - Method in class org.apache.pinot.tools.AutoAddInvertedIndexTool

description() - Method in interface org.apache.pinot.tools.Command

description() - Method in class org.apache.pinot.tools.filesystem.PinotFSBenchmarkRunner

description() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkRunner

description() - Method in class org.apache.pinot.tools.perf.QueryRunner

description() - Method in class org.apache.pinot.tools.segment.converter.PinotSegmentConvertCommand

description() - Method in class org.apache.pinot.tools.segment.converter.SegmentMergeCommand

description() - Method in class org.apache.pinot.tools.SegmentDumpTool

description() - Method in class org.apache.pinot.tools.UpdateSegmentState

description() - Method in class org.apache.pinot.tools.ValidateTableRetention

DICT_FILE_EXTENSION - Static variable in interface org.apache.pinot.tools.anonymizer.GlobalDictionaries

DictionaryToRawIndexConverter - Class in org.apache.pinot.tools.segment.converter

Class to convert segment with dictionary encoded column to raw index (without dictionary).

DictionaryToRawIndexConverter() - Constructor for class org.apache.pinot.tools.segment.converter.DictionaryToRawIndexConverter

DistinctCountFunction - Class in org.apache.pinot.tools.scan.query

DistinctCountFunction(ResultTable, String) - Constructor for class org.apache.pinot.tools.scan.query.DistinctCountFunction

doMain(String[]) - Method in class org.apache.pinot.tools.SegmentDumpTool

downloadSegment(String, String, File, File) - Method in class org.apache.pinot.tools.backfill.BackfillSegmentUtils

Downloads a segment from a table to a directory locally, and backs it up to given backup path

E

EnumArrayOptionHandler<T extends Enum<T>> - Class in org.apache.pinot.tools.admin.command

EnumArrayOptionHandler(CmdLineParser, OptionDef, Setter<T>) - Constructor for class org.apache.pinot.tools.admin.command.EnumArrayOptionHandler

equals(Object) - Method in class org.apache.pinot.tools.scan.query.GroupByOperator

EqualsPredicateFilter - Class in org.apache.pinot.tools.scan.query

EqualsPredicateFilter(Dictionary, String) - Constructor for class org.apache.pinot.tools.scan.query.EqualsPredicateFilter

estimateMemoryUsed(File, int[], int[], int, int) - Method in class org.apache.pinot.tools.realtime.provisioning.MemoryEstimator

Given a sample segment, the time for which it consumed, numReplicas and numPartitions, estimate how much memory would be required per host for this table

Algorithm:
Given numReplicas and numPartitions, we can find out total consuming partitions per host, for various numHosts
totalConsumingPartitionsPerHost = (numReplicas * numPartitions)/numHosts

Given a sample realtime completed segment (with size s), and how long it consumed for (t),
we can estimate how much memory the table would require for various combinations of num hosts and num hours

For estimating the memory occupied by completed segments-
For each numHoursToConsume we compute:
If a segment with size s takes time t to complete, then consuming for time numHoursToConsume would create segment with size estimatedSize = (numHoursToConsume/t)*s
If retention for completed segments in memory is rt hours, then the segment would be in memory for (rt-numHoursToConsume) hours
A segment would complete every numHoursToConsume hours, so we would have at a time numCompletedSegmentsAtATime = (rt-numHoursToConsume)/numHoursToConsume to hold in memory
As a result, totalCompletedSegmentsMemory per ConsumingPartition = estimatedSize * numCompletedSegmentsAtATime

For estimating the memory occupied by consuming segments-
Using the sample segment, we initialize the stats history
For each numHoursToConsume we compute:
If totalDocs in sample segment is n when it consumed for time t, then consuming for time numHoursToConsume would create totalDocs = (numHoursToConsume/t)*n
We create a MutableSegmentImpl using the totalDocs, and then fetch the memory used by the memory manager, to get totalConsumingSegmentMemory per ConsumingPartition

totalMemory = (totalCompletedMemory per ConsumingPartition + totalConsumingMemory per ConsumingPartition) * totalConsumingPartitionsPerHost

execute() - Method in class org.apache.pinot.tools.admin.command.AddSchemaCommand

execute() - Method in class org.apache.pinot.tools.admin.command.AddTableCommand

execute() - Method in class org.apache.pinot.tools.admin.command.AddTenantCommand

execute() - Method in class org.apache.pinot.tools.admin.command.AnonymizeDataCommand

execute() - Method in class org.apache.pinot.tools.admin.command.AvroSchemaToPinotSchema

execute() - Method in class org.apache.pinot.tools.admin.command.ChangeNumReplicasCommand

execute() - Method in class org.apache.pinot.tools.admin.command.ChangeTableState

execute() - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

execute() - Method in class org.apache.pinot.tools.admin.command.DeleteClusterCommand

execute() - Method in class org.apache.pinot.tools.admin.command.GenerateDataCommand

execute() - Method in class org.apache.pinot.tools.admin.command.GitHubEventsQuickStartCommand

execute() - Method in class org.apache.pinot.tools.admin.command.LaunchDataIngestionJobCommand

execute() - Method in class org.apache.pinot.tools.admin.command.MoveReplicaGroup

execute() - Method in class org.apache.pinot.tools.admin.command.OfflineSegmentIntervalCheckerCommand

execute() - Method in class org.apache.pinot.tools.admin.command.OperateClusterConfigCommand

execute() - Method in class org.apache.pinot.tools.admin.command.PostQueryCommand

execute() - Method in class org.apache.pinot.tools.admin.command.QuickStartCommand

execute() - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

execute() - Method in class org.apache.pinot.tools.admin.command.RebalanceTableCommand

execute() - Method in class org.apache.pinot.tools.admin.command.SegmentProcessorFrameworkCommand

execute() - Method in class org.apache.pinot.tools.admin.command.ShowClusterInfoCommand

execute() - Method in class org.apache.pinot.tools.admin.command.StartBrokerCommand

execute() - Method in class org.apache.pinot.tools.admin.command.StartControllerCommand

execute() - Method in class org.apache.pinot.tools.admin.command.StartKafkaCommand

execute() - Method in class org.apache.pinot.tools.admin.command.StartMinionCommand

execute() - Method in class org.apache.pinot.tools.admin.command.StartServerCommand

execute() - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

execute() - Method in class org.apache.pinot.tools.admin.command.StartZookeeperCommand

execute() - Method in class org.apache.pinot.tools.admin.command.StopProcessCommand

execute() - Method in class org.apache.pinot.tools.admin.command.StreamAvroIntoKafkaCommand

execute() - Method in class org.apache.pinot.tools.admin.command.StreamGitHubEventsCommand

execute() - Method in class org.apache.pinot.tools.admin.command.UploadSegmentCommand

execute() - Method in class org.apache.pinot.tools.admin.command.ValidateConfigCommand

execute() - Method in class org.apache.pinot.tools.admin.command.VerifyClusterStateCommand

execute() - Method in class org.apache.pinot.tools.admin.command.VerifySegmentState

execute(String[]) - Method in class org.apache.pinot.tools.admin.PinotAdministrator

execute() - Method in class org.apache.pinot.tools.AutoAddInvertedIndexTool

execute() - Method in interface org.apache.pinot.tools.Command

execute() - Method in class org.apache.pinot.tools.filesystem.PinotFSBenchmarkRunner

execute(String) - Method in class org.apache.pinot.tools.GitHubEventsQuickstart

execute() - Method in class org.apache.pinot.tools.HybridQuickstart

execute() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkRunner

execute() - Method in class org.apache.pinot.tools.perf.QueryRunner

execute(String[]) - Method in class org.apache.pinot.tools.PinotToolLauncher

execute() - Method in class org.apache.pinot.tools.Quickstart

execute() - Method in class org.apache.pinot.tools.RealtimeQuickStart

execute() - Method in class org.apache.pinot.tools.segment.converter.PinotSegmentConvertCommand

execute() - Method in class org.apache.pinot.tools.segment.converter.SegmentMergeCommand

execute() - Method in class org.apache.pinot.tools.SegmentDumpTool

execute() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEventsStream

Starts the stream.

execute() - Method in class org.apache.pinot.tools.UpdateSegmentState

execute() - Method in class org.apache.pinot.tools.UpsertQuickStart

execute() - Method in class org.apache.pinot.tools.ValidateTableRetention

extractColumnsUsedInFilter(String, String) - Static method in class org.apache.pinot.tools.anonymizer.PinotDataAndQueryAnonymizer.FilterColumnExtractor

F

fetchSchema() - Method in class org.apache.pinot.tools.data.generator.DataGenerator

FilterColumnExtractor() - Constructor for class org.apache.pinot.tools.anonymizer.PinotDataAndQueryAnonymizer.FilterColumnExtractor

fixTableIdealState(String) - Method in class org.apache.pinot.tools.UpdateSegmentState

G

generateAvro(long, int) - Method in class org.apache.pinot.tools.data.generator.DataGenerator

generateAvroFiles() - Method in class org.apache.pinot.tools.anonymizer.PinotDataAndQueryAnonymizer

* Data Generator * *

generateBrokerConf(int) - Static method in class org.apache.pinot.tools.utils.PinotConfigUtils

generateControllerConf(String, String, String, String, String, ControllerConf.ControllerMode, boolean) - Static method in class org.apache.pinot.tools.utils.PinotConfigUtils

generateControllerConf(String) - Static method in class org.apache.pinot.tools.utils.PinotConfigUtils

generateCsv(long, int) - Method in class org.apache.pinot.tools.data.generator.DataGenerator

GenerateDataCommand - Class in org.apache.pinot.tools.admin.command

Class to implement GenerateData command.

GenerateDataCommand() - Constructor for class org.apache.pinot.tools.admin.command.GenerateDataCommand

generateMinionConf(String, int) - Static method in class org.apache.pinot.tools.utils.PinotConfigUtils

generateQueries() - Method in class org.apache.pinot.tools.anonymizer.PinotDataAndQueryAnonymizer.QueryGenerator

generateQuery(String, PrintWriter) - Method in class org.apache.pinot.tools.anonymizer.PinotDataAndQueryAnonymizer.QueryGenerator

generateReport(String) - Static method in class org.apache.pinot.tools.query.comparison.StatsGenerator

generateServerConf(String, int, int, String, String) - Static method in class org.apache.pinot.tools.utils.PinotConfigUtils

Generator - Interface in org.apache.pinot.tools.data.generator

Sep 13, 2014

GeneratorFactory - Class in org.apache.pinot.tools.data.generator

Sep 13, 2014

GeneratorFactory() - Constructor for class org.apache.pinot.tools.data.generator.GeneratorFactory

get(int, int) - Method in class org.apache.pinot.tools.scan.query.ResultTable

getActiveMemoryPerHost() - Method in class org.apache.pinot.tools.realtime.provisioning.MemoryEstimator

getAggregationFunc(ResultTable, String, String) - Static method in class org.apache.pinot.tools.scan.query.AggregationFuncFactory

getAllSegments(String, CommonConstants.Segment.SegmentType) - Method in class org.apache.pinot.tools.backfill.BackfillSegmentUtils

Fetches the list of all segment names for a table

getAllServicesHealth() - Method in class org.apache.pinot.tools.service.api.resources.PinotServiceManagerHealthCheck

getAllTenantTables() - Method in class org.apache.pinot.tools.UpdateSegmentState

getAssignees() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getAuthorAssociation() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getAuthors() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getAvailablePort() - Static method in class org.apache.pinot.tools.utils.PinotConfigUtils

getAvroSchema(Schema) - Static method in class org.apache.pinot.tools.data.generator.AvroWriter

getBootstrapConfigPaths() - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

getBootstrapServices() - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

getBrokerHost() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getBrokerHost() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getBrokerPort() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getBrokerPort() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getCardinality() - Method in class org.apache.pinot.tools.data.generator.SchemaAnnotation

getCardinalityMap() - Method in class org.apache.pinot.tools.data.generator.DataGeneratorSpec

getClusterName() - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

getClusterName() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getClusterName() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getClusterName() - Method in class org.apache.pinot.tools.service.PinotServiceManager

getCollectorConfig() - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

getColumn() - Method in class org.apache.pinot.tools.data.generator.SchemaAnnotation

getColumn(int) - Method in class org.apache.pinot.tools.scan.query.ResultTable

getColumnList() - Method in class org.apache.pinot.tools.scan.query.ResultTable

getColumnMap() - Method in class org.apache.pinot.tools.scan.query.ResultTable

getColumns() - Method in class org.apache.pinot.tools.data.generator.DataGeneratorSpec

getCommenters() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getCommitters() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getConfig() - Method in class org.apache.pinot.tools.service.api.resources.PinotInstanceStatus

getConsumingMemoryPerHost() - Method in class org.apache.pinot.tools.realtime.provisioning.MemoryEstimator

getControllerDataDir() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getControllerHost() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getControllerPort() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getControllerPort() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getCreatedTimeMillis() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getDataTypesMap() - Method in class org.apache.pinot.tools.data.generator.DataGeneratorSpec

getDefaultKafkaConfiguration() - Static method in class org.apache.pinot.tools.utils.KafkaStarterUtils

getDefaultMetaVariable() - Method in class org.apache.pinot.tools.admin.command.EnumArrayOptionHandler

Returns "T[]".

getDerivedValueForOrigValueSV(String, Object) - Method in class org.apache.pinot.tools.anonymizer.ArrayBasedGlobalDictionaries

getDerivedValueForOrigValueSV(String, Object) - Method in interface org.apache.pinot.tools.anonymizer.GlobalDictionaries

getDerivedValueForOrigValueSV(String, Object) - Method in class org.apache.pinot.tools.anonymizer.MapBasedGlobalDictionaries

getDerivedValuesForOrigValuesMV(String, Object[]) - Method in class org.apache.pinot.tools.anonymizer.ArrayBasedGlobalDictionaries

getDerivedValuesForOrigValuesMV(String, Object[]) - Method in interface org.apache.pinot.tools.anonymizer.GlobalDictionaries

getDerivedValuesForOrigValuesMV(String, Object[]) - Method in class org.apache.pinot.tools.anonymizer.MapBasedGlobalDictionaries

getDialect() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getElapsedTimeMillis() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getEndIndex() - Method in class org.apache.pinot.tools.scan.query.RangePredicateFilter

getFieldTypesMap() - Method in class org.apache.pinot.tools.data.generator.DataGeneratorSpec

getFunction(int) - Method in class org.apache.pinot.tools.scan.query.ResultTable

getFunctionMode() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getGeneratorFor(FieldSpec.DataType, int) - Static method in class org.apache.pinot.tools.data.generator.GeneratorFactory

getGeneratorFor(FieldSpec.DataType, int, int) - Static method in class org.apache.pinot.tools.data.generator.GeneratorFactory

getGeneratorFor(PatternType, Map<String, Object>) - Static method in class org.apache.pinot.tools.data.generator.GeneratorFactory

getHelixAdmin() - Method in class org.apache.pinot.tools.PinotZKChanger

getHelixManager() - Method in class org.apache.pinot.tools.PinotZKChanger

getHelp() - Method in class org.apache.pinot.tools.admin.command.AddSchemaCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.AddTableCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.AddTenantCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.AnonymizeDataCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.AvroSchemaToPinotSchema

getHelp() - Method in class org.apache.pinot.tools.admin.command.ChangeNumReplicasCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.ChangeTableState

getHelp() - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.DeleteClusterCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.GenerateDataCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.GitHubEventsQuickStartCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.LaunchDataIngestionJobCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.MoveReplicaGroup

getHelp() - Method in class org.apache.pinot.tools.admin.command.OfflineSegmentIntervalCheckerCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.OperateClusterConfigCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.PostQueryCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.QuickStartCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.RebalanceTableCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.SegmentProcessorFrameworkCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.ShowClusterInfoCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.StartBrokerCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.StartControllerCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.StartKafkaCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.StartMinionCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.StartServerCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.StartZookeeperCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.StopProcessCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.StreamAvroIntoKafkaCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.StreamGitHubEventsCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.UploadSegmentCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.ValidateConfigCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.VerifyClusterStateCommand

getHelp() - Method in class org.apache.pinot.tools.admin.command.VerifySegmentState

getHelp() - Method in class org.apache.pinot.tools.AutoAddInvertedIndexTool

getHelp() - Method in interface org.apache.pinot.tools.Command

getHelp() - Method in class org.apache.pinot.tools.filesystem.PinotFSBenchmarkRunner

getHelp() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkRunner

getHelp() - Method in class org.apache.pinot.tools.perf.QueryRunner

getHelp() - Method in class org.apache.pinot.tools.segment.converter.PinotSegmentConvertCommand

getHelp() - Method in class org.apache.pinot.tools.segment.converter.SegmentMergeCommand

getHelp() - Method in class org.apache.pinot.tools.SegmentDumpTool

getHelp() - Method in class org.apache.pinot.tools.UpdateSegmentState

getHelp() - Method in class org.apache.pinot.tools.ValidateTableRetention

getIngestionJobFile() - Method in class org.apache.pinot.tools.QuickstartTableRequest

getInputDataDir() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getInputSegmentsDir() - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

getInstanceId() - Method in class org.apache.pinot.tools.service.api.resources.PinotInstanceStatus

getInstanceId() - Method in class org.apache.pinot.tools.service.PinotServiceManager

getInstanceStatus(String) - Method in class org.apache.pinot.tools.service.PinotServiceManager

getJobSpecFile() - Method in class org.apache.pinot.tools.admin.command.LaunchDataIngestionJobCommand

getLabels() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getMergedBy() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getMergedTimeMillis() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getMetricColumns() - Method in class org.apache.pinot.tools.query.comparison.SegmentInfoProvider

Return the list of metric columns

getName() - Method in class org.apache.pinot.tools.AbstractBaseCommand

getName() - Method in class org.apache.pinot.tools.admin.command.AddSchemaCommand

getName() - Method in class org.apache.pinot.tools.admin.command.AddTableCommand

getName() - Method in class org.apache.pinot.tools.admin.command.AddTenantCommand

getName() - Method in class org.apache.pinot.tools.admin.command.AnonymizeDataCommand

getName() - Method in class org.apache.pinot.tools.admin.command.ChangeNumReplicasCommand

getName() - Method in class org.apache.pinot.tools.admin.command.ChangeTableState

getName() - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

getName() - Method in class org.apache.pinot.tools.admin.command.DeleteClusterCommand

getName() - Method in class org.apache.pinot.tools.admin.command.GenerateDataCommand

getName() - Method in class org.apache.pinot.tools.admin.command.GitHubEventsQuickStartCommand

getName() - Method in class org.apache.pinot.tools.admin.command.LaunchDataIngestionJobCommand

getName() - Method in class org.apache.pinot.tools.admin.command.MoveReplicaGroup

getName() - Method in class org.apache.pinot.tools.admin.command.OfflineSegmentIntervalCheckerCommand

getName() - Method in class org.apache.pinot.tools.admin.command.OperateClusterConfigCommand

getName() - Method in class org.apache.pinot.tools.admin.command.PostQueryCommand

getName() - Method in class org.apache.pinot.tools.admin.command.QuickStartCommand

getName() - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

getName() - Method in class org.apache.pinot.tools.admin.command.RebalanceTableCommand

getName() - Method in class org.apache.pinot.tools.admin.command.SegmentProcessorFrameworkCommand

getName() - Method in class org.apache.pinot.tools.admin.command.StartBrokerCommand

getName() - Method in class org.apache.pinot.tools.admin.command.StartControllerCommand

getName() - Method in class org.apache.pinot.tools.admin.command.StartKafkaCommand

getName() - Method in class org.apache.pinot.tools.admin.command.StartMinionCommand

getName() - Method in class org.apache.pinot.tools.admin.command.StartServerCommand

getName() - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

getName() - Method in class org.apache.pinot.tools.admin.command.StartZookeeperCommand

getName() - Method in class org.apache.pinot.tools.admin.command.StopProcessCommand

getName() - Method in class org.apache.pinot.tools.admin.command.StreamAvroIntoKafkaCommand

getName() - Method in class org.apache.pinot.tools.admin.command.StreamGitHubEventsCommand

getName() - Method in class org.apache.pinot.tools.admin.command.UploadSegmentCommand

getName() - Method in class org.apache.pinot.tools.admin.command.ValidateConfigCommand

getName() - Method in class org.apache.pinot.tools.admin.command.VerifyClusterStateCommand

getName() - Method in class org.apache.pinot.tools.AutoAddInvertedIndexTool

getName() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkRunner

getName() - Method in class org.apache.pinot.tools.perf.QueryRunner

getName() - Method in class org.apache.pinot.tools.segment.converter.SegmentMergeCommand

getName() - Method in class org.apache.pinot.tools.SegmentDumpTool

getName() - Method in class org.apache.pinot.tools.UpdateSegmentState

getName() - Method in class org.apache.pinot.tools.ValidateTableRetention

getNumAuthors() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getNumCommenters() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getNumComments() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getNumCommits() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getNumCommitters() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getNumDocsScanned() - Method in class org.apache.pinot.tools.scan.query.QueryResponse

getNumDocsScanned() - Method in class org.apache.pinot.tools.scan.query.ResultTable

getNumFilesChanged() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getNumLinesAdded() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getNumLinesDeleted() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getNumReviewComments() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getNumReviewers() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getNumSegmentsQueriedPerHost() - Method in class org.apache.pinot.tools.realtime.provisioning.MemoryEstimator

getOptimalSegmentSize() - Method in class org.apache.pinot.tools.realtime.provisioning.MemoryEstimator

getOrganization() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getOutputDir() - Method in class org.apache.pinot.tools.data.generator.DataGeneratorSpec

getOutputFileFormat() - Method in class org.apache.pinot.tools.data.generator.DataGeneratorSpec

getOutputSegmentsDir() - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

getPartitionerConfigs() - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

getPattern() - Method in class org.apache.pinot.tools.data.generator.SchemaAnnotation

getPatternMap() - Method in class org.apache.pinot.tools.data.generator.DataGeneratorSpec

getPerfMode() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getPerfUrl() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getPID() - Static method in class org.apache.pinot.tools.admin.command.AbstractBaseAdminCommand

getPinotAllInstancesStatus() - Method in class org.apache.pinot.tools.service.api.resources.PinotServiceManagerInstanceResource

getPinotInstanceStatus(String) - Method in class org.apache.pinot.tools.service.api.resources.PinotServiceManagerInstanceResource

getPort() - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

getProcessingTime() - Method in class org.apache.pinot.tools.scan.query.ResultTable

getPropertyFile() - Method in class org.apache.pinot.tools.admin.command.LaunchDataIngestionJobCommand

getQueriesDirectory() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getQueryFile() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getRangeEnd() - Method in class org.apache.pinot.tools.data.generator.SchemaAnnotation

getRangeMap() - Method in class org.apache.pinot.tools.data.generator.DataGeneratorSpec

getRangeStart() - Method in class org.apache.pinot.tools.data.generator.SchemaAnnotation

getRecordFilterConfig() - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

getRecordTransformerConfig() - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

getRefBrokerHost() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getRefBrokerPort() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getRefControllerPort() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getRefServerPort() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getRepo() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getRequestedReviewers() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getRequestedTeams() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getResultFile() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getResultsOutputDirectory() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getResultType() - Method in class org.apache.pinot.tools.scan.query.ResultTable

getReviewers() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getRow(int) - Method in class org.apache.pinot.tools.scan.query.ResultTable

getRows() - Method in class org.apache.pinot.tools.scan.query.ResultTable

getRunningInstanceIds() - Method in class org.apache.pinot.tools.service.PinotServiceManager

getSchemaFile() - Method in class org.apache.pinot.tools.QuickstartTableRequest

getSchemaFile() - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

getSchemaFileName() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getSchemaFileNamePath() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getSegmentConfig() - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

getSegmentFileFormat() - Method in class org.apache.pinot.tools.QuickstartTableRequest

getSegmentName() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getSegmentsDir() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getServerHost() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getServerInstanceDataDir() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getServerInstanceName() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getServerInstanceSegmentTarDir() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getServerPort() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getServerPort() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getServiceHealth(String) - Method in class org.apache.pinot.tools.service.api.resources.PinotServiceManagerHealthCheck

getServicePort() - Method in class org.apache.pinot.tools.service.PinotServiceManager

getServiceRole() - Method in class org.apache.pinot.tools.service.api.resources.PinotInstanceStatus

getServiceStatus() - Method in class org.apache.pinot.tools.service.api.resources.PinotInstanceStatus

getServiceStatus() - Method in class org.apache.pinot.tools.service.PinotServiceManagerStatusCallback

getSingleValueDimensionColumns() - Method in class org.apache.pinot.tools.query.comparison.SegmentInfoProvider

Return the list of single-value dimension columns.

getSingleValueDimensionValuesMap() - Method in class org.apache.pinot.tools.query.comparison.SegmentInfoProvider

Return the map from single-value dimension names to values list for the column.

getStartCluster() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getStarterHealth() - Method in class org.apache.pinot.tools.service.api.resources.PinotServiceManagerHealthCheck

getStartIndex() - Method in class org.apache.pinot.tools.scan.query.RangePredicateFilter

getStarTree() - Method in class org.apache.pinot.tools.StarTreeIndexViewer.StarTreeViewRestResource

getStarTreeHtml() - Method in class org.apache.pinot.tools.StarTreeIndexViewer.StarTreeViewRestResource

getStartZookeeper() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getStatusDescription() - Method in class org.apache.pinot.tools.service.api.resources.PinotInstanceStatus

getStatusDescription() - Method in class org.apache.pinot.tools.service.PinotServiceManagerStatusCallback

getTableConfigFile() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getTableConfigFile() - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

getTableName() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getTableName() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getTableName() - Method in class org.apache.pinot.tools.QuickstartTableRequest

getTableRequestFile() - Method in class org.apache.pinot.tools.QuickstartTableRequest

getTableType() - Method in class org.apache.pinot.tools.QuickstartTableRequest

getTimeColumnName() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getTimeUnit() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

getTimeUnitMap() - Method in class org.apache.pinot.tools.data.generator.DataGeneratorSpec

getTimeUsedMs() - Method in class org.apache.pinot.tools.scan.query.QueryResponse

getTitle() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getTopicCreationProps(int) - Static method in class org.apache.pinot.tools.utils.KafkaStarterUtils

getTotalDocs() - Method in class org.apache.pinot.tools.scan.query.QueryResponse

getTotalDocs() - Method in class org.apache.pinot.tools.scan.query.ResultTable

getUserId() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getUserType() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

getValues() - Method in class org.apache.pinot.tools.admin.command.LaunchDataIngestionJobCommand

getZkAddress() - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

getZkAddress() - Method in class org.apache.pinot.tools.service.PinotServiceManager

getZkHost() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getZkPort() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

getZookeeperAddress() - Method in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

GitHubAPICaller - Class in org.apache.pinot.tools.streams.githubevents

Helper class to make http calls to GitHub API

GitHubEventsQuickstart - Class in org.apache.pinot.tools

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

GitHubEventsQuickstart() - Constructor for class org.apache.pinot.tools.GitHubEventsQuickstart

GitHubEventsQuickStartCommand - Class in org.apache.pinot.tools.admin.command

Command to run GitHubEventsQuickStart

GitHubEventsQuickStartCommand() - Constructor for class org.apache.pinot.tools.admin.command.GitHubEventsQuickStartCommand

GlobalDictionaries - Interface in org.apache.pinot.tools.anonymizer

GroupByOperator - Class in org.apache.pinot.tools.scan.query

GroupByOperator(List<Object>) - Constructor for class org.apache.pinot.tools.scan.query.GroupByOperator

H

hashCode() - Method in class org.apache.pinot.tools.scan.query.GroupByOperator

helixAdmin - Variable in class org.apache.pinot.tools.PinotZKChanger

helixManager - Variable in class org.apache.pinot.tools.PinotZKChanger

HybridQuickstart - Class in org.apache.pinot.tools

HybridQuickstart() - Constructor for class org.apache.pinot.tools.HybridQuickstart

I

increasingQPSQueryRunner(PerfBenchmarkDriverConf, Stream<String>, int, int, int, double, double, int, int, int, long) - Static method in class org.apache.pinot.tools.perf.QueryRunner

Use multiple threads to run query at an increasing target QPS.

init(int, int, String, String) - Method in class org.apache.pinot.tools.admin.command.GenerateDataCommand

init(int, String) - Method in class org.apache.pinot.tools.admin.command.StartZookeeperCommand

init(DataGeneratorSpec) - Method in class org.apache.pinot.tools.data.generator.DataGenerator

init() - Method in interface org.apache.pinot.tools.data.generator.Generator

init() - Method in class org.apache.pinot.tools.data.generator.NumberGenerator

init() - Method in class org.apache.pinot.tools.data.generator.PatternMixtureGenerator

init() - Method in class org.apache.pinot.tools.data.generator.PatternSeasonalGenerator

init() - Method in class org.apache.pinot.tools.data.generator.PatternSequenceGenerator

init() - Method in class org.apache.pinot.tools.data.generator.PatternSpikeGenerator

init() - Method in class org.apache.pinot.tools.data.generator.PatternStringGenerator

init() - Method in class org.apache.pinot.tools.data.generator.RangeDoubleGenerator

init() - Method in class org.apache.pinot.tools.data.generator.RangeFloatGenerator

init() - Method in class org.apache.pinot.tools.data.generator.RangeIntGenerator

init() - Method in class org.apache.pinot.tools.data.generator.RangeLongGenerator

init() - Method in class org.apache.pinot.tools.data.generator.StringGenerator

initializeStatsHistory() - Method in class org.apache.pinot.tools.realtime.provisioning.MemoryEstimator

Initialize the stats file using the sample segment provided.

InPredicateFilter - Class in org.apache.pinot.tools.scan.query

InPredicateFilter(Dictionary, List<String>) - Constructor for class org.apache.pinot.tools.scan.query.InPredicateFilter

isCleanOnStartup() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

isConfigureResources() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

isEmpty() - Method in class org.apache.pinot.tools.scan.query.ResultTable

isOverrideOutDir() - Method in class org.apache.pinot.tools.data.generator.DataGeneratorSpec

isRange() - Method in class org.apache.pinot.tools.data.generator.SchemaAnnotation

isRunQueries() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

isStable(String) - Method in class org.apache.pinot.tools.PinotZKChanger

return true if IdealState = ExternalView

isStarted() - Method in class org.apache.pinot.tools.service.PinotServiceManager

isStartZookeeper() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

isVerbose() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

iterator() - Method in class org.apache.pinot.tools.scan.query.ResultTable

J

JarUtils - Class in org.apache.pinot.tools.utils

json - Static variable in class org.apache.pinot.tools.StarTreeIndexViewer.StarTreeViewRestResource

K

KAFKA_JSON_MESSAGE_DECODER_CLASS_NAME - Static variable in class org.apache.pinot.tools.utils.KafkaStarterUtils

KAFKA_PRODUCER_CLASS_NAME - Static variable in class org.apache.pinot.tools.utils.KafkaStarterUtils

KAFKA_SERVER_STARTABLE_CLASS_NAME - Static variable in class org.apache.pinot.tools.utils.KafkaStarterUtils

KAFKA_STREAM_CONSUMER_FACTORY_CLASS_NAME - Static variable in class org.apache.pinot.tools.utils.KafkaStarterUtils

KAFKA_STREAM_LEVEL_CONSUMER_CLASS_NAME - Static variable in class org.apache.pinot.tools.utils.KafkaStarterUtils

KafkaStarterUtils - Class in org.apache.pinot.tools.utils

KafkaStarterUtils() - Constructor for class org.apache.pinot.tools.utils.KafkaStarterUtils

L

launchDataIngestionJob() - Method in class org.apache.pinot.tools.admin.command.QuickstartRunner

LaunchDataIngestionJobCommand - Class in org.apache.pinot.tools.admin.command

Class to implement LaunchDataIngestionJob command.

LaunchDataIngestionJobCommand() - Constructor for class org.apache.pinot.tools.admin.command.LaunchDataIngestionJobCommand

loadTable(PerfBenchmarkDriver, String, String, List<String>, List<String>) - Static method in class org.apache.pinot.tools.perf.PerfBenchmarkRunner

M

main(String[]) - Static method in class org.apache.pinot.tools.admin.command.GenerateDataCommand

main(String[]) - Static method in class org.apache.pinot.tools.admin.command.LaunchDataIngestionJobCommand

main(String[]) - Static method in class org.apache.pinot.tools.admin.command.MoveReplicaGroup

main(String[]) - Static method in class org.apache.pinot.tools.admin.command.StartZookeeperCommand

main(String[]) - Static method in class org.apache.pinot.tools.admin.command.VerifySegmentState

main(String[]) - Static method in class org.apache.pinot.tools.admin.PinotAdministrator

main(String[]) - Static method in class org.apache.pinot.tools.admin.PinotBroker

main(String[]) - Static method in class org.apache.pinot.tools.admin.PinotController

main(String[]) - Static method in class org.apache.pinot.tools.admin.PinotMinion

main(String[]) - Static method in class org.apache.pinot.tools.admin.PinotServer

main(String[]) - Static method in class org.apache.pinot.tools.admin.PinotServiceManagerStarter

main(String[]) - Static method in class org.apache.pinot.tools.data.generator.DataGenerator

main(String[]) - Static method in class org.apache.pinot.tools.data.generator.NumberGenerator

main(String[]) - Static method in class org.apache.pinot.tools.data.generator.StringGenerator

main(String[]) - Static method in class org.apache.pinot.tools.HybridQuickstart

main(String[]) - Static method in class org.apache.pinot.tools.perf.PerfBenchmarkDriver

main(String[]) - Static method in class org.apache.pinot.tools.perf.PerfBenchmarkRunner

Main method for the class.

main(String[]) - Static method in class org.apache.pinot.tools.perf.QueryRunner

main(String[]) - Static method in class org.apache.pinot.tools.perf.ZookeeperLauncher

main(String[]) - Static method in class org.apache.pinot.tools.PinotIdealstateChanger

main(String[]) - Static method in class org.apache.pinot.tools.PinotNumReplicaChanger

main(String[]) - Static method in class org.apache.pinot.tools.PinotToolLauncher

main(String[]) - Static method in class org.apache.pinot.tools.query.comparison.QueryComparison

main(String[]) - Static method in class org.apache.pinot.tools.query.comparison.StatsGenerator

main(String[]) - Static method in class org.apache.pinot.tools.Quickstart

main(String[]) - Static method in class org.apache.pinot.tools.RealtimeQuickStart

main(String[]) - Static method in class org.apache.pinot.tools.scan.query.ScanBasedQueryProcessor

main(String[]) - Static method in class org.apache.pinot.tools.scan.query.Utils

main(String[]) - Static method in class org.apache.pinot.tools.segment.converter.DictionaryToRawIndexConverter

Main method for the class.

main(String[]) - Static method in class org.apache.pinot.tools.SegmentDumpTool

main(String[]) - Static method in class org.apache.pinot.tools.service.PinotServiceManager

main(String[]) - Static method in class org.apache.pinot.tools.SpeedTest

main(String[]) - Static method in class org.apache.pinot.tools.StarTreeIndexViewer

main(String[]) - Static method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEventsStream

main(String[]) - Static method in class org.apache.pinot.tools.UpsertQuickStart

MapBasedGlobalDictionaries - Class in org.apache.pinot.tools.anonymizer

MaxFunction - Class in org.apache.pinot.tools.scan.query

MeetupRsvpStream - Class in org.apache.pinot.tools.streams

MeetupRsvpStream() - Constructor for class org.apache.pinot.tools.streams.MeetupRsvpStream

MeetupRsvpStream(boolean) - Constructor for class org.apache.pinot.tools.streams.MeetupRsvpStream

MemoryEstimator - Class in org.apache.pinot.tools.realtime.provisioning

Given a sample segment, this class can estimate how much memory would be used per host, for various combinations of numHostsToProvision and numHoursToConsume

MemoryEstimator(TableConfig, File, int, long, int) - Constructor for class org.apache.pinot.tools.realtime.provisioning.MemoryEstimator

MinFunction - Class in org.apache.pinot.tools.scan.query

MinMaxRangeFunction - Class in org.apache.pinot.tools.scan.query

MoveReplicaGroup - Class in org.apache.pinot.tools.admin.command

Command to migrate a subset of replica group from current servers to the provided destination servers.

MoveReplicaGroup() - Constructor for class org.apache.pinot.tools.admin.command.MoveReplicaGroup

multiThreadedQueryRunner(PerfBenchmarkDriverConf, Stream<String>, int, int, int, int, int, long) - Static method in class org.apache.pinot.tools.perf.QueryRunner

Use multiple threads to run queries as fast as possible.

N

next() - Method in interface org.apache.pinot.tools.data.generator.Generator

next() - Method in class org.apache.pinot.tools.data.generator.NumberGenerator

next() - Method in class org.apache.pinot.tools.data.generator.PatternMixtureGenerator

next() - Method in class org.apache.pinot.tools.data.generator.PatternSeasonalGenerator

next() - Method in class org.apache.pinot.tools.data.generator.PatternSequenceGenerator

next() - Method in class org.apache.pinot.tools.data.generator.PatternSpikeGenerator

next() - Method in class org.apache.pinot.tools.data.generator.PatternStringGenerator

next() - Method in class org.apache.pinot.tools.data.generator.RangeDoubleGenerator

next() - Method in class org.apache.pinot.tools.data.generator.RangeFloatGenerator

next() - Method in class org.apache.pinot.tools.data.generator.RangeIntGenerator

next() - Method in class org.apache.pinot.tools.data.generator.RangeLongGenerator

next() - Method in class org.apache.pinot.tools.data.generator.StringGenerator

nextQuery() - Method in class org.apache.pinot.tools.query.comparison.StarTreeQueryGenerator

Randomly generate a query.

NotInPredicateFilter - Class in org.apache.pinot.tools.scan.query

NotInPredicateFilter(Dictionary, List<String>) - Constructor for class org.apache.pinot.tools.scan.query.NotInPredicateFilter

NotPredicateFilter - Class in org.apache.pinot.tools.scan.query

NotPredicateFilter(Dictionary, String) - Constructor for class org.apache.pinot.tools.scan.query.NotPredicateFilter

NumberGenerator - Class in org.apache.pinot.tools.data.generator

Sep 12, 2014

NumberGenerator(Integer, FieldSpec.DataType, boolean) - Constructor for class org.apache.pinot.tools.data.generator.NumberGenerator

O

OfflineSegmentIntervalCheckerCommand - Class in org.apache.pinot.tools.admin.command

Pinot admin command to list all offline segments with invalid intervals, group by table name

OfflineSegmentIntervalCheckerCommand() - Constructor for class org.apache.pinot.tools.admin.command.OfflineSegmentIntervalCheckerCommand

OperateClusterConfigCommand - Class in org.apache.pinot.tools.admin.command

OperateClusterConfigCommand() - Constructor for class org.apache.pinot.tools.admin.command.OperateClusterConfigCommand

org.apache.pinot.tools - package org.apache.pinot.tools

org.apache.pinot.tools.admin - package org.apache.pinot.tools.admin

org.apache.pinot.tools.admin.command - package org.apache.pinot.tools.admin.command

org.apache.pinot.tools.anonymizer - package org.apache.pinot.tools.anonymizer

org.apache.pinot.tools.backfill - package org.apache.pinot.tools.backfill

org.apache.pinot.tools.config.validator - package org.apache.pinot.tools.config.validator

org.apache.pinot.tools.data.generator - package org.apache.pinot.tools.data.generator

org.apache.pinot.tools.filesystem - package org.apache.pinot.tools.filesystem

org.apache.pinot.tools.perf - package org.apache.pinot.tools.perf

org.apache.pinot.tools.query.comparison - package org.apache.pinot.tools.query.comparison

org.apache.pinot.tools.realtime.provisioning - package org.apache.pinot.tools.realtime.provisioning

org.apache.pinot.tools.scan.query - package org.apache.pinot.tools.scan.query

org.apache.pinot.tools.segment.converter - package org.apache.pinot.tools.segment.converter

org.apache.pinot.tools.segment.processor - package org.apache.pinot.tools.segment.processor

org.apache.pinot.tools.service - package org.apache.pinot.tools.service

org.apache.pinot.tools.service.api.resources - package org.apache.pinot.tools.service.api.resources

org.apache.pinot.tools.streams - package org.apache.pinot.tools.streams

org.apache.pinot.tools.streams.githubevents - package org.apache.pinot.tools.streams.githubevents

org.apache.pinot.tools.utils - package org.apache.pinot.tools.utils

P

parseArguments(Parameters) - Method in class org.apache.pinot.tools.admin.command.EnumArrayOptionHandler

Tries to parse String[] argument from Parameters.

PatternMixtureGenerator - Class in org.apache.pinot.tools.data.generator

PatternMixtureGenerator enables combination of multiple Generators in alternating and additive patterns, including nested mixture models.

PatternMixtureGenerator(Map<String, Object>) - Constructor for class org.apache.pinot.tools.data.generator.PatternMixtureGenerator

PatternMixtureGenerator(List<List<Generator>>) - Constructor for class org.apache.pinot.tools.data.generator.PatternMixtureGenerator

PatternSeasonalGenerator - Class in org.apache.pinot.tools.data.generator

PatternSeasonalGenerator generates sinus wave patterns with a linear trend, gaussian noise, and cyclically repeating scaling factors.

PatternSeasonalGenerator(Map<String, Object>) - Constructor for class org.apache.pinot.tools.data.generator.PatternSeasonalGenerator

PatternSeasonalGenerator(double, double, double, double, double, double, int, double[]) - Constructor for class org.apache.pinot.tools.data.generator.PatternSeasonalGenerator

PatternSequenceGenerator - Class in org.apache.pinot.tools.data.generator

PatternSequenceGenerator produces a series of sequentially increasing (decreasing) numbers, optionally with a fixed number of repetitions per values.

PatternSequenceGenerator(Map<String, Object>) - Constructor for class org.apache.pinot.tools.data.generator.PatternSequenceGenerator

PatternSequenceGenerator(long, long, long) - Constructor for class org.apache.pinot.tools.data.generator.PatternSequenceGenerator

PatternSpikeGenerator - Class in org.apache.pinot.tools.data.generator

PatternSpikeGenerator produces a series of log-normal spikes with log-normal arrival times, with optional smoothing.

PatternSpikeGenerator(Map<String, Object>) - Constructor for class org.apache.pinot.tools.data.generator.PatternSpikeGenerator

PatternSpikeGenerator(double, PatternSpikeGenerator.DistributionType, double, double, PatternSpikeGenerator.DistributionType, double, double, double, int) - Constructor for class org.apache.pinot.tools.data.generator.PatternSpikeGenerator

PatternStringGenerator - Class in org.apache.pinot.tools.data.generator

TemplateStringGenerator produces series of strings by cycling through a predefined list of values, optionally with a number of repetitions per value.

PatternStringGenerator(Map<String, Object>) - Constructor for class org.apache.pinot.tools.data.generator.PatternStringGenerator

PatternStringGenerator(String[], long) - Constructor for class org.apache.pinot.tools.data.generator.PatternStringGenerator

PatternType - Enum in org.apache.pinot.tools.data.generator

PatternType describes the types of time series models available for generation.

PerfBenchmarkDriver - Class in org.apache.pinot.tools.perf

PerfBenchmarkDriver(PerfBenchmarkDriverConf) - Constructor for class org.apache.pinot.tools.perf.PerfBenchmarkDriver

PerfBenchmarkDriver(PerfBenchmarkDriverConf, String, String, String, boolean) - Constructor for class org.apache.pinot.tools.perf.PerfBenchmarkDriver

PerfBenchmarkDriverConf - Class in org.apache.pinot.tools.perf

PerfBenchmarkDriverConf() - Constructor for class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

PerfBenchmarkRunner - Class in org.apache.pinot.tools.perf

PerfBenchmarkRunner() - Constructor for class org.apache.pinot.tools.perf.PerfBenchmarkRunner

perfQuery(String) - Method in class org.apache.pinot.tools.query.comparison.ClusterStarter

PinotAdministrator - Class in org.apache.pinot.tools.admin

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.

PinotAdministrator() - Constructor for class org.apache.pinot.tools.admin.PinotAdministrator

PinotBroker - Class in org.apache.pinot.tools.admin

Simple shim so that jps -l shows PinotBroker instead of PinotAdministrator

PinotBroker() - Constructor for class org.apache.pinot.tools.admin.PinotBroker

PinotConfigUtils - Class in org.apache.pinot.tools.utils

PinotConfigUtils() - Constructor for class org.apache.pinot.tools.utils.PinotConfigUtils

PinotController - Class in org.apache.pinot.tools.admin

Simple shim so that jps -l shows PinotController instead of PinotAdministrator

PinotController() - Constructor for class org.apache.pinot.tools.admin.PinotController

PinotDataAndQueryAnonymizer - Class in org.apache.pinot.tools.anonymizer

The goal of this tool is to generate test dataset (as Avro files) with characteristics similar to a given source dataset.

PinotDataAndQueryAnonymizer(String, String, String, Map<String, Integer>, Set<String>, boolean) - Constructor for class org.apache.pinot.tools.anonymizer.PinotDataAndQueryAnonymizer

Create an instance of PinotDataGenerator

PinotDataAndQueryAnonymizer.FilterColumnExtractor - Class in org.apache.pinot.tools.anonymizer

* Filter Column Extractor * *

PinotDataAndQueryAnonymizer.QueryGenerator - Class in org.apache.pinot.tools.anonymizer

* QueryGenerator * *

PinotFSBenchmarkDriver - Class in org.apache.pinot.tools.filesystem

PinotFSBenchmarkDriver(String, String, String, String, Integer, Integer, Integer) - Constructor for class org.apache.pinot.tools.filesystem.PinotFSBenchmarkDriver

PinotFSBenchmarkRunner - Class in org.apache.pinot.tools.filesystem

PinotFSBenchmarkRunner() - Constructor for class org.apache.pinot.tools.filesystem.PinotFSBenchmarkRunner

PinotIdealstateChanger - Class in org.apache.pinot.tools

PinotIdealstateChanger(String, String, String, boolean) - Constructor for class org.apache.pinot.tools.PinotIdealstateChanger

PinotInstanceStatus - Class in org.apache.pinot.tools.service.api.resources

PinotInstanceStatus(ServiceRole, String, PinotConfiguration, ServiceStatus.Status, String) - Constructor for class org.apache.pinot.tools.service.api.resources.PinotInstanceStatus

PinotMinion - Class in org.apache.pinot.tools.admin

Simple shim so that jps -l shows PinotMinion instead of PinotAdministrator

PinotMinion() - Constructor for class org.apache.pinot.tools.admin.PinotMinion

PinotNumReplicaChanger - Class in org.apache.pinot.tools

PinotNumReplicaChanger(String, String, boolean) - Constructor for class org.apache.pinot.tools.PinotNumReplicaChanger

PinotSegmentConvertCommand - Class in org.apache.pinot.tools.segment.converter

The PinotSegmentConvertCommand class provides tools to convert Pinot segments into another format.

PinotSegmentConvertCommand() - Constructor for class org.apache.pinot.tools.segment.converter.PinotSegmentConvertCommand

PinotSegmentConverter - Interface in org.apache.pinot.tools.segment.converter

PinotSegmentToAvroConverter - Class in org.apache.pinot.tools.segment.converter

The PinotSegmentToAvroConverter class is the tool to convert Pinot segment to AVRO format.

PinotSegmentToAvroConverter(String, String) - Constructor for class org.apache.pinot.tools.segment.converter.PinotSegmentToAvroConverter

PinotSegmentToCsvConverter - Class in org.apache.pinot.tools.segment.converter

The PinotSegmentToCsvConverter class is the tool to convert Pinot segment to CSV format.

PinotSegmentToJsonConverter - Class in org.apache.pinot.tools.segment.converter

The PinotSegmentToJsonConverter class is the tool to convert Pinot segment to JSON format.

PinotSegmentToJsonConverter(String, String) - Constructor for class org.apache.pinot.tools.segment.converter.PinotSegmentToJsonConverter

PinotServer - Class in org.apache.pinot.tools.admin

Simple shim so that jps -l shows PinotServer instead of PinotAdministrator

PinotServer() - Constructor for class org.apache.pinot.tools.admin.PinotServer

PinotServiceManager - Class in org.apache.pinot.tools.service

PinotServiceManager is a user entry point to start Pinot instances in one process.

PinotServiceManager(String, String) - Constructor for class org.apache.pinot.tools.service.PinotServiceManager

PinotServiceManager(String, String, int) - Constructor for class org.apache.pinot.tools.service.PinotServiceManager

PinotServiceManager(String, String, String, int) - Constructor for class org.apache.pinot.tools.service.PinotServiceManager

PinotServiceManagerAdminApiApplication - Class in org.apache.pinot.tools.service

PinotServiceManagerAdminApiApplication(PinotServiceManager) - Constructor for class org.apache.pinot.tools.service.PinotServiceManagerAdminApiApplication

PinotServiceManagerHealthCheck - Class in org.apache.pinot.tools.service.api.resources

PinotServiceManagerHealthCheck() - Constructor for class org.apache.pinot.tools.service.api.resources.PinotServiceManagerHealthCheck

PinotServiceManagerInstanceResource - Class in org.apache.pinot.tools.service.api.resources

PinotServiceManagerInstanceResource() - Constructor for class org.apache.pinot.tools.service.api.resources.PinotServiceManagerInstanceResource

PinotServiceManagerStarter - Class in org.apache.pinot.tools.admin

Simple shim so that jps -l shows StartServiceManager instead of PinotAdministrator

PinotServiceManagerStarter() - Constructor for class org.apache.pinot.tools.admin.PinotServiceManagerStarter

PinotServiceManagerStatusCallback - Class in org.apache.pinot.tools.service

PinotServiceManagerStatusCallback(PinotServiceManager) - Constructor for class org.apache.pinot.tools.service.PinotServiceManagerStatusCallback

PinotTableRebalancer - Class in org.apache.pinot.tools

Helper class for pinot-admin tool's RebalanceTable command.

PinotTableRebalancer(String, String, boolean, boolean, boolean, boolean, boolean, int, boolean) - Constructor for class org.apache.pinot.tools.PinotTableRebalancer

PinotToolLauncher - Class in org.apache.pinot.tools

PinotToolLauncher() - Constructor for class org.apache.pinot.tools.PinotToolLauncher

PinotZKChanger - Class in org.apache.pinot.tools

This class provides utilities that change zookeeper state in a cluster

PinotZKChanger(String, String) - Constructor for class org.apache.pinot.tools.PinotZKChanger

PORT - Static variable in class org.apache.pinot.tools.utils.KafkaStarterUtils

postQuery(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriver

postQuery(String, String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriver

postQuery(String, String, String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriver

PostQueryCommand - Class in org.apache.pinot.tools.admin.command

PostQueryCommand() - Constructor for class org.apache.pinot.tools.admin.command.PostQueryCommand

PredicateFilter - Interface in org.apache.pinot.tools.scan.query

prettyPrintResponse(JsonNode) - Static method in class org.apache.pinot.tools.Quickstart

print() - Method in class org.apache.pinot.tools.scan.query.ResultTable

printExamples() - Method in class org.apache.pinot.tools.AbstractBaseCommand

printExamples() - Method in class org.apache.pinot.tools.admin.command.AnonymizeDataCommand

printExamples() - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

printExamples() - Method in class org.apache.pinot.tools.admin.command.RebalanceTableCommand

printResult(QueryResponse) - Static method in class org.apache.pinot.tools.scan.query.ScanBasedQueryProcessor

printSegmentAssignment(Map<String, Map<String, String>>) - Method in class org.apache.pinot.tools.PinotZKChanger

printStatus(Quickstart.Color, String) - Static method in class org.apache.pinot.tools.Quickstart

printUsage() - Method in class org.apache.pinot.tools.AbstractBaseCommand

printUsage() - Method in class org.apache.pinot.tools.admin.PinotAdministrator

printUsage() - Method in interface org.apache.pinot.tools.Command

printUsage() - Method in class org.apache.pinot.tools.PinotToolLauncher

processQuery(String) - Method in class org.apache.pinot.tools.scan.query.ScanBasedQueryProcessor

Projection - Class in org.apache.pinot.tools.scan.query

propertyStore - Variable in class org.apache.pinot.tools.PinotZKChanger

PullRequestMergedEvent - Class in org.apache.pinot.tools.streams.githubevents

Represents the pull request merged event

PullRequestMergedEvent(JsonNode, JsonNode, JsonNode, JsonNode) - Constructor for class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEvent

Construct a PullRequestMergedEvent from the github event of type PullRequestEvent which is also merged and closed.

PullRequestMergedEventsStream - Class in org.apache.pinot.tools.streams.githubevents

Creates a Kafka producer, for given kafka broker list Continuously fetches github events data.

PullRequestMergedEventsStream(String, String, String, String) - Constructor for class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEventsStream

Q

query(String) - Method in class org.apache.pinot.tools.query.comparison.ClusterStarter

QueryComparison - Class in org.apache.pinot.tools.query.comparison

QueryComparison(QueryComparisonConfig) - Constructor for class org.apache.pinot.tools.query.comparison.QueryComparison

QueryComparison.ComparisonStatus - Enum in org.apache.pinot.tools.query.comparison

QueryComparisonConfig - Class in org.apache.pinot.tools.query.comparison

QueryComparisonConfig(File) - Constructor for class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

QueryGenerator(String, String, String, String, Set<String>, Set<String>) - Constructor for class org.apache.pinot.tools.anonymizer.PinotDataAndQueryAnonymizer.QueryGenerator

QueryResponse - Class in org.apache.pinot.tools.scan.query

QueryRunner - Class in org.apache.pinot.tools.perf

QueryRunner() - Constructor for class org.apache.pinot.tools.perf.QueryRunner

Quickstart - Class in org.apache.pinot.tools

Quickstart() - Constructor for class org.apache.pinot.tools.Quickstart

Quickstart.Color - Enum in org.apache.pinot.tools

QuickStartCommand - Class in org.apache.pinot.tools.admin.command

QuickStartCommand() - Constructor for class org.apache.pinot.tools.admin.command.QuickStartCommand

QuickstartRunner - Class in org.apache.pinot.tools.admin.command

QuickstartRunner(List<QuickstartTableRequest>, int, int, int, File, boolean) - Constructor for class org.apache.pinot.tools.admin.command.QuickstartRunner

QuickstartRunner(List<QuickstartTableRequest>, int, int, int, File) - Constructor for class org.apache.pinot.tools.admin.command.QuickstartRunner

QuickstartTableRequest - Class in org.apache.pinot.tools

QuickstartTableRequest(String, File, File, File, FileFormat) - Constructor for class org.apache.pinot.tools.QuickstartTableRequest

QuickstartTableRequest(String, File, File) - Constructor for class org.apache.pinot.tools.QuickstartTableRequest

R

RangeDoubleGenerator - Class in org.apache.pinot.tools.data.generator

RangeDoubleGenerator(double, double) - Constructor for class org.apache.pinot.tools.data.generator.RangeDoubleGenerator

RangeFloatGenerator - Class in org.apache.pinot.tools.data.generator

RangeFloatGenerator(float, float) - Constructor for class org.apache.pinot.tools.data.generator.RangeFloatGenerator

RangeIntGenerator - Class in org.apache.pinot.tools.data.generator

RangeIntGenerator(int, int) - Constructor for class org.apache.pinot.tools.data.generator.RangeIntGenerator

RangeLongGenerator - Class in org.apache.pinot.tools.data.generator

RangeLongGenerator(long, long) - Constructor for class org.apache.pinot.tools.data.generator.RangeLongGenerator

RangePredicateFilter - Class in org.apache.pinot.tools.scan.query

RangePredicateFilter(Dictionary, List<String>) - Constructor for class org.apache.pinot.tools.scan.query.RangePredicateFilter

readConfigFromFile(String) - Static method in class org.apache.pinot.tools.utils.PinotConfigUtils

readControllerConfigFromFile(String) - Static method in class org.apache.pinot.tools.utils.PinotConfigUtils

RealtimeProvisioningHelperCommand - Class in org.apache.pinot.tools.admin.command

Given a set of input params, output a table of num hosts to num hours and the memory required per host

RealtimeProvisioningHelperCommand() - Constructor for class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

RealtimeQuickStart - Class in org.apache.pinot.tools

RealtimeQuickStart() - Constructor for class org.apache.pinot.tools.RealtimeQuickStart

rebalance(String) - Method in class org.apache.pinot.tools.PinotTableRebalancer

RebalanceTableCommand - Class in org.apache.pinot.tools.admin.command

A sub-command for pinot-admin tool to rebalance a specific table

RebalanceTableCommand() - Constructor for class org.apache.pinot.tools.admin.command.RebalanceTableCommand

ResultTable - Class in org.apache.pinot.tools.scan.query

run() - Method in class org.apache.pinot.tools.admin.command.OperateClusterConfigCommand

run() - Method in class org.apache.pinot.tools.admin.command.PostQueryCommand

run() - Method in class org.apache.pinot.tools.filesystem.PinotFSBenchmarkDriver

run() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriver

run() - Method in class org.apache.pinot.tools.scan.query.Aggregation

run() - Method in class org.apache.pinot.tools.scan.query.AggregationFunc

run() - Method in class org.apache.pinot.tools.scan.query.AvgFunction

run() - Method in class org.apache.pinot.tools.scan.query.CountFunction

run() - Method in class org.apache.pinot.tools.scan.query.DistinctCountFunction

run() - Method in class org.apache.pinot.tools.scan.query.MaxFunction

run() - Method in class org.apache.pinot.tools.scan.query.MinFunction

run() - Method in class org.apache.pinot.tools.scan.query.MinMaxRangeFunction

run() - Method in class org.apache.pinot.tools.scan.query.Projection

run() - Method in class org.apache.pinot.tools.scan.query.Selection

run() - Method in class org.apache.pinot.tools.scan.query.SumFunction

run() - Method in class org.apache.pinot.tools.streams.AirlineDataStream

run() - Method in class org.apache.pinot.tools.streams.MeetupRsvpStream

runQuery(String) - Method in class org.apache.pinot.tools.admin.command.QuickstartRunner

S

savePID(String) - Method in class org.apache.pinot.tools.admin.command.AbstractBaseAdminCommand

ScanBasedQueryProcessor - Class in org.apache.pinot.tools.scan.query

ScanBasedQueryProcessor(String) - Constructor for class org.apache.pinot.tools.scan.query.ScanBasedQueryProcessor

SchemaAnnotation - Class in org.apache.pinot.tools.data.generator

SchemaAnnotation() - Constructor for class org.apache.pinot.tools.data.generator.SchemaAnnotation

SchemaAnnotation(String, int) - Constructor for class org.apache.pinot.tools.data.generator.SchemaAnnotation

SchemaAnnotation(String, int, int) - Constructor for class org.apache.pinot.tools.data.generator.SchemaAnnotation

SchemaAnnotation(String, Map<String, Object>) - Constructor for class org.apache.pinot.tools.data.generator.SchemaAnnotation

SchemaValidator - Class in org.apache.pinot.tools.config.validator

seal() - Method in class org.apache.pinot.tools.scan.query.ResultTable

SEGMENT_NAME - Static variable in class org.apache.pinot.tools.query.comparison.QueryComparisonConfig

SegmentDumpTool - Class in org.apache.pinot.tools

SegmentDumpTool() - Constructor for class org.apache.pinot.tools.SegmentDumpTool

SegmentInfoProvider - Class in org.apache.pinot.tools.query.comparison

Given a segments directory, pick all segments and read the dictionaries for all single-value dimension columns.

SegmentInfoProvider(String) - Constructor for class org.apache.pinot.tools.query.comparison.SegmentInfoProvider

Assume that segments directory has at least one segment.

SegmentMergeCommand - Class in org.apache.pinot.tools.segment.converter

Segment merge command.

SegmentMergeCommand() - Constructor for class org.apache.pinot.tools.segment.converter.SegmentMergeCommand

SegmentProcessorFrameworkCommand - Class in org.apache.pinot.tools.admin.command

Command to run SegmentProcessorFramework

SegmentProcessorFrameworkCommand() - Constructor for class org.apache.pinot.tools.admin.command.SegmentProcessorFrameworkCommand

SegmentProcessorFrameworkSpec - Class in org.apache.pinot.tools.segment.processor

Container for all spec related to Segment Processor Framework required for running via pinot-admin

SegmentProcessorFrameworkSpec() - Constructor for class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

Selection - Class in org.apache.pinot.tools.scan.query

Selection(ImmutableSegment, SegmentMetadataImpl, List<Integer>, List<Pair>) - Constructor for class org.apache.pinot.tools.scan.query.Selection

sendDeleteRequest(String, String) - Static method in class org.apache.pinot.tools.admin.command.AbstractBaseAdminCommand

sendPostRequest(String, String) - Static method in class org.apache.pinot.tools.admin.command.AbstractBaseAdminCommand

sendRequest(String, String, String) - Static method in class org.apache.pinot.tools.admin.command.AbstractBaseAdminCommand

sendTableCreationRequest(JsonNode) - Method in class org.apache.pinot.tools.admin.command.AddTableCommand

serialize(String) - Method in class org.apache.pinot.tools.anonymizer.ArrayBasedGlobalDictionaries

serialize(String) - Method in interface org.apache.pinot.tools.anonymizer.GlobalDictionaries

serialize(String) - Method in class org.apache.pinot.tools.anonymizer.MapBasedGlobalDictionaries

setAdminPort(int) - Method in class org.apache.pinot.tools.admin.command.StartServerCommand

setAvroFile(String) - Method in class org.apache.pinot.tools.admin.command.StreamAvroIntoKafkaCommand

setBootstrapConfigPaths(String[]) - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

setBootstrapServices(String[]) - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

setBrokerHost(String) - Method in class org.apache.pinot.tools.admin.command.PostQueryCommand

setBrokerHost(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setBrokerHost(String) - Method in class org.apache.pinot.tools.query.comparison.ClusterStarter

setBrokerPort(String) - Method in class org.apache.pinot.tools.admin.command.PostQueryCommand

setBrokerPort(int) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setBrokerPort(String) - Method in class org.apache.pinot.tools.query.comparison.ClusterStarter

setCardinality(int) - Method in class org.apache.pinot.tools.data.generator.SchemaAnnotation

setCleanOnStartup(boolean) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setClusterName(String) - Method in class org.apache.pinot.tools.admin.command.DeleteClusterCommand

setClusterName(String) - Method in class org.apache.pinot.tools.admin.command.StartBrokerCommand

setClusterName(String) - Method in class org.apache.pinot.tools.admin.command.StartControllerCommand

setClusterName(String) - Method in class org.apache.pinot.tools.admin.command.StartServerCommand

setClusterName(String) - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

setClusterName(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setClusterName(String) - Method in class org.apache.pinot.tools.query.comparison.ClusterStarter

setClusterName(String) - Method in class org.apache.pinot.tools.UpdateSegmentState

setCollectorConfig(CollectorConfig) - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

setColumn(String) - Method in class org.apache.pinot.tools.data.generator.SchemaAnnotation

setColumns(String) - Method in class org.apache.pinot.tools.segment.converter.DictionaryToRawIndexConverter

Setter for columns to convert.

setCompareNumDocs(boolean) - Static method in class org.apache.pinot.tools.query.comparison.QueryComparison

setConfig(String) - Method in class org.apache.pinot.tools.admin.command.OperateClusterConfigCommand

setConfigFileName(String) - Method in class org.apache.pinot.tools.admin.command.StartBrokerCommand

setConfigFileName(String) - Method in class org.apache.pinot.tools.admin.command.StartControllerCommand

setConfigFileName(String) - Method in class org.apache.pinot.tools.admin.command.StartServerCommand

setConfigureResources(boolean) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setControllerDataDir(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setControllerHost(String) - Method in class org.apache.pinot.tools.admin.command.AddSchemaCommand

setControllerHost(String) - Method in class org.apache.pinot.tools.admin.command.AddTableCommand

setControllerHost(String) - Method in class org.apache.pinot.tools.admin.command.OperateClusterConfigCommand

setControllerHost(String) - Method in class org.apache.pinot.tools.admin.command.UploadSegmentCommand

setControllerHost(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setControllerPort(String) - Method in class org.apache.pinot.tools.admin.command.AddSchemaCommand

setControllerPort(String) - Method in class org.apache.pinot.tools.admin.command.AddTableCommand

setControllerPort(String) - Method in class org.apache.pinot.tools.admin.command.OperateClusterConfigCommand

setControllerPort(String) - Method in class org.apache.pinot.tools.admin.command.StartControllerCommand

setControllerPort(String) - Method in class org.apache.pinot.tools.admin.command.UploadSegmentCommand

setControllerPort(int) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setControllerPort(String) - Method in class org.apache.pinot.tools.query.comparison.ClusterStarter

setControllerUrl(String) - Method in class org.apache.pinot.tools.admin.command.AddTenantCommand

setDataDir(String) - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

setDataDir(String) - Method in class org.apache.pinot.tools.admin.command.StartControllerCommand

setDataDir(String) - Method in class org.apache.pinot.tools.admin.command.StartServerCommand

setDataDir(String) - Method in class org.apache.pinot.tools.segment.converter.DictionaryToRawIndexConverter

Setter for DictionaryToRawIndexConverter._dataDir

setDialect(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setEventType(String) - Method in class org.apache.pinot.tools.admin.command.StreamGitHubEventsCommand

setExecute(boolean) - Method in class org.apache.pinot.tools.admin.command.AddSchemaCommand

setExecute(boolean) - Method in class org.apache.pinot.tools.admin.command.AddTableCommand

setExecute(boolean) - Method in class org.apache.pinot.tools.admin.command.AddTenantCommand

setFormat(FileFormat) - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

setHelp(boolean) - Method in class org.apache.pinot.tools.admin.command.LaunchDataIngestionJobCommand

setHelp(boolean) - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

setIngestionJobFile(File) - Method in class org.apache.pinot.tools.QuickstartTableRequest

setIngestionRate(int) - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

setInputSegmentsDir(String) - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

setInstances(int) - Method in class org.apache.pinot.tools.admin.command.AddTenantCommand

setJobSpecFile(String) - Method in class org.apache.pinot.tools.admin.command.LaunchDataIngestionJobCommand

setKafkaBrokerList(String) - Method in class org.apache.pinot.tools.admin.command.StreamAvroIntoKafkaCommand

setKafkaBrokerList(String) - Method in class org.apache.pinot.tools.admin.command.StreamGitHubEventsCommand

setKafkaTopic(String) - Method in class org.apache.pinot.tools.admin.command.StreamAvroIntoKafkaCommand

setMaxUsableHostMemory(String) - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

setName(String) - Method in class org.apache.pinot.tools.admin.command.AddTenantCommand

setNumDocsScanned(int) - Method in class org.apache.pinot.tools.scan.query.ResultTable

setNumHosts(String) - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

setNumHours(String) - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

setNumPartitions(int) - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

setNumThreads(int) - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

setOffline(int) - Method in class org.apache.pinot.tools.admin.command.AddTenantCommand

setOperation(String) - Method in class org.apache.pinot.tools.admin.command.OperateClusterConfigCommand

setOutDir(String) - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

setOutputDir(String) - Method in class org.apache.pinot.tools.segment.converter.DictionaryToRawIndexConverter

Setter for DictionaryToRawIndexConverter._outputDir

setOutputFormat(String) - Method in class org.apache.pinot.tools.admin.command.StreamAvroIntoKafkaCommand

setOutputSegmentsDir(String) - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

setOverwrite(boolean) - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

setOverwrite(boolean) - Method in class org.apache.pinot.tools.segment.converter.DictionaryToRawIndexConverter

Setter for DictionaryToRawIndexConverter._overwrite When set to true, already existing output directory is overwritten.

setOverwrite(boolean) - Method in class org.apache.pinot.tools.UpdateSegmentState

setPartitionerConfigs(List<PartitionerConfig>) - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

setPattern(Map<String, Object>) - Method in class org.apache.pinot.tools.data.generator.SchemaAnnotation

setPersonalAccessToken(String) - Method in class org.apache.pinot.tools.admin.command.GitHubEventsQuickStartCommand

setPersonalAccessToken(String) - Method in class org.apache.pinot.tools.admin.command.StreamGitHubEventsCommand

setPort(int) - Method in class org.apache.pinot.tools.admin.command.StartBrokerCommand

setPort(int) - Method in class org.apache.pinot.tools.admin.command.StartServerCommand

setPort(int) - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

setPostCreationVerification(boolean) - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

setProcessingTime(long) - Method in class org.apache.pinot.tools.scan.query.ResultTable

setPropertyFile(String) - Method in class org.apache.pinot.tools.admin.command.LaunchDataIngestionJobCommand

setPushFrequency(String) - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

setQueriesDirectory(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setQuery(String) - Method in class org.apache.pinot.tools.admin.command.PostQueryCommand

setQueryType(String) - Method in class org.apache.pinot.tools.admin.command.PostQueryCommand

setRange(boolean) - Method in class org.apache.pinot.tools.data.generator.SchemaAnnotation

setRangeEnd(int) - Method in class org.apache.pinot.tools.data.generator.SchemaAnnotation

setRangeStart(int) - Method in class org.apache.pinot.tools.data.generator.SchemaAnnotation

setReaderConfigFile(String) - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

setRealtime(int) - Method in class org.apache.pinot.tools.admin.command.AddTenantCommand

setRecordFilterConfig(RecordFilterConfig) - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

setRecordTransformerConfig(RecordTransformerConfig) - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

setResultsOutputDirectory(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setResultType(ResultTable.ResultType) - Method in class org.apache.pinot.tools.scan.query.ResultTable

setRetentionHours(int) - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

setRetry(int) - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

setRole(TenantRole) - Method in class org.apache.pinot.tools.admin.command.AddTenantCommand

setRunQueries(boolean) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setSampleCompletedSegmentDir(String) - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

setSchemaFile(String) - Method in class org.apache.pinot.tools.admin.command.AddTableCommand

setSchemaFile(String) - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

setSchemaFile(String) - Method in class org.apache.pinot.tools.admin.command.StreamGitHubEventsCommand

setSchemaFile(File) - Method in class org.apache.pinot.tools.QuickstartTableRequest

setSchemaFile(String) - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

setSchemaFileNamePath(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setSchemaFilePath(String) - Method in class org.apache.pinot.tools.admin.command.AddSchemaCommand

setSegmentConfig(SegmentConfig) - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

setSegmentDir(String) - Method in class org.apache.pinot.tools.admin.command.StartServerCommand

setSegmentDir(String) - Method in class org.apache.pinot.tools.admin.command.UploadSegmentCommand

setSegmentDirName(String) - Method in class org.apache.pinot.tools.query.comparison.ClusterStarter

setSegmentFileFormat(FileFormat) - Method in class org.apache.pinot.tools.QuickstartTableRequest

setServerHost(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setServerInstanceDataDir(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setServerInstanceName(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setServerInstanceSegmentTarDir(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setServerPort(int) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setServerPort(String) - Method in class org.apache.pinot.tools.query.comparison.ClusterStarter

setStartBroker(boolean) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setStartController(boolean) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setStartServer(boolean) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setStartZookeeper(boolean) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setStartZookeeper(boolean) - Method in class org.apache.pinot.tools.query.comparison.ClusterStarter

setTableConfigFile(String) - Method in class org.apache.pinot.tools.admin.command.AddTableCommand

setTableConfigFile(String) - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

setTableConfigFile(String) - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

setTableConfigFile(String) - Method in class org.apache.pinot.tools.segment.processor.SegmentProcessorFrameworkSpec

setTableName(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setTableName(String) - Method in class org.apache.pinot.tools.query.comparison.ClusterStarter

setTableName(String) - Method in class org.apache.pinot.tools.QuickstartTableRequest

setTableName(String) - Method in class org.apache.pinot.tools.UpdateSegmentState

setTableRequestFile(File) - Method in class org.apache.pinot.tools.QuickstartTableRequest

setTableType(TableType) - Method in class org.apache.pinot.tools.QuickstartTableRequest

setTenantIsolation(boolean) - Method in class org.apache.pinot.tools.admin.command.StartControllerCommand

setTenantName(String) - Method in class org.apache.pinot.tools.UpdateSegmentState

setTopic(String) - Method in class org.apache.pinot.tools.admin.command.StreamGitHubEventsCommand

setTotalDocs(int) - Method in class org.apache.pinot.tools.scan.query.ResultTable

setType(String) - Method in class org.apache.pinot.tools.admin.command.QuickStartCommand

setValues(List<String>) - Method in class org.apache.pinot.tools.admin.command.LaunchDataIngestionJobCommand

setVerbose(boolean) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setZkAddress(String) - Method in class org.apache.pinot.tools.admin.command.DeleteClusterCommand

setZkAddress(String) - Method in class org.apache.pinot.tools.admin.command.StartBrokerCommand

setZkAddress(String) - Method in class org.apache.pinot.tools.admin.command.StartControllerCommand

setZkAddress(String) - Method in class org.apache.pinot.tools.admin.command.StartServerCommand

setZkAddress(String) - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

setZkAddress(String) - Method in class org.apache.pinot.tools.admin.command.StreamAvroIntoKafkaCommand

setZkAddress(String) - Method in class org.apache.pinot.tools.query.comparison.ClusterStarter

setZkAddress(String) - Method in class org.apache.pinot.tools.UpdateSegmentState

setZkHost(String) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

setZkPort(int) - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

shouldStartBroker() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

shouldStartController() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

shouldStartServer() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkDriverConf

ShowClusterInfoCommand - Class in org.apache.pinot.tools.admin.command

ShowClusterInfoCommand() - Constructor for class org.apache.pinot.tools.admin.command.ShowClusterInfoCommand

shutdown() - Method in class org.apache.pinot.tools.streams.AirlineDataStream

shutdown() - Method in class org.apache.pinot.tools.streams.githubevents.GitHubAPICaller

shutdown() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEventsStream

Shuts down the stream.

singleThreadedQueryRunner(PerfBenchmarkDriverConf, Stream<String>, int, int, int, long) - Static method in class org.apache.pinot.tools.perf.QueryRunner

Use single thread to run queries as fast as possible.

size() - Method in class org.apache.pinot.tools.scan.query.ResultTable

sortOriginalValuesInGlobalDictionaries() - Method in class org.apache.pinot.tools.anonymizer.ArrayBasedGlobalDictionaries

This is the second step where we complete the global dictionaries by sorting the original values to get sort order across all segments

sortOriginalValuesInGlobalDictionaries() - Method in interface org.apache.pinot.tools.anonymizer.GlobalDictionaries

sortOriginalValuesInGlobalDictionaries() - Method in class org.apache.pinot.tools.anonymizer.MapBasedGlobalDictionaries

This is the second step where we complete the global dictionaries by sorting the original values to get sort order across all segments

SpeedTest - Class in org.apache.pinot.tools

Compares perf between Heap, Direct and Memory Mapped

SpeedTest() - Constructor for class org.apache.pinot.tools.SpeedTest

start(int) - Method in class org.apache.pinot.tools.perf.ZookeeperLauncher

start() - Method in class org.apache.pinot.tools.query.comparison.ClusterStarter

start() - Method in class org.apache.pinot.tools.service.PinotServiceManager

start(int) - Method in class org.apache.pinot.tools.service.PinotServiceManagerAdminApiApplication

start() - Method in class org.apache.pinot.tools.streams.githubevents.PullRequestMergedEventsStream

startAll() - Method in class org.apache.pinot.tools.admin.command.QuickstartRunner

startAllButServer() - Method in class org.apache.pinot.tools.perf.PerfBenchmarkRunner

startBroker(PinotConfiguration) - Method in class org.apache.pinot.tools.service.PinotServiceManager

StartBrokerCommand - Class in org.apache.pinot.tools.admin.command

Class to implement StartBroker command.

StartBrokerCommand() - Constructor for class org.apache.pinot.tools.admin.command.StartBrokerCommand

startComponents(boolean, boolean, boolean, boolean, String) - Static method in class org.apache.pinot.tools.perf.PerfBenchmarkDriver

Start cluster components with default configuration.

startController(ControllerConf) - Method in class org.apache.pinot.tools.service.PinotServiceManager

StartControllerCommand - Class in org.apache.pinot.tools.admin.command

Class to implement StartController command.

StartControllerCommand() - Constructor for class org.apache.pinot.tools.admin.command.StartControllerCommand

StartKafkaCommand - Class in org.apache.pinot.tools.admin.command

Class for command to start Kafka.

StartKafkaCommand() - Constructor for class org.apache.pinot.tools.admin.command.StartKafkaCommand

startMinion(PinotConfiguration) - Method in class org.apache.pinot.tools.service.PinotServiceManager

StartMinionCommand - Class in org.apache.pinot.tools.admin.command

Class to implement StartMinion command.

StartMinionCommand() - Constructor for class org.apache.pinot.tools.admin.command.StartMinionCommand

startPinotInstance(String, boolean, String) - Method in class org.apache.pinot.tools.service.api.resources.PinotServiceManagerInstanceResource

StarTreeIndexViewer - Class in org.apache.pinot.tools

StarTreeIndexViewer(File) - Constructor for class org.apache.pinot.tools.StarTreeIndexViewer

StarTreeIndexViewer.StarTreeViewRestResource - Class in org.apache.pinot.tools

StarTreeQueryGenerator - Class in org.apache.pinot.tools.query.comparison

Given a list of dimension and metric columns, and possible values for dimension columns: Generate queries of the form: SELECT SUM(m1), SUM(m2)...

StarTreeQueryGenerator(String, List<String>, List<String>, Map<String, List<Object>>, List<String>) - Constructor for class org.apache.pinot.tools.query.comparison.StarTreeQueryGenerator

StarTreeViewRestResource() - Constructor for class org.apache.pinot.tools.StarTreeIndexViewer.StarTreeViewRestResource

startRole(ServiceRole, Map<String, Object>) - Method in class org.apache.pinot.tools.service.PinotServiceManager

startServer(PinotConfiguration) - Method in class org.apache.pinot.tools.service.PinotServiceManager

startServer(int, int, String, Properties) - Static method in class org.apache.pinot.tools.utils.KafkaStarterUtils

StartServerCommand - Class in org.apache.pinot.tools.admin.command

Class to implement StartServer command.

StartServerCommand() - Constructor for class org.apache.pinot.tools.admin.command.StartServerCommand

startServers(int, int, String, Properties) - Static method in class org.apache.pinot.tools.utils.KafkaStarterUtils

StartServiceManagerCommand - Class in org.apache.pinot.tools.admin.command

Starts services in the following order, and returns false on any startup failure:

StartServiceManagerCommand() - Constructor for class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

StartZookeeperCommand - Class in org.apache.pinot.tools.admin.command

Class for command to start ZooKeeper.

StartZookeeperCommand() - Constructor for class org.apache.pinot.tools.admin.command.StartZookeeperCommand

StatsGenerator - Class in org.apache.pinot.tools.query.comparison

StatsGenerator() - Constructor for class org.apache.pinot.tools.query.comparison.StatsGenerator

stop() - Method in class org.apache.pinot.tools.admin.command.QuickstartRunner

stop() - Method in class org.apache.pinot.tools.admin.command.StartZookeeperCommand

stop() - Method in class org.apache.pinot.tools.perf.ZookeeperLauncher

stop() - Method in class org.apache.pinot.tools.service.PinotServiceManager

stop() - Method in class org.apache.pinot.tools.service.PinotServiceManagerAdminApiApplication

stopBroker() - Method in class org.apache.pinot.tools.admin.command.StopProcessCommand

stopController() - Method in class org.apache.pinot.tools.admin.command.StopProcessCommand

stopPinotInstance(String) - Method in class org.apache.pinot.tools.service.api.resources.PinotServiceManagerInstanceResource

stopPinotInstance(ServiceStartable) - Method in class org.apache.pinot.tools.service.PinotServiceManager

stopPinotInstanceById(String) - Method in class org.apache.pinot.tools.service.PinotServiceManager

StopProcessCommand - Class in org.apache.pinot.tools.admin.command

Class for command to stop a process.

StopProcessCommand() - Constructor for class org.apache.pinot.tools.admin.command.StopProcessCommand

StopProcessCommand(boolean) - Constructor for class org.apache.pinot.tools.admin.command.StopProcessCommand

stopPublishing() - Method in class org.apache.pinot.tools.streams.MeetupRsvpStream

stopServer() - Method in class org.apache.pinot.tools.admin.command.StopProcessCommand

stopZookeeper() - Method in class org.apache.pinot.tools.admin.command.StopProcessCommand

StreamAvroIntoKafkaCommand - Class in org.apache.pinot.tools.admin.command

Class for command to stream Avro data into Kafka.

StreamAvroIntoKafkaCommand() - Constructor for class org.apache.pinot.tools.admin.command.StreamAvroIntoKafkaCommand

StreamGitHubEventsCommand - Class in org.apache.pinot.tools.admin.command

Command to stream GitHub events into a kafka topic

StreamGitHubEventsCommand() - Constructor for class org.apache.pinot.tools.admin.command.StreamGitHubEventsCommand

StringGenerator - Class in org.apache.pinot.tools.data.generator

Sep 12, 2014

StringGenerator(Integer) - Constructor for class org.apache.pinot.tools.data.generator.StringGenerator

SumFunction - Class in org.apache.pinot.tools.scan.query

T

TableConfigValidator - Class in org.apache.pinot.tools.config.validator

TAR_SUFFIX - Static variable in class org.apache.pinot.tools.backfill.BackfillSegmentUtils

targetQPSQueryRunner(PerfBenchmarkDriverConf, Stream<String>, int, int, int, double, int, int, long) - Static method in class org.apache.pinot.tools.perf.QueryRunner

Use multiple threads to run query at a target QPS.

TMP_DIR - Static variable in class org.apache.pinot.tools.utils.PinotConfigUtils

toString() - Method in class org.apache.pinot.tools.admin.command.AddSchemaCommand

toString() - Method in class org.apache.pinot.tools.admin.command.AddTableCommand

toString() - Method in class org.apache.pinot.tools.admin.command.AddTenantCommand

toString() - Method in class org.apache.pinot.tools.admin.command.AvroSchemaToPinotSchema

toString() - Method in class org.apache.pinot.tools.admin.command.ChangeTableState

toString() - Method in class org.apache.pinot.tools.admin.command.CreateSegmentCommand

toString() - Method in class org.apache.pinot.tools.admin.command.DeleteClusterCommand

toString() - Method in class org.apache.pinot.tools.admin.command.GenerateDataCommand

toString() - Method in class org.apache.pinot.tools.admin.command.GitHubEventsQuickStartCommand

toString() - Method in class org.apache.pinot.tools.admin.command.LaunchDataIngestionJobCommand

toString() - Method in class org.apache.pinot.tools.admin.command.MoveReplicaGroup

toString() - Method in class org.apache.pinot.tools.admin.command.OfflineSegmentIntervalCheckerCommand

toString() - Method in class org.apache.pinot.tools.admin.command.OperateClusterConfigCommand

toString() - Method in class org.apache.pinot.tools.admin.command.PostQueryCommand

toString() - Method in class org.apache.pinot.tools.admin.command.QuickStartCommand

toString() - Method in class org.apache.pinot.tools.admin.command.RealtimeProvisioningHelperCommand

toString() - Method in class org.apache.pinot.tools.admin.command.SegmentProcessorFrameworkCommand

toString() - Method in class org.apache.pinot.tools.admin.command.ShowClusterInfoCommand

toString() - Method in class org.apache.pinot.tools.admin.command.StartBrokerCommand

toString() - Method in class org.apache.pinot.tools.admin.command.StartControllerCommand

toString() - Method in class org.apache.pinot.tools.admin.command.StartKafkaCommand

toString() - Method in class org.apache.pinot.tools.admin.command.StartMinionCommand

toString() - Method in class org.apache.pinot.tools.admin.command.StartServerCommand

toString() - Method in class org.apache.pinot.tools.admin.command.StartServiceManagerCommand

toString() - Method in class org.apache.pinot.tools.admin.command.StartZookeeperCommand

toString() - Method in class org.apache.pinot.tools.admin.command.StopProcessCommand

toString() - Method in class org.apache.pinot.tools.admin.command.StreamAvroIntoKafkaCommand

toString() - Method in class org.apache.pinot.tools.admin.command.StreamGitHubEventsCommand

toString() - Method in class org.apache.pinot.tools.admin.command.UploadSegmentCommand

toString() - Method in class org.apache.pinot.tools.data.generator.DataGeneratorSpec

toString() - Method in class org.apache.pinot.tools.scan.query.QueryResponse

toString() - Method in class org.apache.pinot.tools.UpdateSegmentState

transformFromIdToValues(ResultTable, Map<String, Dictionary>, boolean) - Method in class org.apache.pinot.tools.scan.query.Projection

U

updateIdealState() - Method in class org.apache.pinot.tools.PinotIdealstateChanger

UpdateSegmentState - Class in org.apache.pinot.tools

UpdateSegmentState() - Constructor for class org.apache.pinot.tools.UpdateSegmentState

uploadSchema() - Method in class org.apache.pinot.tools.admin.command.AddTableCommand

uploadSegment(String, String, File, File) - Method in class org.apache.pinot.tools.backfill.BackfillSegmentUtils

Uploads the segment tar to the controller.

UploadSegmentCommand - Class in org.apache.pinot.tools.admin.command

Class for command to upload data into Pinot.

UploadSegmentCommand() - Constructor for class org.apache.pinot.tools.admin.command.UploadSegmentCommand

UpsertQuickStart - Class in org.apache.pinot.tools

UpsertQuickStart() - Constructor for class org.apache.pinot.tools.UpsertQuickStart

Utils - Class in org.apache.pinot.tools.scan.query

Utils() - Constructor for class org.apache.pinot.tools.scan.query.Utils

V

validate(Schema) - Static method in class org.apache.pinot.tools.config.validator.SchemaValidator

validate(TableConfig) - Static method in class org.apache.pinot.tools.config.validator.TableConfigValidator

ValidateConfigCommand - Class in org.apache.pinot.tools.admin.command

Class for command to validate configs.

ValidateConfigCommand() - Constructor for class org.apache.pinot.tools.admin.command.ValidateConfigCommand

validateControllerConfig(ControllerConf) - Static method in class org.apache.pinot.tools.utils.PinotConfigUtils

ValidateTableRetention - Class in org.apache.pinot.tools

ValidateTableRetention() - Constructor for class org.apache.pinot.tools.ValidateTableRetention

valueOf(String) - Static method in enum org.apache.pinot.tools.data.generator.PatternType

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.pinot.tools.query.comparison.QueryComparison.ComparisonStatus

Returns the enum constant of this type with the specified name.

valueOf(String) - Static method in enum org.apache.pinot.tools.Quickstart.Color

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.pinot.tools.data.generator.PatternType

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.pinot.tools.query.comparison.QueryComparison.ComparisonStatus

Returns an array containing the constants of this enum type, in the order they are declared.

values() - Static method in enum org.apache.pinot.tools.Quickstart.Color

Returns an array containing the constants of this enum type, in the order they are declared.

verifyClusterState(String, long) - Method in class org.apache.pinot.tools.ClusterStateVerifier

Assemble and scan the candidate table names, return true if all the tables are stable.

VerifyClusterStateCommand - Class in org.apache.pinot.tools.admin.command

VerifyClusterStateCommand() - Constructor for class org.apache.pinot.tools.admin.command.VerifyClusterStateCommand

VerifySegmentState - Class in org.apache.pinot.tools.admin.command

VerifySegmentState() - Constructor for class org.apache.pinot.tools.admin.command.VerifySegmentState

W

waitForExternalViewUpdate(String, String, long) - Static method in class org.apache.pinot.tools.perf.PerfBenchmarkDriver

waitForStable(String) - Method in class org.apache.pinot.tools.PinotZKChanger

Wait till state has stabilized PinotZKChanger.isStable(String)

writeNext() - Method in class org.apache.pinot.tools.data.generator.AvroWriter

Z

ZOOKEEPER_CONNECT - Static variable in class org.apache.pinot.tools.utils.KafkaStarterUtils

ZookeeperLauncher - Class in org.apache.pinot.tools.perf

ZookeeperLauncher() - Constructor for class org.apache.pinot.tools.perf.ZookeeperLauncher

ZookeeperLauncher(String) - Constructor for class org.apache.pinot.tools.perf.ZookeeperLauncher

_

_column - Variable in class org.apache.pinot.tools.scan.query.AggregationFunc

_rows - Variable in class org.apache.pinot.tools.scan.query.AggregationFunc

A B C D E F G H I J K L M N O P Q R S T U V W Z _