A B C D E F G H I K M O P R S T V

A

addFilterAndArguments(Configuration, Class<? extends Filter>, List<String>) - Static method in class com.google.cloud.bigtable.mapreduce.Import

Add a Filter to be instantiated on import

addPutToKv(Put, Cell) - Method in class com.google.cloud.bigtable.mapreduce.Import.Importer

B

BigtableResultHasher() - Constructor for class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor.BigtableResultHasher

BigtableSyncMapper - Class in com.google.cloud.bigtable.mapreduce.validation

Bigtable SyncMapper

BigtableSyncMapper() - Constructor for class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncMapper

BigtableSyncTableAccessor - Class in org.apache.hadoop.hbase.mapreduce

A helper class to provide access to package protected variables of SyncTable.

BigtableSyncTableJob - Class in com.google.cloud.bigtable.mapreduce.validation

Bigtable SyncTable Job

BigtableSyncTableJob(Configuration) - Constructor for class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

BigtableTableHashAccessor - Class in org.apache.hadoop.hbase.mapreduce

A helper class to access package private fields of HashTable.TableHash.

BigtableTableHashAccessor.BigtableResultHasher - Class in org.apache.hadoop.hbase.mapreduce

BULK_OUTPUT_CONF_KEY - Static variable in class com.google.cloud.bigtable.mapreduce.Import

Constant BULK_OUTPUT_CONF_KEY="import.bulk.output"

C

CF_RENAME_PROP - Static variable in class com.google.cloud.bigtable.mapreduce.Import

Constant CF_RENAME_PROP="HBASE_IMPORTER_RENAME_CFS"

cleanup(Mapper<ImmutableBytesWritable, Result, ImmutableBytesWritable, Put>.Context) - Method in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportHBaseSnapshotJob.SnapshotMapper

com.google.cloud.bigtable.mapreduce - package com.google.cloud.bigtable.mapreduce

com.google.cloud.bigtable.mapreduce.hbasesnapshots - package com.google.cloud.bigtable.mapreduce.hbasesnapshots

com.google.cloud.bigtable.mapreduce.validation - package com.google.cloud.bigtable.mapreduce.validation

com.google.cloud.bigtable.thirdparty.org.apache.hadoop.hbase.mapreduce - package com.google.cloud.bigtable.thirdparty.org.apache.hadoop.hbase.mapreduce

configureCfRenaming(Configuration, Map<String, String>) - Static method in class com.google.cloud.bigtable.mapreduce.Import

Sets a configuration property with key Import.CF_RENAME_PROP in conf that tells the mapper how to rename column families.

counters - Variable in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

createSubmittableJob(Configuration, String[]) - Static method in class com.google.cloud.bigtable.mapreduce.Export

createSubmittableJob(Configuration) - Static method in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportHBaseSnapshotJob

Sets up the actual job.

createSubmittableJob(Configuration, String[]) - Static method in class com.google.cloud.bigtable.mapreduce.Import

Sets up the actual job.

createSubmittableJob(Configuration, String[]) - Static method in class com.google.cloud.bigtable.thirdparty.org.apache.hadoop.hbase.mapreduce.Export

Sets up the actual job.

D

doCommandLine(SyncTable, String[]) - Method in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

SyncTable command line parsing utility

Driver - Class in com.google.cloud.bigtable.mapreduce

Driver for bigtable mapreduce jobs.

Driver() - Constructor for class com.google.cloud.bigtable.mapreduce.Driver

E

Export - Class in com.google.cloud.bigtable.mapreduce

Export() - Constructor for class com.google.cloud.bigtable.mapreduce.Export

Export - Class in com.google.cloud.bigtable.thirdparty.org.apache.hadoop.hbase.mapreduce

Export an HBase table.

Export() - Constructor for class com.google.cloud.bigtable.thirdparty.org.apache.hadoop.hbase.mapreduce.Export

F

FILTER_ARGS_CONF_KEY - Static variable in class com.google.cloud.bigtable.mapreduce.Import

Constant FILTER_ARGS_CONF_KEY="import.filter.args"

FILTER_CLASS_CONF_KEY - Static variable in class com.google.cloud.bigtable.mapreduce.Import

Constant FILTER_CLASS_CONF_KEY="import.filter.class"

filterKv(Filter, Cell) - Static method in class com.google.cloud.bigtable.mapreduce.Import

Attempt to filter out the keyvalue

finishBatch() - Method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor.BigtableResultHasher

G

getBatchHash() - Method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor.BigtableResultHasher

getBatchSize() - Method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor.BigtableResultHasher

getBatchSize(HashTable.TableHash) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor

getBatchStartKey() - Method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor.BigtableResultHasher

getConfDryRunKey() - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

getHashDataDir() - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor

getHashOutputDataFilePrefix() - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor

getNumHashFiles(HashTable.TableHash) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor

getPartitions(HashTable.TableHash) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor

getScan(HashTable.TableHash) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor

getSourceBigtableAppProfile() - Method in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

getSourceBigtableInstance() - Method in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

getSourceBigtableProjectId() - Method in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

getSourceConnection(SyncTable.SyncMapper) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

getSourceHashDir(SyncTable) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

getSourceTable(SyncTable.SyncMapper) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

getSourceTableConfKey() - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

getSourceTableName(SyncTable) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

getSourceZkCluster(SyncTable) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

getSourceZkClusterConfKey() - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

getSplits(JobContext) - Method in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ShuffledTableSnapshotInputFormat

getSplits(JobContext) - Method in class com.google.cloud.bigtable.mapreduce.ShuffledSequenceFileInputFormat

getStartRow(HashTable.TableHash) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor

getStopRow(HashTable.TableHash) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor

getTableName(HashTable.TableHash) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor

getTargetBigtableAppProfile() - Method in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

getTargetBigtableInstance() - Method in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

getTargetBigtableProjectId() - Method in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

getTargetConnection(SyncTable.SyncMapper) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

getTargetTable(SyncTable.SyncMapper) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

getTargetTableConfKey() - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

getTargetTableName(SyncTable) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

getTargetZkCluster(SyncTable) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

getTargetZkClusterConfKey() - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

H

hashResult(Result) - Method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor.BigtableResultHasher

I

Import - Class in com.google.cloud.bigtable.mapreduce

Import data written by Export.

Import() - Constructor for class com.google.cloud.bigtable.mapreduce.Import

Import.Importer - Class in com.google.cloud.bigtable.mapreduce

Write table content out to files.

Import.KeyValueImporter - Class in com.google.cloud.bigtable.mapreduce

A mapper that just writes out KeyValues.

IMPORT_SNAPSHOT_JOBNAME_KEY - Static variable in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportJobCommon

Importer() - Constructor for class com.google.cloud.bigtable.mapreduce.Import.Importer

ImportHBaseSnapshotJob - Class in com.google.cloud.bigtable.mapreduce.hbasesnapshots

A Mapreduce job to import an HBase snapshot to Bigtable.

ImportHBaseSnapshotJob() - Constructor for class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportHBaseSnapshotJob

ImportHBaseSnapshotJob.ScanCounter - Enum in com.google.cloud.bigtable.mapreduce.hbasesnapshots

ImportHBaseSnapshotJob.SnapshotMapper - Class in com.google.cloud.bigtable.mapreduce.hbasesnapshots

MAPPER

ImportJobCommon - Class in com.google.cloud.bigtable.mapreduce.hbasesnapshots

ImportJobCommon() - Constructor for class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportJobCommon

initTableSnapshotMapperJob(String, Scan, Class<? extends TableMapper>, Class<?>, Class<?>, Job, boolean, Path, RegionSplitter.SplitAlgorithm, int) - Static method in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ShuffledTableMapReduceUtil

Sets up the job for reading from a table snapshot.

innerMain(Configuration, String[]) - Static method in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportHBaseSnapshotJob

Call this method to avoid the ImportHBaseSnapshotJob.main(String[]) System.exit.

instantiateFilter(Configuration) - Static method in class com.google.cloud.bigtable.mapreduce.Import

Create a Filter to apply to all incoming keys (KeyValues) to optionally not include in the job output

isBatchStarted() - Method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor.BigtableResultHasher

isTableEndRow(byte[]) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor

K

KeyValueImporter() - Constructor for class com.google.cloud.bigtable.mapreduce.Import.KeyValueImporter

M

main(String[]) - Static method in class com.google.cloud.bigtable.mapreduce.Driver

main.

main(String[]) - Static method in class com.google.cloud.bigtable.mapreduce.Export

main(String[]) - Static method in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportHBaseSnapshotJob

main(String[]) - Static method in class com.google.cloud.bigtable.mapreduce.Import

Main entry point.

main(String[]) - Static method in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

Main entry point.

main(String[]) - Static method in class com.google.cloud.bigtable.thirdparty.org.apache.hadoop.hbase.mapreduce.Export

Main entry point.

map(ImmutableBytesWritable, Result, Mapper<ImmutableBytesWritable, Result, ImmutableBytesWritable, Put>.Context) - Method in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportHBaseSnapshotJob.SnapshotMapper

map(ImmutableBytesWritable, Result, Mapper<ImmutableBytesWritable, Result, ImmutableBytesWritable, Mutation>.Context) - Method in class com.google.cloud.bigtable.mapreduce.Import.Importer

map(ImmutableBytesWritable, Result, Mapper<ImmutableBytesWritable, Result, ImmutableBytesWritable, KeyValue>.Context) - Method in class com.google.cloud.bigtable.mapreduce.Import.KeyValueImporter

MAX_CELLS - Static variable in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportHBaseSnapshotJob.SnapshotMapper

O

org.apache.hadoop.hbase.mapreduce - package org.apache.hadoop.hbase.mapreduce

P

printUsage(String, String[]) - Static method in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

processKV(ImmutableBytesWritable, Result, Mapper<ImmutableBytesWritable, Result, ImmutableBytesWritable, Mutation>.Context, Put, Delete) - Method in class com.google.cloud.bigtable.mapreduce.Import.Importer

R

run(String[]) - Method in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportHBaseSnapshotJob

Job runner

run(String[]) - Method in class com.google.cloud.bigtable.mapreduce.Import

run(String[]) - Method in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

S

setConfFromArgs(Configuration, String[]) - Static method in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportHBaseSnapshotJob

setDoDeletes(SyncTable, boolean) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

setDoPuts(SyncTable, boolean) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

setDryRun(SyncTable, boolean) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

setIgnoreTimestamps(SyncTable, boolean) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

setSourceConnection(SyncTable.SyncMapper, Connection) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

setSourceHashDir(SyncTable, Path) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

setSourceTable(SyncTable.SyncMapper, Table) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

setSourceTableName(SyncTable, String) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

setSourceZkCluster(SyncTable, String) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

setTargetConnection(SyncTable.SyncMapper, Connection) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

setTargetTable(SyncTable.SyncMapper, Table) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

setTargetTableName(SyncTable, String) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

setTargetZkCluster(SyncTable, String) - Static method in class org.apache.hadoop.hbase.mapreduce.BigtableSyncTableAccessor

setup(Mapper<ImmutableBytesWritable, Result, ImmutableBytesWritable, Put>.Context) - Method in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportHBaseSnapshotJob.SnapshotMapper

setup(Mapper<ImmutableBytesWritable, Result, ImmutableBytesWritable, Mutation>.Context) - Method in class com.google.cloud.bigtable.mapreduce.Import.Importer

setup(Mapper<ImmutableBytesWritable, Result, ImmutableBytesWritable, KeyValue>.Context) - Method in class com.google.cloud.bigtable.mapreduce.Import.KeyValueImporter

setup(Mapper<ImmutableBytesWritable, Result, ImmutableBytesWritable, Mutation>.Context) - Method in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncMapper

ShuffledSequenceFileInputFormat<K,V> - Class in com.google.cloud.bigtable.mapreduce

An InputFormat randomizes the order of SequenceFile splits.

ShuffledSequenceFileInputFormat() - Constructor for class com.google.cloud.bigtable.mapreduce.ShuffledSequenceFileInputFormat

ShuffledTableMapReduceUtil - Class in com.google.cloud.bigtable.mapreduce.hbasesnapshots

Utility for TableMapper for shuffled snapshot input format

ShuffledTableMapReduceUtil() - Constructor for class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ShuffledTableMapReduceUtil

ShuffledTableSnapshotInputFormat - Class in com.google.cloud.bigtable.mapreduce.hbasesnapshots

A SnapshotInputFormat that randomizes the order of snapshot splits.

ShuffledTableSnapshotInputFormat() - Constructor for class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ShuffledTableSnapshotInputFormat

SNAPSHOT_RESTOREDIR_KEY - Static variable in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportJobCommon

SNAPSHOT_SPLITS_PER_REGION_DEFAULT - Static variable in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportJobCommon

SNAPSHOT_SPLITS_PER_REGION_KEY - Static variable in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportJobCommon

SnapshotMapper() - Constructor for class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportHBaseSnapshotJob.SnapshotMapper

SNAPSHOTNAME_KEY - Static variable in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportJobCommon

SOURCE_BT_APP_PROFILE_CONF_KEY - Static variable in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

SOURCE_BT_INSTANCE_CONF_KEY - Static variable in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

SOURCE_BT_PROJECTID_CONF_KEY - Static variable in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

startBatch(ImmutableBytesWritable) - Method in class org.apache.hadoop.hbase.mapreduce.BigtableTableHashAccessor.BigtableResultHasher

T

TABLE_NAME - Static variable in class com.google.cloud.bigtable.mapreduce.Import

Constant TABLE_NAME="import.table.name"

TABLENAME_KEY - Static variable in class com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportJobCommon

TARGET_BT_APP_PROFILE_CONF_KEY - Static variable in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

TARGET_BT_INSTANCE_CONF_KEY - Static variable in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

TARGET_BT_PROJECTID_CONF_KEY - Static variable in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

V

valueOf(String) - Static method in enum com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportHBaseSnapshotJob.ScanCounter

Returns the enum constant of this type with the specified name.

values() - Static method in enum com.google.cloud.bigtable.mapreduce.hbasesnapshots.ImportHBaseSnapshotJob.ScanCounter

Returns an array containing the constants of this enum type, in the order they are declared.

verifyRequiredArgsSet(SyncTable, String[], String, String, String, String) - Method in class com.google.cloud.bigtable.mapreduce.validation.BigtableSyncTableJob

verify required options and args are correctly set

A B C D E F G H I K M O P R S T V