org.apache.fluo.api.data.Bytes.toString()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(4.5k)|赞(0)|评价(0)|浏览(63)

本文整理了Java中org.apache.fluo.api.data.Bytes.toString()方法的一些代码示例,展示了Bytes.toString()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Bytes.toString()方法的具体详情如下:
包路径:org.apache.fluo.api.data.Bytes
类名称:Bytes
方法名:toString

Bytes.toString介绍

[英]Creates UTF-8 String using Bytes data
[中]使用字节数据创建UTF-8字符串

代码示例

代码示例来源:origin: org.apache.fluo/fluo-api

/**
 * Retrieves Row in RowColumn as a String using UTF-8 encoding.
 *
 * @return Row
 */
public String getsRow() {
 return row.toString();
}

代码示例来源:origin: org.apache.fluo/fluo-api

/**
 * Retrieves Row in RowColumn as a String using UTF-8 encoding.
 *
 * @return Row
 */
public String getsRow() {
 return row.toString();
}

代码示例来源:origin: apache/fluo

/**
 * Retrieves Row in RowColumn as a String using UTF-8 encoding.
 *
 * @return Row
 */
public String getsRow() {
 return row.toString();
}

代码示例来源:origin: apache/incubator-rya

/**
 * Given a Byte row, return the query node Id
 * @param row - the Byte row used to identify the BatchInformation
 * @return - the queryId that the batch task is performed on
 */
public static String getNodeId(Bytes row) {
  String[] stringArray = row.toString().split(IncrementalUpdateConstants.NODEID_BS_DELIM);;
  Preconditions.checkArgument(stringArray.length == 2);
  return stringArray[0];
}

代码示例来源:origin: org.apache.rya/rya.pcj.fluo.app

/**
 * Given a Byte row, return the query node Id
 * @param row - the Byte row used to identify the BatchInformation
 * @return - the queryId that the batch task is performed on
 */
public static String getNodeId(Bytes row) {
  String[] stringArray = row.toString().split(IncrementalUpdateConstants.NODEID_BS_DELIM);;
  Preconditions.checkArgument(stringArray.length == 2);
  return stringArray[0];
}

代码示例来源:origin: org.apache.fluo/fluo-api

@Override
public Map<String, Map<Column, String>> gets(Collection<? extends CharSequence> rows,
  Set<Column> columns) {
 Map<Bytes, Map<Column, Bytes>> rcvs = get(Collections2.transform(rows, this::s2bConv), columns);
 Map<String, Map<Column, String>> ret = new HashMap<>(rcvs.size());
 for (Entry<Bytes, Map<Column, Bytes>> entry : rcvs.entrySet()) {
  ret.put(entry.getKey().toString(), Maps.transformValues(entry.getValue(), b -> b.toString()));
 }
 return ret;
}

代码示例来源:origin: org.apache.fluo/fluo-api

/**
 * Get the column family as a string using UTF-8 encoding.
 */
public String getsFamily() {
 return getFamily().toString();
}

代码示例来源:origin: org.apache.fluo/fluo-api

/**
 * Get the column family as a string using UTF-8 encoding.
 */
public String getsQualifier() {
 return getQualifier().toString();
}

代码示例来源:origin: apache/fluo

/**
 * Get the column visibility as a string using UTF-8 encoding.
 */
public String getsVisibility() {
 return getVisibility().toString();
}

代码示例来源:origin: org.apache.fluo/fluo-api

/**
 * Get the column visibility as a string using UTF-8 encoding.
 */
public String getsVisibility() {
 return getVisibility().toString();
}

代码示例来源:origin: apache/fluo

@Override
 public String getsRow() {
  return getRow().toString();
 }
}

代码示例来源:origin: apache/fluo

/**
 * Get the column family as a string using UTF-8 encoding.
 */
public String getsFamily() {
 return getFamily().toString();
}

代码示例来源:origin: apache/fluo

/**
 * Get the column family as a string using UTF-8 encoding.
 */
public String getsQualifier() {
 return getQualifier().toString();
}

代码示例来源:origin: org.apache.fluo/fluo-mapreduce

public static void fetchFamilies(Job job, Bytes... fams) {
 // TODO support binary data
 String[] sfams = new String[fams.length];
 for (int i = 0; i < sfams.length; i++) {
  sfams[i] = fams[i].toString();
 }
 fetchFamilies(job, sfams);
}

代码示例来源:origin: org.apache.fluo/fluo-api

@Override
public Map<RowColumn, String> gets(Collection<RowColumn> rowColumns) {
 Map<RowColumn, Bytes> bytesMap = get(rowColumns);
 return Maps.transformValues(bytesMap, b -> b.toString());
}

代码示例来源:origin: org.apache.fluo/fluo-mapreduce

public static void fetchFamilies(Job job, Bytes... fams) {
 // TODO support binary data
 String[] sfams = new String[fams.length];
 for (int i = 0; i < sfams.length; i++) {
  sfams[i] = fams[i].toString();
 }
 fetchFamilies(job, sfams);
}

代码示例来源:origin: apache/fluo

@Override
public Map<Column, String> gets(CharSequence row, Set<Column> columns) {
 Map<Column, Bytes> values = get(s2bConv(row), columns);
 return Maps.transformValues(values, b -> b.toString());
}

代码示例来源:origin: org.apache.fluo/fluo-api

@Override
public Map<Column, String> gets(CharSequence row, Set<Column> columns) {
 Map<Column, Bytes> values = get(s2bConv(row), columns);
 return Maps.transformValues(values, b -> b.toString());
}

代码示例来源:origin: org.apache.fluo/fluo-api

@Override
public String gets(CharSequence row, Column column) {
 Bytes val = get(s2bConv(row), column);
 if (val == null) {
  return null;
 }
 return val.toString();
}

代码示例来源:origin: org.apache.fluo/fluo-api

@Override
public String gets(CharSequence row, Column column, String defaultValue) {
 Bytes val = get(s2bConv(row), column);
 if (val == null) {
  return defaultValue;
 }
 return val.toString();
}

相关文章