本文整理了Java中com.alibaba.datax.common.element.Record.getColumn方法的一些代码示例，展示了Record.getColumn的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Record.getColumn方法的具体详情如下：
包路径：com.alibaba.datax.common.element.Record
类名称：Record
方法名：getColumn
暂无
代码示例来源：origin: ECNU-1X/DataX-Masking
private void setupStatement(Record record) throws SQLException {
// 一开始的时候就已经校验过record中的列数量与ps中需要的值数量相等
for (int i = 0; i < numberOfColumnsToWrite; i++) {
Column col = record.getColumn(i);
int sqlType = columnTypes[i];
// PreparedStatement中的索引从1开始，所以用i+1
setupColumn(i + 1, sqlType, col);
}
}代码示例来源：origin: ECNU-1X/DataX-Masking
public static DirtyRecord asDirtyRecord(final Record record) {
DirtyRecord result = new DirtyRecord();
for (int i = 0; i < record.getColumnNumber(); i++) {
result.addColumn(record.getColumn(i));
}
return result;
}代码示例来源：origin: ECNU-1X/DataX-Masking
private String recordToString(Record record) {
int recordLength = record.getColumnNumber();
if (0 == recordLength) {
return NEWLINE_FLAG;
}
Column column;
StringBuilder sb = new StringBuilder();
for (int i = 0; i < recordLength; i++) {
column = record.getColumn(i);
sb.append(column.asString()).append(fieldDelimiter);
}
sb.setLength(sb.length() - 1);
sb.append(NEWLINE_FLAG);
return sb.toString();
}
}代码示例来源：origin: ECNU-1X/DataX-Masking
@Override
public int compare(Record record1, Record record2) {
int hashPartition1 = AdsInsertProxy.getHashPartition(record1.getColumn(partitionColumnIndex).asString(), partitionCount);
int hashPartition2 = AdsInsertProxy.getHashPartition(record2.getColumn(partitionColumnIndex).asString(), partitionCount);
return hashPartition1 - hashPartition2;
}
});代码示例来源：origin: ECNU-1X/DataX-Masking
private String recordToString(Record record) {
int recordLength = record.getColumnNumber();
if (0 == recordLength) {
return NEWLINE_FLAG;
}
Column column;
List dataList = new ArrayList();
for (int i = 0; i < recordLength; i++) {
column = record.getColumn(i);
Map tmpmap = new HashMap<>();
tmpmap.put("value",column.getRawData());
tmpmap.put("type",column.getType());
dataList.add(tmpmap);
}
String jsonStr = JSON.toJSON(dataList).toString();
System.out.println(jsonStr);
return jsonStr;
}
}代码示例来源：origin: ECNU-1X/DataX-Masking
protected PreparedStatement fillPreparedStatement(PreparedStatement preparedStatement, Record record)
throws SQLException {
for (int i = 0; i < this.columnNumber; i++) {
int columnSqltype = this.resultSetMetaData.getMiddle().get(i);
preparedStatement = fillPreparedStatementColumnType(preparedStatement, i, columnSqltype, record.getColumn(i));
}
return preparedStatement;
}代码示例来源：origin: ECNU-1X/DataX-Masking
public static List<Pair<String, ColumnValue>> getAttrFromRecord(int pkCount, List<OTSAttrColumn> attrColumns, Record r) {
List<Pair<String, ColumnValue>> attr = new ArrayList<Pair<String, ColumnValue>>(r.getColumnNumber());
for (int i = 0; i < attrColumns.size(); i++) {
Column col = r.getColumn(i + pkCount);
OTSAttrColumn expect = attrColumns.get(i);
if (col.getRawData() == null) {
attr.add(new Pair<String, ColumnValue>(expect.getName(), null));
continue;
}
ColumnValue cv = ColumnConversion.columnToColumnValue(col, expect);
attr.add(new Pair<String, ColumnValue>(expect.getName(), cv));
}
return attr;
}代码示例来源：origin: ECNU-1X/DataX-Masking
public static RowPrimaryKey getPKFromRecord(List<OTSPKColumn> pkColumns, Record r) {
RowPrimaryKey primaryKey = new RowPrimaryKey();
int pkCount = pkColumns.size();
for (int i = 0; i < pkCount; i++) {
Column col = r.getColumn(i);
OTSPKColumn expect = pkColumns.get(i);
if (col.getRawData() == null) {
throw new IllegalArgumentException(String.format(OTSErrorMessage.PK_COLUMN_VALUE_IS_NULL_ERROR, expect.getName()));
}
PrimaryKeyValue pk = ColumnConversion.columnToPrimaryKeyValue(col, expect);
primaryKey.addPrimaryKeyColumn(expect.getName(), pk);
}
return primaryKey;
}代码示例来源：origin: ECNU-1X/DataX-Masking
throw DataXException.asDataXException(Hbase11xWriterErrorCode.CONSTRUCT_VERSION_ERROR, String.format("您的versionColumn配置项中中index值超出范围,根据reader端配置,index的值小于%s,而您配置的值为%s，请检查并修改.",record.getColumnNumber(),index));
if(record.getColumn(index).getRawData() == null){
throw DataXException.asDataXException(Hbase11xWriterErrorCode.CONSTRUCT_VERSION_ERROR, "您指定的版本为空!");
if(record.getColumn(index) instanceof LongColumn || record.getColumn(index) instanceof DoubleColumn){
timestamp = record.getColumn(index).asLong();
}else {
Date date;
try{
date = df_ms.parse(record.getColumn(index).asString());
}catch (ParseException e){
try {
date = df_senconds.parse(record.getColumn(index).asString());
} catch (ParseException e1) {
LOG.info(String.format("您指定第[%s]列作为hbase写入版本,但在尝试用yyyy-MM-dd HH:mm:ss 和 yyyy-MM-dd HH:mm:ss SSS 去解析为Date时均出错,请检查并修改",index));代码示例来源：origin: ECNU-1X/DataX-Masking
Column column = record.getColumn(columnIndex);代码示例来源：origin: ECNU-1X/DataX-Masking
throw DataXException.asDataXException(Hbase094xWriterErrorCode.ILLEGAL_VALUE, String.format("您的column配置项中中index值超出范围,根据reader端配置,index的值小于%s,而您配置的值为%s，请检查并修改.",record.getColumnNumber(),index));
byte[] columnBytes = getColumnByte(columnType,record.getColumn(index));代码示例来源：origin: ECNU-1X/DataX-Masking
@Override
public Record evaluate(Record record, Object... paras) {
try {
if (paras.length < 2) {
throw new RuntimeException("dx_enum transformer缺少参数");
}
columnIndex = (Integer) paras[0];
key = String.valueOf(paras[1]);
} catch (Exception e) {
throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_ILLEGAL_PARAMETER, "paras:" + Arrays.asList(paras).toString() + " => " + e.getMessage());
}
Column column = record.getColumn(columnIndex);
try {
String oriValue = column.asString();
if(oriValue == null){
return record;
}
int offset = Integer.parseInt(key);
double newValue = EnumerateMasker.mask(column.asLong(), offset);
record.setColumn(columnIndex, new DoubleColumn(newValue));
} catch (Exception e){
throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_RUN_EXCEPTION, e.getMessage(),e);
}
return record;
}
}代码示例来源：origin: ECNU-1X/DataX-Masking
int colNum = record.getColumnNumber();
for (int i = 0; i < colNum; i++) {
Column col = record.getColumn(i);
if (col != null) {
String value;代码示例来源：origin: ECNU-1X/DataX-Masking
ArrayList<String> keyList = new ArrayList<String>();
for (int index : indexesFromUser) {
Column col = record.getColumn(index);
if (col == null) {
throw DataXException.asDataXException(OcsWriterErrorCode.DIRTY_RECORD, String.format("不存在第%s列", index));代码示例来源：origin: ECNU-1X/DataX-Masking
public byte[] getRowkey(Record record){
byte[] rowkeyBuffer = {};
for (Configuration aRowkeyColumn : rowkeyColumn) {
Integer index = aRowkeyColumn.getInt(Key.INDEX);
String type = aRowkeyColumn.getString(Key.TYPE);
ColumnType columnType = ColumnType.getByTypeName(type);
if(index == -1){
String value = aRowkeyColumn.getString(Key.VALUE);
rowkeyBuffer = Bytes.add(rowkeyBuffer,getValueByte(columnType,value));
}else{
if(index >= record.getColumnNumber()){
throw DataXException.asDataXException(Hbase094xWriterErrorCode.CONSTRUCT_ROWKEY_ERROR, String.format("您的rowkeyColumn配置项中中index值超出范围,根据reader端配置,index的值小于%s,而您配置的值为%s，请检查并修改.",record.getColumnNumber(),index));
}
byte[] value = getColumnByte(columnType,record.getColumn(index));
rowkeyBuffer = Bytes.add(rowkeyBuffer, value);
}
}
return rowkeyBuffer;
}代码示例来源：origin: ECNU-1X/DataX-Masking
@Override
public Record evaluate(Record record, Object... paras) {
try {
if (paras.length < 1) {
throw new RuntimeException("dx_md5 transformer缺少参数");
}
columnIndex = (Integer) paras[0];
} catch (Exception e) {
throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_ILLEGAL_PARAMETER, "paras:" + Arrays.asList(paras).toString() + " => " + e.getMessage());
}
Column column = record.getColumn(columnIndex);
try {
String oriValue = column.asString();
if (oriValue == null) {
return record;
}
if(column.getType() == Column.Type.STRING) {
MD5EncryptionImpl masker = new MD5EncryptionImpl();
String newValue = masker.execute(oriValue);
record.setColumn(columnIndex, new StringColumn(newValue));
}
} catch (Exception e) {
throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_RUN_EXCEPTION, e.getMessage(), e);
}
return record;
}
}代码示例来源：origin: ECNU-1X/DataX-Masking
public byte[] getRowkey(Record record){
byte[] rowkeyBuffer = {};
for (Configuration aRowkeyColumn : rowkeyColumn) {
Integer index = aRowkeyColumn.getInt(Key.INDEX);
String type = aRowkeyColumn.getString(Key.TYPE);
ColumnType columnType = ColumnType.getByTypeName(type);
if(index == -1){
String value = aRowkeyColumn.getString(Key.VALUE);
rowkeyBuffer = Bytes.add(rowkeyBuffer,getValueByte(columnType,value));
}else{
if(index >= record.getColumnNumber()){
throw DataXException.asDataXException(Hbase11xWriterErrorCode.CONSTRUCT_ROWKEY_ERROR, String.format("您的rowkeyColumn配置项中中index值超出范围,根据reader端配置,index的值小于%s,而您配置的值为%s，请检查并修改.",record.getColumnNumber(),index));
}
byte[] value = getColumnByte(columnType,record.getColumn(index));
rowkeyBuffer = Bytes.add(rowkeyBuffer, value);
}
}
return rowkeyBuffer;
}代码示例来源：origin: ECNU-1X/DataX-Masking
throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_ILLEGAL_PARAMETER, "paras:" + Arrays.asList(paras).toString() + " => " + e.getMessage());
Column column = record.getColumn(columnIndex);
try {
String oriValue = column.asString();代码示例来源：origin: ECNU-1X/DataX-Masking
throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_ILLEGAL_PARAMETER, "paras:" + Arrays.asList(paras).toString() + " => " + e.getMessage());
Column column = record.getColumn(columnIndex);
try {
String oriValue = column.asString();代码示例来源：origin: ECNU-1X/DataX-Masking
throw DataXException.asDataXException(TransformerErrorCode.TRANSFORMER_ILLEGAL_PARAMETER, "paras:" + Arrays.asList(paras).toString() + " => " + e.getMessage());
Column column = record.getColumn(columnIndex);
try {
String oriValue = column.asString();内容来源于网络，如有侵权，请联系作者删除！