public static CloudBigtableTableConfiguration BuildImportConfig ( ImportOptions opts ) { CloudBigtableTableConfiguration . Builder builder = new CloudBigtableTableConfiguration . Builder ( ) . withProjectId ( opts . getBigtableProject ( ) ) . withInstanceId ( opts . getBigtableInstanceId ( ) ) . withTableId ( opts . getBigtableTableId ( ) ) ; if ( opts . getBigtableAppProfileId ( ) != null ) { builder . withAppProfileId ( opts . getBigtableAppProfileId ( ) ) ; } ValueProvider enableThrottling = ValueProvider . NestedValueProvider . of ( opts . getMutationThrottleLatencyMs ( ) , ( Integer throttleMs ) -> String . valueOf ( throttleMs > 0 ) ) ; builder . withConfiguration ( BigtableOptionsFactory . BIGTABLE_BUFFERED_MUTATOR_ENABLE_THROTTLING , enableThrottling ) ; builder . withConfiguration ( BigtableOptionsFactory . BIGTABLE_BUFFERED_MUTATOR_THROTTLING_THRESHOLD_MILLIS , ValueProvider . NestedValueProvider . of ( opts . getMutationThrottleLatencyMs ( ) , String :: valueOf ) ) ; return builder . build ( ) ; }
Builds CloudBigtableTableConfiguration from input runtime parameters for import job .