类org.apache.hadoop.hbase.filter.MultipleColumnPrefixFilter源码实例Demo

下面列出了怎么用org.apache.hadoop.hbase.filter.MultipleColumnPrefixFilter的API类实例代码及写法,或者点击链接到github查看源代码。

源代码1 项目: BigDataPlatform   文件: TransformBaseRunner.java
protected Filter getColumnFilter(String[] columns) {
  int length = columns.length;
  byte[][] filter = new byte[length][];
  for (int i = 0; i < length; i++) {
    filter[i] = Bytes.toBytes(columns[i]);
  }
  return new MultipleColumnPrefixFilter(filter);
}
 
源代码2 项目: BigDataArchitect   文件: ActiveUserRunner.java
/**
 * 获取这个列名过滤的column
 * 
 * @param columns
 * @return
 */
private Filter getColumnFilter(String[] columns) {
    int length = columns.length;
    byte[][] filter = new byte[length][];
    for (int i = 0; i < length; i++) {
        filter[i] = Bytes.toBytes(columns[i]);
    }
    return new MultipleColumnPrefixFilter(filter);
}
 
源代码3 项目: BigDataArchitect   文件: NewInstallUserRunner.java
/**
 * 获取这个列名过滤的column
 * 
 * @param columns
 * @return
 */
private Filter getColumnFilter(String[] columns) {
    int length = columns.length;
    byte[][] filter = new byte[length][];
    for (int i = 0; i < length; i++) {
        filter[i] = Bytes.toBytes(columns[i]);
    }
    return new MultipleColumnPrefixFilter(filter);
}
 
源代码4 项目: BigDataArchitect   文件: TransformerBaseRunner.java
/**
 * 获取这个列名过滤的column
 * 
 * @param columns
 * @return
 */
protected Filter getColumnFilter(String[] columns) {
    int length = columns.length;
    byte[][] filter = new byte[length][];
    for (int i = 0; i < length; i++) {
        filter[i] = Bytes.toBytes(columns[i]);
    }
    return new MultipleColumnPrefixFilter(filter);
}
 
 类所在包
 类方法
 同包方法