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

Tuple.getField介绍

[英]Gets the field at the specified position.
[中]获取指定位置的字段。

代码示例

代码示例来源：origin: apache/flink

@Override
  public double[] extract(Tuple in) {
    double[] out = new double[indexes.length];
    for (int i = 0; i < indexes.length; i++) {
      out[i] = (Double) in.getField(indexes[i]);
    }
    return out;
  }
}

代码示例来源：origin: apache/flink

@Override
public OUT extract(Tuple in) {
  return in.getField(fieldId);
}

代码示例来源：origin: apache/flink

@SuppressWarnings("unchecked")
@Override
public F get(T record) {
  return (F) record.getField(pos);
}

代码示例来源：origin: apache/flink

@Override
  @SuppressWarnings("unchecked")
  public Key getKey(Type value) {
    return (Key) value.getField(0);
  }
}

代码示例来源：origin: apache/flink

@Override
@SuppressWarnings("unchecked")
public void aggregate(Tuple value) {
  for (int i = 0; i < columnAggregators.length; i++) {
    columnAggregators[i].aggregate(value.getField(i));
  }
}

代码示例来源：origin: apache/flink

@Override
  public Integer getKey(T value) {
    return value.getField(0);
  }
}

代码示例来源：origin: apache/flink

@Override
  public String getKey(T t) throws Exception {
    return t.getField(field);
  }
}

代码示例来源：origin: apache/flink

@Override
public int extractKeys(Object record, Object[] target, int index) {
  int localIndex = index;
  for(int i = 0; i < comparators.length; i++) {
    localIndex += comparators[i].extractKeys(((Tuple) record).getField(keyPositions[i]), target, localIndex);
  }
  return localIndex - index;
}

代码示例来源：origin: apache/flink

@Override
  protected Object[] extractFields(OUT record) {
    Object[] fields = new Object[record.getArity()];
    for (int i = 0; i < fields.length; i++) {
      fields[i] = record.getField(i);
    }
    return fields;
  }
}

代码示例来源：origin: apache/flink

@Override
  public Long getKey(T t) throws Exception {
    return ((Tuple) t).getField(field);
  }
}

代码示例来源：origin: apache/flink

@Override
  public Integer getKey(T t) throws Exception {
    return ((Tuple) t).getField(field);
  }
}

代码示例来源：origin: apache/flink

@SuppressWarnings("unchecked")
  @Override
  public R map(Tuple inTuple) throws Exception {
    for (int i = 0; i < fields.length; i++) {
      outTuple.setField(inTuple.getField(fields[i]), i);
    }
    return (R) outTuple;
  }
}

代码示例来源：origin: apache/flink

public TupleSerializer(Tuple value) {
  serializer = new Serializer[value.getArity()];
  for (int x = 0; x < serializer.length; x++) {
    serializer[x] = getSerializer(value.getField(x));
  }
}

代码示例来源：origin: apache/flink

@Override
  public T set(T record, F fieldValue) {
    final R inner = record.getField(pos);
    record.setField(innerAccessor.set(inner, fieldValue), pos);
    return record;
  }
}

代码示例来源：origin: apache/flink

@Override
  protected Object[] extract(IN record) {
    Object[] al = new Object[record.getArity()];
    for (int i = 0; i < record.getArity(); i++) {
      al[i] = record.getField(i);
    }
    return al;
  }
}

代码示例来源：origin: apache/flink

@Override
public void serialize(T value, DataOutputView target) throws IOException {
  for (int i = 0; i < arity; i++) {
    Object o = value.getField(i);
    try {
      fieldSerializers[i].serialize(o, target);
    } catch (NullPointerException npex) {
      throw new NullFieldException(i, npex);
    }
  }
}

代码示例来源：origin: apache/flink

@Override
public T deserialize(T reuse, DataInputView source) throws IOException {
  for (int i = 0; i < arity; i++) {
    Object field = fieldSerializers[i].deserialize(reuse.getField(i), source);
    reuse.setField(field, i);
  }
  return reuse;
}

代码示例来源：origin: apache/flink

@Override
  public Tuple2<Integer, Integer> getKey(T value) {
    return new Tuple2<Integer, Integer>(value.<Integer>getField(0), value.<Integer>getField(1));
  }
}

代码示例来源：origin: apache/flink

@Override
public T copy(T from) {
  T target = instantiateRaw();
  for (int i = 0; i < arity; i++) {
    Object copy = fieldSerializers[i].copy(from.getField(i));
    target.setField(copy, i);
  }
  return target;
}

代码示例来源：origin: apache/flink

@Override
protected void deepEquals(String message, T should, T is) {
  for (int x = 0; x < should.getArity(); x++) {
    assertEquals((Object)should.getField(x), is.getField(x));
  }
}