Skip to content

Commit

Permalink
updates documentation
Browse files Browse the repository at this point in the history
  • Loading branch information
otaviojava committed Apr 21, 2019
1 parent 82b5758 commit 0e61c58
Showing 1 changed file with 3 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@

/**
* Configuration to HBase that returns {@link HBaseColumnFamilyManagerFactory}
* <p>hbase-family-n-: as prefix to add family, eg: hbase-family-1=column-family</p>
* <p>hbase.family.n: as prefix to add family, eg: hbase,family.1=column-family</p>
*/
public class HBaseColumnConfiguration implements ColumnConfiguration<HBaseColumnFamilyManagerFactory> {

Expand Down Expand Up @@ -84,11 +84,10 @@ public HBaseColumnFamilyManagerFactory get() {

@Override
public HBaseColumnFamilyManagerFactory get(Settings settings) throws NullPointerException {

requireNonNull(settings, "settings is required");

List<String> families = settings.keySet().stream().filter(s -> s.startsWith("hbase-family-"))
.map(settings::get).map(Object::toString).collect(Collectors.toList());
List<String> families = settings.prefix(HbaseConfigurations.FAMILY.get())
.stream().map(Object::toString).collect(Collectors.toList());
return new HBaseColumnFamilyManagerFactory(configuration, families);
}

Expand Down

0 comments on commit 0e61c58

Please sign in to comment.