|
Change Parameter Type upsertListener : UpsertListener to upsertListener : UpsertListener<RECORD> in method protected UpsertExecutor(conn Connection, columnInfoList List<ColumnInfo>, preparedStatement PreparedStatement, upsertListener UpsertListener<RECORD>) in class org.apache.phoenix.util.UpsertExecutor |
From |
To |
|
Change Parameter Type csvRecords : Iterable<CSVRecord> to records : Iterable<RECORD> in method public execute(records Iterable<RECORD>) : void in class org.apache.phoenix.util.UpsertExecutor |
From |
To |
|
Change Parameter Type tablesStartKeys : Set<CsvTableRowkeyPair> to tablesStartKeys : Set<TableRowkeyPair> in method package configurePartitioner(job Job, tablesStartKeys Set<TableRowkeyPair>) : void in class org.apache.phoenix.mapreduce.MultiHfileOutputFormat |
From |
To |
|
Change Parameter Type key : CsvTableRowkeyPair to key : TableRowkeyPair in method protected reduce(key TableRowkeyPair, values Iterable<KeyValue>, context Reducer<TableRowkeyPair,KeyValue,TableRowkeyPair,KeyValue>) : void in class org.apache.phoenix.mapreduce.FormatToKeyValueReducer |
From |
To |
|
Change Parameter Type conn : PhoenixConnection to conn : Connection in method private createStatement(conn Connection, tableName String, columnInfoList List<ColumnInfo>) : PreparedStatement in class org.apache.phoenix.util.UpsertExecutor |
From |
To |
|
Change Parameter Type context : Reducer<CsvTableRowkeyPair,KeyValue,CsvTableRowkeyPair,KeyValue> to context : Reducer<TableRowkeyPair,KeyValue,TableRowkeyPair,KeyValue> in method protected reduce(key TableRowkeyPair, values Iterable<KeyValue>, context Reducer<TableRowkeyPair,KeyValue,TableRowkeyPair,KeyValue>) : void in class org.apache.phoenix.mapreduce.FormatToKeyValueReducer |
From |
To |
|
Change Parameter Type tablesStartKeys : Set<CsvTableRowkeyPair> to tablesStartKeys : Set<TableRowkeyPair> in method private writePartitions(conf Configuration, partitionsPath Path, tablesStartKeys Set<TableRowkeyPair>) : void in class org.apache.phoenix.mapreduce.MultiHfileOutputFormat |
From |
To |
|
Change Parameter Type other : CsvTableRowkeyPair to other : TableRowkeyPair in method public compareTo(other TableRowkeyPair) : int in class org.apache.phoenix.mapreduce.bulkload.TableRowkeyPair |
From |
To |
|
Move Method public testBuildColumnInfoList() : void from class org.apache.phoenix.mapreduce.CsvToKeyValueMapperTest to public testBuildColumnInfoList() : void from class org.apache.phoenix.mapreduce.FormatToKeyValueMapperTest |
From |
To |
|
Move Method public testBuildColumnInfoList_ContainingNulls() : void from class org.apache.phoenix.mapreduce.CsvToKeyValueMapperTest to public testBuildColumnInfoList_ContainingNulls() : void from class org.apache.phoenix.mapreduce.FormatToKeyValueMapperTest |
From |
To |
|
Move Method public testLoadPreUpdateProcessor_ClassNotFound() : void from class org.apache.phoenix.mapreduce.CsvToKeyValueMapperTest to public testLoadPreUpdateProcessor_ClassNotFound() : void from class org.apache.phoenix.mapreduce.FormatToKeyValueMapperTest |
From |
To |
|
Move Method public testLoadPreUpdateProcessor_NotConfigured() : void from class org.apache.phoenix.mapreduce.CsvToKeyValueMapperTest to public testLoadPreUpdateProcessor_NotConfigured() : void from class org.apache.phoenix.mapreduce.FormatToKeyValueMapperTest |
From |
To |
|
Move Method public testLoadPreUpdateProcessor() : void from class org.apache.phoenix.mapreduce.CsvToKeyValueMapperTest to public testLoadPreUpdateProcessor() : void from class org.apache.phoenix.mapreduce.FormatToKeyValueMapperTest |
From |
To |
|
Move Method public generateColumnInfo(conn Connection, tableName String, columns List<String>, strict boolean) : List<ColumnInfo> from class org.apache.phoenix.util.CSVCommonsLoader to public generateColumnInfo(conn Connection, tableName String, columns List<String>, strict boolean) : List<ColumnInfo> from class org.apache.phoenix.util.SchemaUtil |
From |
To |
|
Pull Up Attribute package INDEX_TABLE_NAME_OPT : Option from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to package INDEX_TABLE_NAME_OPT : Option from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Attribute package OUTPUT_PATH_OPT : Option from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to package OUTPUT_PATH_OPT : Option from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Attribute public TABLE_NAME_CONFKEY : String from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to public TABLE_NAME_CONFKEY : String from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Attribute package INPUT_PATH_OPT : Option from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to package INPUT_PATH_OPT : Option from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Attribute private conn : Connection from class org.apache.phoenix.util.csv.CsvUpsertExecutor to protected conn : Connection from class org.apache.phoenix.util.UpsertExecutor |
From |
To |
|
Pull Up Attribute private columnInfoList : List<ColumnInfo> from class org.apache.phoenix.util.csv.CsvUpsertExecutorTest to protected columnInfoList : List<ColumnInfo> from class org.apache.phoenix.util.AbstractUpsertExecutorTest |
From |
To |
|
Pull Up Attribute private conn : PhoenixConnection from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to protected conn : PhoenixConnection from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Attribute private COUNTER_GROUP_NAME : String from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to protected COUNTER_GROUP_NAME : String from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Attribute private dataTypes : List<PDataType> from class org.apache.phoenix.util.csv.CsvUpsertExecutor to protected dataTypes : List<PDataType> from class org.apache.phoenix.util.UpsertExecutor |
From |
To |
|
Pull Up Attribute public IGNORE_INVALID_ROW_CONFKEY : String from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to public IGNORE_INVALID_ROW_CONFKEY : String from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Attribute package IMPORT_COLUMNS_OPT : Option from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to package IMPORT_COLUMNS_OPT : Option from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Attribute private preUpdateProcessor : ImportPreUpsertKeyValueProcessor from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to protected preUpdateProcessor : ImportPreUpsertKeyValueProcessor from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Attribute private upsertCount : long from class org.apache.phoenix.util.csv.CsvUpsertExecutor to protected upsertCount : long from class org.apache.phoenix.util.UpsertExecutor |
From |
To |
|
Pull Up Attribute package HELP_OPT : Option from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to package HELP_OPT : Option from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Attribute private LOG : Logger from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to protected LOG : Logger from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Attribute public TABLE_CONFIG_CONFKEY : String from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to public TABLE_CONFIG_CONFKEY : String from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Attribute private preparedStatement : PreparedStatement from class org.apache.phoenix.util.csv.CsvUpsertExecutorTest to protected preparedStatement : PreparedStatement from class org.apache.phoenix.util.AbstractUpsertExecutorTest |
From |
To |
|
Pull Up Attribute public COLUMN_INFO_CONFKEY : String from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to public COLUMN_INFO_CONFKEY : String from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Attribute private preparedStatement : PreparedStatement from class org.apache.phoenix.util.csv.CsvUpsertExecutor to protected preparedStatement : PreparedStatement from class org.apache.phoenix.util.UpsertExecutor |
From |
To |
|
Pull Up Attribute public INDEX_TABLE_NAME_CONFKEY : String from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to public INDEX_TABLE_NAME_CONFKEY : String from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Attribute package ZK_QUORUM_OPT : Option from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to package ZK_QUORUM_OPT : Option from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Attribute public TABLE_NAMES_CONFKEY : String from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to public TABLE_NAMES_CONFKEY : String from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Attribute private LOG : Logger from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to protected LOG : Logger from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Attribute private conn : Connection from class org.apache.phoenix.util.csv.CsvUpsertExecutorTest to protected conn : Connection from class org.apache.phoenix.util.AbstractUpsertExecutorTest |
From |
To |
|
Pull Up Attribute package SCHEMA_NAME_OPT : Option from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to package SCHEMA_NAME_OPT : Option from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Attribute package TABLE_NAME_OPT : Option from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to package TABLE_NAME_OPT : Option from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Attribute private tableNames : List<String> from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to protected tableNames : List<String> from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Attribute package IGNORE_ERRORS_OPT : Option from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to package IGNORE_ERRORS_OPT : Option from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Change Variable Type first : CsvTableRowkeyPair to first : TableRowkeyPair in method private writePartitions(conf Configuration, partitionsPath Path, tablesStartKeys Set<TableRowkeyPair>) : void in class org.apache.phoenix.mapreduce.MultiHfileOutputFormat |
From |
To |
|
Change Variable Type startKeys : Set<CsvTableRowkeyPair> to startKeys : Set<TableRowkeyPair> in method public configureIncrementalLoad(job Job, tablesToBeLoaded List<TargetTableRef>) : void in class org.apache.phoenix.mapreduce.MultiHfileOutputFormat |
From |
To |
|
Change Variable Type startKey : CsvTableRowkeyPair to startKey : TableRowkeyPair in method private writePartitions(conf Configuration, partitionsPath Path, tablesStartKeys Set<TableRowkeyPair>) : void in class org.apache.phoenix.mapreduce.MultiHfileOutputFormat |
From |
To |
|
Change Variable Type tablesStartKeys : Set<CsvTableRowkeyPair> to tablesStartKeys : Set<TableRowkeyPair> in method public configureIncrementalLoad(job Job, tablesToBeLoaded List<TargetTableRef>) : void in class org.apache.phoenix.mapreduce.MultiHfileOutputFormat |
From |
To |
|
Change Variable Type ret : Set<CsvTableRowkeyPair> to ret : Set<TableRowkeyPair> in method private getRegionStartKeys(tableName String, table RegionLocator) : Set<TableRowkeyPair> in class org.apache.phoenix.mapreduce.MultiHfileOutputFormat |
From |
To |
|
Change Variable Type sorted : TreeSet<CsvTableRowkeyPair> to sorted : TreeSet<TableRowkeyPair> in method private writePartitions(conf Configuration, partitionsPath Path, tablesStartKeys Set<TableRowkeyPair>) : void in class org.apache.phoenix.mapreduce.MultiHfileOutputFormat |
From |
To |
|
Pull Up Method private completebulkload(conf Configuration, outputPath Path, tablesToBeLoaded List<TargetTableRef>) : void from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to private completebulkload(conf Configuration, outputPath Path, tablesToBeLoaded List<TargetTableRef>) : void from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Method public execute(csvRecords Iterable<CSVRecord>) : void from class org.apache.phoenix.util.csv.CsvUpsertExecutor to public execute(records Iterable<RECORD>) : void from class org.apache.phoenix.util.UpsertExecutor |
From |
To |
|
Pull Up Method protected cleanup(context Context) : void from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to protected cleanup(context Context) : void from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Method private loadData(conf Configuration, cmdLine CommandLine) : int from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to private loadData(conf Configuration, cmdLine CommandLine) : int from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Method public tearDown() : void from class org.apache.phoenix.util.csv.CsvUpsertExecutorTest to public tearDown() : void from class org.apache.phoenix.util.AbstractUpsertExecutorTest |
From |
To |
|
Pull Up Method private printHelpAndExit(errorMessage String, options Options) : void from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to private printHelpAndExit(errorMessage String, options Options) : void from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Method private printHelpAndExit(options Options, exitCode int) : void from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to private printHelpAndExit(options Options, exitCode int) : void from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Method public close() : void from class org.apache.phoenix.util.csv.CsvUpsertExecutor to public close() : void from class org.apache.phoenix.util.UpsertExecutor |
From |
To |
|
Pull Up Method package buildColumnInfoList(conf Configuration) : List<ColumnInfo> from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to package buildColumnInfoList(conf Configuration) : List<ColumnInfo> from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Method package CsvUpsertExecutor(conn Connection, columnInfoList List<ColumnInfo>, preparedStatement PreparedStatement, upsertListener UpsertListener, arrayElementSeparator String) from class org.apache.phoenix.util.csv.CsvUpsertExecutor to protected UpsertExecutor(conn Connection, columnInfoList List<ColumnInfo>, preparedStatement PreparedStatement, upsertListener UpsertListener<RECORD>) from class org.apache.phoenix.util.UpsertExecutor |
From |
To |
|
Pull Up Method public testExecute_InvalidType() : void from class org.apache.phoenix.util.csv.CsvUpsertExecutorTest to public testExecute_InvalidType() : void from class org.apache.phoenix.util.AbstractUpsertExecutorTest |
From |
To |
|
Pull Up Method protected map(key LongWritable, value Text, context Context) : void from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to protected map(key LongWritable, value Text, context Context) : void from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Method public submitJob(conf Configuration, qualifiedTableName String, inputPath Path, outputPath Path, tablesToBeLoaded List<TargetTableRef>) : int from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to public submitJob(conf Configuration, qualifiedTableName String, inputPath Path, outputPath Path, tablesToBeLoaded List<TargetTableRef>) : int from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Method private validateTable(conn Connection, schemaName String, tableName String) : void from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to private validateTable(conn Connection, schemaName String, tableName String) : void from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Method package configureColumnInfoList(conf Configuration, columnInfoList List<ColumnInfo>) : void from class org.apache.phoenix.mapreduce.CsvToKeyValueMapper to package configureColumnInfoList(conf Configuration, columnInfoList List<ColumnInfo>) : void from class org.apache.phoenix.mapreduce.FormatToKeyValueMapper |
From |
To |
|
Pull Up Method public testExecute_TooManyFields() : void from class org.apache.phoenix.util.csv.CsvUpsertExecutorTest to public testExecute_TooManyFields() : void from class org.apache.phoenix.util.AbstractUpsertExecutorTest |
From |
To |
|
Pull Up Method package parseOptions(args String[]) : CommandLine from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to protected parseOptions(args String[]) : CommandLine from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Method package getQualifiedTableName(schemaName String, tableName String) : String from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to package getQualifiedTableName(schemaName String, tableName String) : String from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Method public create(conn PhoenixConnection, tableName String, columnInfoList List<ColumnInfo>, upsertListener UpsertListener, arrayElementSeparator String) : CsvUpsertExecutor from class org.apache.phoenix.util.csv.CsvUpsertExecutor to private createStatement(conn Connection, tableName String, columnInfoList List<ColumnInfo>) : PreparedStatement from class org.apache.phoenix.util.UpsertExecutor |
From |
To |
|
Pull Up Method package buildImportColumns(conn Connection, cmdLine CommandLine, qualifiedTableName String) : List<ColumnInfo> from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to package buildImportColumns(conn Connection, cmdLine CommandLine, qualifiedTableName String) : List<ColumnInfo> from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Method public testExecute_TooFewFields() : void from class org.apache.phoenix.util.csv.CsvUpsertExecutorTest to public testExecute_TooFewFields() : void from class org.apache.phoenix.util.AbstractUpsertExecutorTest |
From |
To |
|
Pull Up Method private getIndexTables(conn Connection, schemaName String, qualifiedTableName String) : List<TargetTableRef> from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to private getIndexTables(conn Connection, schemaName String, qualifiedTableName String) : List<TargetTableRef> from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Method public run(args String[]) : int from class org.apache.phoenix.mapreduce.CsvBulkLoadTool to public run(args String[]) : int from class org.apache.phoenix.mapreduce.AbstractBulkLoadTool |
From |
To |
|
Pull Up Method public testExecute_NullField() : void from class org.apache.phoenix.util.csv.CsvUpsertExecutorTest to public testExecute_NullField() : void from class org.apache.phoenix.util.AbstractUpsertExecutorTest |
From |
To |
|
Pull Up Method public testExecute() : void from class org.apache.phoenix.util.csv.CsvUpsertExecutorTest to public testExecute() : void from class org.apache.phoenix.util.AbstractUpsertExecutorTest |
From |
To |