test_class.file: common/src/test/java/org/apache/cassandra/diff/YamlJobConfigurationTest.java
test_class.identifier: YamlJobConfigurationTest
test_case.body: @Test
      public void testLoadYamlFilterOutDisallowedKeyspaces() {
          JobConfiguration jobConfiguration = load("test_load_config_all_keyspaces_filtered_out.yaml");
          Assert.assertNotNull(jobConfiguration.filteredKeyspaceTables());
          Assert.assertTrue("All tables should be filtered out", jobConfiguration.filteredKeyspaceTables().isEmpty());
          Assert.assertFalse("It should not be in the discover mode", jobConfiguration.shouldAutoDiscoverTables());
      }
test_case.class_method_signature: YamlJobConfigurationTest.testLoadYamlFilterOutDisallowedKeyspaces()
test_case.full_signature: @Test public void testLoadYamlFilterOutDisallowedKeyspaces()
test_case.identifier: testLoadYamlFilterOutDisallowedKeyspaces
test_case.invocations: load assertNotNull filteredKeyspaceTables assertTrue isEmpty filteredKeyspaceTables assertFalse shouldAutoDiscoverTables
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testLoadYamlFilterOutDisallowedKeyspaces()
focal_class.declarator: splits = 10000
focal_class.modifier: public
focal_class.original_string: public int splits = 10000;
focal_class.type: int
focal_class.var_name: splits
focal_class.declarator: keyspace_tables
focal_class.modifier: public
focal_class.original_string: public List<KeyspaceTablePair> keyspace_tables;
focal_class.type: List<KeyspaceTablePair>
focal_class.var_name: keyspace_tables
focal_class.declarator: disallowed_keyspaces
focal_class.modifier: public
focal_class.original_string: public List<String> disallowed_keyspaces;
focal_class.type: List<String>
focal_class.var_name: disallowed_keyspaces
focal_class.declarator: buckets = 100
focal_class.modifier: public
focal_class.original_string: public int buckets = 100;
focal_class.type: int
focal_class.var_name: buckets
focal_class.declarator: rate_limit = 10000
focal_class.modifier: public
focal_class.original_string: public int rate_limit = 10000;
focal_class.type: int
focal_class.var_name: rate_limit
focal_class.declarator: job_id = null
focal_class.modifier: public
focal_class.original_string: public String job_id = null;
focal_class.type: String
focal_class.var_name: job_id
focal_class.declarator: token_scan_fetch_size
focal_class.modifier: public
focal_class.original_string: public int token_scan_fetch_size;
focal_class.type: int
focal_class.var_name: token_scan_fetch_size
focal_class.declarator: partition_read_fetch_size
focal_class.modifier: public
focal_class.original_string: public int partition_read_fetch_size;
focal_class.type: int
focal_class.var_name: partition_read_fetch_size
focal_class.declarator: read_timeout_millis
focal_class.modifier: public
focal_class.original_string: public int read_timeout_millis;
focal_class.type: int
focal_class.var_name: read_timeout_millis
focal_class.declarator: reverse_read_probability
focal_class.modifier: public
focal_class.original_string: public double reverse_read_probability;
focal_class.type: double
focal_class.var_name: reverse_read_probability
focal_class.declarator: consistency_level = "ALL"
focal_class.modifier: public
focal_class.original_string: public String consistency_level = "ALL";
focal_class.type: String
focal_class.var_name: consistency_level
focal_class.declarator: metadata_options
focal_class.modifier: public
focal_class.original_string: public MetadataKeyspaceOptions metadata_options;
focal_class.type: MetadataKeyspaceOptions
focal_class.var_name: metadata_options
focal_class.declarator: cluster_config
focal_class.modifier: public
focal_class.original_string: public Map<String, Map<String, String>> cluster_config;
focal_class.type: Map<String, Map<String, String>>
focal_class.var_name: cluster_config
focal_class.declarator: specific_tokens = null
focal_class.modifier: public
focal_class.original_string: public String specific_tokens = null;
focal_class.type: String
focal_class.var_name: specific_tokens
focal_class.declarator: disallowed_tokens = null
focal_class.modifier: public
focal_class.original_string: public String disallowed_tokens = null;
focal_class.type: String
focal_class.var_name: disallowed_tokens
focal_class.declarator: retry_options
focal_class.modifier: public
focal_class.original_string: public RetryOptions retry_options;
focal_class.type: RetryOptions
focal_class.var_name: retry_options
focal_class.file: common/src/main/java/org/apache/cassandra/diff/YamlJobConfiguration.java
focal_class.identifier: YamlJobConfiguration
focal_class.interfaces: implements JobConfiguration
focal_class.class_method_signature: YamlJobConfiguration.load(InputStream inputStream)
focal_class.full_signature: public static YamlJobConfiguration load(InputStream inputStream)
focal_class.identifier: load
focal_class.modifiers: public static
focal_class.parameters: (InputStream inputStream)
focal_class.return: YamlJobConfiguration
focal_class.signature: YamlJobConfiguration load(InputStream inputStream)
focal_class.class_method_signature: YamlJobConfiguration.keyspaceTables()
focal_class.full_signature: public List<KeyspaceTablePair> keyspaceTables()
focal_class.identifier: keyspaceTables
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: List<KeyspaceTablePair>
focal_class.signature: List<KeyspaceTablePair> keyspaceTables()
focal_class.class_method_signature: YamlJobConfiguration.disallowedKeyspaces()
focal_class.full_signature: public List<String> disallowedKeyspaces()
focal_class.identifier: disallowedKeyspaces
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: List<String>
focal_class.signature: List<String> disallowedKeyspaces()
focal_class.class_method_signature: YamlJobConfiguration.splits()
focal_class.full_signature: public int splits()
focal_class.identifier: splits
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int splits()
focal_class.class_method_signature: YamlJobConfiguration.buckets()
focal_class.full_signature: public int buckets()
focal_class.identifier: buckets
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int buckets()
focal_class.class_method_signature: YamlJobConfiguration.rateLimit()
focal_class.full_signature: public int rateLimit()
focal_class.identifier: rateLimit
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int rateLimit()
focal_class.class_method_signature: YamlJobConfiguration.jobId()
focal_class.full_signature: public Optional<UUID> jobId()
focal_class.identifier: jobId
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: Optional<UUID>
focal_class.signature: Optional<UUID> jobId()
focal_class.class_method_signature: YamlJobConfiguration.tokenScanFetchSize()
focal_class.full_signature: public int tokenScanFetchSize()
focal_class.identifier: tokenScanFetchSize
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int tokenScanFetchSize()
focal_class.class_method_signature: YamlJobConfiguration.partitionReadFetchSize()
focal_class.full_signature: public int partitionReadFetchSize()
focal_class.identifier: partitionReadFetchSize
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int partitionReadFetchSize()
focal_class.class_method_signature: YamlJobConfiguration.readTimeoutMillis()
focal_class.full_signature: public int readTimeoutMillis()
focal_class.identifier: readTimeoutMillis
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int readTimeoutMillis()
focal_class.class_method_signature: YamlJobConfiguration.reverseReadProbability()
focal_class.full_signature: public double reverseReadProbability()
focal_class.identifier: reverseReadProbability
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: double
focal_class.signature: double reverseReadProbability()
focal_class.class_method_signature: YamlJobConfiguration.consistencyLevel()
focal_class.full_signature: public String consistencyLevel()
focal_class.identifier: consistencyLevel
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String consistencyLevel()
focal_class.class_method_signature: YamlJobConfiguration.metadataOptions()
focal_class.full_signature: public MetadataKeyspaceOptions metadataOptions()
focal_class.identifier: metadataOptions
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: MetadataKeyspaceOptions
focal_class.signature: MetadataKeyspaceOptions metadataOptions()
focal_class.class_method_signature: YamlJobConfiguration.retryOptions()
focal_class.full_signature: public RetryOptions retryOptions()
focal_class.identifier: retryOptions
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: RetryOptions
focal_class.signature: RetryOptions retryOptions()
focal_class.class_method_signature: YamlJobConfiguration.clusterConfig(String identifier)
focal_class.full_signature: public Map<String, String> clusterConfig(String identifier)
focal_class.identifier: clusterConfig
focal_class.modifiers: public
focal_class.parameters: (String identifier)
focal_class.return: Map<String, String>
focal_class.signature: Map<String, String> clusterConfig(String identifier)
focal_class.class_method_signature: YamlJobConfiguration.specificTokens()
focal_class.full_signature: public SpecificTokens specificTokens()
focal_class.identifier: specificTokens
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: SpecificTokens
focal_class.signature: SpecificTokens specificTokens()
focal_class.class_method_signature: YamlJobConfiguration.toString()
focal_class.full_signature: public String toString()
focal_class.identifier: toString
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: String
focal_class.signature: String toString()
focal_class.class_method_signature: YamlJobConfiguration.toTokens(String str)
focal_class.full_signature: private static Set<BigInteger> toTokens(String str)
focal_class.identifier: toTokens
focal_class.modifiers: private static
focal_class.parameters: (String str)
focal_class.return: Set<BigInteger>
focal_class.signature: Set<BigInteger> toTokens(String str)
focal_method.body: public static YamlJobConfiguration load(InputStream inputStream) {
          Yaml yaml = new Yaml(new CustomClassLoaderConstructor(YamlJobConfiguration.class,
                                                                Thread.currentThread().getContextClassLoader()));
          return yaml.loadAs(inputStream, YamlJobConfiguration.class);
      }
focal_method.class_method_signature: YamlJobConfiguration.load(InputStream inputStream)
focal_method.full_signature: public static YamlJobConfiguration load(InputStream inputStream)
focal_method.identifier: load
focal_method.invocations: getContextClassLoader currentThread loadAs
focal_method.modifiers: public static
focal_method.parameters: (InputStream inputStream)
focal_method.return: YamlJobConfiguration
focal_method.signature: YamlJobConfiguration load(InputStream inputStream)